批量插入数据

主要命名空间

using System.Data.SqlClient;

　|-SqlBulkCopy

　|-SqlConnection

　|-SqlTransaction

--------------------------BatchInsert<T>(List<T> toList, SqlRowsCopiedEventHandler resulthandler = null)-------------------

批量插入主要用的就是SqlBulkCopy类。

--------------------------------------------------------------------------------------------------------------------------------

public static void BatchInsert<T>(List<T> toList, SqlRowsCopiedEventHandler resulthandler = null)
{
    using (var conn = Connection)
    {
        using (var tran = conn.BeginTransaction())
        {
            using (var bi = new SqlBulkCopy(conn, SqlBulkCopyOptions.KeepIdentity, tran))
            {
                var tp=typeof (T);
                bi.BulkCopyTimeout = 1000;
                var name = tp.Name.EndsWith("Model") ? tp.Name.Substring(0, tp.Name.Length - 5):tp.Name;
                bi.BatchSize = toList.Count;
                bi.DestinationTableName = name;
                foreach (var propertyInfo in tp.GetProperts())
                {
                    var attribute = (IgnoreAttribute)System.Attribute.GetCustomAttribute(propertyInfo, typeof(IgnoreAttribute));
                    if (null == attribute || !attribute.Ignore)
                    {
                        bi.ColumnMappings.Add(propertyInfo.Name, propertyInfo.Name);
                    }
                }
                var dtb = DataTableHelper.GetTable(toList);
                dtb.TableName = name;
                if (resulthandler != null)
                    bi.SqlRowsCopied += resulthandler;//成功的回调事件！
                bi.WriteToServer(dtb);
                tran.Commit();//这里用了事务，如果数据量较大，建议开启；因为插入时会锁表，所以建议读写分离。
            }
        }
    }
}

-------------------------------------------DataTableHelper.GetTable<T>(IList<T> ts)--------------------------------------

利用反射，获取需要的字段的名称和类型

---------------------------------------------------------------------------------------------------------------------------

DateTable dt=new DataTable();

var t=typeof(T);

var ptys=t.GetPropertys().Where(p=>p.GetAttribute<Ignore>()==null);

//将Column添加到DataTable

ptys.Foreach(p=>dt.Columns.Add(p.Name,p.Nullable.GetUnderlingType(p)||p.PropertyType))

//将数据添加到table

foreach(var item in ts){

var row=dt.NewRow()

ptys.Foreach(p=>row[p.Name]=p.GetValue());

}