SqlServer使用SqlBulkCopy批量新增和更新數據，快速高效

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Collections;
using System.Reflection;
using System.Configuration;
 
namespace Magic.Tool
{
    /// <summary>
    /// sqlserver數據庫批量新增修改類
    /// </summary>
    public static class SqlBulkHelper
    {
        #region 數據庫連接字符串
        /// <summary>
        /// 數據庫連接字符串
        /// </summary>
        public static readonly string ConnString = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
        #endregion
 
        #region SqlBulkCopy方式批量新增數據
        /// <summary>
        /// SqlBulkCopy方式批量新增數據
        /// </summary>
        /// <typeparam name="T">對象</typeparam>
        /// <param name="modelList">實體類集合</param>
        /// <param name="destinationTableName">目標表明</param>
        /// <param name="removeColumns">移除的字段列集合</param>
        /// <param name="bulkCopyTimeout">超時時間</param>
        public static void BulkCopy<T>(List<T> modelList, string destinationTableName, List<string> removeColumns = null, int? bulkCopyTimeout = null)
        {
            if (string.IsNullOrEmpty(destinationTableName))
            {
                destinationTableName = typeof(T).Name;
            }
            var dt = ContainHelper.ListToTable(modelList);
            if (removeColumns != null && removeColumns.Count > 0)
            {
                foreach (var item in removeColumns)
                {
                    dt.Columns.Remove(item);
                }
            }
            using (SqlConnection conn = new SqlConnection(ConnString))
            {
                using (var sbc = new SqlBulkCopy(conn))
                {
                    sbc.BatchSize = modelList.Count;
                    sbc.DestinationTableName = destinationTableName;
                    sbc.BulkCopyTimeout = bulkCopyTimeout ?? 300;
                    conn.Open();
                    sbc.WriteToServer(dt);
                }
            }
        }
        #endregion
 
        #region SqlBulkCopy方式批量修改數據
        /// <summary>
        /// SqlBulkCopy方式批量修改數據
        /// </summary>
        /// <typeparam name="T">對象</typeparam>
        /// <param name="modelList">實體類集合</param>
        /// <param name="onRelations">關聯字段</param>
        /// <param name="destinationTableName">目標表名</param>
        /// <param name="removeColumns">移除的字段列集合</param>
        /// <param name="UpdateColumns">更新的字段集合，不填則全部</param>
        public static void BatchUpdate<T>(List<T> modelList, string onRelations, string destinationTableName = null, List<string> removeColumns = null, List<string> UpdateColumns = null)
        {
            if (string.IsNullOrEmpty(destinationTableName))
                destinationTableName = typeof(T).Name.Replace("EN", "");
            var dt = ContainHelper.ListToTable(modelList);
            if (removeColumns != null && removeColumns.Count > 0)
            {
                foreach (var item in removeColumns)
                {
                    dt.Columns.Remove(item);
                }
            }
            var sbUpdateColumns = new StringBuilder();
            var columnsIndex = 0;
            //只更新某字段
            if (UpdateColumns != null && UpdateColumns.Count > 0)
            {
                foreach (var updateColumn in UpdateColumns)
                {
                    if (columnsIndex > 0)
                    {
                        sbUpdateColumns.Append(", ");
                    }
                    sbUpdateColumns.AppendFormat("T.{0} = Tmp.{0}", updateColumn);
                    columnsIndex++;
                }
            }
            else
            {
                //更新全部字段
                for (var i = 0; i < dt.Columns.Count; i++)
                {
                    var colname = dt.Columns[i];
                    if (colname.ColumnName != onRelations)
                    {
                        if (columnsIndex > 0)
                        {
                            sbUpdateColumns.Append(", ");
                        }
                        sbUpdateColumns.AppendFormat("T.{0} = Tmp.{0}", colname.ColumnName);
                        columnsIndex++;
                    }
                }
            }
 
 
            string sbOnRelation = string.Format("T.{0} = Tmp.{1}", onRelations, onRelations);
            var tempTableName = @"#Temp" + destinationTableName;
            var createtempsql = string.Format("select * into {0} from {1} where 1=2", tempTableName, destinationTableName);
            var updatesql = string.Format("UPDATE T SET {0} FROM {1} T INNER JOIN {2} Tmp ON {3}; DROP TABLE {2};", sbUpdateColumns.ToString(), destinationTableName, tempTableName, sbOnRelation.ToString());
 
            using (SqlConnection conn = new SqlConnection(ConnString))
            {
                using (SqlCommand command = new SqlCommand("", conn))
                {
                    try
                    {
                        conn.Open();
                        command.CommandText = createtempsql;
                        command.ExecuteNonQuery();
                        using (SqlBulkCopy bulkcopy = new SqlBulkCopy(conn))
                        {
                            bulkcopy.BulkCopyTimeout = 300;
                            bulkcopy.DestinationTableName = tempTableName;
                            bulkcopy.WriteToServer(dt);
                            bulkcopy.Close();
                        }
 
                        command.CommandTimeout = 300;
                        command.CommandText = updatesql;
                        int countQuery = command.ExecuteNonQuery();
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine("BatchUpdate:{0}表失敗,原因:{1}", destinationTableName, ex.Message + ex.StackTrace);
                        // Handle exception properly
                    }
                    finally
                    {
                        //stopwatch.Stop();
                        //Console.WriteLine("更新耗時:{0}",stopwatch.ElapsedMilliseconds);
                        //list.Clear();
                        conn.Close();
                    }
                }
            }
        }
        #endregion
 
    }
}

MSCL超級工具類庫
基於C#開發的超強工具類，包含數據庫操作，字符串處理，文件或者文件夾處理
網絡請求，緩存處理，數據容器等上百個常用工具類封裝，附帶調用示例和參數說明，
提供CHM詳細文檔，上百個生產環境使用，穩定高效，簡單易用。
真正做到“工具在手，一切盡有”，讓你大幅度的提高編程效率，提高編程水平。
聯系QQ：7400799（請備注 "MSCL"）

===============================================

重要壓縮文件忘記解壓密碼？網上下載rar/zip/7z等壓縮文件，需要密碼？
====極速解密助手，支持支持RAR/ZIP/7Z等多種壓縮文檔解密======
★ 解密不超過24小時，跟密碼復雜程度相關
★ 解密成功后再收費，無套路
★ 解密成功后自動刪除原件，無后顧之憂
聯系QQ：7400799（請備注 "文件解密"）

==============================================

Magic.Orm已在數百個成熟項目中應用，是比較完善的ORM框架（基於C#開發）。開發過程中參考了NBear與MySoft，吸取了其中的一些精華，加入新思想，
后期參考EF的Lambda語法進行大量擴展。

為什么選擇Magic.Orm?

• 上手簡單，0學習成本。使用方便，按照sql書寫習慣編寫C#.NET代碼。功能強大。
• 高性能，接近手寫Sql。
• 體積小（不到200kb，僅一個dll）。
• 完美支持Sql Server(2000至最新版),MySql,Oracle,Access,Sqlite等數據庫。
• 支持大量Lambda表達式寫法。
• 不需要像NHibernate的XML配置，不需要像EF的各種數據庫連接驅動，集成簡單。

購買源碼 請聯系QQ：7400799（請備注 "ORM"）