node mysql如何封装，高效封装Node.js MySQL模块

Node.js中MySQL数据库操作的优雅封装实践

在Node.js中封装MySQL操作的核心在于通过创建统一的数据库连接池、抽象CRUD方法及引入Promise化接口来提升代码的可维护性和复用性。 封装不仅能减少重复代码，还能有效管理连接资源、统一错误处理，并增强项目应对需求变化的灵活性，以下将逐步解析封装的关键步骤与最佳实践。

建立数据库连接池

使用mysql2或mysql库创建连接池是封装的基础，连接池能自动管理多个数据库连接，避免频繁建立和断开连接的开销：

const mysql = require('mysql2/promise');
class DB {
  constructor() {
    this.pool = mysql.createPool({
      host: 'localhost',
      user: 'root',
      database: 'test',
      waitForConnections: true,
      connectionLimit: 10,
      queueLimit: 0
    });
  }
}

关键点：配置connectionLimit可控制并发连接数，waitForConnections确保连接队列的稳定性。

封装核心查询方法

将常用的查询操作抽象为通用方法,是封装的核心环节：

async query(sql, params) {
  const connection = await this.pool.getConnection();
  try {
    const [results] = await connection.execute(sql, params);
    return results;
  } finally {
    connection.release(); // 确保连接释放
  }
}

注意：务必使用try...finally保证连接释放，防止资源泄漏。

实现常用CRUD抽象

基于通用查询方法,可进一步封装业务中高频使用的操作：

async find(table, conditions = {}) {
  const keys = Object.keys(conditions);
  const where = keys.map(k => `${k} = ?`).join(' AND ');
  const sql = `SELECT * FROM ${table} ${where ? 'WHERE ' + where : ''}`;
  return this.query(sql, Object.values(conditions));
}
async insert(table, data) {
  const keys = Object.keys(data);
  const placeholders = keys.map(() => '?').join(',');
  const sql = `INSERT INTO ${table} (${keys.join(',')}) VALUES (${placeholders})`;
  const result = await this.query(sql, Object.values(data));
  return result.insertId; // 返回插入ID
}

优势：这样的封装让业务代码更简洁，例如db.find('users', { status: 1 })即可完成条件查询。

统一错误处理机制

健壮的封装必须包含完整的错误处理，建议在类层面添加错误拦截：

async safeQuery(sql, params) {
  try {
    return await this.query(sql, params);
  } catch (error) {
    // 可在此添加日志记录、报警等逻辑
    console.error('Database error:', error.message);
    throw new Error(`Query failed: ${error.message}`);
  }
}

支持事务操作

对于需要原子性的操作,事务支持必不可少：

async transaction(callback) {
  const connection = await this.pool.getConnection();
  await connection.beginTransaction();
  try {
    const result = await callback(connection);
    await connection.commit();
    return result;
  } catch (error) {
    await connection.rollback();
    throw error;
  } finally {
    connection.release();
  }
}

应用场景：转账、订单创建等需要多表数据一致性的操作。

进阶优化建议

1. 连接健康检查：定期验证空闲连接的有效性
2. SQL注入防护：始终使用参数化查询（如示例中的占位符）
3. 配置外部化：将数据库配置移至环境变量或配置文件中
4. TypeScript支持：添加类型定义提升开发体验
5. 查询日志：开发环境可记录SQL语句便于调试

通过上述封装,我们构建了一个可复用、易维护且安全的MySQL操作层，实际项目中，可根据业务需求进一步扩展，例如添加缓存机制、读写分离支持或数据模型层，良好的封装不仅能提升开发效率，还能为后续的性能优化和架构演进奠定坚实基础，建议根据项目规模选择合适的封装粒度，避免过度设计，保持代码的简洁与灵活。