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

更新时间：2020年02月11日 09:37:00 作者：怀素真

这篇文章主要介绍了node.js中 mysql 增删改查操作及async，await处理,结合实例形式分析了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);

四、按流的方式进行查询

const mysql = require('mysql');
//创建数据库连接
let conn = mysql.createConnection({
  //主机地址
  host: '127.0.0.1',
  //用户名
  user: 'root',
  //密码
  password: '123456',
  //数据库
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
let query = conn.query('select * from tb_user');
//Query类继承自Sequence，而Sequence继承自EventEmitter
//所以Query类的实例是可以监听事件
//发生错误时
query.on('error', function (err) {
  console.log(err);
});
//获取查询字段信息
query.on('fields', function (fields) {
  console.log(fields);
});
//获取查询结果
query.on('result', function (result) {
  //暂停获取结果
  conn.pause();
  //跟流的pause()和resume()很类似，控制获取数据的频率。
  setTimeout(function () {
    console.log(result);
    //恢复获取结果
    conn.resume();
  }, 1000);
});
//查询结束
query.on('end', function () {
  console.log('查询结束');
});
conn.end();

通过query.stream()方法返回一个可读流来获取数据

const mysql = require('mysql');
//创建数据库连接
let conn = mysql.createConnection({
  //主机地址
  host: '127.0.0.1',
  //用户名
  user: 'root',
  //密码
  password: '123456',
  //数据库
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
//从一个查询中获取一个可读流
let qs = conn.query('select * from tb_user').stream({highWaterMark: 2});
let result = [];
qs.on('data', function (data) {
  result.push(data);
});
qs.on('end', function () {
  console.log('查询结束');
  console.log(result);
});
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('连接成功');
});
//开启一个事务
conn.beginTransaction(function (err) {
  if (err) {
    throw err;
  }
  conn.query('update account set money = money - 50 where name = ?', ['A'], function (err, data) {
    if (err) {
      //如果有错误则回滚
      return conn.rollback(function () {
        throw err;
      });
    }
    conn.query('update account set money = money + 50 where name = ?', ['B'], function (err, data) {
      if (err) {
        //如果有错误则回滚
        return conn.rollback(function () {
          throw err;
        });
      }
      //提交事务
      conn.commit(function (err) {
        if (err) {
          //如果有错误则回滚
          return conn.rollback(function () {
            throw err;
          });
        }
        console.log('处理成功');
        conn.end();
      });
    });
  });
});

六、解决mysql嵌套回调的问题

有些时候我们的操作需要上一个操作的结果，这样会导致比较深的嵌套问题，为了解决可以使用async和await来解决，而async和await又是基于promise的。

const mysql = require('mysql');
//创建数据库连接
let conn = mysql.createConnection({
  //主机地址
  host: '127.0.0.1',
  //用户名
  user: 'root',
  //密码
  password: '123456',
  //数据库
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
function query(conn, sql, params = []) {
  if (!conn) {
    return;
  }
  return new Promise(function (resolve, reject) {
    conn.query(sql, params, function (err, data) {
      if (err) {
        reject(err);
      } else {
        resolve(data);
      }
    });
  });
}
(async function () {
  let result = await query(conn, 'select * from tb_user');
  console.log(result);
  let row = await query(conn, 'select * from tb_user where id = ?', [result[0].id]);
  console.log(row);
  conn.end();
})();

当然我们还可以使用 util.promiseify() 进行包装。

const mysql = require('mysql');
const util = require('util');
//创建数据库连接
let conn = mysql.createConnection({
  //主机地址
  host: '127.0.0.1',
  //用户名
  user: 'root',
  //密码
  password: '123456',
  //数据库
  database: 'test',
  //端口
  port: 3306,
  //字符集
  charset: 'utf8'
});
//注意通过util.promisify进行包装的函数，必须满足
//1、函数的最后一个参数是回调函数
//2、回调函数的参数为(err, result)，前者是错误，后者是正常结果
//注意这里不要重新创建一个变量，不然会报错。
conn.query = util.promisify(conn.query);
(async function () {
  let result = await conn.query('select * from tb_user');
  console.log(result);
  let row = await conn.query('select * from tb_user where id = ?', [result[0].id]);
  console.log(row);
  conn.end();
})();

希望本文所述对大家node.js程序设计有所帮助。

您可能感兴趣的文章:

node+koa实现数据mock接口的方法
本篇文章主要介绍了node+koa实现数据mock接口的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-09-09
一文详解Node中的文件模块与核心模块
这篇文章主要介绍了一文详解Node 中文件模块与核心模块，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的朋友可以参考一下
2022-07-07
node连接redis的方法实现
本文主要介绍了node连接redis的方法实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-02-02
Node.js实现用户评论社区功能（体验前后端开发的乐趣）
这篇文章主要介绍了Node.js实现用户评论社区（体验前后端开发的乐趣） ,需要的朋友可以参考下
2019-05-05
nodejs使用async模块同步执行的方法
今天小编就为大家分享一篇关于nodejs使用async模块同步执行的方法，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
2019-03-03
浅谈node模块与npm包管理工具
这篇文章主要介绍了node模块与npm包管理工具,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-01-01
Koa2微信公众号开发之本地开发调试环境搭建
本篇文章主要介绍了Koa2微信公众号开发之本地开发调试环境搭建，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-05-05
node.js Sequelize实现单实例字段或批量自增、自减
Sequelize 可以实现针对单个实例的一或多个字段的自增、自减操作，也可以对符合条件的数据进行批量的自增、自减操作。单个实例字段的自增、自减可以利用Instance的相应方法实现，而批量自增、自减则需要借助sequelize提供的字面量方法实现。下面来看看详细的介绍吧。
2016-12-12
node-sass是干什么用的
node-sass是一个项目依赖，在一个项目中在使用sass语法的时候，必须通过sass-loader来解析sass，从而使sass语法变成浏览器能够识别的CSS语法，下面介绍node-sass是什么，一起看看吧
2023-08-08
node.js中的url.parse方法使用举例
url.parse()可以将一个完整的URL地址,分为很多部分,下面这篇文章主要给大家介绍了关于node.js中url.parse方法使用的相关资料,文中通过实例代码和图文介绍的非常详细,需要的朋友可以参考下
2023-03-03

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

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具