正在阅读:C#+Oracle开发中执行存储过程问题C#+Oracle开发中执行存储过程问题

2005-07-22 10:16 出处: 作者:dinya 责任编辑:moningfeng

[内容摘要]

  当前开发过程中,微软的.NET以其易用和对网络的支持性好等而倍受开发人员的青睐,不少项目使用Oralce数据库作为后台数据库,但是在开发过程中需要通过前台程序调用数据库中的一些对象,本文将以一个实例的形式,对C#+Oracle数据库的开发中C#执行Oracle存储过程问题做一简要阐述。

[本文适宜读者范围]

  .NET+Oracel开发人员,Oracle初级

[系统环境]

  OS:windows 2000 Professional (英文版) Oracle:8.1.7.1.0 .NET:.Net 2003

[正文]

  我们在使用C#+Oracle 数据库开发C/S结构的程序时。有相当大一部分的事务会考虑放在Oracle数据库中来处理,以减少网络数据流量、提高程序的性能。这样就要求我们将业务逻辑化,抽象化,使用Oracle的存储过程是一个不错的选择。下面我将使用一个实例来说明一下C#使用Oracle存储过程来执行业务操作的过程:

需求描述:

  在前端界面上输入用户名、密码、用户姓名、用户电话号码及用户类型等基础资料后。调用Oracle数据库中的增加用户信息的存储过程来执行增加新用户信息的功能。要求用户名、密码及用户类型不能为空,用户名不能有重复,本例中使用OldDbConnection来连接Oracle数据库。

1、在数据库中建一用户表及用户ID的序列:

create sequence seq_user_information
increment by 1
start with 1
nomaxvalue
nocycle
cache 10
create table user_information
(
 user_id number primary key, --用户序号
 user_login_name varchar2(30) not null, --登陆名
 user_password varchar2(50) not null, --用户密码
 user_name varchar2(20), --用户姓名
 user_telephone varchar2(20), --用户电话
 user_type number(5) , --用户类型
 creation_date date not null, --创建日期
 last_update_date date not null --最后修改日期
)



2、在Oracle中建执行插入操作的存储过程:

create or replace procedure insert_user_information
(
 p_user_login_name in varchar2,
 p_user_password in varchar2,
 p_user_name in varchar2,
 p_user_telephone in varchar2,
 p_user_type in number,
 p_out out number
) as
 v_count number;
begin
 if p_user_login_name is null or p_user_password is null then
  p_out:=-1; --用户名和密码不能为空,
  return ;
 end if;
 if p_user_type is null then p_out:=-2; --用户类型不能为空
  return ;
 end if;
 select count(*) into v_count from user_information a where .user_login_name=upper(p_user_login_name);
 if v_count>0 then
  p_out:=-3; --该用户名已经存在
  return ;
 end if;
 insert into user_information
  values(seq_user_information.nextval,upper(p_user_login_name), p_user_password,p_user_name,p_user_telephone,p_user_type, sysdate,sysdate);
 commit;
 p_out:=0; --操作成功
 return ;
exception
 when others then
  p_out:=-4; --插入过程中出现异常
  return ;
end ;



3、在.NET项目建一个到数据库的联结:

  在项目中新增加一个类文件。名称:clsPublic,

//添加引用:
using System;
using System.Data;
using System.Data.OleDb;
//连接字符串
private string connectora="Provider=MSDAORA.1;Password=fran;User ID=fran;Data Source=demo;Persist Security Info=True";
//连接Oracle数据库
public OleDbConnection ConnectDB()
{
 try
 {
  OleDbConnection conn=new OleDbConnection();
  conn.ConnectionString=connectora;
  conn.Open();
  return conn;
 }
 catch
 {
  return null;
 }
}



4、在类文件中添加如下内容,用来执行Oracle中的过程:

public int Insert_User_Information(string v_user_login_name,string v_user_password,string v_user_name,string v_user_telephone,int v_user_type,string proc_name)
{
 int i;
 cmdOra.Parameters.Clear();
 cmdOra.CommandText=proc_name;
 cmdOra.CommandType=CommandType.StoredProcedure;
 cmdOra.Connection=new clsPublic().ConnectDB();

 cmdOra.Parameters.Add("p_user_login_name",OleDbType.VarChar);
 cmdOra.Parameters.Add("p_user_password",OleDbType.VarChar);
 cmdOra.Parameters.Add("p_user_name",OleDbType.VarChar);
 cmdOra.Parameters.Add("p_user_telephone",OleDbType.VarChar);
 cmdOra.Parameters.Add("p_user_type",OleDbType.Integer);
 cmdOra.Parameters.Add("p_out",OleDbType.Integer);

 cmdOra.Parameters["p_user_login_name"].Value=v_user_login_name;
 cmdOra.Parameters["p_user_password"].Value=v_user_password;
 cmdOra.Parameters["p_user_name"].Value=v_user_name;
 cmdOra.Parameters["p_user_telephone"].Value=v_user_telephone;
 cmdOra.Parameters["p_user_type"].Value=v_user_type;

 cmdOra.Parameters["p_user_login_name"].Direction=ParameterDirection.Input;
 cmdOra.Parameters["p_user_password"].Direction=ParameterDirection.Input;
 cmdOra.Parameters["p_user_name"].Direction=ParameterDirection.Input;
 cmdOra.Parameters["p_user_telephone"].Direction=ParameterDirection.Input;
 cmdOra.Parameters["p_user_type"].Direction=ParameterDirection.Input;
 cmdOra.Parameters["p_out"].Direction=ParameterDirection.ReturnValue;

 try
 {
  cmdOra.ExecuteNonQuery();
  i=(int)cmdOra.Parameters["p_out"].Value;
 }
 catch
 {
  i=-88;
 }
 finally
 {
  if(cmdOra.Connection.State==ConnectionState.Open)
 {
  cmdOra.Connection.Close();
  cmdOra.Connection.Dispose();
  cmdOra.Parameters.Clear();
  cmdOra.Dispose();
 }
 }
 return i;
}



5、在窗体界面中调用执行存储过程

private void button3_Click_1(object sender, System.EventArgs e)
{
  int i=new clsPublic().Insert_User_Information ("dinya","111","DINYA","13877778888",0, "cux_franchiser.insert_user_information"); MessageBox.Show(i.ToString());
}


  在本例第二步中,定义一个输出参数用来存储执行的结果,Oracle存储过程允许给输出参数直接赋值,在。NET中设置该参数类型:

  cmdOra.Parameters["p_out"].Direction=ParameterDirection.ReturnValue;


  将其设置为返回值,这样在调用Insert_User_Information执行存储过程后,该参数将执行结果返回给用户。

  在第五步窗体界面中调用存储过程的时候,最后一个参数为"cux_franchiser.insert_user_information",该值中cux_franchiser为自己定义的一个包,insert_user_information为包中的过程。(具体对包的使用请参考Oracle相关书籍中有关包的使用一节)。

  其中需要指出的是,用来连接Oracle数据库的联结串会因为OleDB的厂家不同而不同,本例中使用微软的,您在开发过程也可以使用Oracle公司的,可以到Oralce 网站下载,地址:  http://www.oracle.com/technology/software/tech/windows/ole_db/index.html

后记:
  在.NET + Oracle的开发过程,当然还有很多其他的操作技巧,希望本文能够起到抛砖引玉的作用,刚接触开发的读者或Oracle初学者,可以参考本文,举一反三。

关注我们

最新资讯离线随时看 聊天吐槽赢奖品