node基于async/await对mysql进行封装

请看下方的完整攻略：

什么是异步/等待(async/await)

异步/等待(async/await)是一种用于处理异步操作的编程模式。在传统的回调函数或者Promise对象中，我们需要使用多个then语句来处理异步任务返回的结果。而使用async/await的方式可以让我们以同步代码的方式来处理异步任务。它可以让我们的代码更加的简单、清晰。

node基于async/await对mysql进行封装

在Node.js中，我们通常使用mysql模块来链接并操作MySQL数据库。但是使用原生的mysql模块会出现很多的问题，我们需要手动处理连接、事务等问题。所以我们可以创建一个用于封装mysql操作的类，从而简化我们的代码。

在下面的示例中，我将展示如何使用async/await来对MySQL数据库进行封装：

创建mysql封装类

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

class MysqlUtil {
  constructor(config){
    this.pool = mysql.createPool(config); // 创建mysql连接池
    this._query = this.query.bind(this); // 将this.query方法的作用域绑定到MysqlUtil类上
  }
  async query(sql,values){
    return new Promise((resolve,reject)=>{
      this.pool.getConnection((err, connection) => {
        if (err) {
          reject(err);
          return;
        }
        connection.query(sql, values, (error, results) => {
          connection.release(); // 将资源返还给连接池
          if (error) {
            reject(error);
            return;
          }
          resolve(results);
        });
      });
    })
  }
}

module.exports = MysqlUtil;

上面的代码中，我创建了一个封装MySQL数据库操作的类MysqlUtil。在MysqlUtil构造函数中，我使用mysql.createPool(config)方法来创建一个连接池，并将其挂载到实例的pool属性上。我们可以通过调用pool.getConnection(callback)方法来获取一个MySQL的连接对象，然后通过连接对象调用query()方法来执行SQL查询语句。

封装查询方法

为了便于使用，我们可以封装一个查询方法，让我们能够直接使用SQL查询语句进行数据库操作。在下面的示例中，我将展示如何使用异步/等待在MySQL数据库中执行查询操作。

const MysqlUtil = require('./MysqlUtil'); // 导入上面的MysqlUtil类

const mysqlConfig = {
  host: 'localhost',  // 连接的 host 地址
  user: 'root',       // MySQL 用户名
  password: '123456', // MySQL 密码
  database: 'test'    // 数据库名称
};
const mysqlUtil = new MysqlUtil(mysqlConfig); // 创建MySQL连接池

// 查询所有的用户信息
async function queryUsers() {
  const sql = 'SELECT * FROM user';
  const users = await mysqlUtil.query(sql) // 直接使用await异步等待mysqlUtil.query()
  return users;
}

queryUsers().then(console.log) // 输出所有的用户信息

在上面的代码中，我使用await关键字来异步等待执行sql查询语句，并且直接返回结果。在queryUsers()方法中，我们可以直接使用SQL查询语句来查询整个user表，然后使用await mysqlUtil.query(sql)方法来执行查询语句。执行成功后，我们就可以直接得到结果了。

封装事务方法

除了查询操作之外，我们还可以使用异步/等待来封装MySQL事务操作。在下面的示例中，我将展示如何使用async/await来封装MySQL事务操作：

const MysqlUtil = require('./MysqlUtil'); // 导入上面的MysqlUtil类

const mysqlConfig = {
  host: 'localhost',  // 连接的 host 地址
  user: 'root',       // MySQL 用户名
  password: '123456', // MySQL 密码
  database: 'test'    // 数据库名称
};
const mysqlUtil = new MysqlUtil(mysqlConfig); // 创建MySQL连接池

// 添加新用户
async function addUser(user) {
  const connection = await mysqlUtil.getConnection(); // 获取Transaction对象
  try{
    await connection.beginTransactionAsync(); // 开启事务
    await connection.queryAsync('INSERT INTO user SET ?', user); // 插入新用户
    await connection.commitAsync(); // 提交事务
  }catch(err){
    await connection.rollbackAsync(); // 回滚事务
  }finally{
    await connection.releaseAsync(); // 释放资源
  }
}

addUser({ name: 'James', age: 20, sex: 'male' }); // 添加新用户

在上面的代码中，我们首先调用mysqlUtil.getConnection()来获取一个MySQL的Connection对象。然后使用Connection.queryAsync(sql,values)方法来执行SQL语句。在示例中，我们使用VALUES来插入一个新用户。

事务的具体处理可以参考注释中的具体操作。

通过以上的方式，我们就可以使用async/await来封装MySQL数据库操作了。

希望我的回答能解决你的问题，如果还有其它疑问，请随时追问。