C# 連接Oracle，並調用存儲過程（存在返回值），C# 調用sql存儲過程

1.獲取Oracle表格信息

        public OracleHelpers(string ConnStr)
        {
            ConnectionString = ConnStr;
            conn = new OracleConnection(ConnectionString);
            error = "";
             //String connString = @"Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=192.168.1.210)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=ORCL)));User Id=TEST;Password=TEST123"; 
             //Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=10.1.50.23)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=未知)));User ID=gadata0004;Password=gold;
        
        }
        public bool CheckConn(out string err)
        {
            try
            {
                conn.Open();
                err = "";
                return true;
            }
            catch (Exception ex)
            {
                err = ex.Message;
                return false;
            }
            finally
            {
                conn.Close();
            }
        }
        //獲取表名列表
        public DataTable GetConnectionTables()
        {
            return GetDataTable("SELECT TABLE_NAME 表名 FROM USER_ALL_TABLES");
        }





        //獲取表名列表
        public DataTable GetConnectionTables(string sqlStr)
        {
            return GetDataTable(sqlStr);
        }

        //獲取Oracle某連接下的所有視圖名
        public DataTable GetConnectionViews()
        {
            return GetDataTable("select View_Name from  user_views");
        }

        //根據sql語句返回datatable
        public DataTable GetDataTable(string sqlStr)
        {
            DataTable dt = null;
            try
            {
                if (conn.State == ConnectionState.Closed)
                {
                    conn.Open();
                }

                OracleDataAdapter da = new OracleDataAdapter(sqlStr, conn);

                dt = new DataTable();
                da.Fill(dt);
            }
            catch (Exception ex)
            {
                error += "GetConnectionViews:" + ex.Message + "\r\n";
                MessageBox.Show(error);
            }
            finally
            {
                conn.Close();
            }
            return dt;
        }

        /// <summary>
        /// 返回DataSet對象
        /// </summary>
        /// <param name="sqlStr">sql語句</param>
        /// <returns>DataSet對象</returns>
        public DataSet GetDataSet(string sqlStr)
        {
            DataSet ds = null;
            try
            {
                if (conn.State == ConnectionState.Closed)
                {
                    conn.Open();
                }

                OracleDataAdapter da = new OracleDataAdapter(sqlStr, conn);

                ds = new DataSet();
                da.Fill(ds);
            }
            catch (Exception ex)
            {
                error += "GetConnectionViews:" + ex.Message + "\r\n";
                MessageBox.Show(error);
            }
            finally
            {
                conn.Close();
            }
            return ds;
        }

        /// <summary>
        /// 獲取表的字段名
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <returns>DataTable</returns>
        public DataTable GetColumns(string tableName)
        {
            //string sSql = "SELE   CT USER_TAB_COLS.COLUMN_NAME as 列名 FROM USER_TAB_COLS " 
            //+ "inner join user_col_comments on user_col_comments.TABLE_NAME = USER_TAB_COLS.TABLE_NAME "
            //+ "and user_col_comments.COLUMN_NAME = USER_TAB_COLS.COLUMN_NAME and USER_TAB_COLS.TABLE_NAME = '" + tableName + "'";
            string sSql = "select distinct COLUMN_NAME as 列名 from all_TAB_COLUMNS where table_name = '" + tableName + "'";
            return GetDataTable(sSql);


            ////獲取表信息的T-SQL語句備用
            //string sql = "SELECT USER_TAB_COLS.TABLE_NAME as 表名, USER_TAB_COLS.COLUMN_NAME as 列名, "
            //    + "USER_TAB_COLS.DATA_TYPE as 數據類型, USER_TAB_COLS.DATA_LENGTH as 長度, "
            //    + "USER_TAB_COLS.NULLABLE as 是否為空, USER_TAB_COLS.COLUMN_ID as 列序號, user_col_comments.comments as 備注 "
            //    + "inner join user_col_comments on user_col_comments.TABLE_NAME = USER_TAB_COLS.TABLE_NAME "
            //    + "and user_col_comments.COLUMN_NAME = USER_TAB_COLS.COLUMN_NAME and USER_TAB_COLS.TABLE_NAME = 'T_COMPANY_DETAIL" + "'";
        }

 

