|
當(dāng)想在數(shù)據(jù)庫(kù)中插入大量數(shù)據(jù)時(shí)，使用insert 不僅效率低，而且會(huì)導(dǎo)致一系列的數(shù)據(jù)庫(kù)性能問(wèn)題 當(dāng)使用insert語(yǔ)句進(jìn)行插入數(shù)據(jù)時(shí)。我使用了兩種方式：
以上方式對(duì)于批量插入數(shù)據(jù)都不是一個(gè)好的選擇， 針對(duì)這種情況我使用了SqlBulkCopy sqlbulkCopy：將其它數(shù)據(jù)源批量加載sqlserver表，就是可以將其它數(shù)據(jù)源插入到數(shù)據(jù)庫(kù)中 示例代碼： 創(chuàng)建測(cè)試User表： 1 CREATE TABLE [dbo].[Users]( 2 [Id] [uniqueidentifier] NOT NULL, 3 [Name] [nvarchar](100) NULL, 4 [Gender] [int] NULL, 5 [Age] [int] NULL, 6 [CityId] [int] NULL, 7 [OpTime] [datetime] NULL, 8 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] 9 ) ON [PRIMARY] 然后定義一個(gè)與表映射的Model,因SqlBulkCopy 的特性，定義的 Model 必須擁有與表所有的字段對(duì)應(yīng)的屬性：也就是定義的model，需要跟數(shù)據(jù)表的字段順序一樣，因?yàn)檗D(zhuǎn)為datatable時(shí)會(huì)按照順序插入 1 public enum Gender 2 { 3 Man = 1, 4 Woman 5 } 6 7 public class User 8 { 9 public Guid Id { get; set; } 10 public string Name { get; set; } 11 public Gender? Gender { get; set; } 12 public int? Age { get; set; } 13 public int? CityId { get; set; } 14 public DateTime? OpTime { get; set; } 15 } 制造些數(shù)據(jù)轉(zhuǎn)為DataTable： List轉(zhuǎn)為DataTable地址：https://www.cnblogs.com/zhangShanGui/p/12038563.html 1 List<User> usersToInsert = new List<User>(); 2 usersToInsert.Add(new User() { Id = Guid.NewGuid(), Name = "so1", Gender = Gender.Man, Age = 18, CityId = 1, OpTime = DateTime.Now }); 3 usersToInsert.Add(new User() { Id = Guid.NewGuid(), Name = "so2", Gender = Gender.Man, Age = 19, CityId = 2, OpTime = DateTime.Now }); 4 usersToInsert.Add(new User() { Id = Guid.NewGuid(), Name = "so3", Gender = Gender.Man, Age = 20, CityId = 3, OpTime = DateTime.Now }); 5 usersToInsert.Add(new User() { Id = Guid.NewGuid(), Name = "so4", Gender = Gender.Man, Age = 21, CityId = 4, OpTime = DateTime.Now }); 6 7 var data = DataTableExtensions.ToDataTable(usersToInsert); 8 using (SqlBulkCopy bulkCopy = new SqlBulkCopy(ConnectionString)) 9 { 10 bulkCopy.DestinationTableName = 11 "Users"; 12 try 13 { 14 bulkCopy.WriteToServer(data, DataRowState.Added); 15 } 16 catch (Exception ex) 17 { 18 Console.WriteLine(ex.Message); 19 } 20 } |
|
|
