How to Call Oracle Stored Procedures from Databricks?

[Raghu101]

How to Call Oracle Stored Procedures from Databricks?

[Meghala]

here i have code

1. val url =
2. "jdbc:mysql://yourIP:yourPort/test?
3. user=yourUsername; password=yourPassword"
4. val df = sqlContext
5. .read
6. .format("jdbc")
7. .option("url", url)
8. .option("dbtable", "people")
9. .load()

[jonathan-dufaul]

Chiming in because I don't know if the above quite answers how to execute a stored procedure. I use PySpark. I believe this should work for oracle, but only was able to test it with MS Sql Server. I had to truncate a table, but the code works for a stored procedure as well.

https://stackoverflow.com/questions/74439747/is-there-a-way-to-just-truncate-a-remote-mssql-table-fr...

General idea is to get the jdbc connection from the jvm gateway and use that to execute sql commands.

sqlSurl = "jdbc:[driver]//ip..."
 
  con = (sc._gateway
          .jvm
          .java
          .sql
          .DriverManager
          .getConnection(sqlsUrl, \
            username, \
            password)
    )
  con.prepareCall(query).execute()
  con.close()

[AdrianLobacz]

Check this link, maybe it will help you solve this problem

https://stackoverflow.com/questions/60354376/how-to-execute-a-stored-procedure-in-azure-databricks-p...

[Meghala]

Thanks it helps me as well​

[sher]

https://datathirst.net/blog/2018/10/12/executing-sql-server-stored-procedures-on-databricks-pyspark/

try this link. this may help you

[Meghala]

It was needed me as well so thanks ​