表數(shù)據(jù)的批量插入

昵稱10504424 2013-05-08

展開全文

當(dāng)一個表要插入數(shù)據(jù)庫時，手動編寫sql插入語句是不太現(xiàn)實的，效率也比較低。

        public void ExecuteTransactionScopeInsertEx(DataTable dt, string tableName)
        {
            using (SqlBulkCopy sbc = new SqlBulkCopy(Common.ConnStr, SqlBulkCopyOptions.UseInternalTransaction))
            {
                //服務(wù)器上目標(biāo)表的名稱   
                sbc.DestinationTableName = tableName;
                sbc.BatchSize = dt.Rows.Count;
                sbc.BulkCopyTimeout = 600;

                for (int i = 0, l = dt.Columns.Count; i < l; i++)
                {
                    //列映射定義數(shù)據(jù)源中的列和目標(biāo)表中的列之間的關(guān)系   
                    sbc.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
                }

                sbc.WriteToServer(dt);
            }
        }

如果表的列名與數(shù)據(jù)庫的列名不能一一對應(yīng)，則需重載上述方法

View Code

        public void ExecuteTransactionScopeInsertEx(DataTable dt, string tableName, string[] dbComlunName)
        {
            using (SqlBulkCopy sbc = new SqlBulkCopy(Common.ConnStr, SqlBulkCopyOptions.UseInternalTransaction))
            {
                //服務(wù)器上目標(biāo)表的名稱   
                sbc.DestinationTableName = tableName;
                sbc.BatchSize = dt.Rows.Count;
                sbc.BulkCopyTimeout = 600;

                for (int i = 0, l = dt.Columns.Count; i < l; i++)
                {
                    //列映射定義數(shù)據(jù)源中的列和目標(biāo)表中的列之間的關(guān)系   
                    sbc.ColumnMappings.Add(dt.Columns[i].ColumnName, dbComlunName[i]);
                }

                sbc.WriteToServer(dt);
            }
        }

如果需要自己指定控件的哪些列對應(yīng)數(shù)據(jù)庫的哪些列，則又需要重載

View Code

        public void ExecuteTransactionScopeInsertEx(DataTable dt, string tableName, string[] displayName, string[] dbComlunName)
        {
            using (SqlBulkCopy sbc = new SqlBulkCopy(Common.ConnStr, SqlBulkCopyOptions.UseInternalTransaction))
            {
                //服務(wù)器上目標(biāo)表的名稱   
                sbc.DestinationTableName = tableName;
                sbc.BatchSize = dt.Rows.Count;
                sbc.BulkCopyTimeout = 600;

                for (int i = 0, l = dt.Columns.Count; i < l; i++)
                {
                    //列映射定義數(shù)據(jù)源中的列和目標(biāo)表中的列之間的關(guān)系   
                    sbc.ColumnMappings.Add(displayName[i], dbComlunName[i]);
                }

                sbc.WriteToServer(dt);
            }
        }