python執行oracle存儲過程_python調用oracle存儲過程 iUpoint

-- 通過cx_Oracle連接配接

import cx_Oracle

# 連接配接資料庫

orcl_engine = 'scott/[email protected]: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:[email protected]: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)