C# Invoke方法与数据库事务管理的整合

在C#中，使用Invoke方法可以方便地执行存储过程或SQL查询，并与数据库事务管理整合。以下是一个示例，展示了如何使用Invoke方法执行存储过程并管理事务。

首先，假设我们有一个名为MyDatabase的数据库，其中包含一个名为sp_MyStoredProcedure的存储过程。该存储过程接受一个输入参数，并返回一个输出参数。

CREATE PROCEDURE sp_MyStoredProcedure
    @InputParam INT,
    @OutputParam INT OUTPUT
AS
BEGIN
    -- 这里是你的存储过程逻辑
    SET @OutputParam = @InputParam * 2
END

接下来，我们将使用C#中的SqlConnection、SqlCommand和Invoke方法来执行此存储过程并管理事务。

using System;
using System.Data;
using System.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "your_connection_string";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            try
            {
                // 开始事务
                connection.Open();
                SqlTransaction transaction = connection.BeginTransaction();

                // 创建SqlCommand对象
                using (SqlCommand command = new SqlCommand("sp_MyStoredProcedure", connection))
                {
                    // 添加参数
                    command.Parameters.AddWithValue("@InputParam", 5);
                    command.Parameters.AddWithValue("@OutputParam", SqlDbType.Int).Direction = ParameterDirection.Output;

                    // 使用Invoke方法执行存储过程
                    object result = command.Invoke();

                    // 获取输出参数的值
                    int outputParam = (int)result;
                    Console.WriteLine("Output parameter: " + outputParam);

                    // 提交事务
                    transaction.Commit();
                }
            }
            catch (Exception ex)
            {
                // 发生异常时回滚事务
                if (connection.State == ConnectionState.Open)
                {
                    transaction?.Rollback();
                }
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

在这个示例中，我们首先创建了一个SqlConnection对象，并打开了连接。然后，我们开始一个事务，并创建一个SqlCommand对象来表示存储过程。我们为存储过程的输入和输出参数添加了值，并使用Invoke方法执行存储过程。最后，我们获取输出参数的值，提交事务，并在发生异常时回滚事务。

请注意，你需要将your_connection_string替换为实际的数据库连接字符串。