C# MySQL 连接池限制和清理连接

Question

我有一个简单的数据库管理器类（一个比它的能力更宏大的名字）：

class DbManager
{
    private MySqlConnectionStringBuilder _connectionString;

    public DbManager()
    {
        _connectionString = new MySqlConnectionStringBuilder();
        _connectionString.UserID = Properties.Database.Default.Username;
        _connectionString.Password = Properties.Database.Default.Password;
        _connectionString.Server = Properties.Database.Default.Server;
        _connectionString.Database = Properties.Database.Default.Schema;
        _connectionString.MaximumPoolSize = 5;
    }


    public MySqlConnection GetConnection()
    {
        MySqlConnection con = new MySqlConnection(_connectionString.GetConnectionString(true));
        con.Open();
        return con;
    }

}

然后我在其他地方有另一个类，它表示其中一个表中的记录，我像这样填充它：

class Contact
{
    private void Populate(object contactID)
    {
        using (OleDbConnection con = DbManager.GetConnection())
        {
            string q = "SELECT FirstName, LastName FROM Contacts WHERE ContactID = ?";

            using (OleDbCommand cmd = new OleDbCommand(q, con))
            {
                cmd.Parameters.AddWithValue("?", contactID);

                using (OleDbDataReader reader = cmd.ExecuteReader())
                {
                    if (reader.HasRows)
                    {
                        reader.Read();
                        this.FirstName = reader.GetString(0);
                        this.LastName = reader.GetString(1);
                        this.Address = new Address();
                        this.Address.Populate(ContactID)
                    }
                }
            }
        }
    }
}


class Address
{
    private void Populate(object contactID)
    {
        using (OleDbConnection con = DbManager.GetConnection())
        {
            string q = "SELECT Address1 FROM Addresses WHERE ContactID = ?";

            using (OleDbCommand cmd = new OleDbCommand(q, con))
            {
                cmd.Parameters.AddWithValue("?", contactID);

                using (OleDbDataReader reader = cmd.ExecuteReader())
                {
                    if (reader.HasRows)
                    {
                        reader.Read();
                        this.Address1 = reader.GetString(0);
                    }
                }
            }
        }
    }
}

现在我认为所有using 语句都会确保连接完成后返回到池中，以供下次使用，但我有一个循环可以创建数百个这样的联系人并填充它们，似乎连接没有被释放。

连接、命令和阅读器都在自己的using语句中。

Answer 1

如果应用程序是多线程的，那么您可能会同时运行 10 个线程。每个都需要自己的连接，但如果您将池大小限制为 5，那么您的第 6 个线程将无法从池中获取连接。

您可能会以某种方式限制线程，但我建议您显着增加应用程序池的大小，以确保您的可用连接数多于线程数。作为一个指标，默认大小（通常对大多数人来说已经足够）是 100。

此外，如果您在 using 块内有任何递归（例如再次调用 populate），正如您在 cmets 中所指出的那样，而不是上面的代码，那么您将遇到更多问题。

如果您在 using 块内调用 populate，那么您将打开并使用来自父级的连接（因此不可重用），然后子调用将打开另一个连接。如果这种情况只发生几次，您的连接分配就会用完。

为了防止这种情况，您希望将辅助 Populate 调用移出 using 块。最简单的方法不是循环调用每个 ID 的记录集调用填充，而是将 ID 添加到列表中，然后在关闭连接后为所有新 ID 执行填充。

或者，您可以懒惰地评估诸如地址之类的东西。将 addressID 存储在一个私有字段中，然后使 Address 成为一个属性，检查其支持字段（不是 addressID）是否已填充，如果没有，则使用 AddressID 查找它。这样做的好处是，如果您从不查看地址，您甚至不会进行数据库调用。根据数据的使用，这可能会为您节省大量的数据库命中，但如果您确实使用了所有细节，那么它只会将它们转移，可能会将它们分散得更多，这可能有助于提高性能，或者可能根本没有任何区别. :)

一般而言，对于数据库访问，我会尝试将所有数据取出并尽快关闭连接，最好是在对数据进行任何复杂计算之前。另一个很好的理由是，根据您的数据库查询等，您可能会锁定您正在使用查询访问的表，这可能会导致数据库方面的锁定问题。

Answer 2

我建议进行一些更改：

1) 在 using 语句终止之前显式关闭连接。查看 OleDbConnection（以及 DbConnection 和 DbConnectionInternal）的源代码让我相信连接没有在 dispose 时显式关闭，只是被放弃了。

2) 修改 Address.Populate 以接受一个连接参数，这样当您只需要一个并从联系人传递打开的连接时，您就不必创建两个打开的连接。如果在连接不可用时会调用 Address.Populate 的情况，您可以在使用连接对象调用 Populate 重载之前在 Address 中创建打开连接的 Populate 的重载版本。 更新 Chris 的建议：我假设人们会知道在这种情况下关闭开放式阅读器，但事实并非如此。如果使用此方法，则必须在将打开的连接传递给该方法之前显式关闭任何打开的读取器。

更新

刚刚验证了建议 #1。来自MSDN Documentation：

"如果 DbConnection 超出范围，则不会关闭。因此，您必须通过调用 Close 或 Dispose 显式关闭连接，它们在功能上是等效的。如果连接池值 Pooling 设置为 true 或 yes，则此也释放物理连接。”