彻底掌握NodeJS中如何使用Sequelize

sequelize是什么？ sequelize是基于NodeJs的ORM框架，它适用于不同的数据库，如：Postgres、MySQL、SQLite、MariaDB，我们可以通过sequelize对数据库进行一系列的操作。通常我用它与MySQL一起使用。该文是我在使用sequelize做完项目后对sequelize的系统整理。

准备工作

一、创建数据库和表，方便学习过程中书写示例代码

创建数据库 lesson

CREATE DATABASE IF NOT EXISTS lesson DEFAULT CHARSET utf8 COLLATE utf8_general_ci;

创建商品表 goods（示例使用，字段从简）

CREATE TABLE IF NOT EXISTS goods(
id INT(20) UNSIGNED NOT NULL PRIMARY KEY AUTO_INCREMENT COMMENT '商品id',
name VARCHAR(64) NOT NULL COMMENT '商品名称',
title VARCHAR(200) NOT NULL COMMENT '商品标题',
descript TEXT COMMENT '商品描述',
num BIGINT UNSIGNED NOT NULL COMMENT '商品库存',
cateid INT(10) UNSIGNED NOT NULL COMMENT '分类id',
price DECIMAL(10,2) NOT NULL DEFAULT '0.00' COMMENT '商品价格',
create_time DATE COMMENT '创建时间',
update_time DATE COMMENT '修改时间'
)ENGINE=InnoDB;

创建分类表 categorys (示例使用，字段从简)

CREATE TABLE IF NOT EXISTS categorys(
id INT(20) UNSIGNED NOT NULL PRIMARY KEY AUTO_INCREMENT COMMENT '分类id',
name VARCHAR(64) NOT NULL COMMENT '分类名称',
create_time DATE COMMENT '创建时间',
update_time DATE COMMENT '修改时间'
)ENGINE=InnoDB;

二、使用koa框架起一个服务

要学习使用sequelize，我们要先用node搭建基础服务，暴露接口方便测试，直观的看到代码效果。

引入包

在使用sequelize之前，我们需要引入两个包：sequelize、mysql2

npm install --save sequelize mysql2

连接数据库

要连接数据库，您必须new一个Sequelize的实例，给Sequelize构造函数传递参数完成连接。

const DB = new Sequelize(database,username,password,{
host:'',
dialect:''
})

database：要连接的数据库name
username：登录数据库时的用户名
password：登录数据库时的密码
options：选项配置参数，为一个对象，内含许多配置属性，如：
- host：数据库主机
- port：数据库端口号
- dialect：指定要连接哪种类新的数据库，如：mysql、postgres等
- define：为模型定义默认选项
- timezone：时区

增

让我们先快速开始一个示例，从示例中学习需要注意的点（请始终记住我们使用的时准备阶段创建的数据库和表）

const {Sequelize,Model} = require('sequelize');
# 连接数据库
const connect = new Sequelize('lesson','root','abc123456',{
host:'localhost',
port:3306,
dialect:'mysql'
})
# 创建模型
class Category extends Model{}
Category.init({
name:Sequelize.STRING
},{
sequelize:connect,
tableName:'categorys'
})
# 新增一点数据
Category.create({name:'房产'})

当我们运行代码新增数据时，会发现数据没有添加成功且控制台报错。

为什么会出现这个问题呢？这是因为Sequelize为了方便开发者，它会自动帮开发者添加上创建时间和更新时间，但是它给这两个时间规定了默认字段为createdAt和updatedAt，如果不做任何配置，我们创建数据库时创建时间和修改时间字段必须与它默认规定的相同。

与这两个字段相关联的有一个timestamp配置属性，这个属性可以启用或不启用Sequelize为开发者自动添加时间，默认为true。

对上面代码做一点点更改，如下：

# 连接数据库
const connect = new Sequelize('lesson','root','abc123456',{
host:'localhost',
port:3306,
dialect:'mysql',
+ define:{
+ timestamp:false
+ }
})

