-- 通过cx_Oracle连接
import cx_Oracle
# 连接数据库
orcl_engine = 'scott/s123@xxxx:1521/orcl'
conn = cx_Oracle.connect(orcl_engine)
# 创建游标
cursor = conn.cursor()
#调用存储过程
try:
pro_name = 'qmcb_km_data'
print('正在执行%s'%(pro_name))
cursor.callproc('存储过程名称', [参数])
cursor.callproc(pro_name)
message = '%s执行成功'%(pro_name)
except Exception as e:
error, = e.args
message = "%s执行失败 "%(pro_name) + error.message
print(message)
-- 通过create_engine连接
from sqlalchemy import create_engine
# 连接数据库
orcl_engien = 'oracle://scott:s123@xxxx:1521/orcl'
db = create_engine(orcl_engien) #不需要close()
conn = db.raw_connection()
cursor = conn.cursor()
#调用存储过程
try:
pro_name = 'qmcb_km_data'
print('正在执行%s'%(pro_name))
cursor.callproc('存储过程名称', [参数])
cursor.callproc(pro_name)
message = '%s执行成功'%(pro_name)
except Exception as e:
error, = e.args
message = "%s执行失败 "%(pro_name) + error.message
print(message)