我有一个简单的数据库管理器类(一个比它应有的能力更宏大的名字):

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 语句中。

最佳答案

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

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

此外，如果您在 using block 中有任何递归(例如再次调用 populate)，正如您在评论中指出的那样，而不是上面的代码你会遇到更多的问题。

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

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

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

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

关于C# MySQL 连接池限制，以及清理连接，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/8345613/