zoukankan      html  css  js  c++  java
  • C# 大数据插入代码

    640?wx_fmt=png

     public static void BulkInsert<T>(string connection ,string tableName, IList<T> list)

            {

                using (var bulkCopy = new SqlBulkCopy(connection))

                {

                    bulkCopy.BatchSize = list.Count;

                    bulkCopy.DestinationTableName = tableName;


                    var table = new DataTable();

                    var props = TypeDescriptor.GetProperties(typeof(T))

                                               .Cast<PropertyDescriptor>()

                                               .Where(propertyInfo => propertyInfo.PropertyType.Namespace.Equals("System"))

                                               .ToArray();


                    foreach (var propertyInfo in props)

                    {

                        bulkCopy.ColumnMappings.Add(propertyInfo.Name, propertyInfo.Name);

                        table.Columns.Add(propertyInfo.Name, Nullable.GetUnderlyingType(propertyInfo.PropertyType) ?? propertyInfo.PropertyType);

                    }


                    var values = new object[props.Length];

                    foreach (var item in list)

                    {

                        for (var i = 0; i < values.Length; i++)

                        {

                            values[i] = props[i].GetValue(item);

                        }


                        table.Rows.Add(values);

                    }


                    bulkCopy.WriteToServer(table);

                }

            }


  • 相关阅读:
    用gdb调试python多线程代码-记一次死锁的发现
    使用docker部署standalone cinder
    Linux上open-iscsi 的安装,配置和使用
    Windows上Ruby开发环境的配置
    在Pypi上发布自己的Python包
    docker X509 证书错误的终极解决办法
    oslo_config中的DuplicateOptError坑
    删除emacs临时文件
    xfce4快捷键设置
    设置emacs启动窗口的两种方法
  • 原文地址:https://www.cnblogs.com/hgmyz/p/12351401.html
Copyright © 2011-2022 走看看