Nodejs中大家是怎么样使用mysql这个package的或者说是管理？

Nodejs中大家是怎么样使用mysql这个package的或者说是管理？

在创建新的connection肯定是占资源的，是不是每次query后一定要end()？ 或者说，这个连接不关闭。如果按照C#或者java来说的话，执行查询后，一定要close().因为一个 连接是十分的占资源，但是在node中或者说在mysql这个package中是怎么样管理connection的。 还有就是大家如何自动处理重新连接。因为mysql这个package8小时候就会自动断开连接。 您可以贴出您的代码，我们讨论下。或者说讲下实现的思路。 由于个人的表达能力有限，不知道大家理解没有。

8 回复

在Node.js中使用MySQL数据库时，确实需要谨慎管理数据库连接以确保应用程序的性能和稳定性。以下是一些最佳实践和示例代码，帮助你理解和管理MySQL连接。

1. 使用连接池

在Node.js中，通常建议使用连接池而不是直接创建和关闭连接。连接池可以有效地管理多个数据库连接，并在需要时重用它们。这样可以避免频繁地打开和关闭连接，从而提高性能。

示例代码：

const mysql = require('mysql2/promise'); // 引入promise版本

// 创建连接池
const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  database: 'testdb',
  password: 'password',
  waitForConnections: true,
  connectionLimit: 10,
  queueLimit: 0
});

async function queryDatabase() {
  const [rows, fields] = await pool.query('SELECT * FROM users');
  console.log(rows);
}

queryDatabase();

2. 自动重新连接

MySQL客户端库不会自动重新连接到数据库。你可以通过监听错误事件来实现自动重新连接。例如：

pool.on('error', (err) => {
  if (err.code === 'PROTOCOL_CONNECTION_LOST') {
    console.error('Database connection was closed.');
    // 在这里进行重新连接逻辑
    reconnectToDatabase();
  } else {
    throw err;
  }
});

function reconnectToDatabase() {
  console.log('Reconnecting to the database...');
  // 重新创建连接池
  pool.end(); // 结束当前连接池
  pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    database: 'testdb',
    password: 'password',
    waitForConnections: true,
    connectionLimit: 10,
    queueLimit: 0
  });
}

3. 关闭连接

在应用程序结束时，记得关闭连接池以释放资源：

process.on('SIGINT', () => {
  pool.end((err) => {
    if (err) {
      console.error('Error closing the connection pool:', err);
    }
    process.exit();
  });
});

通过这些方法，你可以更高效地管理和维护Node.js应用程序中的MySQL连接，同时确保应用程序的稳定性和性能。


可以使用连接池

不知道你说的c# java是怎样的使用情况，说下apache php吧，每次请求apache都会启动一个新进程来处理客户端请求，每个进程都是隔离的，php模块针对每个用户都要重新建立所有资源，进程结束要释放所有资源。所以php创建mysql链接后也一定要关闭链接，及时你不关闭链接，脚本也会帮你关闭链接。nodejs完全不同，只有一个进程，所有用户请求共享相同的环境，所以在nodejs进程启动起来后建立mysql链接就不用关闭，所有用户共享这一个链接， 直到nodejs进程结束，也就是服务器关闭。 每次请求创建和释放链接在nodejs里是不适用的

  1. mysql包本身不提供连接池，可以使用这个模块generic-pool，不过这个模块不提供我下面说的功能。
  2. 不是mysql的package8小时就断开连接，是mysql server 默认8小时会断开闲置连接，如果有connection pool，就定期检查里面的connection是否可用就OK了，比如随便发个sql: select 1 + 1

嗯，感谢您的解答，现在对Nodejs中的mysql这个package对于connection有了进一步的理解，还有就是它里面的end()方法的使用占不占资源，或者说，end()方法是不是在拿到了con并且进行查询之后，一定要调用。

嗯，感谢您的解答，但是在mysql包里面是有mysql.createPool()提供连接池的使用的。您提供的方法还是很不错的。

mysql这个模块有连接池。node中不用关连接。

在Node.js中使用mysql包来管理和操作MySQL数据库时，通常会采取连接池的方式而不是直接创建单个连接，这样可以更高效地利用资源，并且能够更好地处理连接重用和自动重新连接等问题。

使用连接池

const mysql = require('mysql');
const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'mydb'
});

// 使用连接池执行查询
pool.query('SELECT * FROM users', (error, results) => {
  if (error) throw error;
  console.log(results);
});

在这个例子中，我们创建了一个连接池，而不是每次执行查询时都去创建一个新的连接。连接池内部会维护一定数量的活跃连接，这些连接可以被重复使用，从而避免了频繁创建和销毁连接带来的性能损耗。

自动重新连接

为了处理连接超时或网络问题导致的断开连接情况，我们可以监听连接池的一些事件来实现自动重新连接。例如：

pool.on('acquire', function(connection) {
  console.log('Connection %d acquired', connection.threadId);
});

pool.on('release', function(connection) {
  console.log('Connection %d released', connection.threadId);
});

pool.on('error', function(err) {
  console.error('Error event on the connection pool:', err.message);
  // 这里可以添加自定义的错误处理逻辑，比如尝试重新初始化连接池
});

pool.getConnection((err, connection) => {
  if (err) {
    console.error('Error getting a connection from the pool:', err.message);
    return;
  }
  connection.query('SELECT * FROM users', (error, results) => {
    connection.release(); // 释放连接到连接池，而不是关闭它
    if (error) throw error;
    console.log(results);
  });
});

总结

  • 使用连接池：通过mysql.createPool()创建连接池，可以有效减少资源消耗并提高性能。
  • 自动重新连接：可以通过监听连接池的错误事件来检测连接问题，并在必要时重新初始化连接池。

这种方法不仅提高了效率，还简化了数据库连接的管理和维护。希望这能帮助你理解和改进你的应用中的数据库连接管理方式。

回到顶部