要对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 mysql await_node.js中对 mysql 进行增删改查等操作和async，await处理相关推荐

  1. 动态网站作业4-JSP中实现数据库的增删改查的操作

    动态网站作业4-JSP中实现数据库的增删改查的操作 用Statement向数据库中添加元素 1.创建JavaBean–UserBean package com.media.bean;public cl ...

  2. node.js中对 mysql 进行增删改查等操作和async，await处理

    要对mysql进行操作,我们需要安装一个mysql的库. 一.安装mysql库 npm install mysql --save 二.对mysql进行简单查询操作 const mysql = requ ...

  3. js中实现cookie的增删改查(document.cookie的使用详情)

    一.设置cookie的值 1.每个cookie都是一个名称/值对,名称/值对用等号连接,并将该名称/值对赋值给document.cookie即可.如:document.cookie="id= ...

  4. node ajax crud,基于node.js和rethinkdb的CRUD(增删改查)Web服务

    基于node.js和rethinkdb的CRUD(增删改查)Web服务 这是一个简单的REST web服务演示案例源码,使用Node.JS和Express 和RethinkDB,后者持久化JSON数据 ...

  5. 用Python+Mysql+MDUI实现的数据库增删改查列表操作及单，多文件上传实例

    用Python+Mysql+MDUI实现的数据库增删改查列表操作及单,多文件上传实例.web服务用flask框架,数据库操作用的pymysql框架.教程在我B站有的. 开源地址:https://git ...

  6. java对数据库的增删改查_在java中对数据库进行增删改查

    代码区域: package com.oracle.jdbc.demo1; import java.sql.Connection; import java.sql.DriverManager; impo ...

  7. 纯JS+HTML+CSS实现表格增删改查翻页--模板文件管理

    纯JS+HTML+CSS实现表格增删改查翻页--模板文件管理 效果 页面 增 删 改 翻页 页面显示条数 查找 跳页 代码 结语 效果 话不多说,直接看效果,本次代码较为复杂,希望大家可以耐心阅读,不 ...

  8. 用 JS（JavaScript ）实现增删改查

    JS小例题 学习内容: 需求 总结: 学习内容: 需求 用 JavaScript 实现简单增删改查 实现代码 <!DOCTYPE html PUBLIC "-//W3C//DTD HT ...

  9. java list集合增删改_Java中集合类list的增删改查

    今天给大家带来的是Java中list类的使用,java.util 包提供了list类来对线性数据操作 List接口是Collection接口的子接口,List有一个重要的实现类--ArrayList类 ...

最新文章

  1. LayoutInflater的inflate函数用法详解
  2. python软件下载免费还是收费-为什么python最强大的IDE是收费的PyCharm?
  3. 计算机itunes无法安装,手把手给你细说win7系统电脑无法安装itunes的解决方案
  4. HTML第二课——css
  5. 必须使用初始化列表的情况
  6. 为什么阿里巴巴Java开发手册中强制要求接口返回值不允许使用枚举？
  7. C ++ 指针 | 指针的详细概念和使用_1
  8. new jQuery.common
  9. fedora30删除 gnome自带的Videos软件
  10. java实现控制继电器_单片机控制继电器
  11. 金蝶K3系统物料替代功能的应用与业务逻辑探讨
  12. 数字小人时钟windows电脑屏幕保护
  13. 别人总结归纳很全的三方库
  14. OSPF的Router-LSA和Network-LSA
  15. 3dsmax修改对象的旋转中心的位置
  16. 【软件工程】软件工程系统开发——系统设计概述
  17. 使用Webcam实现拍照功能
  18. 【Pandas】返回 视图 还是 副本？SettingwithCopyWarning 的原理和解决方案(摘录转载）
  19. 立象Argox OX- 100条码机如何打印标签
  20. linux如何查看内存ddr几代,如何通过命令查看内存是ddr2还是ddr3的？

热门文章

  1. STM32配置一般过程（持续更新中）
  2. MySQL · 引擎分析 · InnoDB行锁分析
  3. 我来阅读lodash源码——Math（一）
  4. DevOps：软件架构师行动指南3.1　概述
  5. Oracle创建用户设置权限
  6. Sql Server之旅——第十四站 深入的探讨锁机制
  7. Introduction to Objects
  8. 正则表达式模式修正符
  9. java 发送邮件
  10. 祝大家春节快乐身体健康