mysql使用连接池时为什么需要释放连接?

jed*_*edu 2 mysql node.js

我正在尝试按照本教程实现nodejs mysql 数据库。我知道

pool.query()是pool.getConnection()+connection.query()+connection.release()的快捷方式。

文章中数据库配置为:

var mysql = require('mysql')
var pool = mysql.createPool({
    connectionLimit: 10,
    host: 'localhost',
    user: 'matt',
    password: 'password',
    database: 'my_database'
})
pool.getConnection((err, connection) => {
    if (err) {
        if (err.code === 'PROTOCOL_CONNECTION_LOST') {
            console.error('Database connection was closed.')
        }
        if (err.code === 'ER_CON_COUNT_ERROR') {
            console.error('Database has too many connections.')
        }
        if (err.code === 'ECONNREFUSED') {
            console.error('Database connection was refused.')
        }
    }
    if (connection) connection.release()
    return
})
module.exports = pool
Run Code Online (Sandbox Code Playgroud)

这可以用作:

pool.query('SELECT * FROM users', function (err, result, fields) {
    if (err) throw new Error(err)
    // Do something with result.
})
Run Code Online (Sandbox Code Playgroud)

但是,我真的不明白这一点

if (connection) connection.release()
Run Code Online (Sandbox Code Playgroud)

如果使用池自动释放连接,为什么我们需要这个?

jfr*_*d00 5

一旦完成pool.getConnection(),您将从池中删除一个连接,然后您可以使用该连接,并且其他任何人都无法从池中访问该连接。使用完毕后,将其放回池中,以便其他人可以使用。

因此,当不使用时pool.query()(正如您所知,它会自动将其放回池中),您必须获得一个连接,对它执行任何您想要的操作,然后自己将其放回池中。

如果您需要做的只是单个查询,那么使用pool.query()并让它自动从池中获取连接,运行查询,然后将其释放回池中。但是,如果您想使用连接执行多项操作,例如多次查询或多次插入数据库,则获取连接,使用它执行多个操作,然后将其释放回池。从池中手动获取连接还允许您在该连接上建立状态并在多个操作之间共享该状态。两次连续的调用pool.query()实际上可能使用池中的不同连接。它们甚至可能并行运行。

但是,我真的不明白这一点

if (connection) connection.release()

如果使用池自动释放连接,为什么我们需要这个?

如果您手动从池中获取连接,那么当您使用完该连接后,您必须手动将其放回池中connection.release()。否则,池中的连接很快就会清空,并且您将拥有一堆任何人都无法使用的空闲连接。

如果您使用像 之类的自动方法pool.query(),那么它将在单个查询操作后将其放回池中。

将其视为自动模式与手动模式。手动模式可以让您更好地控制自己的工作方式,但当自动模式符合您的需求时,它会更容易使用。当自动模式 ( pool.query()) 不能完全满足您的要求时,请手动从池中获取连接,使用它并将其放回。

  • @jedu,它们本身不必相互依赖,但如果其中一个成功而另一个失败,那么这将使数据库处于不一致的状态。考虑有两个表的示例:user_account(用户名,密码)和 user_profile(姓名,姓氏,出生日期)。每当创建新帐户时,都需要进行两次插入。如果第一个成功而第二个失败(通过使用 2 * pool.query() ),那么您就有麻烦了。在这种情况下,您应该使用手动连接,以便 connection.rollback() '撤消'第一个成功的查询并保持数据库一致 (3认同)