数据库基础 以及 Node 操作方法

Posted on   |   In   |     |   Views

数据库：存储数据的仓库。

  • 数据结构化
  • 实现数据共享
    • 可以减少冗余数据
  • 数据独立性高
  • 数据统一管理与控制

数据库介绍

  • MySQL 数据库
  • Oracle
    • Orcale数据库管理系统由甲骨文公司开发，在数据库领域一直处于领先地位
    • 商业收费，大型系统，淘宝、京东就使用了 Oracle 数据库
  • SqlServer 数据库
    • 由微软公司开发，只能在Windows上运行。.net开发程序员
  • DB2
    • 由IBM公司开发，在金融行业中使用的比较多。IBM的服务器，买服务器送数据库
    • 商业收费
  • MS SQL Server
    • 以上这些数据库都是使用 SQL 语言进行操作
    • SQL 语言就是用于 关系型数据库 的一个操作语言
    • 利用这个 SQL 语言可以增删改查库和表，以及增删改查表数据
    • 表 就是 关系
    • 表与表之间就是关系

  • MongoDB

    • 非关系型数据库
    • 没有表，这个数据库中存储的数据都在集合中，类似于 JavaScript 对象，其实就是 json 格式的数据
    • 集合没有结构，集合就是一个数组
    • 也可以往集合中插入数据

  • 关系型数据库存储结构

    • 数据库服务器
      • 数据库管理系统
    • 数据库
    • 数据表
      • 根据业务设计表结构
    • 记录
      • 根据表结构存储记录数据

MongoDB

MongoDB是由10gen公司开发的一个介于关系型数据库和非关系型数据库之间的产品，是非关系型数据库中功能最丰富，最像关系型数据库的。他支持的数据结构非常松散，是类似json的格式，所以可以存储比较复杂的数据结构类型。MongoDB数据库管理系统最大的特点就是它支持的查询语言非常强大，语法类似于面向对象的查询语言。它还是一个开源的数据库，对于大数据量、高并发的互联网应用，支持非常不错。操作非关系型数据库不需要使用SQL语言。

MongoDB 官网：https://www.mongodb.com/

  • MongoDB 是一个非关系型数据库
  • 面向文档存储
  • 开源免费、高性能
  • MongoDB 将数据存储为一个文档，数据结构由键值(key=>value)对组成
  • MongoDB 文档类似于 JSON 对象
  • 字段值可以包含其他文档，数组及文档数组
  • Mongo支持丰富的查询表达式
  • 查询指令使用JSON形式的标记，可轻易查询文档中内嵌的对象及数组。

创建数据目录并启动MongoDB数据库服务器

启动MongoDB数据库需要指定一个数据存储目录

  • 在 c 盘 根目录创建一个目录：data
  • 接下来启动 MongoDB 服务器
    • 打开终端，输入：mongod 你刚才创建的目录的绝对路径

注意：如果发现执行上面的命令收到这样一个提示：

1
'mongod' 不是内部或外部命令，也不是可运行的程序或批处理文件。

解决方案：将 MongoDB 安装目录下的 bin 目录配置到环境变量。

如果执行完上面的命令启动成功后不要动这个命令台了，说明 MongoDB 服务器正在运行。

MongoDB 默认运行的端口号是 27017

如何关闭？

在终端中：Ctrl + C 关闭 MongoDB 数据库。

连接 MongoDB 数据库

存储结构

  • 数据库
    • 一个mongodb中可以建立多个数据库
    • MongoDB的默认数据库为”db”，该数据库存储在data目录中
    • MongoDB的单个实例可以容纳多个独立的数据库，每一个都有自己的集合和文档
    • 不同的数据库也放置在不同的文件中
    • show dbs 显示所有数据库列表
    • db 显示当前数据库对象或集合
    • use 数据库名字 连接到一个指定的数据库
  • 集合
    • 集合就是 MongoDB 文档组，类似于关系型数据库中的表
    • 集合存在于数据库中，集合没有固定的结构，就是一个 JSON
    • 通常情况下我们插入集合的数据都会有一定的关联性。
    • 当第一个文档插入时，集合就会被创建。
    • db.col.find() 查询所有数据
    • db.col.findOne({}) 查询指定数据
  • 文档
    • 文档是一个键值(key-value)对(即BSON)

