封裝List集合一個批量導入數據庫的工具類

    public class CommonDal
    {
        #region 數據導入相關
        /// <summary>
        /// 批量導入數據
        /// </summary>
        /// <param name="dt">將要導入的數據源</param>
        /// <param name="TbName">目標表名稱</param>
        public static void Bulk_ImportDatable(DataTable dt, string TargetTableName)
        {
            using (SqlConnection destinationConnection = DBHelper.CreateConnection())
            {
                using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection))
                {
                    try
                    {
                        bulkCopy.DestinationTableName = TargetTableName;//要插入的表的表明  
                        for (int i = 0; i < dt.Columns.Count; i++)
                        {
                            bulkCopy.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
                        }
                        bulkCopy.WriteToServer(dt);
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                    }
                }
            }

        }
        #endregion
        #region 數據表操作相關
        #region 增
        /// <summary>
        /// 向數據表中插入一條數據
        /// </summary>
        /// <typeparam name="T">插入數據的參數類型,注意名稱和表明保持一致</typeparam>
        /// <param name="obj">插入的數據對象</param>
        /// <returns></returns>
        public int InsertInfo<T>(T obj) where T : class
        {
            using (IDbConnection conn = DBHelper.CreateConnection())
            {
                return conn.Insert<T>(obj);
            }
        }
        #endregion
        #region 刪除
        /// <summary>
        /// 通過表名稱truncate掉表數據
        /// </summary>
        /// <param name="tablename">需要清除數據的表名稱</param>
        /// <returns></returns>
        public bool truncateTableByName(string tablename)
        {
            using (IDbConnection conn = DBHelper.CreateConnection())
            {
                string sql = " TRUNCATE TABLE " + tablename;
                DynamicParameters param = new DynamicParameters();
                param.Add("TableName", tablename);
                return conn.Execute(sql, param) > 0;
            }
        }
        /// <summary>
        /// 將主表數據清除並且清除部分關聯信息表的關聯數據
        /// </summary>
        /// <param name="truncateTableName">要清除數據的主表名稱</param>
        /// <param name="deleteTableName">要清除關聯數據的關聯信息表名稱</param>
        /// <param name="sqlWhereList">清除關聯信息數據的Where條件</param>
        public void truncateAndDeleteTable(string truncateTableName, string deleteTableName, List<SqlWhereModel> sqlWhereList)
        {
            truncateTableByName(truncateTableName);
            deleteTableByName(deleteTableName, sqlWhereList);
        }

        /// <summary>
        /// 通過表名稱和Where條件delete掉表數據
        /// </summary>
        /// <param name="TableName">需要清除數據的表名稱</param>
        /// <param name="paramModel">Where參數集合</param>
        /// <returns></returns>
        public bool deleteTableByName(string TableName, List<SqlWhereModel> paramModel)
        {
            using (IDbConnection conn = DBHelper.CreateConnection())
            {
                //sql語句拼接時使用StringBulider 防止長度限制
                StringBuilder sql = new StringBuilder("delete from " + TableName);
                StringBuilder sbwhere = new StringBuilder(" where 1=1 ");
                DynamicParameters parameters = new DynamicParameters();
                paramModel.ForEach(p =>
                {
                    sbwhere.AppendLine(" and " + p.ParamName + " = @" + p.ParamValue);
                    parameters.Add(p.ParamValue);
                });

                return conn.Execute(sql.AppendLine(sbwhere.ToString()).ToString(), parameters) > 0;
            }
        }
        /// <summary>
        /// 通過表名稱delete掉表數據
        /// </summary>
        /// <param name="TableName">需要清除數據的表名稱</param>
        /// <returns></returns>
        public bool deleteTableByName(string TableName)
        {
            using (IDbConnection conn = DBHelper.CreateConnection())
            {
                //sql語句拼接時使用StringBulider 防止長度限制
                StringBuilder sql = new StringBuilder(@"delete from " + TableName);
                return conn.Execute(sql.ToString()) > 0;
            }
        }
        #endregion
        #region 修改

        #endregion
        #region 查詢
        /// <summary>
        /// 通過id判斷是否存在記錄
        /// </summary>
        /// <param name="dc">傳入id</param>
        /// <returns>返回泛型對象</returns>
        public T getExistsById<T>(long id) where T : class
        {
            using (IDbConnection coon = DBHelper.CreateConnection())
            {
                return coon.Get<T>(id);
            }
        }
        /// <summary>
        /// 通過name查詢是否存在
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="Name"></param>
        /// <returns></returns>
        public T getExistsByName<T>(string Name) where T : dtModelBase
        {
            using (IDbConnection coon = DBHelper.CreateConnection())
            {

                var predicate = Predicates.Field<T>(f => f.Name, Operator.Eq, Name);
                IEnumerable<T> list = coon.GetList<T>(predicate);
                return list.FirstOrDefault();
            }
        }
        /// <summary>
        /// 通過標准名Ename查詢是否存在
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="Name"></param>
        /// <returns></returns>
        public T getExistsByEName<T>(string EName, string Tbname) where T : class
        {
            using (IDbConnection coon = DBHelper.CreateConnection())
            {
                string sql = "select * from " + Tbname + " where EName =@EName";
                IEnumerable<T> list = coon.Query<T>(sql, new { EName });
                return list.FirstOrDefault();
            }
        }
        /// <summary>
        /// 讀取數據源
        /// </summary>
        /// <returns></returns>
        public List<T> GetSourceDt<T>() where T : class
        {
            IEnumerable<T> list = null;
            using (IDbConnection conn = DBHelper.CreateConnection())
            {
                list = conn.GetList<T>().ToList();
            }
            return list.ToList();
        }
        #endregion
        #endregion
    }

 public class SqlWhereModel
    {
        public string ParamName { get; set; }
        public string ParamValue { get; set; }
    }

結合上一篇List和DataTable相互轉換的類直接 進行數據庫批量插入操作調用示例

  DataTable dt = ListTranDataTableHelper.ToDataTable(listv, DatableProperty.PropertyRenameDic);
            CommonDal.Bulk_ImportDatable(dt, targetTableName);