在实例化Sequelize时，加上define参数配置，可以作用于全局。我们如上配置全局timestamp为false，即表示关闭自动添加时间，再次运行代码我们会发现数据库添加了一条数据。

解决了上面添加数据失败的问题，但是没有创建时间，这显然不是我们所希望的。我们再对代码做一些改动，添加上create_time字段如下：

# 创建模型
class Category extends Model{}
Category.init({
name:Sequelize.STRING,
+ update_time:{
+ type:Sequelize.DATE
+ }
},{
sequelize:connect,
tableName:'categorys'
})
# 新增一点数据
+ const create_time = new Date().getTime();
Category.create({name:'房产',create_time:create_time})

这时再打开数据库，我们可以看到有一条具有创建时间的数据已经被添加上去了

做到这里，我们知道了，不用Sequelize自动添加时间的方式，我们可以自己手动编码添加，而且数据库的时间字段可以是任意合法的字符。

当然，我们开启了timestamp，数据库的时间字段也可以是任意合法的字符。这时候需要我们配置字段别名，这是很简单的，只需要添加两行代码就可以了，如下：

# 连接数据库
const connect = new Sequelize('lesson','root','abc123456',{
host:'localhost',
port:3306,
dialect:'mysql',
+ define:{
+ timestamp:true,
+ createdAt:'create_time',
+ updatedAt:'update_time'
+ }
})

上述篇幅，我们已经知道如何连接数据库和向数据库中添加数据，但是有些业务场景，不仅仅只是将我们在输入框中的数据原样插入到数据库中，可能会对输入的数据做一些改动，如用户注册时，密码需要加密然后再插入到数据库中。

需要实现这个需求，我们需要学习Sequelize的Setters、Getters和Virtuals

Setters： setter是为模型中字段的set()函数，它接收字段的值。它作用在数据的添加阶段，在set()函数中，我们可以获取字段的值并对原始值做一系列的变化，然后再设置最终值。

Getters： getter是为模型中字段的get()函数，它作用在数据的获取阶段，在get()函数中，我们可以先对返回值做一系列的操作，再返回最终值。

Virtuals： virtuals是虚拟字段，它不存在与数据库中。开发者可以使用它将两个字段拼接返回。

接下来我们来看看实际使用的栗子，代码如下：

Category.init({
name:{
type:Sequelize.STRING,
set(val){
const newVal = val + 'sb'; // 所有添加的数据 name后都加上sb字符
this.setDataValue('name',newVal);
},
get() {
const rawValue = this.getDataValue('name'); //获取字段值
return rawValue ? rawValue.toUpperCase() : null; //将字段值的字母转换成大写输出
}
},
vitName:{ // 这是一个虚拟字段
type:Sequelize.VIRTUAL,
get(){
return `${this.name}`
}
}
},{
sequelize:connect,
tableName:'categorys'
})

查

到现在，我们已经学习了Sequelize很多的知识点了，接下来我们继续学习Sequelize的查询、修改、删除等方法。在学习之前我们还是先将数据库的数据维护一份正式一点的数据。

分别是分类表和商品表如下图:

Sequelize为开发者提供了查找方法，默认情况下，所有查找器方法的结果都是模型类的实例，而不是简单的javascript对象。这意味着在数据库返回结果后，Sequelize会自动将所有内容打包到适当的实例对象中。在某些情况下，当结果太多时，这种包装可能效率低下，可以通过{raw:true}选项配置禁用。

查询选择器：

findAll：它生成一条标准的SELECT查询语句，在不受到条件语句限制的情况下从表中检索所有数据。
findByPk：根据提供的主键，从表中检索处一条数据。
findOne：如果不提供查询选项的话，它会检索到表中第一条数据。
count：检索数据库中所有数据，得到数据总数。
findAndCountAll：可以获得数据总量和数据列表。这在做分页数据时时非常方便的。

现在我们来查询表数据，实现一些需求。

所有商品：

router.get('/pro/list',async (ctx,next) => {
const result = await Product.findAll();
ctx.body = {
msg:result
}
})