基本操作

  • show dbs 查看数据库列表
  • use 名称 创建一个数据库
    • 这里表示如果有该数据库则切换到该数据库
    • 如果没有，则创建（创建不是真的创建，只有当你在这个数据库中插入一个集合数据之后才会创建成功）
  • show collections 查看当前数据库中的集合
  • db.集合名称.insert({文档对象}) 向集合中插入一个文档（JSON 对象）
    • 如果该集合不存在，则直接新建，并将数据插入进去
    • 如果该集合已存在，则直接将数据添加到该集合中
  • db.集合名.find() 查询集合中的所有数据
  • db.集合名.find(文档条件) 按照文档条件查询
  • db.集合名.findOne(文档条件) 按照文档条件查询，只查询匹配项的第一个
  • db.dropDatabase() 自杀，删除数据库当前数据库
  • db.集合名.drop() 删除数据库中的指定集合
  • db.集合名.update(文档条件, 文档对象) 根据文档条件，整体更新为文档对象
  • db.集合名.update(文档条件, { $set:文档对象 }) 根据文档条件，更新指定字段
    • 如果更新的文档对象中的字段已存在，则更新
    • 如果不存在，则直接怼进去
  • db.集合名.save(文档)
    • 如果文档中包含一个 "_id" : ObjectId("56064f89ade2f21f36b03136") 该字段
    • 则会找到匹配项条件，整体替换
    • 如果没有该字段，则直接 insert
  • db.集合名.remove(条件文档)

在 Node 中操作 MongoDB

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
var mongodb = require('mongodb');
var MongoClient = mongodb.MongoClient;
// Connection URL 
var url = 'mongodb://localhost:27017/itcast';
// Use connect method to connect to the Server 
MongoClient.connect(url, function (err, db) {
  // 2. 使用 db 
  // 插入数据
  // db.collection('duanzi').insertMany([
  //   { nickname: '斜阳烟柳', gender: 0, age: 20, content: '小时候，村里有只狗很凶，我和哥哥对它又恨又怕。一次，我哥在家偷我爸的酒喝。碰巧那只狗从我家门前经过，我哥借酒壮胆，抄起棍子冲了出去。凶狗见势不妙，仓皇逃窜，我哥就满村追着打。第二天，我哥和凶狗在一条窄巷遇上，彼此一愣，各自扭头撒腿就跑...', }
  // ], (err, result) => {
  //   if (err) {
  //     throw err;
  //   }
  //   console.log('插入数据成功');
  // });
  // 查询数据
  db.collection('duanzi').find({}).toArray((err, docs) => {
    if (err) {
      throw err;
    }
    console.log(docs);
  })
  db.close();
});

oracle、sqlserver、DB2、MySQL 都是关系型数据库。

安装和配置 MySQL 数据库

官方网站：http://www.mysql.com/

启动 和 停止MySQL服务：

通过Windows的运行，输入services.msc找到MySQL服务

通过DOS命令启动MySQL服务（使用管理员权限打开终端）

登录MySQL数据库:

mysql -h localhost -P 3306 -u root -p

  • -h：主机名
  • -P：端口
  • -u：用户名
  • -p：密码

mysql默认连接localhost和3306，所以可以省略-h和-P:

mysql -u root -p

在命令行中输入“help;”或者“\h”，就会显示出MySQL的帮助信息。

命令 简写 具体含义
? \? 显示帮助信息
exit \q 退出MySQL
help \h 显示帮助信息
quit \q 退出MySQL
status \s 获取MySQL服务器状态信息
use \u 用来选择一个数据库，以一个数据库名作为参数

