如何用SqlBulkTools批量更新表中布尔列值为True？

错误原因 #

你传入的primaryIds是单纯的主键值数组，但SqlBulkTools的ForCollection要求集合中的元素必须包含匹配用的主键字段和要更新的目标字段。当前代码仅传入主键ID，却只声明了要更新的columnName，导致Bulk操作时数据列与表结构列不匹配，触发“输入数组长度大于表中列数”的错误。

修正后的代码 #

public static async Task<int> BulkSetToDeleteAsync(string connectionString, dynamic[] primaryIds, string tableName, string primaryKeyName, string columnName, CancellationToken ct)
{
    if (primaryIds is null || primaryIds.Length == 0)
    {
        return 0;
    }

    // 构造包含主键和目标列的集合，目标列固定设为true（对应SQL的1）
    var updateEntities = primaryIds.Select(id => new 
    {
        PrimaryKey = id,
        TargetColumn = true
    }).ToList();

    var query = new BulkOperations()
        .Setup()
        .ForCollection(updateEntities)
        .WithTable(tableName)
        // 映射实体属性到数据库列：主键属性对应数据库主键列，目标列属性对应要更新的列
        .AddColumn(primaryKeyName, x => x.PrimaryKey)
        .AddColumn(columnName, x => x.TargetColumn)
        .WithBulkCopySettings(new BulkCopySettings 
        { 
            EnableStreaming = true, 
            SqlBulkCopyOptions = SqlBulkCopyOptions.TableLock | SqlBulkCopyOptions.KeepIdentity 
        })
        // 仅执行更新操作，不需要插入
        .BulkUpdate()
        .MatchTargetOn(primaryKeyName);

    using var connection = new SqlConnection(connectionString);
    return await query.CommitAsync(connection, null, ct).ConfigureAwait(false);
}

关键改动说明 #

• 构造正确的实体集合：将单个主键ID包装成包含主键和目标列的匿名对象，确保集合元素包含Bulk操作所需的所有字段。
• 明确列映射：使用AddColumn的重载方法，显式指定实体属性与数据库列的对应关系，避免列映射错误。
• 使用BulkUpdate而非BulkInsertOrUpdate：因为你的需求是标记已存在的记录为删除，不需要插入新记录，用BulkUpdate更贴合业务逻辑，也能避免不必要的插入判断。

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