得到的结果为：

{
"msg": [
{
"id": 2,
"name": "工装七分裤",
"title": "优衣库男装工装七分裤(卷边) 425146 UNIQLO ",
"descript": "优衣库男装工装七分裤(卷边) 425146 UNIQLO 优衣库男装工装七分裤(卷边) 425146 UNIQLO ",
"num": 158,
"cateid": 2,
"price": "149.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
},
{
"id": 3,
"name": "花花公子旗舰短袖t恤",
"title": "花花公子旗舰短袖t恤男2020新款夏季潮牌宽松男士半袖潮流打底衫T ",
"descript": "花花公子旗舰短袖t恤男2020新款夏季潮牌宽松男士半袖潮流打底衫T 花花公子旗舰短袖t恤男2020新款夏季潮牌宽松男士半袖潮流打底衫T ",
"num": 3000,
"cateid": 2,
"price": "269.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
},
{
"id": 4,
"name": "华为nova",
"title": "Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰店 ",
"descript": "Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰店",
"num": 2500,
"cateid": 3,
"price": "1999.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
},
{
"id": 5,
"name": "荣耀30",
"title": "华为旗下荣耀30新品5G手机50倍超稳远摄麒麟985芯片全新智能手机正品官方旗舰店",
"descript": "华为旗下荣耀30新品5G手机50倍超稳远摄麒麟985芯片全新智能手机正品官方旗舰店华为旗下荣耀30新品5G手机50倍超稳远摄麒麟985芯片全新智能手机正品官方旗舰店",
"num": 3512,
"cateid": 3,
"price": "3299.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
},
{
"id": 6,
"name": "美的变频空调",
"title": "美的i青春大1.5匹空调智能挂机冷暖壁挂式官方旗舰店",
"descript": "美的i青春大1.5匹空调智能挂机冷暖壁挂式官方旗舰店美的i青春大1.5匹空调智能挂机冷暖壁挂式官方旗舰店",
"num": 4215,
"cateid": 4,
"price": "2999.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
},
{
"id": 7,
"name": "格力Gree",
"title": "Gree/格力 KFR-35GW 大1.5匹空调挂机智能变频冷暖一级壁挂式品悦",
"descript": "Gree/格力 KFR-35GW 大1.5匹空调挂机智能变频冷暖一级壁挂式品悦Gree/格力 KFR-35GW 大1.5匹空调挂机智能变频冷暖一级壁挂式品悦",
"num": 4215,
"cateid": 4,
"price": "4199.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
},
{
"id": 8,
"name": "郁香菲2020夏季新品",
"title": "郁香菲2020夏季新品荷叶边两穿收腰长款连衣裙纯色垂感飘逸长裙 ",
"descript": "郁香菲2020夏季新品荷叶边两穿收腰长款连衣裙纯色垂感飘逸长裙郁香菲2020夏季新品荷叶边两穿收腰长款连衣裙纯色垂感飘逸长裙 ",
"num": 4215,
"cateid": 5,
"price": "699.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
},
{
"id": 9,
"name": "美背文胸",
"title": "运动内衣女无钢圈聚拢冰丝无痕背心式胸罩夏季薄款调整型美背文胸 ",
"descript": "运动内衣女无钢圈聚拢冰丝无痕背心式胸罩夏季薄款调整型美背文胸运动内衣女无钢圈聚拢冰丝无痕背心式胸罩夏季薄款调整型美背文胸 ",
"num": 10000,
"cateid": 5,
"price": "99.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
}
]
}

条件查询

查询

router.get('/pro/list',async (ctx,next) => {
const result = await Product.findAll({
where:{
id:4
}
});
ctx.body = {
msg:result
}
})

结果：

{
"msg": [
{
"id": 4,
"name": "华为nova",
"title": "Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰店 ",
"descript": "Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰店",
"num": 2500,
"cateid": 3,
"price": "1999.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
}
]
}

查询