数据库的存储结构

  • 一个数据库服务器上可以有多个数据库
  • 一个数据库中可以有多个表
    • 一个表一定要有表结构
    • 所有的数据存储在表中，所以有了数据库之后，要先设计你的表结构
  • 一张表中存储多条记录
    • 记录按照表结构的形式进行存储

创建数据库和表

创建数据库

1
CREATE DATABASE [IF NOT EXISTS] db_name

查看数据库

1
SHOW DATABASES;

显示数据库创建语句

1
SHOW CREATE DATABASE db_name;

删除数据库

1
DROP DATABASE [IF EXISTS] db_name;

选择数据库

1
USE db_name;

查看当前使用的数据库

1
SELECT database();

数据类型

整数类型

类型 大小 范围（有符号） 范围（无符号） 用途
TINYINT 1 字节 (-128，127) (0，255) 小整数值
SMALLINT 2 字节 (-32 768，32 767) (0，65 535) 大整数值
MEDIUMINT 3 字节 (-8 388 608，8 388 607) (0，16 777 215) 大整数值
INT或INTEGER 4 字节 (-2 147 483 648，2 147 483 647) (0，4 294 967 295) 大整数值
… … … … …

浮点型

在MySQL数据库中，存储小数都是使用浮点数和定点数来表示的。

浮点数有两种：

  • 单精度浮点数（FLOAT）
  • 双精度浮点数(DOUBLE)

定点数（DECIMAL）[ˈdesɪml]

时间和日期类型

类型 大小(字节) 范围 格式 用途
DATE 3 1000-01-01/9999-12-31 YYY-MM-DD 日期值
TIME 3 ‘-838:59:59’/‘838:59:59’ H:MM:SS 时间值或持续时间
YEAR 1 1901/2155 YYY 年份值
DATETIME 8 1000-01-01 00:00:00/9999-12-31 23:59:59 YYY-MM-DD HH:MM:SS 混合日期和时间值
TIMESTAMP 8 1970-01-01 00:00:00/2037 年某时 YYYMMDD HHMMSS 混合日期和时间值，时间戳

如果插入的数值不合法，系统会自动将对应的零值插入到数据库中。

  • YEAR

使用4位字符串或数字表示，范围为‘1901‘ ~ ‘2155’或1901~2155

例如，输入‘2016‘或者2016，插入到数据库的值均为2016

  • DATE

DATE类型用来表示日期值，不包含时间部分。

可以使用“YYYY-MM-DD“或‘YYYYMMDD‘字符串表示

例如，输入‘2016-10-01‘或’20161001‘插入到数据库的日期都是2016-10-01

  • TIME

TIME类型用于表示时间值，它的显示形式一般为HH:MM:SS,其中HH 表示小时，MM表示分，SS表示秒

可以使用下面三种方式指定时间的值：

  1. 以“D HH：MM：SS“字符串格式表示。其中，D表示日，可以取0-34之间的值，插入数据时，小时的值等于（D*24+HH）
  • 例如，输入‘2 11:30:50‘，插入数据库的日期为 59:30:50
  1. 以‘HHMMSS‘字符串格式或者HHMMSS数字格式表示
  • 例如：输入‘345454‘或345454，插入数据库的日期为34:54:54
  1. 使用CURRENT_TIME或NOW()输入当前系统时间
  • DATETIME

指定DATETIME类型的值：

  1. 以‘YYYY-MM-DD HH:MM:SS‘或者’YYYYMMDDHHMMSS‘字符串或数字都可以。
  2. 使用NOW来输入当前系统的日期和时间
  • TIMESTAMP

TIMESTAMP类型显示形式和DATETIME相同，但取值范围比DATETIME小。

  1. 输入CURRENT_TIMESTAMP输入系统当前日期和时间
  2. 输入NULL时，系统会自动输入当前日期和时间
  3. 无任何输入时，系统会输入系统当前日期和时间

