天天看點

.net調用ORACLE存儲過程傳回結果集及函數

oracle段:

首先在oracle建立package和package body,将在這裡面定義函數和存儲過程傳回結果集。

1:建立package:

create or replace package scott.pk_wt

is

type mytype is ref cursor;

procedure p_wt(mycs out mytype);

function f_get(str in varchar2)

return varchar2;

end;

/

說明:其實package隻是個聲明罷了。我們在這裡定義了一個存儲過程傳回結集和一個函數,傳回字元串。

2:建立package body:

create or replace package body scott.pk_wt

procedure p_wt(mycs out mytype)

begin

open mycs for select * from test;

end p_wt;

function f_get(str varchar2)

return varchar2

str_temp varchar2(100) := 'good luck!';

str_temp := str_temp || str;

return str_temp;

end f_get;

end pk_wt;

說明:這裡建立package body是具體的說明和使用,将采用什麼方式實作。。

c#段:

在c#中代碼将分為兩部分,一部分是使用函數,另外一部分是使用結果集。

定義一個連接配接,從webconfig裡去取得:

private oracleconnection orcn=new oracleconnection(system.configuration.configurationsettings.appsettings["scott"]);

c#調用oracle函數:

oraclecommand cmd=new oraclecommand("pk_wt.f_get",orcn);

   cmd.commandtype=commandtype.storedprocedure;

   oracleparameter p1=new oracleparameter("str",oracletype.varchar,10);

   p1.direction=system.data.parameterdirection.input;

   p1.value=this.textbox1.text;

   oracleparameter p2=new oracleparameter("result",oracletype.varchar,100);

   p2.direction=system.data.parameterdirection.returnvalue;

   cmd.parameters.add(p1);

   cmd.parameters.add(p2);

   orcn.open();

   cmd.executenonquery();

   orcn.close();

   this.button_function.text=p2.value.tostring();

其中result是系統自定義的函數傳回變量,特别要注意的是,函數的參數的傳回類型要指定,另外就是command類型也需要指定,另外和一般的存儲過程沒什麼差别。

c#調用oracle傳回結果集:

oraclecommand cmd=new oraclecommand("pk_wt.p_wt",orcn);

   oracleparameter p1=new oracleparameter("mycs",oracletype.cursor);

   p1.direction=system.data.parameterdirection.output;

   oracledataadapter da=new oracledataadapter(cmd);

   dataset ds=new dataset();

   da.fill(ds,"test");

   this.datagrid1.datasource=ds;

   this.datagrid1.databind();