Re: Inserting date into ignite with spark jdbc

[Andrei Aleksandrov]

Hi,

It will be great if you share the reproducer.

BR,
Andrei

11/3/2020 10:17 AM, Humphrey пишет:

Let me have a summarize here. Working with
| IgniteDataFrameSettings.OPTION_CONFIG_FILE(), configPath |
seems to work fine.

But when I'm using the JDBC thin client connection, (like connecting to a
database through JDBC Driver) it was giving me the error:
*java.sql.SQLException: No PRIMARY KEY defined for CREATE TABLE* even when
supplying the option *OPTION_CREATE_TABLE_PRIMARY_KEY_FIELDS*.

Do you want me to make a reproducible example? Or is there already a ticket?

Humphrey


aealexsandrov wrote

Denis,

I can check it out soon. The mentioned problem can probably only be
related to JDBC data frames. In this case, I will create a JIRA ticket.
But as I know using OPTION_CREATE_TABLE_PRIMARY_KEY_FIELDS should be the
same as I showed in my example.

BR,
Andrei

10/30/2020 6:01 PM, Denis Magda пишет:

Andrey,

Do we need to update our docs? It feels like the docs miss these
details or have an outdated example.

-
Denis


On Fri, Oct 30, 2020 at 7:03 AM Andrei Aleksandrov
<

aealexsandrov@
  <mailto:
aealexsandrov@
>> wrote:

     Hi,

     Here's an example with correct syntax that should work fine:

     |DataFrameWriter < Row > df = resultDF .write()
     .format(IgniteDataFrameSettings.FORMAT_IGNITE())
     .option(IgniteDataFrameSettings.OPTION_CONFIG_FILE(), configPath)
     .option(IgniteDataFrameSettings.OPTION_TABLE(), "Person")

.option(IgniteDataFrameSettings.OPTION_CREATE_TABLE_PRIMARY_KEY_FIELDS(),

     "id, city_id")
     .option(IgniteDataFrameSettings.OPTION_CREATE_TABLE_PARAMETERS(),
     "template=partitioned,backups=1") .mode(Append); |

     Please let me know if something is wrong here.

     BR,
     Andrei

     10/30/2020 2:20 AM, Humphrey пишет:

     Hello guys this question has been asked on  Stack Overflow

<https://stackoverflow.com/questions/64554684/how-to-create-a-table-with-primary-key-using-jdbc-spark-connector-to-ignite>

<https://stackoverflow.com/questions/64554684/how-to-create-a-table-with-primary-key-using-jdbc-spark-connector-to-ignite>
     but yet no answer is a provided.

     I'm facing the same issue (trying to insert data in ignite using
     spark.jdbc):
     Exception in thread "main" java.sql.SQLException: No PRIMARY KEY
defined for
     CREATE TABLE
        at

org.apache.ignite.internal.jdbc.thin.JdbcThinConnection.sendRequest(JdbcThinConnection.java:1004)

     Code:
          println("-- writing using jdbc --")
          val prop = Properties()
          prop["driver"] = "org.apache.ignite.IgniteJdbcThinDriver"

          df.write().apply {
                  mode(SaveMode.Overwrite)
                  format("jdbc")
                  option("url", "jdbc:ignite:thin://127.0.0.1
<http://127.0.0.1>";)
                  option("dbtable", "comments")

option(IgniteDataFrameSettings.OPTION_CREATE_TABLE_PRIMARY_KEY_FIELDS(),

     "last_name")
          }.save()

     The last option doesn't seem to work/help.



     --
     Sent from:http://apache-ignite-users.70518.x6.nabble.com/
<http://apache-ignite-users.70518.x6.nabble.com/>

--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/