标记。利用它可以保存表中某条记录的最后修改时间。自动维护。

CHAR和VARCHAR

插入值 CHAR(4) 存储需求 VARCHAR(4) 存储需求
‘’ ‘’ 4个字节 ‘’ 1个字节
‘ab’ ‘ab’ 4个字节 ‘ab’ 3个字节
‘abc’ 4个字节 ‘abc’ 4个字节
‘abcd’ 4个字节 ‘abcd’ 5个字节
‘abcde’ ‘abcd’ 4个字节 ‘abcd’ 5个字节

当数据为CHAR(4)类型时，不管插入值的长度是多少，所占用的存储空间都是4个字节。而VARCHAR（4）所对应的数据所占用的字节数为实际长度加1.

总结：

  • 字符长度不固定的类型使用VARCHAR 查询的时候要计算字节的长度

  • 字符串长度固定的使用CHAR 查询速度快。

  • VARCAHR比CHAR省空间

  • CHAR比VARCHAR省时间

TEXT类型

表示大文本数据，例如：文章内容、评论等

基本操作

查看表结构

查看当前数据库中的所有表： show tables;

查看表结构: desc table_name;

查看建表语句: show create table table_name;

修改数据表

增加列: ALTER TABLE table_name ADD colum datatype;

修改列: ALTER TABLE table_name MODIFY colum datatype;

删除列: ALTER TABLE table_name DROP colum;

修改表名: rename TABLE table_name to new_table_name;

修改列名: ALTER TABLE table_name change colum_name new_colum_name datatype;

删除数据表

DROP TABLE table_name;

表的约束

约束条件 说明
PRIMARY KEY 主键约束，用于唯一标识对应的记录
FOREIGN KEY 外键约束
NOT NULL 非空约束
UNIQUE 唯一性约束
DEFAULT 默认值约束，用于设置字段的默认值

表的约束条件都是针对表中字段进行限制，从而保证数据表中数据的正确性和唯一性。

主键约束

每个数据表中最多只能有一个主键约束，定义为PRIMARY KEY 的字段不能有重复值且不能为NULL值。也就是非空而且唯一

语法：字段名 数据类型 PRIMARY KEY

非空约束

非空约束指的是字段的值不能为NULL，在MySQL中，非空约束是通过NOT NULL 定义的。

语法：字段名 数据类型 NOT NULL;

唯一约束

唯一约束用于保证数据表中字段的唯一性，即表中字段的值不能重复出现。

语法：字段名 数据类型 UNIQUE;

默认约束

默认约束用于给数据库中的字段指定默认值，即当在表中插入一条记录时，如果没有给这个字段赋值，数据库系统会为这个字段插入默认值。

语法：字段名 数据类型 DEFAULT 默认值;

设置表的字段值自动增加

如果想为表中插入的新纪录自动生成唯一ID。可以使用AUTO_INCREMENT实现

语法：字段名 数据类型 AUTO_INCREMENT;

添加、更新与删除数据

添加数据

为表中所有字段添加数据

1
2
INSERT INTO 表名
VALUES(列1值,列2值,...)

注意：

  • values中的值必须与表中的字段一一对应。
  • 插入的数据应与字段中的数据类型相同
  • 数据的大小应该在列的规定范围内，例如不能将一个长度为80的字符串插入到长度为40个列中
  • 字符和日期型数据应该包含在单引号中
  • 如果要插入一个空值，不指定或者使用NULL

按照指定列添加数据：

1
2
INSERT INTO 表名(列1名, 列2名,...)
VALUES(列1值, 列2值,...)

注意: values中的值必须与列声明中的列一一对应

同时添加多条记录

1
2
3
4
5
INSERT INTO employee
VALUES (value1,value2,value3...),
        (value1,value2,value3...),
        (value1,value2,value3),
        ...;

更新全部数据：

1
2
UPDATE 表名
SET 列名=值, 列名=值[,列名=值]

按条件更新：

