使用ADO.NET操作Oracle數據庫

本文將示例使用C#的ADO.NET技術調用Oralce的存儲過程和函數及操作Oracle數據庫。

在oracle的hr數據庫中建立存儲過程

在oralce的hr數據庫中建立函數

新建控制台項目，在主函數添加代碼：

           string strConn = "Data Source=jayjay;User ID=hr;Password=oracle;Unicode=True";

            //調用存儲過程
            using (OracleConnection conn = new OracleConnection(strConn))
            {
                conn.Open();
                using (OracleCommand cmd = new OracleCommand("INSERT_PROCEDURE", conn))
                {
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.ExecuteNonQuery();
                }
            }
            //顯示調用存儲過程后的數據
            using (OracleConnection conn = new OracleConnection(strConn))
            {
                conn.Open();
                using (OracleCommand cmd = new OracleCommand("select * from Jobs where JOB_ID='MY_JOB'", conn))
                {
                    cmd.CommandType = CommandType.Text;
                    OracleDataAdapter adapter = new OracleDataAdapter(cmd);
                    DataSet dataSet = new DataSet();
                    adapter.Fill(dataSet);//執行cmd.ExecuteReader();並將結果添加到DataSet容器中 23                     DataRow row = dataSet.Tables[0].Rows[0];
                    Console.WriteLine("執行select * from Jobs where JOB_ID=MY_JOB之后得到的信息：");
                    for(int i =0 ;i<4;i++)
                    {
                        Console.WriteLine(row[i]);
                    }
                }
            }

            //調用函數
            using (OracleConnection conn = new OracleConnection(strConn))
            {
                conn.Open();
                using (OracleCommand cmd = new OracleCommand("UPDATE_MIN_SALARY", conn))
                {
                    cmd.CommandType = CommandType.StoredProcedure;
                    
                    // 將參數類型設置為 返回值類型
                    OracleParameter parameter = new OracleParameter();
                    parameter.Direction = ParameterDirection.ReturnValue;
                    parameter.OracleType = OracleType.Int32;
                    cmd.Parameters.Add(parameter);

                    cmd.ExecuteNonQuery();
                    Console.WriteLine("受影響的行數為：" + parameter.Value);
                }
            }

            //顯示調用函數后的數據
            using (OracleConnection conn = new OracleConnection(strConn))
            {
                conn.Open();
                using (OracleCommand cmd = new OracleCommand("select * from Jobs where MIN_SALARY=4000", conn))
                {
                    cmd.CommandType = CommandType.Text;
                    OracleDataAdapter adapter = new OracleDataAdapter(cmd);
                    DataSet dataSet = new DataSet();
                    adapter.Fill(dataSet);

                    Console.WriteLine("執行select * from Jobs where MIN_SALARY=4000之后得到的行數：" + dataSet.Tables[0].Rows.Count);                  
                }
            }

            Console.ReadKey();
        }

ps:由於使用的是32位的老版本oracle 10g，所以項目的目標平台要改為x86，即32位平台，不然conn.open();會報錯！