apachespark中Dataframe写入格式jdbc的列Map

xlpyo6sf  于 2021-05-17  发布在  Spark
关注(0)|答案(1)|浏览(389)

我能够将dataframe记录加载到oracle数据库中而没有任何错误,但是我想知道如何在df中将列Map到oracle
我想以jdbc写格式将employee\ id字段从dataframeMap到oracle中的id列。
列Map:

df          ---------- Oracle
Employee_id ----------    ID

targetdf=spark.sql(final_sql)

targetdf.show()

targetdf.write \
   .format("jdbc") \
   .option("url", "jdbc:oracle:thin:@***************") \
   .option("driver", "oracle.jdbc.driver.OracleDriver") \
   .option("dbtable", target_table) \
   .option("user", "hr") \
   .option("password", "******") \
   .mode('append').save()
vlurs2pr

vlurs2pr1#

你能做到的

targetdf = targetdf.withColumnRenamed("Employee_id", "ID")

在写入oracle数据库之前。Map基于列名。

相关问题