Oracle创建包、存储过程，及C#中调用

create or replace package body PK_DataTransfer is

--  积分卡合并                            2009-7-14
    procedure p_MemberMergence(s_SMemberID in nvarchar2,s_TMemberID in nvarchar2,n_Usersn in number) is
    begin
         update plus.tsell s
            set s.memberid=s_TMemberID,s.lastupdatedby=n_Usersn,s.lastupdatedon=sysdate
          where s.memberid=s_SMemberID;

         update plus.tsellrgoods r
            set r.memberid=s_TMemberID,r.lastupdatedby=n_Usersn,r.lastupdatedon=sysdate
          where r.memberid=s_SMemberID;

         update plus.tpointmanage p
            set p.ghmembersn=(select ghmembersn
                                from tmember
                               where memberid=s_TMemberID)
               ,p.lastupdatedby=n_Usersn,p.lastupdatedon=sysdate
         where p.ghmembersn=(select ghmembersn
                               from tmember
                              where memberid=s_SMemberID);

         update plus.tmember m
            set m.mpointsum=nvl(m.mpointsum,0)+(select mpointsum
                                                  from plus.tmember a
                                                 where a.memberid=s_SMemberID)
               ,m.lastupdatedby=n_Usersn,m.lastupdatedon=sysdate
          where m.memberid=s_TMemberID;

         update plus.tmember m
            set m.flag='*',m.pointsum=0,m.amountsum=0,m.lastupdatedby=n_Usersn,m.lastupdatedon=sysdate
          where m.memberid=s_SMemberID;

         commit;
    end;

C#中执行Oracle中的存储过程
 OracleParameter[] pms={new OracleParameter("s_SMemberID",OracleType.NVarChar,50),
            new OracleParameter("s_TMemberID",OracleType.NVarChar,50),
            new OracleParameter("n_Usersn",OracleType.Number)
           };
    pms[0].Value=ds.Tables[0].Rows[0][0].ToString();
    pms[0].Direction=ParameterDirection.Input;
    pms[1].Value=ds.Tables[0].Rows[0][1].ToString();
    pms[1].Direction=ParameterDirection.Input;
    pms[2].Value=Convert.ToInt64(this.Session["UserId"].ToString());
    pms[2].Direction=ParameterDirection.Input;
    dboperReq.RunProcedure("PK_DataTransfer.p_MemberMergence",pms);

public void RunProcedure(string storedProcName,OracleParameter[] parameters)
  {
   OracleConnection oracleconn = new OracleConnection() ;
   OracleCommand oraclecmd = new OracleCommand() ;
   oracleconn.ConnectionString =ConfigurationSettings.AppSettings["DBConnfortrans"] ;
   oraclecmd.Connection = oracleconn ;
   oracleconn.Open() ;   
   OracleTransaction otrans=oracleconn.BeginTransaction();         
   
   try
   {
    oraclecmd.Transaction=otrans;
    oraclecmd.CommandText=storedProcName;//声明存储过程名
    oraclecmd.CommandType=CommandType.StoredProcedure;
    foreach(OracleParameter parameter in parameters)
    {
     oraclecmd.Parameters.Add(parameter);
    }
    oraclecmd.ExecuteNonQuery();//执行存储过程
    otrans.Commit();
    oraclecmd.Dispose();
    oracleconn.Dispose();
   }
   catch(Exception err)
   {
    otrans.Rollback();
    oraclecmd.Dispose();
    oracleconn.Dispose();
    throw err ;
   }
  }