C# Oracle 事务提交示例

在 C# 中，当需要对 Oracle 数据库进行多次操作时，通常需要开启事务，以确保这些操作是原子性的，即要么全部执行成功，要么全部回滚（即全部不执行）。本示例将介绍如何在 C# 中使用 Oracle 数据库并实现事务提交。

安装 Oracle 数据库

在使用 Oracle 数据库前，首先需要安装 Oracle 数据库和 Oracle Data Access Components（ODAC）。可以从 Oracle 官网下载和安装 Oracle Database 和 ODAC。

连接 Oracle 数据库

要连接 Oracle 数据库，需要使用 OracleConnection 类。以下是一个连接 Oracle 数据库的示例：

string connectionString = "User Id=myUsername;Password=myPassword;Data Source=myOracleDB;";
using (OracleConnection connection = new OracleConnection(connectionString))
{
    connection.Open();
    // To Do: 数据库操作
}

在连接字符串中，需要指定用户名（User Id）、密码（Password）和数据源（Data Source）等参数。连接字符串的具体格式可以根据实际情况进行调整。

开启事务

要开启事务，需要在 OracleConnection 对象上调用 BeginTransaction 方法。以下是一个开启事务的示例：

OracleTransaction transaction = null;
try
{
    using (OracleConnection connection = new OracleConnection(connectionString))
    {
        connection.Open();
        transaction = connection.BeginTransaction();
        // To Do: 数据库操作
        transaction.Commit();
    }
}
catch (Exception ex)
{
    if (transaction != null)
    {
        transaction.Rollback();
    }
    // To Do: 异常处理
}

在代码中，使用 try-catch-finally 来确保事务能够正确提交或回滚。当出现异常时，需要调用 Rollback 方法来回滚事务。注意，在 using 块中打开事务是不可行的，因为事务会影响整个连接，而 using 块在操作完成后会自动关闭连接。

数据库操作

在事务中进行数据库操作时，需要使用 OracleCommand 对象。以下是一个插入数据的示例：

const string query = "INSERT INTO myTable (field1, field2) VALUES (:field1, :field2)";
using (OracleCommand command = new OracleCommand(query, connection, transaction))
{
    command.Parameters.Add(new OracleParameter("field1", "value1"));
    command.Parameters.Add(new OracleParameter("field2", "value2"));
    command.ExecuteNonQuery();
}

在代码中，使用 OracleCommand 对象构造 SQL 查询语句，并在其中使用参数来避免 SQL 注入攻击。必须将 OracleCommand 对象的 Transaction 属性设置为事务对象，以确保这些操作在同一事务中执行。

完整示例代码

string connectionString = "User Id=myUsername;Password=myPassword;Data Source=myOracleDB;";
OracleTransaction transaction = null;

try
{
    using (OracleConnection connection = new OracleConnection(connectionString))
    {
        connection.Open();
        transaction = connection.BeginTransaction();

        const string query1 = "INSERT INTO myTable (field1, field2) VALUES (:field1, :field2)";
        using (OracleCommand command = new OracleCommand(query1, connection, transaction))
        {
            command.Parameters.Add(new OracleParameter("field1", "value1"));
            command.Parameters.Add(new OracleParameter("field2", "value2"));
            command.ExecuteNonQuery();
        }

        const string query2 = "UPDATE myTable SET field1 = :field1 WHERE field2 = :field2";
        using (OracleCommand command = new OracleCommand(query2, connection, transaction))
        {
            command.Parameters.Add(new OracleParameter("field1", "newValue1"));
            command.Parameters.Add(new OracleParameter("field2", "value2"));
            command.ExecuteNonQuery();
        }

        transaction.Commit();
    }
}
catch (Exception ex)
{
    if (transaction != null)
    {
        transaction.Rollback();
    }
    Console.WriteLine(ex.Message);
}

以上是一个插入和更新数据的事务示例。在 using 块中使用 OracleConnection 和 OracleCommand 对象，并在事务提交前使用 Commit 方法提交事务。如果发生异常，使用 Rollback 方法回滚事务，终止所有操作。

总结

在 C# 中实现 Oracle 事务提交，需要先连接 Oracle 数据库，并使用 OracleTransaction 对象开启事务。在事务中进行数据库操作时，需要使用 OracleCommand 对象，并将其 Transaction 属性设置为事务对象。在操作完成后，需要使用 Commit 方法提交事务。如果操作失败，需要使用 Rollback 方法回滚事务，终止所有操作。