汇集 MySQL 与 Microsoft 企业库的连接

Question

我的设置是 MySql.Data.MySqlClient v6.9.8.0 和 Microsoft.Practices.EnterpriseLibrary.Data v6.0.0。

该程序是一个很长的运行程序，它持续运行以侦听任务，然后使用某种形式的数据库操作执行作业（取决于请求是什么。）有时请求会在其他，有时他们之间会隔几个小时。

我试过在连接字符串中使用 Pooling=true，但它给我带来了很多问题（并非总是如此 - 这些是间歇性问题。）

这是一个例子：

[MySqlException (0x80004005): Authentication to host 'localhost' for user 'root' using method 'mysql_native_password' failed with message: Reading from the stream has failed.]

关闭 pooling 解决了这个问题，但同时它使查询变慢，因为我们不能重用连接。我在网上搜索过，很多人都有同样的问题，我发现的唯一 fix/workaround 是 Pooling=false，如果可能的话我宁愿避免它。

下面是我的查询代码示例：

Database db = this.GetDatabase(databaseName);

List<dynamic> results = new List<dynamic>();

// Run the sql query
using (DbCommand dbCommand = db.GetSqlStringCommand(query))
{

    foreach (var parameter in inParameters)
    {
        db.AddInParameter(dbCommand, parameter.Key, parameter.Value.Item1, parameter.Value.Item2);
    }

    foreach (var parameter in outParameters)
    {
        db.AddOutParameter(dbCommand, parameter.Key, parameter.Value.Item1, parameter.Value.Item2);
    }

    using (IDataReader dataReader = db.ExecuteReader(dbCommand))
    {
        IDictionary<string, object> instance;

        do
        {
            // Read each row
            while (dataReader.Read())
            {
                instance = new ExpandoObject() as IDictionary<string, object>;

                // Populate the object on the fly with the data
                for (int i = 0; i < dataReader.FieldCount; i++)
                {
                    instance.Add(dataReader.GetName(i), dataReader[i]);
                }

                // Add the object to the results list
                results.Add(instance);
            }
        } while (dataReader.NextResult());
    }

    return results;
}

有什么想法吗？

Answer 1

你能试试这个吗？我知道我知道。使用 "using" 应该意味着我不必调用 dataReader.Close() 方法...但我仍然这样做。我还稍微修改了 dr.Read 块。

这家伙说的。

http://www.joseguay.com/uncategorized/ensure-proper-closure-disposal-of-a-datareader

我知道，我知道。你不应该这样做。即使在使用 Ent 库时，我也会执行额外的 .Close 步骤来尝试确保。

Database db = this.GetDatabase(databaseName);

List<dynamic> results = new List<dynamic>();

// Run the sql query
using (DbCommand dbCommand = db.GetSqlStringCommand(query))
{

    foreach (var parameter in inParameters)
    {
        db.AddInParameter(dbCommand, parameter.Key, parameter.Value.Item1, parameter.Value.Item2);
    }

    foreach (var parameter in outParameters)
    {
        db.AddOutParameter(dbCommand, parameter.Key, parameter.Value.Item1, parameter.Value.Item2);
    }

    using (IDataReader dataReader = db.ExecuteReader(dbCommand))
    {
        IDictionary<string, object> instance;

        while (dataReader.Read())
        {
            instance = new ExpandoObject() as IDictionary<string, object>;

            // Populate the object on the fly with the data
            for (int i = 0; i < dataReader.FieldCount; i++)
            {
                instance.Add(dataReader.GetName(i), dataReader[i]);
            }

            // Add the object to the results list
            results.Add(instance);
        }

        if (dataReader != null)
        {
            try
            {
                dataReader.Close();
            }
            catch { }
        }           

    }

    return results;
}

汇集 MySQL 与 Microsoft 企业库的连接

Pooling MySQL Connections with Microsoft Enterprise Library

.net

c#

mysql

enterprise-library

connection-pooling