如何使用sqlalchemy和python调用refcursor返回类型的Oracle函数

Question

函数给出如下：

CREATE or replace function get_data(data_key integer) return sys_refcursor 
is
result1 sys_refcursor;
BEGIN
open result1 for 'Select DISTINCT COL1
        FROM REF_TABLE
        where DATA_KEY='||data_key;
return result1;
END;

调用上述函数

variable rc refcursor;
exec :rc :=get_data(30038);
print rc;

这在SQL开发人员中工作正常。如何使用python和sqlalchemy调用相同的内容？

Answer 1

我用cx_Oracle而不是SQLAlchemy，它工作了。结果输出与我对 sqlqhe 的期望相同。我将函数转换为过程。

程序

CREATE or replace procedure get_data(data_key in integer, result out 
sys_refcursor) as
BEGIN
open result for 'Select DISTINCT COL1
        FROM ref_table
        where DATA_KEY='||data_key;
END;

使用 python 和 cx_Oracle 调用上述过程的代码

import cx_Oracle
import pandas as pd
conn = cx_Oracle.connect('system/<password>@127.0.0.1/XE')
cur = conn.cursor()
myvar = cur.var(cx_Oracle.CURSOR)
cur.callproc('get_data', (30038, myvar))
data = myvar.getvalue().fetchall()
if len(data) == 0:
    data = {}
df = pd.DataFrame(data, columns=[i[0] for i in myvar.getvalue().description])
print df

上述代码的输出

                      COL1
--------------------------
0                   219586
1                   246751
2                   228245
3                   244517
4                   220765
5                   243467
6                   246622
7                   222784