1
2
3
UPDATE 表名
SET 列名=值, 列名=值[,列名=值]
WHERE 条件;

总结：

  • UPDATE语句可以用新值更新原有表中行的列。
  • SET字句指定要修改哪些列和要给与哪些值
  • WHERE需要给定一个条件，表示要更新符号该条件的行，没有WHERE字句，则更新所有行

条件可以使用的运算符：

1
2
3
4
5
6
7
8
9
-- 比较运算符 > < <= >= = <>  大于、小于、大于(小于等于)、不等于
BETWEEN…AND -- 显示在某一区间的值
IN(set) -- 显示在in列表中的值，例：in(100,200)
LIKE -- ‘张pattern’ 模糊查询%
IS NULL -- 判断是否为空
-- 逻辑运算符 AND 多个条件同时成立
OR  多个条件任一成立
NOT 不成立，例：WHERE NOT(salary>100)

删除数据：

删除全部数据

1
DELETE FROM 表名;

根据条件删除：

1
2
DELETE FROM 表名
WHERE 条件;

初始化

runcate初始化数据表

1
truncate table_name;

truncate和delete的区别：

  • delete会一条一条的删
  • truncate先摧毁整张表，再创建一张和原来的表结构一模一样的表
  • 拿拆迁举例子
  • truncate在效率上比delete高
  • truncate只能删除整表的数据，也就是格式化。
  • truncate会把自增id截断恢复为1

总结：

  • 如果不使用WHERE语句，将删除表中所有数据
  • DELETE不能删除某一列的值，（可使用UPDATE）
  • 使用DELETE语句仅仅删除记录，不删除表本身，如果要删除表，使用DROP TABLE语句
  • 删除表中所有数据也可以使用truncate table_name语句

单表查询

简单查询

1
SELECT [DISTINCT] *|{colum1, colum2, colum3...} FROM table_name;
  • SELECT指定查询哪些列的数据
  • column指定列名
    • 号表示查询所有列
  • FROM 指定查询哪种表
  • DISTINCT 可选，指查询结果时，是否去除重复数据

查询表中所有数据：

1
SELECT * FROM 表名;

按照指定列查询表中所有数据：

1
SELECT 列名,列名[,列名] FROM 表名;

根据条件查询数据：

1
2
SELECT * FROM 表名
WHERE 条件;

在WHERE字句中经常使用的运算符

比较运算符 > < <= >= = <> 大于、小于、大于(小于等于)、不等于
比较运算符 BETWEEN…AND 显示在某一区间的值
比较运算符 IN(set) 显示在in列表中的值，例：in(100,200)
比较运算符 LIKE ‘张pattern’ 模糊查询%
比较运算符 IS NULL 判断是否为空
逻辑运算符 AND 多个条件同时成立
逻辑运算符 OR 多个条件任一成立
逻辑运算符 NOT 不成立，例：WHERE NOT(salary>100)

LIKE语句中，% 代表零个或多个任意字符，_代表一个字符，例如：name LIKE '_a%';

多表查询：

1
2
3
4
5
6
7
-- 多表查询
-- 找到表 articles 中 user_id 等于 users 表中 id 的
-- 多表查询可以起别名
SELECT a.id as article_id, a.title, a.time
FROM articles as a
INSERT JOIN users as u
ON a.user_id=u.id

查询总记录数：

1
2
-- 查询表中的总记录数据
SELECT COUNT(id) as count FROM articles;

聚合函数

在实际开发中，经常需要对某些数据进行统计，例如统计某个字段的最大值，最小值，平均值等，为此，MySQL提供了一些函数来实现这些功能。

函数名称 作用
COUNT() 返回某行的列数
SUM() 返回某列值的和
AVG() 返回某列的平均值
MAX() 返回某列值的最大值
MIN() 返回某列的最小值
  • COUNT（列名）返回某一列，行的总数
  • COUNT（列名）返回某一列，行的总数
  • SUM()函数返回满足WHERE条件的行的和
