C#调用oracle存储过程

　　Oracle方面
　　１．创建Oracle过程存储
　　create or replace procedure proce_test(paramin in varchar2,paramout out varchar2,paraminout in out varchar2)
　　as
　　 varparam varchar2(28);
　　begin
　　 varparam:=paramin;
　　 paramout:=varparam|| paraminout; 
　　end;
　　２．测试过程存储
　　declare
　　 param_out varchar2(28);
　　 param_inout varchar2(28);
　　begin
　　 param_inout:='ff'; 
　　 proce_test('dd',param_out,param_inout); 
　　 dbms_output.put_line(param_out);
　　end;
　　C#方面
　　引用Oracle组件 
　　using System;
　　using System.Data;
　　using System.Data.OracleClient; 
　　namespace WebApplication4
　　{
　　 public class OraOprater
　　 {
　　 private OracleConnection conn=null;
　　 private OracleCommand cmd=null;
　　 public OraOprater()
　　 {
　　 string mConn="data source=ora9i.ora.com;user id=ora;password=ora"; //连接数据库
　　 conn=new OracleConnection(mConn);
　　 try
　　 {
　　 conn.Open();
　　 cmd=new OracleCommand();
　　 cmd.Connection=conn;
　　 }
　　 catch(Exception e)
　　 {
　　 throw e;
　　 }
　　 }
　　 public string SpExeFor(string m_A,string m_B)
　　 {
　　 //存储过程的参数声明
　　 OracleParameter[] parameters={
　　 new OracleParameter("paramin",OracleType.VarChar,20),
　　 new OracleParameter("paramout",OracleType.VarChar,20),
　　 new OracleParameter("paraminout",OracleType.VarChar,20)
　　 };
　　 parameters[0].Value=m_A;
　　 parameters[2].Value=m_B;
　　 parameters[0].Direction=ParameterDirection.Input;
　　 parameters[1].Direction=ParameterDirection.Output;
　　 parameters[2].Direction=ParameterDirection.InputOutput;
　　 try
　　 {
　　 RunProcedure("proce_test",parameters);
　　 return parameters[1].Value.ToString();
　　 }
　　 catch(Exception e)
　　 {
　　 throw e;
　　 }
　　 }
　　 private void RunProcedure(string storedProcName,OracleParameter[] parameters)
　　 {
　　 cmd.CommandText=storedProcName;//声明存储过程名
　　 cmd.CommandType=CommandType.StoredProcedure;
　　 foreach(OracleParameter parameter in parameters)
　　 {
　　 cmd.Parameters.Add(parameter);
　　 }
　　 cmd.ExecuteNonQuery();//执行存储过程
　　 }
　　 }
　　}
　　测试结果：ddff

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

返回类型是cursor时：

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
is
procedure p_wt(mycs out mytype)
is
begin
open mycs for select * from test;
end p_wt;

function f_get(str varchar2)
return varchar2
is
str_temp varchar2(100) := 'good luck!'; 
begin
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);
   cmd.CommandType=CommandType.StoredProcedure;
   OracleParameter p1=new OracleParameter("mycs",OracleType.Cursor);
   p1.Direction=System.Data.ParameterDirection.Output;
   cmd.Parameters.Add(p1);
   OracleDataAdapter da=new OracleDataAdapter(cmd);
   DataSet ds=new DataSet();
   da.Fill(ds,"test");
   this.DataGrid1.DataSource=ds;
   this.DataGrid1.DataBind();
这里没什么可说的类。。只是定义的数据类型是游标，类型是OUTPUT，另外没什么了

 

//定义游标参数
OracleParameter outResult = new OracleParameter("prm_OutResult", OracleDbType.RefCursor, ParameterDirection.InputOutput);

//定义一个执行的SQL
command.CommandType = CommandType.Text;
command.CommandText = "BEGIN TestProcedure(:prm_OutResult); END;";

DataTable outTable = new DataTable();

//调用PL/SQL
command.ExecuteNonQuery();

//OUT参数取得
OracleRefCursor refCursor = (OracleRefCursor)outResult.Value;

//将参数读进一个DataTable
OracleDataAdapter adapter = new OracleDataAdapter(command);
adapter.Fill(outTable , refCursor);