Вставить запись из фрейма данных в таблицу MySQL с помощью Spark / java

Question

У меня есть фрейм данных:

+------------+-------+-------------------+-----------+---+------+--------------------+-----------+
|   id_alerte|id_type|      tracking_time|ID_tracking|vue|    id|         observation|id_vehicule|
+------------+-------+-------------------+-----------+---+------+--------------------+-----------+
|188978561024|      9|2020-02-19 09:20:54|  900100393|  0|100491|LE VEHICULE A ARR...|     997801|
+------------+-------+-------------------+-----------+---+------+--------------------+-----------+

Моя таблица базы данных:

+------------------+-------------+
|id_alertePrimaire | int(11)     |
+------------------+-------------+      
|  id_alerte       | int P_K     |
|  id_type         | int(11)     |      
| dateAlerte       | timestamp   |          
| id_tracking      | bigint(20)  |                  
| vue              | tinyint(1)  |          
| id_alert_prog    | int(11)     |              
| observation      | varchar(255)|          
| id_vehicule      |  int(11)    |
+------------------+-------------+              

Я хочу сохранить эту запись в майской SQL таблице

код, который я использую:

data.write().format("jdbc").option("url", "myurl")
                             .option("driver", "com.mysql.jdbc.Driver")
                             .option("dbtable", "alerte").option("user", "root").option("password", "").mode("append");

Я не получаю ошибки, но ничего не добавляется в таблицу базы данных

Если у вас есть идеи, я был бы очень благодарен

Answer 1

Вы передаете строку "myurl" строку вместо значения переменной mysql.

Попробуйте использовать myurl в опции (или) сохранить свой jdb c URL жестко задан <jdbc:mysql>...

data.write().format("jdbc").option("url", myurl)
                             .option("driver", "com.mysql.jdbc.Driver")
                             .option("dbtable", "alerte").option("user", "root").option("password", "").mode("append");