C# 開発でマルチスレッドを使用してデータベースに同時にアクセスする方法

C# 開発でマルチスレッドを使用してデータベースに同時にアクセスする方法

C# 開発では、データベースへのマルチスレッドの同時アクセスが一般的な要件です。マルチスレッドを使用するとデータベース操作の効率が向上しますが、スレッドの安全性やデータベース接続管理などの問題にも注意する必要があります。この記事では、C# でマルチスレッドを使用してデータベースに同時にアクセスする方法を紹介し、具体的なコード例を示します。

1. データベース接続の作成

マルチスレッドを使用してデータベースに同時にアクセスする前に、まずデータベース接続を作成する必要があります。通常、ADO.NET が提供する SqlConnection クラスを使用してデータベース接続を作成します。具体的なコードは次のとおりです。

using System.Data.SqlClient;

string connectionString = "Data Source=your_server;Initial Catalog=your_database;User ID=your_username;Password=your_password";
SqlConnection connection = new SqlConnection(connectionString);
connection.Open();

2. データベース操作メソッドの作成

複数のスレッドがデータベースに同時にアクセスする場合、通常、データベース操作をスレッドが実行できるメソッドにカプセル化します。電話。このメソッドは、データベース接続を開き、データベース操作を実行し、結果を返す役割を果たします。具体的なコードは次のとおりです。

// 执行SQL查询
public static DataTable ExecuteQuery(string sql)
{
    SqlCommand command = new SqlCommand(sql, connection);
    SqlDataAdapter adapter = new SqlDataAdapter(command);
    DataTable dataTable = new DataTable();
    adapter.Fill(dataTable);
    
    return dataTable;
}

// 执行SQL非查询操作
public static int ExecuteNonQuery(string sql)
{
    SqlCommand command = new SqlCommand(sql, connection);
    return command.ExecuteNonQuery();
}

3. データベースへのマルチスレッド同時アクセスの作成

データベースへのマルチスレッド同時アクセスを使用する前に、スレッドセーフなデータベース接続。これは、スレッド ローカル ストレージ (ThreadLocal) を使用して実現できます。具体的なコードは次のとおりです。

using System.Threading;

private static ThreadLocal<SqlConnection> connectionHolder = new ThreadLocal<SqlConnection>(() =>
{
    SqlConnection threadConnection = new SqlConnection(connectionString);
    threadConnection.Open();
    return threadConnection;
});

// 获取当前线程的数据库连接
private static SqlConnection GetThreadConnection()
{
    return connectionHolder.Value;
}

// 执行SQL查询
public static DataTable ExecuteQueryThreadSafe(string sql)
{
    SqlCommand command = new SqlCommand(sql, GetThreadConnection());
    SqlDataAdapter adapter = new SqlDataAdapter(command);
    DataTable dataTable = new DataTable();
    adapter.Fill(dataTable);
    
    return dataTable;
}

// 执行SQL非查询操作
public static int ExecuteNonQueryThreadSafe(string sql)
{
    SqlCommand command = new SqlCommand(sql, GetThreadConnection());
    return command.ExecuteNonQuery();
}

4. マルチスレッドを使用してデータベースに同時にアクセスする

マルチスレッドを使用してデータベースに同時にアクセスする場合、複数のコードを作成できます。スレッドを使用してデータベース操作を同時に実行します。具体的なコードは次のとおりです。

ThreadPool.QueueUserWorkItem((state) =>
{
    string querySql = "SELECT * FROM your_table";
    DataTable result = ExecuteQueryThreadSafe(querySql);
    // 处理查询结果
});

ThreadPool.QueueUserWorkItem((state) =>
{
    string updateSql = "UPDATE your_table SET your_column = value";
    int affectedRows = ExecuteNonQueryThreadSafe(updateSql);
    // 处理更新结果
});

// 等待所有线程执行完毕
// ...

// 关闭数据库连接
connection.Close();

上記は、マルチスレッドを使用してデータベースに同時にアクセスするための具体的なコード例です。マルチスレッドを使用するとデータベース操作の効率が向上しますが、同時アクセスの競合やリソースのリークを避けるために、スレッドの安全性やデータベース接続管理などの問題にも注意する必要があります。この記事が、C# 開発でデータベースへのマルチスレッド同時アクセスを使用するのに役立つことを願っています。

以上がC# 開発でマルチスレッドを使用してデータベースに同時にアクセスする方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。