使用ExecuteNonQuery批量更新记录时数据库出现重复记录问题

这个坑我之前踩过好几次！先别着急往多线程和锁上面想，90%的概率是变量/参数的作用域或者对象复用导致的，先从最基础的地方排查：

1. 检查循环中是否复用了同一个实体对象 #

如果你在循环外面创建了用于更新的实体对象，每次循环只修改它的属性，那麻烦就来了——因为对象是引用类型，所有循环迭代里用的都是同一个对象的引用。如果ExecuteNonQuery的执行有延迟（比如数据库命令队列、缓存），最终所有更新操作都会使用最后一次循环赋值的属性值。

举个错误示例：

// 错误：循环外创建对象，所有迭代共享同一个引用
var updateRecord = new UserRecord();
foreach (var user in userList)
{
    updateRecord.UserId = user.UserId;
    updateRecord.Status = user.NewStatus;
    // 执行更新
    dbCommand.ExecuteNonQuery();
}

修正方法：每次循环内部创建新的对象，确保每个迭代都有独立的实例：

// 正确：循环内创建对象，每个迭代用独立实例
foreach (var user in userList)
{
    var updateRecord = new UserRecord();
    updateRecord.UserId = user.UserId;
    updateRecord.Status = user.NewStatus;
    dbCommand.ExecuteNonQuery();
}

2. 排查SQL参数的复用问题 #

如果你的更新用了SqlParameter（或者其他数据库参数），循环中复用同一个参数对象而没有正确重置，也会出现这种问题。因为参数是绑定到命令对象的，有时候参数值的更新不会立即生效，或者命令缓存了旧的参数值。

错误示例：

// 错误：复用同一个参数对象
var updateCmd = new SqlCommand("UPDATE Users SET Status = @Status WHERE UserId = @UserId", dbConn);
var statusParam = new SqlParameter("@Status", SqlDbType.Int);
var userIdParam = new SqlParameter("@UserId", SqlDbType.Int);
updateCmd.Parameters.Add(statusParam);
updateCmd.Parameters.Add(userIdParam);

foreach (var user in userList)
{
    statusParam.Value = user.NewStatus;
    userIdParam.Value = user.UserId;
    updateCmd.ExecuteNonQuery();
}

修正方案：

• 每次循环直接修改已添加参数的Value（确保命令没有被缓存）：

foreach (var user in userList)
{
    updateCmd.Parameters["@Status"].Value = user.NewStatus;
    updateCmd.Parameters["@UserId"].Value = user.UserId;
    updateCmd.ExecuteNonQuery();
}

• 更稳妥的方式：每次循环创建新的命令对象，避免参数复用的风险：

foreach (var user in userList)
{
    using (var updateCmd = new SqlCommand("UPDATE Users SET Status = @Status WHERE UserId = @UserId", dbConn))
    {
        updateCmd.Parameters.AddWithValue("@Status", user.NewStatus);
        updateCmd.Parameters.AddWithValue("@UserId", user.UserId);
        updateCmd.ExecuteNonQuery();
    }
}

3. 再验证多线程与事务的可能性 #

如果上面的排查都没问题，再回到你怀疑的多线程和事务：

• 确认你的函数是否被多线程调用？如果多个线程共享同一个数据库连接或命令对象，必然会出现数据混乱——数据库连接/命令不是线程安全的，必须每个线程/每个操作单独创建。
• 检查事务范围：如果事务包裹了整个循环，且循环内的操作没有正确提交（或者事务隔离级别设置不当），可能出现重复，但这种情况更多是锁等待或脏读，而非最后一条记录重复。可以尝试把事务放到循环内（如果业务允许），或者确保每次循环的操作都被正确提交。

4. 快速调试技巧 #

在循环中执行ExecuteNonQuery之前，打印当前要更新的参数值，比如：

Console.WriteLine($"准备更新：UserId={user.UserId}，Status={user.NewStatus}");

这样就能直观看到每次迭代的参数是否正确，快速定位是代码层面的参数问题，还是数据库层面的异常。

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