C#中使用UpdateDataSet结合存储过程批量更新数据

核心实现逻辑

该方案的核心在于将内存中的数据变更（Insert/Update/Delete）映射到特定的数据库存储过程。通过配置SqlCommand参数并与DataSet列关联，可以自动化处理整批数据的同步。

第1步：定义数据保存方法

首先创建一个辅助方法，用于接收包含业务数据的对象和待更新的DataSet。此方法封装了连接字符串获取、命令构建及事务控制入口。

public bool SaveSMSMessage(SMSBatch smsBatch, DataSet smsMessages) 
{
    // 使用 SqlDatabase 实例管理连接
    SqlDatabase db = new SqlDatabase(this.ConsultantsConnString);
    
    // 定义要调用的存储过程名称及参数占位符
    string sqlCmd = "EXEC cn.SMSSaveSMSMessage @SMSBatchID, @SMSTypeID, @SubsidiaryID, @ContactID, @Message, @PhoneNumber";
    
    // ... 后续步骤见下文
}

第2步：配置 SqlCommand 参数

创建SqlCommand对象后，需要设置超时时间以防止长时间阻塞，并为固定参数赋值。对于来自DataSet的动态列，需明确指定数据类型和数据版本。

using (SqlCommand cmd = db.GetSqlStringCommand(sqlCmd) as SqlCommand)
{
    // 设置较长的超时时间以适应大批量操作
    cmd.CommandTimeout = 600;
    
    // 绑定静态参数
    cmd.Parameters.AddWithValue("@SMSBatchID", smsBatch.SMSBatchID);
    cmd.Parameters.AddWithValue("@SMSTypeID", smsBatch.SMSType.SMSTypeID);
    cmd.Parameters.AddWithValue("@SubsidiaryID", smsBatch.SMSType.SubsidiaryID);
    
    // 绑定从 DataSet 动态获取的参数
    db.AddInParameter(cmd, "@ContactID", DbType.Int64, "ContactID", DataRowVersion.Current);
    db.AddInParameter(cmd, "@Message", DbType.String, "Message", DataRowVersion.Current);
    
    // 处理可选字段：检查列是否存在
    if (smsMessages.Tables[0].Columns.Contains("PhoneNumber"))
    {
        db.AddInParameter(cmd, "@PhoneNumber", DbType.String, "PhoneNumber", DataRowVersion.Current);
    }
    else
    {
        db.AddInParameter(cmd, "@PhoneNumber", DbType.String, DBNull.Value);
    }
}

第3步：执行 UpdateDataSet 批量提交

调用db.UpdateDataSet是执行实际数据库交互的关键步骤。该方法会根据DataRowState自动判断哪些行需要插入、更新或删除，并通过之前配置的SqlCommand执行相应的存储过程逻辑。

// parameters 说明:
// 1. dataset: 待同步的数据集
// 2. tableName: 数据集表名
// 3. command: 用于执行的 SqlCommand
// 4. transaction: 事务对象（此处传 null 则不强制使用外部事务范围）
// 5. updateBehavior: UpdateBehavior.Transactional 确保原子性

int rowsEffected = db.UpdateDataSet(smsMessages, "SMSMessage", null, cmd, null, UpdateBehavior.Transactional);
return true;

注意事项与优化建议

• 事务管理：代码注释中包含TransactionScope的示例。若需更严格的全局事务控制，可取消注释并包裹整个方法逻辑，但需注意嵌套事务的性能影响。
• 存储过程配合：上述C#代码仅负责传递参数和执行。实际的批量处理逻辑必须在SQL Server端的cn.SMSSaveSMSMessage存储过程中实现。建议在存储过程内部使用批量合并逻辑（如MERGE或临时表）以提高数据库端性能。
• 安全性：虽然使用了参数化查询防止SQL注入，但仍需验证SMSBatch对象来源的安全性。
• 错误处理：生产环境中应捕获SqlException并记录rowsEffected的实际值，以便排查部分失败的情况。

总结

通过UpdateDataSet与存储过程的结合，开发者可以将复杂的数据同步逻辑集中在数据库层，同时保持C#代码的简洁性。这种方法特别适用于ERP、CRM等系统中常见的单据批量导入或状态同步场景。

以上就是C#中使用UpdateDataSet结合存储过程批量更新数据的详细内容，更多关于C#数据库操作优化的资料请关注本站其它相关文章！