MySQL 数据连接未关闭/池化

Question

我正在开发完全重新开发的网站和销售系统，并且很快就遇到了这个 Max_connections 问题。

我发布了这个问题： 关闭/池化 MySQL ODBC 连接 最近，但此后尝试了其他一些事情，仍然一片空白，但可以提供更多细节...

我建立了一个相当复杂的销售流程，在创建发票时，我似乎留下了 7 个“流程”运行每次。我统计了创建发票过程中数据连接的使用次数，根据几个条件值，数据连接的使用次数为 7-9 次，因此实际上数据连接根本没有关闭。

为了加快编码速度，我创建了几个处理数据库连接的函数，因此我将在下面发布这些函数。

首先，我的连接字符串是：

"DRIVER={MySQL ODBC 3.51 Driver}; SERVER=mysql.dc-servers.com; DATABASE=jamieha_admin; UID=USERID; PASSWORD=pWD; OPTION=3;pooled=true;Max Pool Size=100" 

我用来打开和关闭数据库以及对数据库执行操作的函数如下：

Function connectionString(sql As String, closeConnection As String) As OdbcConnection
    Dim DBConnection As String = ConfigurationManager.ConnectionStrings("dbConnNew").ConnectionString
     'this is getting the connection string from web.config file.
    Dim oConnection As OdbcConnection = New OdbcConnection(DBConnection) 'call data connection
    connectionString = New OdbcConnection(DBConnection)
   If closeConnection <> "close" Then _
       connectionString.Open() ' open data connection
End Function

该函数为我提供了一个 OdbcConnection 连接字符串对象，然后我可以使用它：

Function openDatabase(sql As String) As OdbcCommand
    openDatabase = New OdbcCommand(sql, connectionString(sql, ""))
End Function

该函数创建一个可用的数据对象时被调用做类似的事情：

Dim stockLevel As OdbcCommand = openDatabase("SQL STATEMENT HERE")
Dim objDataReader As OdbcDataReader =      stockLevel.ExecuteReader(CommandBehavior.CloseConnection)
    '=== DO STUFF WITH objDataReader ==='
objDataReader.Close()

读完试图确保数据连接正确关闭等等后，我读到添加（CommandBehavior.CloseConnection）应该确保连接在不再使用时关闭，但这似乎不是正在发生，所以我有创建了一个单独的“closeCONnection”函数，如下所示：

Function closeConn()
    If connectionString("", "", "close") IsNot Nothing AndAlso connectionString("", "close").State = ConnectionState.Open Then
        connectionString("", "close").Close()
        connectionString("", "close").Dispose()
    End If
End Function

每次使用 openDatabase 函数后都会调用此函数，并且也在我为插入/更新和删除创建的函数中调用，如下所示：

Function insertData(InsertSql As String)
    Dim dataInsert = openDatabase(InsertSql, "new")
    dataInsert.ExecuteNonQuery()
    closeConn()
End Function

我不确定是否使所有这些函数让我的生活变得更轻松或更困难，但我试图减少每个需要数据访问的文件中的代码，但我不相信它确实如此。

但是，它已经清楚地表明我在何时何地打开和关闭数据库（或至少尝试），

但进程并未关闭。如果我快速连续运行销售流程 3 或 4 次，并且这 7 个流程仍然处于活动状态并添加到其中，我就会遇到 max_connections 问题。

不完全理解数据库连接是如何工作的，我担心我对此感到不知所措，因此不得不再次问你......！

谁能告诉我：

a) 我的连接字符串是否正确，是否有更好的连接可用于 MySQL？

b) 使用此方法创建 ODBCConnection 对象，是否可以在这样的函数中关闭它？

c) 为什么 (CommandBehavior.CloseConnection) 没有关闭连接（这个问题在我尝试手动关闭连接之前就出现了）

Answer 1

不幸的是，您遇到的问题来自您的设计和对连接的引用处理不当。

但不用担心。修复起来并不困难。 :-)

在 VB.Net 中，您总是需要按照以下模式访问数据：

1. 创建连接。
2. 创建使用连接的命令（包括添加任何参数值）。
3. 打开连接。
4. 执行命令。
5. 关闭连接。

这有一些变体，例如在关闭连接之前循环行，但通常这就是它的工作方式。为了确保连接关闭，VB.Net提供了Try/Finally块和Using语句。您需要使用其中之一来确保连接已关闭。

我将通过以正确的方式重写您的方法来向您展示我的意思。

首先，将您的连接创建代码包装到一个函数中。

Function GetConnection() As OdbcConnection

    Dim DBConnection As String = ConfigurationManager.ConnectionStrings("dbConnNew").ConnectionString

    GetConnection = New OdbcConnection(DBConnection)

End Function

其次，编写一个函数来创建命令。 （openDatabase 是错误的名称，所以我将其更改为 CreateCommand）。

Function CreateCommand(sql As String, connection As OdbcConnection) As OdbcCommand

    CreateCommand = New OdbcCommand(sql, connection)

End Function

现在，当您希望在数据库中执行查询或语句时，可以遵循以下模式：

Dim connection As OdbcConnection = GetConnection()
Dim stockLevel As OdbcCommand = CreateCommand("SQL STATEMENT HERE", connection)
Try
    connection.Open()
    Dim objDataReader As OdbcDataReader = stockLevel.ExecuteReader(CommandBehavior.CloseConnection)
Finally
    connection.Dispose()
End Try

使用 Try/Finally 块意味着连接将始终正确关闭，即使异常导致代码在您期望之前返回到。

另一种简写是Using语句（它实际上与Finally块中的Dispose执行完全相同的操作）：

Dim connection As OdbcConnection = GetConnection()
Dim stockLevel As OdbcCommand = CreateCommand("SQL STATEMENT HERE", connection)

Using connection
    connection.Open()
    Dim objDataReader As OdbcDataReader = stockLevel.ExecuteReader(CommandBehavior.CloseConnection)
End Using

如果您想将InsertData函数包装在命令中，您可以这样做：

Dim connection As OdbcConnection = GetConnection()
Dim stockLevel As OdbcCommand = CreateCommand(InsertSql, connection)

Using connection
    connection.Open()
    Dim result As Integer = stockLevel.ExecuteNonQuery()
End Using

我怀疑第一次你尝试过这个，你让你的连接保持打开状态，而没有关闭它们。我还假设（根据您所写的内容）您添加了 closeConn 方法来解决这个问题。不幸的是，每次调用 connectionString 时，您实际上都是在创建并打开一个新连接，然后您可以对其调用 Close 或 Dispose。初始连接永远不会关闭。

希望有帮助。