question Oracle Update statement from Spark in Support Questions

Oracle Update statement from Spark

anujtanwar12 — Fri, 18 May 2018 05:35:55 GMT

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()
?

Re: Oracle Update statement from Spark

falbani — Fri, 18 May 2018 23:33:59 GMT

@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.

Re: Oracle Update statement from Spark

anujtanwar12 — Fri, 18 May 2018 23:34:02 GMT

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()