程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> Oracle數據庫 >> Oracle教程 >> 用python讀取oracle函數返回值,pythonoracle

用python讀取oracle函數返回值,pythonoracle

編輯:Oracle教程

用python讀取oracle函數返回值,pythonoracle


在oracle中創建一個函數,本來是想返回一個index table的,沒有成功。想到文本也可以傳輸信息,就突然來了靈感,把返回值設置文本格式。

考慮到返回數據量可能會很大,varchar2類型長度吃緊,於是將返回值類型設置為clob。

我是用scott用戶的測試表emp,這個是函數定義情況:

 1 create or replace function test_query_func(dept varchar2)
 2 return clob
 3 is
 4        type test_record is record
 5        (rec_empno       emp.empno%type,
 6         rec_ename       emp.ename%type,
 7         rec_job            emp.job%type,
 8         rec_sal            emp.sal%type);
 9        type test_query_arr is table of test_record index by binary_integer;
10        cursor cur is select empno, ename, job, sal from emp where deptno = dept;
11        test_query test_query_arr;
12        i integer := 0;
13  ss  varchar2(200) := '';
14  res clob := '[';
15 begin
16        for c in cur loop
17            i := i + 1;
18            test_query(i) := c;
19        end loop;
20        for q in 1..test_query.count loop
21            ss := '(''' || test_query(q).rec_empno || ''', ''' || test_query(q).rec_ename ||  ''', ''' || test_query(q).rec_job || ''', ''' ||  test_query(q).rec_sal || ''')';
22  if q < test_query.count then
23     ss := ss || ',';
24  end if;
25  res := res || ss;
26        end loop;
27  res := res || ']';
28  return res;
29 end;

 可以在pl/sql developer測試這個函數的返回值:

1 begin
2    dbms_output.put_line(test_query_func('30'));
3 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庫:

 1 import cx_Oracle as ora;
 2 con = ora.connect('scott/scott@oradb');
 3 cur = con.cursor();
 4 cur.execute('select test_query_func(30) from dual');
 5 res = cur.fetchall()[0][0].read();
 6 cur.close();
 7 con.close();
 8 data = eval(res);
 9 import pandas as pd;
10 df = pd.DataFrame(data, columns = ['empno', 'ename', 'job', 'sal']);
11 print(df)

這樣oracle中函數返回的長字符串值就轉化為DataFrame對象了:

 empnoenamejobsal 0 7499 ALLEN SALESMAN 1600 1 7521 WARD SALESMAN 1250 2 7654 MARTIN SALESMAN 1250 3 7698 BLAKE MANAGER 2850 4 7844 TURNER SALESMAN 1500 5 7900 JAMES CLERK 950

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved