Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
12-30-2022 03:52 PM
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.
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()