2.調用 三個存儲過程  增、刪、改 

        public void item_update(string myitemcode,
            string myitemcode_new, string myitemname, string myitemstyle,
            string myitemnaturename, string myitemtypename, string mypositionname,
            out int intmark, out string strreason)
        {
            OracleCommand cmd = new OracleCommand();
            OracleConnection conn = new OracleConnection(ConnectionString);
            try
            {
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = "item_Update";
                OracleParameter[] parm = new OracleParameter[9];
                parm[0] = new OracleParameter("myitemcode", OracleType.VarChar);
                parm[1] = new OracleParameter("myitemcode_new", OracleType.VarChar);
                parm[2] = new OracleParameter("myitemname", OracleType.VarChar);
                parm[3] = new OracleParameter("myitemstyle", OracleType.VarChar);
                parm[4] = new OracleParameter("myitemnaturename", OracleType.VarChar);
                parm[5] = new OracleParameter("myitemtypename", OracleType.VarChar);
                parm[6] = new OracleParameter("mypositionname", OracleType.VarChar);
                parm[7] = new OracleParameter("intmark", OracleType.Int32);
                parm[8] = new OracleParameter("strreason", OracleType.VarChar,35);
                for (int i = 0; i < parm.Length - 2; i++)
                {
                    parm[i].Direction = ParameterDirection.Input;
                }
               //指定返回參數
                parm[7].Direction = ParameterDirection.Output;
                parm[8].Direction = ParameterDirection.Output;
               //傳入參數賦值
                parm[0].Value = myitemcode;
                parm[1].Value = myitemcode_new;
                parm[2].Value = myitemname;
                parm[3].Value = myitemstyle;
                parm[4].Value = myitemnaturename;
                parm[5].Value = myitemtypename;
                parm[6].Value = mypositionname;
                //將對象放到cmd里面
                for (int i = 0; i < parm.Length; i++)
                {
                    cmd.Parameters.Add(parm[i]);
                }
                if (conn.State != ConnectionState.Open)
                    conn.Open();

                cmd.Connection = conn;
                cmd.ExecuteNonQuery();

                //返回參數
                intmark = Convert.ToInt32(parm[7].Value);//res
                strreason = parm[8].Value.ToString();//err
            }
            catch
            {

                intmark = 3;
                strreason = "";
            }

            finally
            {
                if (conn.State == ConnectionState.Open)
                    conn.Close();
                conn.Dispose();
                cmd.Parameters.Clear();
                cmd.Dispose();
            }
        }
        public void item_deleted(string itemcode, out int intmark, out string strreason)
        {
            OracleCommand cmd = new OracleCommand();
            OracleConnection conn = new OracleConnection(ConnectionString);
            try
            {
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = "item_deleted";
                OracleParameter[] parm = new OracleParameter[3];
                parm[0] = new OracleParameter("itemcode", OracleType.VarChar);
                parm[1] = new OracleParameter("intmark", OracleType.Int32);
                parm[2] = new OracleParameter("strreason", OracleType.VarChar,35);
                for (int i = 0; i < parm.Length - 2; i++)
                {
                    parm[i].Direction = ParameterDirection.Input;
                }
                parm[1].Direction = ParameterDirection.Output;
                parm[2].Direction = ParameterDirection.Output;

                parm[0].Value = itemcode;
                for (int i = 0; i < parm.Length; i++)
                {
                    cmd.Parameters.Add(parm[i]);
                }
                if (conn.State != ConnectionState.Open)
                    conn.Open();

                cmd.Connection = conn;
                cmd.ExecuteNonQuery();

                //返回參數
                intmark = Convert.ToInt32(parm[1].Value);//res
                strreason = parm[2].Value.ToString();//err
            }
            catch
            {
                intmark = 3;
                strreason = "";
            }

            finally
            {
                if (conn.State == ConnectionState.Open)
                    conn.Close();
                conn.Dispose();
                cmd.Parameters.Clear();
                cmd.Dispose();
            }
        }

        public void item_insert(string myitemcode, string myitemname, string myitemstyle, string myitemnaturename,
            string myitemtypename, string mypositionname, string myitemunitgroupname, string myunitname, string mycustomname0, string mycustomname2,
            out int intmark, out string strreason)
        {
            //ConnectionString
            OracleCommand cmd = new OracleCommand();
            OracleConnection conn = new OracleConnection(ConnectionString);
            try
            {
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = "item_insert";
                OracleParameter[] parm = new OracleParameter[12];
                parm[0] = new OracleParameter("myitemcode", OracleType.VarChar);
                parm[1] = new OracleParameter("myitemname", OracleType.VarChar);
                parm[2] = new OracleParameter("myitemstyle", OracleType.VarChar);
                parm[3] = new OracleParameter("myitemnaturename", OracleType.VarChar);
                parm[4] = new OracleParameter("myitemtypename", OracleType.VarChar);
                parm[5] = new OracleParameter("mypositionname", OracleType.VarChar);
                parm[6] = new OracleParameter("myitemunitgroupname", OracleType.VarChar);
                parm[7] = new OracleParameter("myunitname", OracleType.VarChar);
                parm[8] = new OracleParameter("mycustomname0", OracleType.VarChar);//out                                                    //out
                parm[9] = new OracleParameter("mycustomname2", OracleType.VarChar);//out
                intmark = 3;
                strreason = "";
                parm[10] = new OracleParameter("intmark", OracleType.Int32);
                parm[11] = new OracleParameter("strreason", OracleType.VarChar,35);
                for (int i = 0; i < parm.Length - 2; i++)
                {
                    parm[i].Direction = ParameterDirection.Input;
                }
                parm[10].Direction = ParameterDirection.Output;
                parm[11].Direction = ParameterDirection.Output;

                parm[0].Value = myitemcode;
                parm[1].Value = myitemname;
                parm[2].Value = myitemstyle;
                parm[3].Value = myitemnaturename;
                parm[4].Value = myitemtypename;
                parm[5].Value = mypositionname;
                parm[6].Value = myitemunitgroupname;
                parm[7].Value = myunitname;
                parm[8].Value = mycustomname0;
                parm[9].Value = mycustomname2;

                for (int i = 0; i < parm.Length; i++)
                {
                    cmd.Parameters.Add(parm[i]);
                }
                if (conn.State != ConnectionState.Open)
                    conn.Open();

                cmd.Connection = conn;
                cmd.ExecuteNonQuery();

                //返回參數
                intmark = Convert.ToInt32(parm[10].Value);//res
                strreason = parm[11].Value.ToString();//err
            }
            catch
            {
                intmark = 3;
                strreason = "";
            }

            finally
            {
                if (conn.State == ConnectionState.Open)
                    conn.Close();
                conn.Dispose();
                cmd.Parameters.Clear();
                cmd.Dispose();
            }

        }

