SQL Server中与BULK INSERT等效的高性能批量更新方案？

针对你的批量更新场景，核心思路是借鉴BULK INSERT的本地处理逻辑——把所有变更数据一次性导入服务器，再通过关联操作完成更新，避免多次发送单条UPDATE带来的网络开销和单语句执行成本。以下是几种具体方案：

方案1：BULK INSERT导入临时表 + 关联UPDATE #

这是最贴近你现有BULK INSERT使用习惯的方案：

1. 预处理变更文件：将TABLE/FIELD/PKEY=new value格式的文件转换成结构化格式（比如CSV），每行包含TableName, FieldName, PKeyValue, NewValue四个字段。
2. 批量导入临时表：用BULK INSERT把所有变更数据导入服务器本地的临时表：

CREATE TABLE #BulkUpdates (
    TableName NVARCHAR(128),
    FieldName NVARCHAR(128),
    PKeyValue NVARCHAR(256),
    NewValue NVARCHAR(MAX)
)

BULK INSERT #BulkUpdates
FROM 'C:\Your\File\Path\changes.csv'
WITH (FIELDTERMINATOR = ',', ROWTERMINATOR = '\n', FIRSTROW = 2) -- 根据实际文件格式调整参数

3. 分表执行关联更新：针对每个表，用单条UPDATE语句关联临时表完成批量更新：

-- 示例：更新Users表的Email字段
UPDATE u
SET u.Email = bu.NewValue
FROM Users u
JOIN #BulkUpdates bu 
  ON u.UserId = bu.PKeyValue 
  AND bu.TableName = 'Users' 
  AND bu.FieldName = 'Email'

-- 示例：更新Orders表的Status字段
UPDATE o
SET o.Status = bu.NewValue
FROM Orders o
JOIN #BulkUpdates bu 
  ON o.OrderId = bu.PKeyValue 
  AND bu.TableName = 'Orders' 
  AND bu.FieldName = 'Status'

这种方式把原本上千次的网络请求压缩成1次BULK INSERT + 少量关联UPDATE，所有操作基本在服务器本地完成，性能能接近BULK INSERT的水平。

方案2：表值参数（TVPs）批量更新 #

如果变更数据来自应用程序而非文件，可以用表值参数直接把批量数据传到服务器：

1. 定义表值类型：

CREATE TYPE BulkUpdateType AS TABLE (
    TableName NVARCHAR(128),
    FieldName NVARCHAR(128),
    PKeyValue NVARCHAR(256),
    NewValue NVARCHAR(MAX)
)

2. 编写存储过程处理更新：

CREATE PROCEDURE ProcessBulkUpdates
    @Updates BulkUpdateType READONLY
AS
BEGIN
    SET NOCOUNT ON;

    -- 更新Users表
    UPDATE u
    SET u.Email = upd.NewValue
    FROM Users u
    JOIN @Updates upd 
      ON u.UserId = upd.PKeyValue 
      AND upd.TableName = 'Users' 
      AND upd.FieldName = 'Email'

    -- 其他表的更新逻辑以此类推
END

3. 应用端传递参数：在应用程序中把变更数据填充到DataTable，然后作为参数调用存储过程，全程只需一次网络请求。

方案3：动态SQL批量处理（适配多表多字段场景） #

如果你的变更涉及大量不同表和字段，不想手动写每个表的UPDATE语句，可以用动态SQL循环处理：

-- 假设临时表已导入数据，且额外增加PrimaryKeyField列存储每个表的主键字段名
ALTER TABLE #BulkUpdates ADD PrimaryKeyField NVARCHAR(128)

DECLARE @TableName NVARCHAR(128), @FieldName NVARCHAR(128), @PrimaryKeyField NVARCHAR(128), @Sql NVARCHAR(MAX)

DECLARE UpdateCursor CURSOR FOR
SELECT DISTINCT TableName, FieldName, PrimaryKeyField FROM #BulkUpdates

OPEN UpdateCursor
FETCH NEXT FROM UpdateCursor INTO @TableName, @FieldName, @PrimaryKeyField

WHILE @@FETCH_STATUS = 0
BEGIN
    -- 用QUOTENAME避免SQL注入和标识符冲突
    SET @Sql = N'UPDATE t
                 SET t.' + QUOTENAME(@FieldName) + N' = bu.NewValue
                 FROM ' + QUOTENAME(@TableName) + N' t
                 JOIN #BulkUpdates bu 
                   ON t.' + QUOTENAME(@PrimaryKeyField) + N' = bu.PKeyValue
                   AND bu.TableName = ''' + @TableName + ''' 
                   AND bu.FieldName = ''' + @FieldName + ''''

    EXEC sp_executesql @Sql

    FETCH NEXT FROM UpdateCursor INTO @TableName, @FieldName, @PrimaryKeyField
END

CLOSE UpdateCursor
DEALLOCATE UpdateCursor

注意：动态SQL必须用QUOTENAME处理所有标识符，避免SQL注入风险；如果主键字段名不统一，需要在临时表中额外存储主键字段名。

以上方案的核心都是减少网络往返次数，让服务器一次性处理所有变更数据，和BULK INSERT的高效逻辑一致，能大幅降低批量更新的耗时。

内容的提问来源于stack exchange，提问作者Maury Markowitz