如何在C#与Sybase中使用事务处理

你遇到的核心问题在于：即便设置了SET CHAINED OFF，如果没有显式启动事务并正确配置ODBC连接的自动提交属性，Sybase仍会默认自动提交每个单独的语句。下面是完整的实现方案，包含事务控制、存储过程调用和条件提交/回滚的逻辑：

关键注意事项 #

• SET CHAINED OFF启用了显式事务模式，必须手动执行BEGIN TRANSACTION来启动事务
• 需将ODBC连接的AutoCommit属性设为false，避免单个语句被自动提交
• 异常场景下务必执行回滚，保证数据一致性

完整代码示例 #

using System;
using System.Data.Odbc;

public class SybaseTransactionHandler
{
    public void ExecuteInsertWithTransaction()
    {
        // 替换为你的Sybase ODBC连接字符串
        string connString = "Driver={Sybase ODBC Driver};Server=你的服务器地址;Port=端口号;Database=目标库;Uid=用户名;Pwd=密码;";
        
        OdbcConnection conn = null;
        
        try
        {
            conn = new OdbcConnection(connString);
            conn.Open();

            // 1. 设置非链式事务模式（开启显式事务支持）
            using (var cmdSetChained = new OdbcCommand("SET CHAINED OFF", conn))
            {
                cmdSetChained.ExecuteNonQuery();
            }

            // 2. 禁用自动提交，把事务控制权握在自己手里
            conn.AutoCommit = false;

            // 3. 显式启动事务
            using (var cmdBeginTran = new OdbcCommand("BEGIN TRANSACTION", conn))
            {
                cmdBeginTran.ExecuteNonQuery();
            }

            // 4. 调用插入存储过程
            using (var cmdProc = new OdbcCommand("你的插入存储过程名", conn))
            {
                cmdProc.CommandType = System.Data.CommandType.StoredProcedure;
                
                // 根据你的存储过程参数添加对应项
                cmdProc.Parameters.Add("@Param1", OdbcType.VarChar).Value = "测试值1";
                cmdProc.Parameters.Add("@Param2", OdbcType.Int).Value = 456;
                
                int affectedRows = cmdProc.ExecuteNonQuery();
                Console.WriteLine($"存储过程执行完成，影响行数: {affectedRows}");
            }

            // ------------------------------
            // 这里添加你的后续业务处理逻辑
            // 比如数据校验、调用其他服务、计算业务规则等
            bool needCommit = true; // 根据实际业务逻辑决定是否提交

            if (needCommit)
            {
                // 5. 提交事务
                using (var cmdCommit = new OdbcCommand("COMMIT TRANSACTION", conn))
                {
                    cmdCommit.ExecuteNonQuery();
                    Console.WriteLine("事务已成功提交");
                }
            }
            else
            {
                // 6. 回滚事务
                using (var cmdRollback = new OdbcCommand("ROLLBACK TRANSACTION", conn))
                {
                    cmdRollback.ExecuteNonQuery();
                    Console.WriteLine("事务已回滚");
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"处理过程中出现错误: {ex.Message}");
            // 异常发生时一定要回滚事务
            if (conn != null && conn.State == System.Data.ConnectionState.Open)
            {
                using (var cmdRollback = new OdbcCommand("ROLLBACK TRANSACTION", conn))
                {
                    try
                    {
                        cmdRollback.ExecuteNonQuery();
                        Console.WriteLine("因异常触发事务回滚");
                    }
                    catch (Exception rollbackEx)
                    {
                        Console.WriteLine("回滚事务时出现错误: {rollbackEx.Message}");
                    }
                }
            }
        }
        finally
        {
            // 确保连接被关闭和释放
            if (conn != null && conn.State == System.Data.ConnectionState.Open)
            {
                conn.Close();
                conn.Dispose();
            }
        }
    }
}

额外补充 #

如果你更习惯使用ODBC内置的事务对象，也可以替换显式SQL语句的方式，示例如下：

// 替换手动BEGIN TRANSACTION的代码
var transaction = conn.BeginTransaction();
// 给后续命令关联事务
cmdProc.Transaction = transaction;
// 提交时直接调用对象方法
transaction.Commit();
// 回滚时调用
transaction.Rollback();

两种方式效果一致，选你顺手的即可，但注意不要混合使用两种事务控制方式。

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