1
2
SELECT SUM(列名) {, SUM(列名)...} FROM table_name
  [WHERE where_definition]

注意：SUM仅对数值起作用，否则报错; 对多列求和，“,”不能少。

  • MAX()/MIN()函数返回满足WHERE条件的一列的最大/最小值
1
2
SELECT MAX(列名) FROM table_name
  [WHERE where_definition];

对查询结果排序

1
2
3
SELECT colum1, colum2, colum3..
    FROM table_name
    ORDER BY colum ASC|DESC;

ORDER BY 指定排序的列，排序的列表即可以是表中的列名，也可以是SELECT语句后指定的列名.

  • ASC 升序，DESC 降序
  • ORDER BY 字句应该位于SELECT 语句的结尾

分组查询

1
2
3
SELECT colum1, colum2, ...
  FROM 表名
  LIMIT [OFFSET, ] 记录数

LIMIT表示从哪一条记录开始往后【不包含该记录】，以及一共查询多少记录

OFFSET表示偏移量:

  • 如果为0则表示从第一条记录开始
  • 如果为5则表示从第6条记录开始

使用场景：分页查询

分页查询一个例子

1
2
3
4
-- 仅仅取了前 10 条
SELECET * FROM articles LIMIT 10
-- 跳过一条取一条
SELECET * FROM articles LIMIT 1, 1

为表和字段区别名

为表取别名

1
2
SELECT 表别名.id,表别名.name... FROM 表名 AS 表别名
  WHERE 表别名.id = 2..

为字段取别名

1
SELECT 字段名 [AS] 别名 [,字段名 [AS] 别名,...] FROM 表名;

多表操作

实际开发中业务逻辑比较复杂，可能有几十到几百张表不等，所以我们就需要对多张表来进行查询操作，对两张以上的表进行操作，就是多表操作。

外键

为了保证数据的完整性，将两张表之间的数据建立关系，因此就需要在成绩表中添加外键约束。

  • 外键是指引用另一个表中的一列或多列，被引用的列应该具有主键约束或唯一约束。
  • 外键用于建立和加强两个表数据之间的链接。

为表添加外键约束

创建表的时候添加外键: 

1
2
3
4
5
6
7
8
9
10
CREATE TABLE department(
    id INT PRIMARY KEY auto_increment,
    name VARCHAR(20) NOT NULL
);
CREATE TABLE employee(
    id INT PRIMARY KEY auto_increment,
    name VARCHAR(20) NOT NULL,
    dept_id INT,
    FOREIGN KEY (id) REFERENCES department(id)
);

表已经存在，通过修改表的语句增加外键:

1
ALTER TABLE 表名 ADD CONSTRAINT 外键名 FOREIGN KEY(外键字段名) REFERENCES 外表表名(主键字段名);

删除外键约束

1
ALTER TABLE 表名 DROP FOREIGN KEY 外键名;

操作关联表

关联关系:

  • 多对一
  • 多对多
  • 一对一

使用 Node 操作 MySQL 数据库

安装：

1
$ npm install --save mysql

使用 Node 操作

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
var mysql = require('mysql');
// 连接数据库
var connection = mysql.createConnection({
  host: 'localhost',
  port: 3306,
  user: 'root',
  password: '*********',
  database: 'personal'
});
// 开始操作之前先连接，这一步可以省略
// 当操作数据库的时候，可以自动连接
// connection.connect();
// 操作数据库
// 第一个参数就是任何 SQL 语言，增删改查，? 是要拼接字符串的数据
// 第二个参数可选，传入数据数组
// 第三个参数：回调函数
//    回调函数中的第一个参数就是异常错误对象
//    回调函数中的第二个参数就是操作结果
//    第三个参数可以省略，基本不考虑
connection.query('SELECT * FROM `users` WHERE `age`>?', [20], function(err, rows, fields) {
  if (err) throw err;
  // 如果是 SELECT，结果是数组
  console.log('The solution is: ', rows[0].solution);
  // 对象中有一个数组很重要：affectedRows
  console.log(`受影响的行数：${rows.affectedRows}`);
});
// 关闭数据库
// 一般就是一个连接操作一次数据库，操作完毕，断开连接
connection.end();