3.三個存儲過程整合成一個

 

 

    public void OrecalNew(string CunChuName, OracleParameter[] parm, int OutCount, out  List<string> Outlist)
        {
            OracleCommand cmd = new OracleCommand();
            OracleConnection conn = new OracleConnection(ConnectionString);
            try
            {
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandText = CunChuName;
                for (int i = 0; i < parm.Length; i++)
                {
                    cmd.Parameters.Add(parm[i]);
                }
                if (conn.State != ConnectionState.Open)
                    conn.Open();

                cmd.Connection = conn;
                cmd.ExecuteNonQuery();

                //返回參數
                if (OutCount != 0)
                {
                    List<string> listOut = new List<string>();
                    for (int a = parm.Length - OutCount; a < parm.Length; a++)
                    {
                        listOut.Add(parm[a].Value.ToString().Trim());
                    }
                    Outlist = listOut;
                }
                else
                {
                    Outlist = new List<string>();
                }
            }
            catch
            {
                Outlist = new List<string>();
            }

            finally
            {
                if (conn.State == ConnectionState.Open)
                    conn.Close();
                conn.Dispose();
                cmd.Parameters.Clear();
                cmd.Dispose();
            }

        }

 4.C# 調取本地SQL server  存儲過程

注釋：C#  在調取SQL存儲過程時，與調取Oracle存儲過程完全一致

SQL 存儲過程

ALTER PROCEDURE [dbo].[Get_Data]    
        @QQ int, 
        @WW int, 
        @EE VARCHAR(50), 
        @RR VARCHAR(50), 
        @TT int out,
        @YY int out
        as 
        begin     
         set  @TT = @QQ * @WW 
         set  @YY = @WW
     end

調取

        public void Begin()
        {
            SqlConnection conn = new SqlConnection("server=.;uid=sa;pwd=123;database=DB_Config");
            //建立一個空的SqlCommand對象
            SqlCommand comm = new SqlCommand();
            //制定調用類型為存儲過程
            comm.CommandType = CommandType.StoredProcedure;
            //存儲過程的名稱
            comm.CommandText = "Get_Data";
            //定義數組
            SqlParameter[] parm = new SqlParameter[6];
            //指定變量的類型
            parm[0] = new SqlParameter("QQ", SqlDbType.BigInt);
            parm[1] = new SqlParameter("WW", SqlDbType.BigInt);
            parm[2] = new SqlParameter("EE", SqlDbType.VarChar);
            parm[3] = new SqlParameter("RR", SqlDbType.VarChar);
            parm[4] = new SqlParameter("TT", SqlDbType.BigInt);
            parm[5] = new SqlParameter("YY", SqlDbType.BigInt);
            //設置變量為傳入參數還是傳出參數
            parm[0].Direction = ParameterDirection.Input;
            parm[1].Direction = ParameterDirection.Input;
            parm[2].Direction = ParameterDirection.Input;
            parm[3].Direction = ParameterDirection.Input;
            parm[4].Direction = ParameterDirection.Output;
            parm[5].Direction = ParameterDirection.Output;
            //給傳入參數賦值
            parm[0].Value = TT1.Text.ToString();
            parm[1].Value = TT2.Text.ToString();
            parm[2].Value = TT3.Text.ToString();
            parm[3].Value = TT4.Text.ToString();

            //將對象放到Comm里面
            for (int a = 0; a < parm.Length; a++)
            {
                comm.Parameters.Add(parm[a]);
            }
            //執行
            if (conn.State != ConnectionState.Open)
                conn.Open();

            comm.Connection = conn;
            comm.ExecuteNonQuery();
            //執行完接收返回參數
            MessageBox.Show("信息："+ parm[4].Value +"and"+parm[5].Value);
        }

親測成功