将Dataframe写入表

siotufzp 于 2021-05-27 发布在 Spark

关注(0)|答案(1)|浏览(426)

我正在尝试向mysql表写入sparkDataframe。我尝试了以下方法：

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

选项是以下键值对的Map：
“url”，“jdbc:oracle:thin:@localhost：1521:xe“
“密码”，“通过”
“驱动程序”，“oracle.jdbc.driver.oracledriver”
“用户”，“用户名”
“dbtable”，“表名”
表'tablename'没有更新，spark控制台中也没有任何错误。有人能帮我吗？

mysql apache-spark apache-spark-sql

来源：https://stackoverflow.com/questions/63234692/write-dataframe-to-table

1条答案

按热度按时间

ecr0jaav1#

尝试更改Map名称，因为方法名称和Map名称都相同。我不确定，但这可能就是问题所在。
其次，我将option参数声明为单独的变量，并将它们传递到option方法中。
`

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()` 方法，因为您没有保存。

赞(0）回复(0）举报 2021-05-27

我来回答

将Dataframe写入表

1条答案

相关问题

热门标签

最新问答