C#中如何执行数据库的批量更新?使用SqlBulkCopy?

月夜之吻
发布: 2025-10-14 10:50:02
原创
491人浏览过
推荐使用表值参数+MERGE语句实现批量更新:先在SQL Server中创建用户定义表类型和存储过程,C#中通过DataTable传递数据,利用MERGE语句高效完成更新操作。

c#中如何执行数据库的批量更新?使用sqlbulkcopy?

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)
);
<p>// 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;</p>
登录后复制
// C#
var table = new DataTable();
table.Columns.Add("Id", typeof(int));
table.Columns.Add("Name", typeof(string));
table.Columns.Add("Email", typeof(string));
<p>// 添加要更新的数据
table.Rows.Add(1, "张三", "zhang@example.com");
table.Rows.Add(2, "李四", "li@example.com");</p><p>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();
}
}</p>
登录后复制

2. 使用 Entity Framework 批量更新(第三方库)

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

推荐库:
  • EntityFramework.Extensions(已归档,旧项目可用)
  • Z.EntityFramework.Extensions(商业库,功能强)
  • EFCore.BulkExtensions(开源免费,支持批量 Insert/Update/Delete)

EFCore.BulkExtensions 示例:

图可丽批量抠图
图可丽批量抠图

用AI技术提高数据生产力,让美好事物更容易被发现

图可丽批量抠图26
查看详情 图可丽批量抠图
using Z.EntityFramework.Extensions; // 或 EFCore.BulkExtensions
<p>context.Users.Where(u => u.Status == 0)
.ExecuteUpdateAsync(setters => setters
.SetProperty(u => u.Status, u => 1));</p>
登录后复制

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 方案,安全、高效、易于维护。

以上就是C#中如何执行数据库的批量更新?使用SqlBulkCopy?的详细内容,更多请关注php中文网其它相关文章!

最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新 English
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号