C#MySQL连接池限制,并清理连接

Question

我有一个简单的DB管理器类(一个比它的能力更值得的名字):

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），正如您在注释中指出的那样，而不是上面的代码，那么您将遇到进一步的问题。

如果你打电话populate，则父级的连接将打开并正在使用（因此不可重用），然后子调用将打开另一个连接。如果这种情况只发生几次，您将耗尽分配的连接。

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

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

一般来说，对于数据库访问，我会尝试尽快抓取所有数据并关闭连接，最好是在对数据进行任何复杂的计算之前。这样做的另一个很好的原因是，根据您的数据库查询等，您可能会在您使用查询访问的表上持有锁，这可能会导致数据库方面的锁定问题。