我们需要在 SQL Server 数据库中创建 100 万个虚拟产品数据，这些数据可用于开发或性能测试。

项目

该项目是使用 .NET 6.0 作为框架的控制台应用程序。

项目名称为 InsertMillionRecords

我们将使用Bogus软件包来生成随机产品数据。

我们使用 Entity Framework Core 作为数据访问层。

产品型号

为了对数据库中的 Products 表进行建模，我们需要创建 Product 类：

public class Product  
{  
    public int Id { get; set; }  
    public string Code { get; set; }  
    public string Description { get; set; }  
    public string Category { get; set; }  
    public decimal Price { get; set; }  
}

实体框架数据上下文

接下来，我们创建 Entity Framework 数据上下文类：

using Microsoft.EntityFrameworkCore;  
  
namespace InsertMillionRecords;  
public class DataContext : DbContext  
{  
    public DataContext(DbContextOptions<DataContext> options) : base(options)  
    {  
    }  
  
    public DbSet<Product> Products { get; set; }  
}

Program.cs文件

初始化数据上下文

首先，我们需要初始化数据上下文：

var connectionString = "Data Source=localhost; Initial Catalog=Product; Integrated Security=True";  
var contextOptionsBuilder = new DbContextOptionsBuilder<DataContext>();  
contextOptionsBuilder.UseSqlServer(connectionString);  
var context = new DataContext(contextOptionsBuilder.Options);

我们通过对连接字符串进行硬编码，使事情变得更简单。不用担心！

创建数据库

每次运行脚本时，我们都需要确保重新创建数据库。

await context.Database.EnsureDeletedAsync();  
await context.Database.EnsureCreatedAsync();

设置 Bogus Faker 类

首先，我们初始化 Faker<Product> 对象。

接下来，我们使用该方法来设置 Product 类的每个属性。RuleFor()

自我解释的代码：

var faker = new Faker<Product>();  
faker.RuleFor(p => p.Code, f => f.Commerce.Ean13());  
faker.RuleFor(p => p.Description, f => f.Commerce.ProductName());  
faker.RuleFor(p => p.Category, f => f.Commerce.Categories(1)[0]);  
faker.RuleFor(p => p.Price, f => f.Random.Decimal(1, 1000));

生成 100 万个虚拟产品数据

var products = faker.Generate(1000000);

该变量现在包含 100 万个产品数据！products

创建 10 批插入

如果我们一次插入 100 万条记录，则可能会发生超时。

因此，我们将该过程分为 10 批。每批一次插入 100K 条记录。

var batches = products  
    .Select((p, i) => (Product: p, Index: i))  
    .GroupBy(x => x.Index / 100_000)  
    .Select(g => g.Select(x => x.Product).ToList())  
    .ToList();

将每个批次插入数据库

var count = 0;  
foreach (var batch in batches)  
{  
    batchCount++;  
    Console.WriteLine($"Inserting batch {count} of {batches.Count}...");  
  
    await context.Products.AddRangeAsync(batch);  
    await context.SaveChangesAsync();  
}

Program.cs文件的完整代码：

using Bogus;  
using InsertMillionRecords;  
using Microsoft.EntityFrameworkCore;  
using System.Diagnostics;  
  
// initialize data context  
var connectionString = "Data Source=localhost; Initial Catalog=Product; Integrated Security=True";  
var contextOptionsBuilder = new DbContextOptionsBuilder<DataContext>();  
contextOptionsBuilder.UseSqlServer(connectionString);  
var context = new DataContext(contextOptionsBuilder.Options);  
  
// create database  
await context.Database.EnsureDeletedAsync();  
await context.Database.EnsureCreatedAsync();  
  
// setup bogus faker  
var faker = new Faker<Product>();  
faker.RuleFor(p => p.Code, f => f.Commerce.Ean13());  
faker.RuleFor(p => p.Description, f => f.Commerce.ProductName());  
faker.RuleFor(p => p.Category, f => f.Commerce.Categories(1)[0]);  
faker.RuleFor(p => p.Price, f => f.Random.Decimal(1, 1000));  
  
// generate 1 million products  
var products = faker.Generate(1000000);  
  
var batches = products  
    .Select((p, i) => (Product: p, Index: i))  
    .GroupBy(x => x.Index / 100000)  
    .Select(g => g.Select(x => x.Product).ToList())  
    .ToList();  
  
// insert batches  
var stopwatch = new Stopwatch();  
stopwatch.Start();  
  
var count = 0;  
foreach (var batch in batches)  
{  
    count++;  
    Console.WriteLine($"Inserting batch {count} of {batches.Count}...");  
  
    await context.Products.AddRangeAsync(batch);  
    await context.SaveChangesAsync();  
}  
  
stopwatch.Stop();  
  
Console.WriteLine($"Elapsed time: {stopwatch.Elapsed}");  
Console.WriteLine("Press any key to exit...");

运行应用程序

现在，让我们运行应用程序。我们可以使用_释放_模式来加快该过程。

在我的机器上花了 1 分 9 秒：

现在，我们在 Products 表中有 100 万条记录：

我计划使用这些虚拟数据来测试 SQL Server 中的全文搜索功能。

源代码获取：公众号回复消息【code：10219】