mysql2数据库插件

使用mysql2插件，操作数据库。

• mysql.createConnection(config对象)，链接数据库。
• connection.execute(SQL语句) || connection.query(SQL语句)，操作数据库。

const mysql = require('mysql2');
 
// connection对象
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  database: 'test',
  password:'123456'
});
 
// query查询
connection.query(
  'SELECT * FROM table_20200510',
  function(err, results) {
    console.log(results); // results contains rows returned by server
  }
);

以上是这种写法无法适用于koa2的async/await语法，如何在koa当中使用mysql2？代码如下：

(async () => {
    const Koa = require('koa');
    const server = new Koa();
    server.listen(3000);

    // 引用，并使用promise语法
    const mysql = require('mysql2/promise');
    // 链接数据库
    const connection = await mysql.createConnection({
        host: 'localhost',
        user: 'root',
        database: 'test',
        password: '123456'
    });
    // 查询表，rows为数据
    server.use(async ctx =>{
        const [ rows ] = await connection.execute(`select * from table_20200510`);
        ctx.response.body = rows;
    });
})();