如何在单条查询中传入两个连接？Oracle主备库同步更新问题

没问题，我来给你梳理下怎么实现同时更新两个Oracle数据库的需求。首先要明确：每个OracleCommand只能绑定一个OracleConnection，所以你没法在单条查询里同时用两个连接，得分别针对每个连接执行更新操作。另外，你原来的代码直接拼接id到SQL里，存在严重的SQL注入风险，我会一起帮你修正这个问题。

方式一：封装通用方法，分别执行更新 #

把更新逻辑封装成可复用的方法，然后传入两个数据库的连接字符串分别调用，代码清晰易维护：

// 封装通用的更新方法
private void UpdateTickStatus(string connectionString, string targetId)
{
    // 使用using自动释放连接资源
    using (OracleConnection connection = new OracleConnection(connectionString))
    {
        connection.Open();
        // 用参数化查询替代字符串拼接，避免SQL注入
        string updateSql = "UPDATE tick SET status = '1' WHERE id = :TargetId";
        
        using (OracleCommand command = new OracleCommand(updateSql, connection))
        {
            // 添加参数并赋值
            command.Parameters.Add(":TargetId", OracleDbType.Varchar2).Value = targetId;
            // 执行更新
            command.ExecuteNonQuery();
        }
    }
}

// 调用方法更新两个库
public void UpdateBothDatabases(string id)
{
    string mainConnStr = ConfigurationManager.ConnectionStrings["delora"].ConnectionString;
    string backupConnStr = ConfigurationManager.ConnectionStrings["delora2"].ConnectionString;

    // 分别更新主库和备份库
    UpdateTickStatus(mainConnStr, id);
    UpdateTickStatus(backupConnStr, id);
}

方式二：使用事务保证原子性（可选） #

如果需要确保两个数据库的更新要么同时成功，要么同时失败（避免一个成功一个失败的不一致情况），可以用TransactionScope实现分布式事务：

using System.Transactions; // 需要引用System.Transactions.dll

public void UpdateBothDatabasesWithTransaction(string id)
{
    // 创建事务范围，默认是Serializable级别
    using (TransactionScope transactionScope = new TransactionScope())
    {
        string mainConnStr = ConfigurationManager.ConnectionStrings["delora"].ConnectionString;
        string backupConnStr = ConfigurationManager.ConnectionStrings["delora2"].ConnectionString;

        // 执行两个更新操作
        UpdateTickStatus(mainConnStr, id);
        UpdateTickStatus(backupConnStr, id);

        // 提交事务：只有调用Complete，事务才会真正提交
        transactionScope.Complete();
    }
    // 如果没有调用Complete，using块结束时会自动回滚事务
}

关键注意事项：

• 使用TransactionScope需要确保你的Oracle客户端版本支持分布式事务，并且服务器端的MSDTC（分布式事务协调器）服务已正确配置。
• 参数化查询是必须的：永远不要直接把用户输入或变量拼接到SQL语句里，这会让你的程序暴露在SQL注入攻击下，参数化查询能有效避免这个问题。

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