【实战】nodejs 必会技能 —— 封装 mysql 数据库连接

// 引入mysql模块
const mysql = require('mysql');

// 创建数据库连接池
const pool = mysql.createPool({
  connectionLimit: 10,
  host: 'example.org',
  user: 'username',
  password: 'password',
  database: 'dbname',
});

// 查询方法
function query(sql, values, callback) {
  pool.query(sql, values, (error, results, fields) => {
    if (error) throw error;
    callback(results, fields);
  });
}

// 关闭连接池
function end() {
  pool.end();
}

// 导出查询和关闭方法
module.exports = { query, end };

// 使用方法示例
const db = require('./database');

// 执行查询
db.query('SELECT * FROM users WHERE id = ?', [1], (results, fields) => {
  console.log(results);
});

// 关闭连接池
db.end();