程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> Oracle數據庫 >> Oracle數據庫基礎 >> Oracle 10g Release2新功能之Ref Cursor

Oracle 10g Release2新功能之Ref Cursor

編輯:Oracle數據庫基礎

Ref Cursor就是我們定義在服務器端的結果集的reference。 當我們打開一個Ref Cursor的時候,沒有任何的數據返回到客戶端,相反,數據在服務器上的地址將會被返回到客戶端。這樣用戶就可以自己決定什麼時間和以那種方式通過Ref Cursor去取數據。

在以前版本的ODP.Net中,我們可以通過Ref Cursor取數據,但是我們不能把Ref Cursor作為一個Input參數傳遞給PL/SQL的存儲過程和存儲函數。但是在Oracle Database 10g Release2,我們能夠很簡單的把Ref Cursor作為Input參數傳遞給PL/SQL的存儲過程和存儲函數。這是Oracle Database 10g Release2的新功能。

我們接下來就以例程的方式來向你介紹這個新功能。

准備數據庫

我們要在數據庫中生成一個表和一個包,我們接下來的例子會用到。

請用HR用戶登錄數據庫,然後運行下面的腳本。
create table processing_result
(
 status varchar2(64)
);
create or replace package cursor_in_out as
type emp_cur_type is ref cursor return employees%rowtype;
procedure process_cursor(p_cursor in emp_cur_type);
end;
/
create or replace package body cursor_in_out as
procedure process_cursor(p_cursor in emp_cur_type) is
employee employees%rowtype;
begin
 loop
  fetch p_cursor into employee;
  exit when p_cursor%notfound;
  insert into processing_result
  values('Processed employee #' ||
  employee.employee_id || ': ' ||
  employee.first_name || ' ' ||
  employee.last_name);
 end loop;
end;
end;
/

創建.Net代碼

數據庫已經准備好了,接下來我們就准備創建.Net代碼。

using System;
using System.Data;
using Oracle.DataAccess.ClIEnt;
using Oracle.DataAccess.Types;
namespace CursorInCursorOut
{
 /// <summary>
 /// Summary description for Class1.
 /// </summary>
 class Class1
 {
  /// <summary>
  /// The main entry point for the application.
  /// </summary>
  [STAThread]
  static void Main(string[] args)
  {
   // create connection to database
   // change for your environment
   string constr = "User Id=hr; PassWord=hr; Data Source=oramag; Pooling=false";
   OracleConnection con = new OracleConnection(constr);
   con.Open();
   // command and parameter objects to get ref cursor
   OracleCommand cmd = con.CreateCommand();
   cmd.CommandText = "begin open :1 for select * from employees where manager_id=101; end;";
   OracleParameter p_rc = cmd.Parameters.Add("p_rc", OracleDbType.RefCursor, DBNull.Value, ParameterDirection.Output);
  // get the ref cursor
  cmd.ExecuteNonQuery();
  // clear parameters to reuse
  cmd.Parameters.Clear();
  // command and parameter objects to pass ref cursor
  // as an input parameter
  cmd.CommandText = "cursor_in_out.process_cursor";
  cmd.CommandType = CommandType.StoredProcedure;
  OracleParameter p_input = cmd.Parameters.Add("p_input", OracleDbType.RefCursor, p_rc.Value,  ParameterDirection.Input);
  // process the input cursor
  cmd.ExecuteNonQuery();
  // clean up objects
  p_input.Dispose();
  p_rc.Dispose();
  cmd.Dispose();
  con.Dispose();
 }
}
}

運行上面的代碼,這個程序本身沒有輸出,但是我們可以通過SQL*PLUS很容易可以看到下面的輸出。

SQL> select * from processing_result;
STATUS
----------------------------------------
Processed employee #108: Nancy Greenberg
Processed employee #200: Jennifer Whalen
Processed employee #203: Susan Mavris
Processed employee #204: Hermann Baer
Processed employee #205: Shelley Higgins
5 rows selected.

我這裡只是給大家一個很簡單的例子,希望大家充分應用Oracle Database的新特性,使你的項目更加的穩定,效率更高。

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