如何优化SQL Server 10K条数据批量插入的执行效率？

阿华AIGC实验室

2026-5-20

我懂你现在的困扰——明明用了SqlBulkCopy比逐行插快，但处理10K条记录还是不够理想。其实SqlBulkCopy本身还有不少优化空间，再搭配一些数据库层面的调整，能让速度再上一个台阶，给你分享几个实用的方案：

1. 调整SqlBulkCopy的关键参数

默认配置的SqlBulkCopy并不是最优状态，修改以下几个参数能立竿见影：

BatchSize：默认值是0（一次性插入所有数据），但分成合适的批次（比如1000-5000条/批）能减少内存占用和日志压力，建议根据你的单条数据大小调整，2000条是个比较通用的起始值
EnableStreaming：开启这个选项后，数据会直接从数据源流式传输，不需要先把所有数据加载到内存，对内存友好的同时也能提升速度
TableLock：在插入期间锁定整个目标表，避免频繁的行锁竞争，大幅降低锁开销（适合插入期间没有其他读写操作的场景）
BulkCopyTimeout：延长超时时间，避免大批次插入时因超时失败

修改后的代码示例：

using (var scope = new TransactionScope(TransactionScopeOption.Required, 
    new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted })) // 降低隔离级别，默认Serializable太严苛
{
    string connectionString = "Data Source=94.73.148.5;Initial Catalog=YirmibesYazilimMutabakat;User id=id;Password=password;";
    using (var sqlConnection = new SqlConnection(connectionString))
    {
        sqlConnection.Open();
        using (var sqlBulkCopy = new SqlBulkCopy(sqlConnection, SqlBulkCopyOptions.TableLock, null)
        {
            DestinationTableName = "YourTargetTableName",
            BatchSize = 2000,
            EnableStreaming = true,
            BulkCopyTimeout = 300 // 设置为5分钟，根据需要调整
        })
        {
            // 明确列映射（如果源和目标列名/顺序不一致必须加，一致也建议加上避免隐式错误）
            sqlBulkCopy.ColumnMappings.Add("SourceColumn1", "TargetColumn1");
            sqlBulkCopy.ColumnMappings.Add("SourceColumn2", "TargetColumn2");
            // 其他列映射...

            sqlBulkCopy.WriteToServer(yourDataTable); // 替换成你的数据源
        }
        scope.Complete();
    }
}

2. 用IDataReader代替DataTable

如果你的数据源是集合（比如List），不要先转成DataTable，直接用IDataReader来流式传输数据，内存占用会低很多，速度也更快。你可以用FastMember这类库快速把集合转成DataReader：

// 先安装FastMember包：Install-Package FastMember
using (var reader = ObjectReader.Create(yourModelList, "Column1", "Column2", "Column3")) // 指定要读取的列
{
    sqlBulkCopy.WriteToServer(reader);
}

3. 数据库层面的优化

批量插入的瓶颈有时候不在代码，而在数据库本身：

暂时禁用索引和约束：插入时维护非聚集索引和外键约束会非常耗时，建议插入前禁用，插入完成后再重建/启用：

-- 禁用非聚集索引
ALTER INDEX ALL ON YourTargetTable DISABLE;
-- 禁用外键约束
ALTER TABLE YourTargetTable NOCHECK CONSTRAINT ALL;

-- 执行批量插入操作

-- 重建索引（比重新启用更快，还能整理碎片）
ALTER INDEX ALL ON YourTargetTable REBUILD;
-- 启用外键约束并检查现有数据
ALTER TABLE YourTargetTable WITH CHECK CHECK CONSTRAINT ALL;

切换恢复模式为简单模式：如果你的业务允许（比如不需要点时间恢复），插入前把数据库恢复模式改成简单，能大幅减少日志生成量，插入完成后再切回完整模式：
```
ALTER DATABASE YirmibesYazilimMutabakat SET RECOVERY SIMPLE;
-- 执行插入
ALTER DATABASE YirmibesYazilimMutabakat SET RECOVERY FULL;
```