设置事务错误，c#， Oracle

本文关键字：Oracle 错误 事务 设置 | 更新日期: 2023-09-27 18:08:33

我有一个程序在我的c#设备应用程序应用程序。这是它的样子:

private void stk_crane_start_movement()
    {
        conn.Open();
        OracleCommand cmd = new OracleCommand();
        OracleTransaction trans;
        trans = conn.BeginTransaction();
        cmd.Transaction = trans;
        cmd.Connection = conn;
        conn.AutoCommit = false;
        cmd.CommandTimeout = 0;
        cmd.CommandText = "dc.stk_crane_start_movement";
        cmd.CommandType = CommandType.StoredProcedure;
        cmd.Parameters.Add("pn_crane_opr_id_no", OracleDbType.Number).Value = empid.ToString();
        cmd.Parameters.Add("pn_crane_movement_id_no", OracleDbType.Number).Value = pn_crane_movement_id_no.ToString();
        cmd.Parameters.Add(new OracleParameter("pv_error", OracleDbType.VarChar));
        cmd.Parameters["pv_error"].Direction = ParameterDirection.Output;
        string pv_error;
        cmd.ExecuteNonQuery();
        pv_error = cmd.Parameters["pv_error"].Value.ToString();
        if (pv_error.ToString() == "")
        {
            trans.Commit();
            trans.Dispose();
            conn.Close();
            cmd.Dispose();
        }
        else
        {
            trans.Rollback();
            MessageBox.Show("" + pv_error, "Error");
        }
    }

我得到ORA-01453: SET TRANSACTION must be first statement of transaction 在 trans = conn.BeginTransaction();

谁能给我解释一下我到底做错了什么?

我也试过这样:

private void stk_crane_start_movement()
    {
        conn.Open();
        OracleCommand cmd = conn.CreateCommand();
        OracleTransaction trans;
        trans = conn.BeginTransaction(IsolationLevel.ReadCommitted);
        cmd.Transaction = trans;
        try
        {
            cmd.CommandText = "dc.stk_crane_start_movement";
            cmd.CommandType = CommandType.StoredProcedure;
            cmd.Parameters.Add("pn_crane_opr_id_no", OracleDbType.Number).Value = empid.ToString();
            cmd.Parameters.Add("pn_crane_movement_id_no", OracleDbType.Number).Value = pn_crane_movement_id_no.ToString();
            cmd.Parameters.Add(new OracleParameter("pv_error", OracleDbType.VarChar));
            cmd.Parameters["pv_error"].Direction = ParameterDirection.Output;
            cmd.ExecuteNonQuery();
            trans.Commit();
        }
        catch
        {
            pv_error = cmd.Parameters["pv_error"].Value.ToString();
            MessageBox.Show("" + pv_error, "Error");
            try
            {
                trans.Rollback();
            }
            catch (OracleException ex)
            {
                MessageBox.Show("Rollback failed" + ex, "Exception Error");
            }
        }
    }

但是因为它不是我期望的异常错误，所以它不会通过try catch语句。我希望它回滚时，我的pv_error变量填充。这就是为什么我在第一个例子中包含了一个if语句。

而且在此之前我没有任何其他交易。

设置事务错误，c#， Oracle

这里有一个建议，如果您已经有一个打开的事务，您可能会看到这个错误。他们建议提交或回滚任何开放的东西。不像在SQL Server中，我已经能够发出预防性的"COMMIT"语句在Oracle中，甚至不知道我是否有任何打开。

我看到你的代码和这里的示例代码之间的唯一区别是，它们在将事务分配给它之前将命令对象绑定到连接:

OracleCommand command = connection.CreateCommand();
command.Transaction = transaction;

你可能想尝试这种变化。您没有设置隔离级别，因此10.2版本以下的oracle oci.dll的问题可能不会在这里出现。

根据MSDN文档，您的第二个版本正确地使用了事务。如果你把它和if语句结合起来，应该没问题:

  private void stk_crane_start_movement()
    {
        conn.Open();
        OracleCommand cmd = conn.CreateCommand();
        OracleTransaction trans;
        trans = conn.BeginTransaction(IsolationLevel.ReadCommitted);
        cmd.Transaction = trans;
        try
        {
            cmd.CommandText = "dc.stk_crane_start_movement";
            cmd.CommandType = CommandType.StoredProcedure;
            cmd.Parameters.Add("pn_crane_opr_id_no", OracleDbType.Number).Value = empid.ToString();
            cmd.Parameters.Add("pn_crane_movement_id_no", OracleDbType.Number).Value = pn_crane_movement_id_no.ToString();
            cmd.Parameters.Add(new OracleParameter("pv_error", OracleDbType.VarChar));
            cmd.Parameters["pv_error"].Direction = ParameterDirection.Output;
            cmd.ExecuteNonQuery();
            pv_error = cmd.Parameters["pv_error"].Value.ToString();                
            if (pv_error.ToString() == "")
            {
               trans.Commit();
               trans.Dispose();
               conn.Close();
               cmd.Dispose();
            }
            else
            {
              trans.Rollback();
              MessageBox.Show("" + pv_error, "Error");
            }
相关文章：