[Snippet]-Csharp 批量导入助手代码片段

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

这是一个创建于 871 天前的主题，其中的信息可能已经有所发展或是发生改变。


    /// <summary>
    /// 批量插入助手
    /// </summary>
    public static class BulkHelper
    {
        /// <summary>
        /// 批量导入入口
        /// </summary>
        /// <param name="con">DbConnection 数据库连接资源</param>
        /// <param name="models">实体列表</param>
        /// <param name="tableName">表名</param>
        /// <typeparam name="T">实体泛型</typeparam>
        public static void BulkCopy<T>(DbConnection con, List<T> models, string tableName = null)
        {
            BulkInsert(con, models, tableName);
        }

        /// <summary>
        /// IList 的扩展方法 用于集合转换 DataTable 类
        /// </summary>
        /// <param name="models">实体列表</param>
        /// <param name="tableName">表名</param>
        /// <typeparam name="T">实体泛型</typeparam>
        /// <returns>DataTable</returns>
        private static DataTable ToSqlBulkCopyDataTable<T>(this List<T> models, string tableName = null)
        {
            var props = TypeDescriptor.GetProperties(typeof(T));

            var table = new DataTable
            {
                TableName = tableName?.ToLowerInvariant() ?? typeof(T).Name.ToLowerInvariant()
            };

            // 表中 字段(列)的填充
            foreach (PropertyDescriptor prop in props)
            {
                var type = Nullable.GetUnderlyingType(prop.PropertyType) ?? prop.PropertyType;
                if (type.IsEnum) type = typeof(int);

                table.Columns.Add(prop.Name.ToLowerInvariant(), type);
            }

            // 表中 数据内容的填充
            foreach (var data in models)
            {
                var newRow = table.NewRow();
                foreach (PropertyDescriptor prop in props)
                {
                    newRow[prop.Name.ToLowerInvariant()] = prop.GetValue(data) ?? DBNull.Value;
                }

                table.Rows.Add(newRow);
            }

            return table;
        }

        /// <summary>
        /// 批量导入或修改
        /// </summary>
        /// <param name="con">DbConnection 数据库资源</param>
        /// <param name="datas">实体列表</param>
        /// <param name="tableName">表名</param>
        /// <typeparam name="T">实体泛型</typeparam>
        private static void BulkInsert<T>(DbConnection con, List<T> datas, string tableName)
        {
            // 数据模型列表转换 DataTable
            var tb = datas.ToSqlBulkCopyDataTable(tableName);

            var ops = new BulkOperation(con);
            // 批量插入 引用 Z.BulkOperations
            ops.BulkInsert(tb);
        }
    }

不知性能上和 EF Core 比会不会好一些 gist 地址-> https://gist.github.com/KomiSans/9824c2352f5efdee68bc70bd6917616a

7 条回复 • 2022-08-10 21:46:18 +08:00