我能够将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()
1条答案
按热度按时间vlurs2pr1#
你能做到的
在写入oracle数据库之前。Map基于列名。