sqlserver數據庫批量插入-SqlBulkCopy

當想在數據庫中插入大量數據時，使用insert 不僅效率低，而且會導致一系列的數據庫性能問題

當使用insert語句進行插入數據時。我使用了兩種方式：

1. 每次插入數據時，都只插入一條數據庫，這個會導致每次插入數據時不斷打開關閉數據庫鏈接，導致效率過低（最差）
2. 使用拼接字符串的方式來進行批量插入數據，但是使用StringBuilder 會占用極大的內存

以上方式對於批量插入數據都不是一個好的選擇， 針對這種情況我使用了SqlBulkCopy

sqlbulkCopy：將其它數據源批量加載sqlserver表，就是可以將其它數據源插入到數據庫中

示例代碼：

創建測試User表：

CREATE TABLE [dbo].[Users](
    [Id] [uniqueidentifier] NOT NULL,
    [Name] [nvarchar](100) NULL,
    [Gender] [int] NULL,
    [Age] [int] NULL,
    [CityId] [int] NULL,
    [OpTime] [datetime] NULL,
    CONSTRAINT [PK_Users] PRIMARY KEY CLUSTERED([Id] ASC)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
 ) ON [PRIMARY]

然后定義一個與表映射的Model,因SqlBulkCopy 的特性，定義的 Model 必須擁有與表所有的字段對應的屬性：也就是定義的model，需要跟數據表的字段順序一樣，因為轉為datatable時會按照順序插入

public enum Gender
{
    Man = 1,
    Woman
}

public class User
{
    public Guid Id { get; set; }
    public string Name { get; set; }
    public Gender? Gender { get; set; }
    public int? Age { get; set; }
    public int? CityId { get; set; }
    public DateTime? OpTime { get; set; }
}

制造些數據轉為DataTable：

List轉為DataTable地址：https://www.cnblogs.com/zhangShanGui/p/12038563.html

List<User> usersToInsert = new List<User>();
usersToInsert.Add(new User() { Id = Guid.NewGuid(), Name = "so1", Gender = Gender.Man, Age = 18, CityId = 1, OpTime = DateTime.Now });
usersToInsert.Add(new User() { Id = Guid.NewGuid(), Name = "so2", Gender = Gender.Man, Age = 19, CityId = 2, OpTime = DateTime.Now });
usersToInsert.Add(new User() { Id = Guid.NewGuid(), Name = "so3", Gender = Gender.Man, Age = 20, CityId = 3, OpTime = DateTime.Now });
usersToInsert.Add(new User() { Id = Guid.NewGuid(), Name = "so4", Gender = Gender.Man, Age = 21, CityId = 4, OpTime = DateTime.Now });

var data = DataTableExtensions.ToDataTable(usersToInsert);
 using (SqlBulkCopy bulkCopy = new SqlBulkCopy(ConnectionString))
                {
                    bulkCopy.DestinationTableName =
                        "Users";
                    try
                    {
                        bulkCopy.WriteToServer(data, DataRowState.Added);
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                    }
                }