router.get('/pro/list',async (ctx,next) => {
const result = await Product.findOne({
where:{
id:4
}
});
ctx.body = {
msg:result
}
})
# 等同于
router.get('/pro/list',async (ctx,next) => {
const result = await Product.findByPk(4);
ctx.body = {
msg:result
}
})

结果一样，都是

{
"msg": {
"id": 4,
"name": "华为nova",
"title": "Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰店 ",
"descript": "Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰Huawei/华为 nova6 SE超级快充4800万AI四摄大运存nova6se 华为手机华为官方旗舰店",
"num": 2500,
"cateid": 3,
"price": "1999.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
}
}

注意：findAll和findOne、findByPk方法得到的结果是不同的，findAll得到的结果是数组包含着数据项，而findOne、findByPk得到的结果就是一条数据

分页查询

我们在项目中经常会需要分页查询，一次性查询所有的数据，无论是服务器还是前端页面显示都是不友好的。Sequelize为开发者提供了分页机制，我们只需配置offset和limit两个属性就可以实现分页。

offset：偏移量，以0开始做偏移
limit：限制条数

值得我们注意的是offset是以0开始做偏移的，通常前端分页会传递两个参数：pageCurrent和pageSize。 pageCurrent通常是以1开始的。所以后端接收到pageCurrent后需要减1传递给Sequelize做偏移。

router.get('/pro/list',async (ctx,next) => {
const { pageCurrent,pageSize } = ctx.request.body;
let limit = pageSize ? pageSize : limit;
let offset = pageCurrent ? (pageCurrent - 1)*limit : offset;
const result = await Product.findAll({
offset,
limit
});
ctx.body = {
msg:result
}
})

指定字段

router.get('/pro/list',async (ctx,next) => {
const result = await Product.findOne({
attributes:['name','price']
});
ctx.body = {
msg:result
}
})

结果

{
"msg": {
"name": "工装七分裤",
"price": "149.00"
}
}

排除字段

router.get('/pro/list',async (ctx,next) => {
const result = await Product.findOne({
attributes:{
exclude:['descript']
}
});
ctx.body = {
msg:result
}
})

结果

{
"msg": {
"id": 2,
"name": "工装七分裤",
"title": "优衣库男装工装七分裤(卷边) 425146 UNIQLO ",
"num": 158,
"cateid": 2,
"price": "149.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
}
}

排序查询

配置order选项，order是一个数组，字段名和排序方式。 desc（降序），asc（升序）

router.get('/pro/list',async (ctx,next) => {
const result = await Product.findAll({
order:[
['id','desc']
]
});
ctx.body = {
msg:result
}
})

关联查询

sequelize提供了四种类型的关联关系

hasOne关联：与目标建立一对一关联关系，外键存在于目标模型中
belongsTo关联：与目标建立一对一关联关系，外键存在于源模型中
hasMany：与目标建立一对多关联关系，外键存在于目标模型中
belongsToMany：与目标建立多对多关联关系，外键存在于源模型中

# 外键存在于源模型中
Product.belongsTo(Category,{
foreignKey:'cateid',
targetKey:'id'
})
# 外键存在于目标模型中
Product.hasOne(Category,{
as:'cate',
foreignKey:'id',
targetKey:'cateid'
})

上面两个代码示例， Product模型是源模型，Category模型是目标模型。cateid是Product中定义的字段列，可以看到使用belongsTo时外键foreignKey的值是cateid 使用hasOne时外键foreignKey的值是id ,这个id是Category中的主键id。

示例代码：

Product.hasOne(Category,{
foreignKey:'id',
targetKey:'cateid'
})
router.get('/pro/list',async (ctx,next) => {
const result = await Product.findOne({
include:{
model:Category
}
});
ctx.body = {
msg:result
}
})

得到结果：

{
"msg": {
"id": 2,
"name": "工装七分裤",
"title": "优衣库男装工装七分裤(卷边) 425146 UNIQLO ",
"descript": "优衣库男装工装七分裤(卷边) 425146 UNIQLO 优衣库男装工装七分裤(卷边) 425146 UNIQLO ",
"num": 158,
"cateid": 2,
"price": "149.00",
"create_time": "2020-07-25",
"update_time": "2020-07-25",
"Category": {
"id": 2,
"name": "男装",
"create_time": "2020-07-25",
"update_time": "2020-07-25"
}
}
}

