python读取oracle函数返回值

在oracle中创建一个函数,本来是想返回一个index table的,没有成功。想到文本也可以传输信息,就突然来了灵感,把返回值设置文本格式。
考虑到返回数据量可能会很大,varchar2类型长度吃紧,于是将返回值类型设置为clob。
我是用scott用户的测试表emp,这个是函数定义情况:

create or replace function test_query_func(dept varchar2)
return clob
is
type test_record is record
(rec_empno emp.empno%type,
rec_ename emp.ename%type,
rec_job emp.job%type,
rec_sal emp.sal%type);
type test_query_arr is table of test_record index by binary_integer;
cursor cur is select empno, ename, job, sal from emp where deptno = dept;
test_query test_query_arr;
i integer := 0;
ss varchar2(200) := ”;
res clob := ‘[‘;
begin
for c in cur loop
i := i + 1;
test_query(i) := c;
end loop;
for q in 1..test_query.count loop
ss := ‘(”’ || test_query(q).rec_empno || ”’, ”’ || test_query(q).rec_ename || ”’, ”’ || test_query(q).rec_job || ”’, ”’ || test_query(q).rec_sal || ”’)’;
if q < test_query.count then ss := ss || ','; end if; res := res || ss; end loop; res := res || ']'; return res; end;

可以在pl/sql developer测试这个函数的返回值:

begin
dbms_output.put_line(test_query_func(’30’));
end;

输出结果:
[(‘7499’, ‘allen’, ‘salesman’, ‘1600’),(‘7521’, ‘ward’, ‘salesman’, ‘1250’),(‘7654’, ‘martin’, ‘salesman’, ‘1250’),(‘7698’, ‘blake’, ‘manager’, ‘2850’),(‘7844’, ‘turner’, ‘salesman’, ‘1500’),(‘7900’, ‘james’, ‘clerk’, ‘950’)]
其实已经定义成一个python中列表中包含元组子元素的样式。
下面是python中的代码,用python连接oracle需要cx_oracle库:

import cx_oracle as ora;
con = ora.connect(‘scott/scott@oradb’);
cur = con.cursor();
cur.execute(‘select test_query_func(30) from dual’);
res = cur.fetchall()[0][0].read();
cur.close();
con.close();
data = eval(res);
import pandas as pd;
df = pd.dataframe(data, columns = [’empno’, ‘ename’, ‘job’, ‘sal’]);
print(df)

这样oracle中函数返回的长字符串值就转化为dataframe对象了:

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

Posted in 未分类

发表评论