Cloudera Community
anujtanwar12
user rank
New Contributor

Re: Oracle Update statement from Spark

by New Contributor in Support Questions
‎05-18-2018 04:34 PM
‎05-18-2018 04:34 PM
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() ... View more

Oracle Update statement from Spark

by New Contributor in Support Questions
‎05-17-2018 10:35 PM
‎05-17-2018 10:35 PM
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() ? ... View more
Labels:
Contact Me
Online
Offline
Last Visited
‎05-18-2018 04:34 PM
Community Statistics
Member Since ‎05-17-2018 10:30 PM
Last Visited ‎05-18-2018 04:34 PM
Posts 2