商品信息中就有了该商品所属分类的信息，可以看到返回的商品信息字段是Category即是以定义的类名Category为字段，我们可以更改它。

Product.hasOne(Category,{
+ as:'cate',
foreignKey:'id',
targetKey:'cateid'
})
router.get('/pro/list',async (ctx,next) => {
const result = await Product.findOne({
include:{
model:Category,
+ as:'cate'
}
});
ctx.body = {
msg:result
}
})

这样分类信息的字段就跟更改成了cate

改

Category.update(param,option)

param：修改的参数集合，Object
option：配置选项

router.post('/edit',async (ctx,next) => {
await Category.update({
name:'男装内裤'
},{
where:{
id:2
}
})
})

上面代码修改id等于2的那条数据，将name字段的值更改为'男装内裤'。

删

Category.destroy(option)

彻底掌握NodeJS中如何使用Sequelize相关推荐

mysql 主键 uniqo_项目总结，彻底掌握NodeJS中如何使用Sequelize
前言 sequelize是什么? sequelize是基于NodeJs的ORM框架,它适用于不同的数据库,如:Postgres.MySQL.SQLite.MariaDB,我们可以通过sequelize ...
记录nodejs使用express搭建一个api服务器程序(5)-nodejs操作SQL数据库,Sequelize和Knex
此文章是我自己用来记录如何搭建一个以express为基础的api服务器框架的过程,并不是什么新手教程,并不会每一步都写得非常详细,如果您要阅读此文,需要一点nodejs和编写代码的基础知识文接上篇 ...
nodejs+html转换pdf,Nodejs中使用phantom将html转为pdf或图片格式的方法
最近在项目中遇到需要把html页面转换为pdf的需求,并且转换成的pdf文件要保留原有html的样式和图片.也就是说,html页面的图片.表格.样式等都需要完整的保存下来. 最初找到三种方法来实现这个 ...
nodeJS中读写文件方法的区别
导言:nodejs中所有与文件相关的操作都在fs模块中,而读写操作又是我们会经常用到的操作,nodejs的fs模块针对读操作为我们提供了readFile,read, createReadStream三 ...
nodejs+html转换pdf,Nodejs中使用phantom将html转为pdf或图片格式的方法.pdf
Nodejs中中使使用用phantom将将html转转为为pdf或或图图片片格格式式的的方方法法最近在项目中遇到需要把html页面转换为pdf 的需求,并且转换的pdf文件要保留原有html的样式 ...
理解nodejs中函数的参数的来由
看一段创建并启动nodejs服务的代码,如下: var http = require('http');http.createServer(function (request, response) {r ...
Nodejs中搭建一个静态Web服务器,通过读取文件获取响应类型
场景 Web服务器一般指网站服务器,是指驻留于因特网上某种类型计算机的程序,可以向浏览器等Web客户端提供文档,也可以放置网站文件让全世界浏览,还可以放置数据文件,让全世界下载.目前最主流的Web服务 ...
Nodejs中的模块系统
一.模块化的定义 ①具有文件作用域 ②具有通信规则:加载和导出规则二.CommonJS模块规范 1.nodejs中的模块系统,具有文件作用域,也具有通信规则,使用require方法加载模块,使用ex ...
不要在nodejs中阻塞event loop
文章目录简介 event loop和worker pool event loop和worker pool中的queue 阻塞event loop event loop的时间复杂度 Event Loo ...
nodejs中使用worker_threads来创建新的线程
文章目录简介 worker_threads isMainThread MessageChannel parentPort和MessagePort markAsUntransferable SHARE ...

彻底掌握NodeJS中如何使用Sequelize

彻底掌握NodeJS中如何使用Sequelize相关推荐

最新文章

热门文章