C# Invoke方法與數(shù)據(jù)庫事務(wù)管理的整合

在C#中，使用Invoke方法可以方便地執(zhí)行存儲(chǔ)過程或SQL查詢，并與數(shù)據(jù)庫事務(wù)管理整合。以下是一個(gè)示例，展示了如何使用Invoke方法執(zhí)行存儲(chǔ)過程并管理事務(wù)。

首先，假設(shè)我們有一個(gè)名為MyDatabase的數(shù)據(jù)庫，其中包含一個(gè)名為sp_MyStoredProcedure的存儲(chǔ)過程。該存儲(chǔ)過程接受一個(gè)輸入?yún)?shù)，并返回一個(gè)輸出參數(shù)。

CREATE PROCEDURE sp_MyStoredProcedure
    @InputParam INT,
    @OutputParam INT OUTPUT
AS
BEGIN
    -- 這里是你的存儲(chǔ)過程邏輯
    SET @OutputParam = @InputParam * 2
END

接下來，我們將使用C#中的SqlConnection、SqlCommand和Invoke方法來執(zhí)行此存儲(chǔ)過程并管理事務(wù)。

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
            {
                // 開始事務(wù)
                connection.Open();
                SqlTransaction transaction = connection.BeginTransaction();

                // 創(chuàng)建SqlCommand對(duì)象
                using (SqlCommand command = new SqlCommand("sp_MyStoredProcedure", connection))
                {
                    // 添加參數(shù)
                    command.Parameters.AddWithValue("@InputParam", 5);
                    command.Parameters.AddWithValue("@OutputParam", SqlDbType.Int).Direction = ParameterDirection.Output;

                    // 使用Invoke方法執(zhí)行存儲(chǔ)過程
                    object result = command.Invoke();

                    // 獲取輸出參數(shù)的值
                    int outputParam = (int)result;
                    Console.WriteLine("Output parameter: " + outputParam);

                    // 提交事務(wù)
                    transaction.Commit();
                }
            }
            catch (Exception ex)
            {
                // 發(fā)生異常時(shí)回滾事務(wù)
                if (connection.State == ConnectionState.Open)
                {
                    transaction?.Rollback();
                }
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

在這個(gè)示例中，我們首先創(chuàng)建了一個(gè)SqlConnection對(duì)象，并打開了連接。然后，我們開始一個(gè)事務(wù)，并創(chuàng)建一個(gè)SqlCommand對(duì)象來表示存儲(chǔ)過程。我們?yōu)榇鎯?chǔ)過程的輸入和輸出參數(shù)添加了值，并使用Invoke方法執(zhí)行存儲(chǔ)過程。最后，我們獲取輸出參數(shù)的值，提交事務(wù)，并在發(fā)生異常時(shí)回滾事務(wù)。

請(qǐng)注意，你需要將your_connection_string替換為實(shí)際的數(shù)據(jù)庫連接字符串。