使用 Node 操作：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
const mysql = require('mysql')
exports.query = (sql, params = [], callback) => {
  const connection = mysql.createConnection({
    connectionLimit : 500,
    host: 'localhost',
    port: 3306,
    user: 'root',
    password: '*********',
    database: 'personal'
  })
  connection.query(sql, params, (err, rows) => {
    if (err) {
      return callback(err)
    }
    callback(null, rows)
    // 操作完毕，结束连接
    connection.end()
  })
}

使用连接池操作 MySQL 数据库

  • 修改安装目录下 my.ini 文件中的: max_connections=1000 默认是 max_connections=151
  • 重启服务器

connection-pool

连接池

封装过程：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
const mysql = require('mysql');
// 使用连接，提高操作数据库效率
// 创建一个连接池，池子存放的连接数量是 100 个
const pool = mysql.createPool({
  connectionLimit: 100,
  host: 'localhost',
  user: 'root',
  password: '*********',
  database: 'personal'
});
for (let i = 0; i < 1000; i++) {
  // 从池子中拿一个可用的连接
  pool.getConnection((err, connection) => {
    if (err) {
      throw err;
    }
    connection.query('INSERT INTO `feedback`(`message`, `name`, `email`, `date`) VALUES(?, ?, ?, ?)', [
      '今天的雾霾很醇厚',
      '校长',
      'xiaozhang@abc.com',
      '2016-11-17 09:31:00'
    ], (err, stat) => {
      // 尽早的释放回连接池
      // 只要操作数据库的回调函数被执行，说明这个连接的任务完成了
      connection.release();
      if (err) {
        throw err;
      }
      console.log(`第${i+1}个任务完成了`);
    });
  });
}

封装：db.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
const mysql = require('mysql');
const pool = mysql.createPool({
  connectionLimit: 100,
  host: 'localhost',
  user: 'root',
  password: '*********',
  database: 'personal'
});
// rest 参数
// 作为函数参数的最后一个参数出现，以 ... 开头，后面跟一个名字
// rest 参数就代替了 arguments
exports.query = function (sql, ...values) {
  let callback;
  let params = [];
  if (values.length === 3) {
    params = values[0];
    callback = values[1];
  } else if (values.length === 2) {
    callback = values[0];
  }
  pool.getConnection((err, connection) => {
    if (err) {
      return callback(err);
    }
    // 如果传递了两个参数，则第二个参数就是 callback
    // 也就是说这种情况下，params 就是 callback
    // 后面的 参数就忽略不计了
    // 如果真的传递了三个参数，那就是一一对应
    connection.query(sql, params, (err, result) => {
      connection.release();
      if (err) {
        return callback(err);
      }
      callback(null, result);
    });
  });
};

promise 版

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
const mysql = require('mysql');
const pool = mysql.createPool({
  connectionLimit: 100,
  host: 'localhost',
  user: 'root',
  password: '*********',
  database: 'personal'
});
exports.query = (sql, params = []) => {
  return new Promise((resolve, reject) => {
    pool.getConnection((err, connection) => {
      if (err) {
        return reject(err);
      }
      connection.query(sql, params, (err, result) => {
        connection.release();
        if (err) {
          return reject(err);
        }
        resolve(result);
      });
    });
  });
};

调用示例：

1
2
3
4
5
6
7
8
9
10
11
12
13
const db = require('./db')
db.query('SELECT 1 + 1 as solution');
  .then(rows => {
    // use rows
    return db.query('INSERT INTO table_name VALUES(?, ?, ?)', ['值1', '值2', '值3'])
  })
  .then(rows => {
    // use rows
  })
  .catch(err => {
    // handle error
  });
感谢您的支持！