Записать фреймворк в таблицу - PullRequest
Новая
       22

Записать фреймворк в таблицу

0 голосов
/ 03 августа 2020

Я пытаюсь записать фрейм данных искры в таблицу MYSQL. Я попробовал следующий метод: 

dataFrame.write().mode(SaveMode.Append).format(JDBC).options(options);

options - это карта следующей пары ключ-значение:

  • "url", "jdbc:oracle:thin:@localhost: 1521: xe"
  • «пароль», «пароль»
  • «драйвер», «oracle .jdb c .driver.OracleDriver»
  • «пользователь», «имя пользователя»
  • «dbtable», «tableName»

таблица «tableName» не обновляется, и я не получаю никаких ошибок в консоли Spark. Может ли кто-нибудь помочь мне с этим?

1 Ответ

0 голосов
/ 04 августа 2020

Попробуйте изменить имя карты, потому что имя метода и имя карты одинаковы. Я не уверен, но это может быть проблемой.

Во-вторых, я объявляю параметры параметров как отдельные переменные и передаю их в метод параметров.

`

url_name = "xxxx"
driver_name = "xxxx"
username = "x"
passwd = "123"
dataFrame.write().mode(SaveMode.Append).format(JDBC).options(url=url_name, driver = driver_name, dbtable = query, user=username, password=passwd);

`

И последнее, проверьте метод .save() после метода параметров, потому что вы не сохраняете.

...