C#利用ODP.NET往oracle中高效插入百萬數據

　　由於工作的原因，要使用winform來處理大量的數據，但是c#自帶的System.data.OracleClient效率不是很高，在網上找了很久，找到了ODP.NET，是oracle為c#提供的。貌似從vs2010開始，微軟開始推薦使用ODP.NET。效率的話，在沒有索引的情況下，100萬數據，不到10秒。剛開始使用的時候，由於不是很懂，所以有一些步驟是多余的，現在重新修改下。(這里是需要安裝ODAC客戶端)

　　1.從官網上下載ODAC，如果你是32位的機器，那下載32的；64位的，就下載64的。我的win7, 64位，所以我下載的是ODAC1120320_x64，具體地址：

　　64位：http://www.oracle.com/technetwork/database/windows/downloads/index-090165.html

　　32位：http://www.oracle.com/technetwork/developer-tools/visual-studio/downloads/index.html

 

　　2.解壓，然后點擊 setup.exe 安裝，然后在這個地址：D:\app\12\product\11.2.0\client_1\odp.net\bin\2.x

　　

　　3.在項目中，添加引用，就可以使用了，用法跟自帶的System.data.OracleClient差不多

　　

　　

　　5.批量插入：

//設置一個數據庫的連接串   
string connectStr = "User Id=scott;Password=tiger;Data Source=";   
OracleConnection conn = new OracleConnection(connectStr);   
OracleCommand command = new OracleCommand();   
command.Connection = conn; //到此為止，還都是我們熟悉的代碼，下面就要開始嘍   
//這個參數需要指定每次批插入的記錄數   
command.ArrayBindCount = recc;   
//在這個命令行中,用到了參數,參數我們很熟悉,但是這個參數在傳值的時候   
//用到的是數組,而不是單個的值,這就是它獨特的地方   
command.CommandText = "insert into dept values(:deptno, :deptname, :loc)";   
conn.Open();   
//下面定義幾個數組,分別表示三個字段,數組的長度由參數直接給出   
int[] deptNo = new int[recc];   
string[] dname = new string[recc];   
string[] loc = new string[recc];   
// 為了傳遞參數,不可避免的要使用參數,下面會連續定義三個   
// 從名稱可以直接看出每個參數的含義,不在每個解釋了   
OracleParameter deptNoParam = new OracleParameter("deptno",   
OracleDbType.Int32);   
deptNoParam.Direction = ParameterDirection.Input;   
deptNoParam.Value = deptNo; command.Parameters.Add(deptNoParam);   
OracleParameter deptNameParam = new OracleParameter("deptname",   
OracleDbType.Varchar2);  
deptNameParam.Direction = ParameterDirection.Input;   
deptNameParam.Value = dname;   
command.Parameters.Add(deptNameParam);  
 OracleParameter deptLocParam = new OracleParameter("loc", OracleDbType.Varchar2); 
deptLocParam.Direction = ParameterDirection.Input;  
 deptLocParam.Value = loc;   
command.Parameters.Add(deptLocParam);   
Stopwatch sw = new Stopwatch();   
sw.Start();   
//在下面的循環中,先把數組定義好,而不是像上面那樣直接生成SQL   
for (int i = 0; i < recc; i++)  
{   
deptNo[i] = i;   
dname[i] = i.ToString();   
loc[i] = i.ToString();   
}   
//這個調用將把參數數組傳進SQL,同時寫入數據庫   
command.ExecuteNonQuery(); 
sw.Stop(); 
System.Diagnostics.Debug.WriteLine("批量插入:" + recc.ToString()   
+ "所占時間:" +sw.ElapsedMilliseconds.ToString());  

　　

　　6.上面的代碼太亂，給一個已經封裝好的批量插入的方法：

/**
        * 批量插入數據
        * @tableName 表名稱
        * @columnRowData 鍵-值存儲的批量數據：鍵是列名稱，值是對應的數據集合
        * @conStr 連接字符串
        * @len 每次批處理數據的大小
        */
        public static int BatchInsert(string tableName, Dictionary<string, object> columnRowData, string conStr, int len)
        {
            if (string.IsNullOrEmpty(tableName))
            {
                throw new ArgumentException("必須指定批量插入的表名稱", "tableName");
            }

            if (columnRowData == null || columnRowData.Count < 1)
            {
                throw new ArgumentException("必須指定批量插入的字段名稱", "columnRowData");
            }

            int iResult = 0;
            string[] dbColumns = columnRowData.Keys.ToArray();
            StringBuilder sbCmdText = new StringBuilder();
            if (columnRowData.Count > 0)
            {
                //准備插入的SQL
                sbCmdText.AppendFormat("INSERT INTO {0}(", tableName);
                sbCmdText.Append(string.Join(",", dbColumns));
                sbCmdText.Append(") VALUES (");
                sbCmdText.Append(":" + string.Join(",:", dbColumns));
                sbCmdText.Append(")");

                using (OracleConnection conn = new OracleConnection(conStr))
                {
                    using (OracleCommand cmd = conn.CreateCommand())
                    {
                        //綁定批處理的行數
                        cmd.ArrayBindCount = len;
                        cmd.BindByName = true;
                        cmd.CommandType = CommandType.Text;
                        cmd.CommandText = sbCmdText.ToString();
                        cmd.CommandTimeout = 600;//10分鍾

                        //創建參數
                        OracleParameter oraParam;
                        List<IDbDataParameter> cacher = new List<IDbDataParameter>();
                        OracleDbType dbType = OracleDbType.Object;
                        foreach (string colName in dbColumns)
                        {
                            dbType = GetOracleDbType(columnRowData[colName]);
                            oraParam = new OracleParameter(colName, dbType);
                            oraParam.Direction = ParameterDirection.Input;
                            oraParam.OracleDbTypeEx = dbType;

                            oraParam.Value = columnRowData[colName];
                            cmd.Parameters.Add(oraParam);
                        }
                        //打開連接
                        conn.Open();

                        /*執行批處理*/
                        var trans = conn.BeginTransaction();
                        try
                        {
                            cmd.Transaction = trans;
                            iResult = cmd.ExecuteNonQuery();
                            trans.Commit();
                        }
                        catch (Exception ex)
                        {
                            trans.Rollback();
                            throw ex;
                        }
                        finally
                        {
                            if (conn != null) conn.Close();
                        }

                    }
                }
            }
            return iResult;
        }

        /**
         * 根據數據類型獲取OracleDbType
         */
        private static OracleDbType GetOracleDbType(object value)
        {
            OracleDbType dataType = OracleDbType.Object;
            if (value is string[])
            {
                dataType = OracleDbType.Varchar2;
            }
            else if (value is DateTime[])
            {
                dataType = OracleDbType.TimeStamp;
            }
            else if (value is int[] || value is short[])
            {
                dataType = OracleDbType.Int32;
            }
            else if (value is long[])
            {
                dataType = OracleDbType.Int64;
            }
            else if (value is decimal[] || value is double[] || value is float[])
            {
                dataType = OracleDbType.Decimal;
            }
            else if (value is Guid[])
            {
                dataType = OracleDbType.Varchar2;
            }
            else if (value is bool[] || value is Boolean[])
            {
                dataType = OracleDbType.Byte;
            }
            else if (value is byte[])
            {
                dataType = OracleDbType.Blob;
            }
            else if (value is char[])
            {
                dataType = OracleDbType.Char;
            }
            return dataType;
        }

　　7.調用封裝的方法：

　　

　　8.完成。

　　對於服務器上的oracle版本問題，我們的是10g，但是我用的ODP是11g的，還是可以插入數據，沒什么問題，貌似可以向下兼容