Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

Oracle Update statement from Spark

avatar
New Contributor

can I execute update statement using

spark.read.format("jdbc").options(

   Map("driver" -> "oracle.jdbc.driver.OracleDriver",<br>     "url" -> url,<br>     "dbtable" -> sqlUpdate,<br>     "user" -> username,<br>     "password" -> password)).load()
?
1 ACCEPTED SOLUTION

avatar

@Anuj Tanwar AFAIK updates are supported with spark jdbc. Alternative is to use standard jdbc - You can read more here https://stackoverflow.com/questions/34643200/spark-dataframes-upsert-to-postgres-table

*** If you found this answer addressed your question, please take a moment to login and click the "accept" link on the answer.

View solution in original post

2 REPLIES 2

avatar

@Anuj Tanwar AFAIK updates are supported with spark jdbc. Alternative is to use standard jdbc - You can read more here https://stackoverflow.com/questions/34643200/spark-dataframes-upsert-to-postgres-table

*** If you found this answer addressed your question, please take a moment to login and click the "accept" link on the answer.

avatar
New Contributor

I used OracleDataSource() to make connection and it worked.

val ods = new OracleDataSource()

ods.setUser(username)
ods.setPassword(password)
ods.setURL(url)

val connection = ods.getConnection()
connection.setAutoCommit(false)

val prepUpdateStat = connection.prepareStatement(sqlUpdate)
prepUpdateStat.execute()
connection.commit()
prepUpdateStat.close()