C#批量更新数据库怎么用SqlBulkCopy？

推荐使用表值参数+MERGE语句实现批量更新：先在SQL Server中创建用户定义表类型和存储过程，C#中通过DataTable传递数据，利用MERGE语句高效完成更新操作。

SqlBulkCopy 是 C# 中用于高效插入大量数据到 SQL Server 的工具，但它只支持批量插入，不支持更新。如果你需要执行数据库的批量更新，不能直接使用 SqlBulkCopy 来完成 UPDATE 操作。

那该怎么实现批量更新？

以下是几种在 C# 中实现数据库批量更新的有效方法：

1. 使用 DataTable + MERGE 语句（推荐）

将数据加载到 DataTable，通过表值参数（Table-Valued Parameter, TVP）传入 SQL Server，再用 MERGE 语句进行插入或更新。

• 在 SQL Server 中创建用户定义表类型（User-Defined Table Type）
• 编写使用 MERGE 的存储过程
• 在 C# 中用 DataTable 配合 SqlCommand 传参

示例代码：

// SQL：定义表类型
CREATE TYPE dbo.UserUpdateType AS TABLE
(
    Id INT,
    Name NVARCHAR(50),
    Email NVARCHAR(100)
);
// SQL：存储过程
CREATE PROCEDURE UpdateUsers (@updates dbo.UserUpdateType READONLY)
AS
MERGE Users AS target
USING @updates AS source ON target.Id = source.Id
WHEN MATCHED THEN
UPDATE SET Name = source.Name, Email = source.Email;

// C#
var table = new DataTable();
table.Columns.Add("Id", typeof(int));
table.Columns.Add("Name", typeof(string));
table.Columns.Add("Email", typeof(string));
// 添加要更新的数据
table.Rows.Add(1, "张三", "zhang@example.com");
table.Rows.Add(2, "李四", "li@example.com");
using (var conn = new SqlConnection(connectionString))
{
conn.Open();
using (var cmd = new SqlCommand("UpdateUsers", conn))
{
cmd.CommandType = CommandType.StoredProcedure;
var param = cmd.Parameters.AddWithValue("@updates", table);
param.SqlDbType = SqlDbType.Structured;
param.TypeName = "dbo.UserUpdateType";
cmd.ExecuteNonQuery();
}
}

2. 使用 Entity Framework 批量更新（第三方库）

EF Core 原生不支持批量更新（SaveChanges 是逐条提交），但可以借助扩展库提升性能。

• EntityFramework.Extensions（已归档，旧项目可用）
• Z.EntityFramework.Extensions（商业库，功能强）
• EFCore.BulkExtensions（开源免费，支持批量 Insert/Update/Delete）

EFCore.BulkExtensions 示例：

using Z.EntityFramework.Extensions; // 或 EFCore.BulkExtensions
context.Users.Where(u => u.Status == 0)
.ExecuteUpdateAsync(setters => setters
.SetProperty(u => u.Status, u => 1));

3. 拼接 SQL 批量语句（小批量适用）

适用于几百条以内数据，手动拼接 UPDATE 语句或使用 CASE WHEN 方法。

UPDATE Users 
SET Name = CASE Id 
    WHEN 1 THEN '张三'
    WHEN 2 THEN '李四'
END,
Email = CASE Id
    WHEN 1 THEN 'zhang@ex.com'
    WHEN 2 THEN 'li@ex.com'
END
WHERE Id IN (1, 2);

注意：SQL 长度有限制，不适合大数据量。

4. 临时表 + UPDATE JOIN

先用 SqlBulkCopy 把数据导入临时表，然后用 UPDATE + JOIN 完成更新。

// 步骤：
// 1. 用 SqlBulkCopy 写入临时表 #TempUpdates
// 2. 执行 UPDATE JOIN
UPDATE u
SET u.Name = t.Name, u.Email = t.Email
FROM Users u
INNER JOIN #TempUpdates t ON u.Id = t.Id;

这种方式结合了 SqlBulkCopy 的高速写入和 SQL 的灵活更新能力。

基本上就这些方法。SqlBulkCopy 虽然不能直接更新，但可以作为批量操作流程的一部分。最推荐的是 表值参数 + MERGE 方案，安全、高效、易于维护。