node.js中 mysql 增删改查操作及async，await处理实例分析

本文实例讲述了node.js中 mysql 增删改查操作及async，await处理。分享给大家供大家参考，具体如下：

要对mysql进行操作，我们需要安装一个mysql的库。

一、安装mysql库

npm install mysql --save

二、对mysql进行简单查询操作

const mysql = require('mysql');//创建数据库连接let conn = mysql.createConnection({  //主机地址  host: '127.0.0.1',  //用户名  user: 'root',  //密码  password: '123456',  //数据库  database: 'test',  //端口  port: 3306,  //字符集  charset: 'utf8'});//连接数据库conn.connect(function (err) {  if (err) {    throw err;  }  console.log('连接成功');});//查询数据库conn.query('select * from tb_user', function (err, data, field) {  if (err) {    throw err;  }  //data表示结果集数据，是一个数组  console.log(data);  data.forEach(function (value) {    console.log(value.id, value.user_name, value.addr);  });  //表字段的详细信息  console.log(field);});//关闭数据库连接conn.end();

二、对mysql进行增删改操作

const mysql = require('mysql');//创建数据库连接let conn = mysql.createConnection({  //主机地址  host: '127.0.0.1',  //用户名  user: 'root',  //密码  password: '123456',  //数据库  database: 'test',  //端口  port: 3306,  //字符集  charset: 'utf8'});//连接数据库conn.connect(function (err) {  if (err) {    throw err;  }  console.log('连接成功');});//插入数据，query()方法可以对sql语句进行参数绑定，用?号作为占位符。conn.query('insert into tb_user values(null, ?, ?)', ['xxx', 'xxx'], function (err, data) {  if (err) {    throw err;  }  if (data && data.affectedRows) {    console.log('插入数据成功，id为', data.insertId);  }});//修改数据conn.query('update tb_user set user_name = ? where id = ?', ['ggg', 7], function (err, data) {  if (err) {    throw err;  }  if (data && data.affectedRows) {    console.log('修改数据成功');  }});//删除数据conn.query('delete from tb_user where id = ?', [5], function (err, data) {  if (err) {    throw err;  }  if (data && data.affectedRows) {    console.log('删除数据成功');  }});//关闭数据库连接conn.end();

三、使用mysql连接池来优化对数据库的操作

频繁的连接和断开mysql是比较消耗资源的，我们可以创建一个连接池，复用连接池中的连接，提高效率。

const mysql = require('mysql');//创建数据库连接池let pool = mysql.createPool({  //连接数量，默认是10  connectionLimit: 20,  //主机地址  host: '127.0.0.1',  //用户名  user: 'root',  //密码  password: '123456',  //数据库  database: 'test',  //端口  port: 3306,  //字符集  charset: 'utf8'});//pool.query()方法可以自动的帮我们在连接池中获取可用连接pool.query('select * from tb_user', function (err, data) {  if (err) {    throw err;  }  data.forEach(function (value) {    console.log(value.id, value.user_name, value.addr);  });});//当然我们也可以手动获取可用连接pool.getConnection(function (err, conn) {  if (err) {    throw err;  }  conn.query('select * from `order`', function (err, data) {    if (err) {      throw err;    }    data.forEach(function (value) {      console.log(value.id, value.order_id, value.user_id);    });    //连接用完之后，需要释放，重新放回连接池中。    //注意这里并没有销毁该连接，该连接仍然可用，但需要重新获取    conn.release();  });});//从连接池中获取连接时，将触发该事件pool.on('acquire', function (conn) {  console.log('获取连接', conn.threadId);});//在连接池中建立新连接时，将触发该事件pool.on('connection', function (conn) {  console.log('建立新连接', conn.threadId);});//等待可用连接时，将触发该事件pool.on('enqueue', function () {  console.log('等待可用连接');});//当连接释放回池中时，触发该事件pool.on('release', function (conn) {  console.log('连接被释放回池中', conn.threadId);});//结束池中所有的连接，不然node.js的事件循环会一直保持setTimeout(function () {  pool.end(function (err) {    console.log('关闭连接池');    console.log(err);  });}, 3000);