C# Mysql 和多线程？

Question

我正在托管一个使用 mysql 连接器的 WCF 服务。出于某种原因，每 5-10 分钟一次，我收到一个错误，表明 mysql 已在使用中。我应该怎么办？设置它以使其阻塞，让它为每个线程创建一个新连接或设置一个管理器，该管理器创建一定数量的连接并将阻塞直到连接可用。实际上异步调用是否已经完成了最后一部分？最后，在另一个线程完成并从该线程获取信息之前阻塞的最佳方法是什么？

public static int Query(this IDbConnection olddb, string query, params object[] args)
{
    using (var db = olddb.CloneEx())
    {
        db.Open();
        using (var com = db.CreateCommand())
        {
            com.CommandText = query;
            for (int i = 0; i < args.Length; i++)
                com.AddParameter("@" + i, args[i]);

            return com.ExecuteNonQuery();
        }
    }
}

未处理的异常：System.NotImplementedException：请求的功能未实现。
  在 MySql.Data.MySqlClient.MySqlConnection.EnlistTransaction （System.Transactions.Transaction 事务）[0x00000] 在：0
  在 MySql.Data.MySqlClient.MySqlConnection.Open () [0x00000] in :0

Answer 1

每当您需要简单地查询您的 SQL 服务器时：

using (var conn = new MySqlConnection("Some connection string"))
using (var cmd = conn.CreateCommand())
{
    conn.Open();
    cmd.CommandText = "SELECT foo FROM bar";
    using (var reader = cmd.ExecuteReader())
    {
        while (reader.Read())
        {
            // process the results
        } 
    }
}

这可确保将连接返回到 ADO.NET 为您管理的连接池中，这样您就不会因为创建多个连接而导致速度变慢。此外，这段代码是完全可重入的，因此根据定义线程安全 => 它可以从任意数量的线程并发执行。