使用ADO.NET操做Oracle數據庫

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

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

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

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

 1            string strConn = "Data Source=jayjay;User ID=hr;Password=oracle;Unicode=True";
 2 
 3             //調用存儲過程
 4             using (OracleConnection conn = new OracleConnection(strConn))
 5             {
 6                 conn.Open();
 7                 using (OracleCommand cmd = new OracleCommand("INSERT_PROCEDURE", conn))
 8                 {
 9                     cmd.CommandType = CommandType.StoredProcedure;
10                     cmd.ExecuteNonQuery();
11                 }
12             }
13             //顯示調用存儲過程後的數據
14             using (OracleConnection conn = new OracleConnection(strConn))
15             {
16                 conn.Open();
17                 using (OracleCommand cmd = new OracleCommand("select * from Jobs where JOB_ID='MY_JOB'", conn))
18                 {
19                     cmd.CommandType = CommandType.Text;
20                     OracleDataAdapter adapter = new OracleDataAdapter(cmd);
21                     DataSet dataSet = new DataSet();
22                     adapter.Fill(dataSet);//執行cmd.ExecuteReader();並將結果添加到DataSet容器中 23                     DataRow row = dataSet.Tables[0].Rows[0];
24                     Console.WriteLine("執行select * from Jobs where JOB_ID=MY_JOB以後獲得的信息：");
25                     for(int i =0 ;i<4;i++)
26                     {
27                         Console.WriteLine(row[i]);
28                     }
29                 }
30             }
31 
32             //調用函數
33             using (OracleConnection conn = new OracleConnection(strConn))
34             {
35                 conn.Open();
36                 using (OracleCommand cmd = new OracleCommand("UPDATE_MIN_SALARY", conn))
37                 {
38                     cmd.CommandType = CommandType.StoredProcedure;
39                     
40                     // 將參數類型設置爲 返回值類型
41                     OracleParameter parameter = new OracleParameter();
42                     parameter.Direction = ParameterDirection.ReturnValue;
43                     parameter.OracleType = OracleType.Int32;
44                     cmd.Parameters.Add(parameter);
45 
46                     cmd.ExecuteNonQuery();
47                     Console.WriteLine("受影響的行數爲：" + parameter.Value);
48                 }
49             }
50 
51             //顯示調用函數後的數據
52             using (OracleConnection conn = new OracleConnection(strConn))
53             {
54                 conn.Open();
55                 using (OracleCommand cmd = new OracleCommand("select * from Jobs where MIN_SALARY=4000", conn))
56                 {
57                     cmd.CommandType = CommandType.Text;
58                     OracleDataAdapter adapter = new OracleDataAdapter(cmd);
59                     DataSet dataSet = new DataSet();
60                     adapter.Fill(dataSet);
61 
62                     Console.WriteLine("執行select * from Jobs where MIN_SALARY=4000以後獲得的行數：" + dataSet.Tables[0].Rows.Count);                  
63                 }
64             }
65 
66             Console.ReadKey();
67         }

ps:因爲使用的是32位的老版本oracle 10g，因此項目的目標平臺要改成x86，即32位平臺，否則conn.open();會報錯！