Nodejs ORM框架Sequelize

（模型，关联表，事务，循环，及常见问题）

建立连接

const Sequelize = require('sequelize');
const sequelize = new Sequelize('database', 'username', 'password', {host: 'host',port: 'port',pool: {max: 50,min: 0,//建立连接最长时间acquire: 30000,//空闲最长连接时间idle: 10000},//默认输出执行sql语句logging: console.log,define: {//默认创建表有 createAt, updateAttimestamps: false,//可以给表设置别名freezeTableName: true,// 字段以下划线（_）来分割（默认是驼峰命名风格）underscored: false},//sequelize v4 必须设置方言dialect: 'mysql',//默认DECIMAL and NEWDECIMAL 返回 StringdialectOptions: {decimalNumbers: true},//设置别名，否则不识别$like等关键词($like: Op.like对应关系)operatorsAliases: 'object',//时间上的统一timezone: "+08:00",
})

模型定义

const DataTypes = Sequelize.DataTypes;
const user = sequelize.define('u', {userId: {type: DataTypes.INTEGER,primaryKey: true,autoIncrement: true},userName: {type: DataTypes.STRING,allowNull: true},birthDay: {type: 'TIMESTAMP',allowNull: false},gender: {type: DataTypes.INTEGER,allowNull: true,defaultValue: 0},ctime: {type: 'TIMESTAMP',allowNull: false,defaultValue: Sequelize.literal('CURRENT_TIMESTAMP')},updatedAt: {type: 'TIMESTAMP',defaultValue: Sequelize.literal('CURRENT_TIMESTAMP'),field: 'ctime'}
}, {tableName: 'user'})const products = sequelize.define('p', {prdId: {type: DataTypes.INTEGER,primaryKey: true,autoIncrement: true},prdName: {type: DataTypes.STRING,allowNull: false},userId: {type: DataTypes.INTEGER,allowNull: false},price: {type: DataTypes.DECIMAL(5, 4),allowNull: false}
})
products.belongsTo(user, { foreignKey: 'userId', targetKey: 'userId', as: 'u' });

注意点：
1. type如果不存在则直接用字符串表示如：’TIMESTAMP’;
2. 如果需要在更新表字段时记录更新时间，可应使用updateAt,并设置默认值和对应的字段名。
3. 如果默认值不是具体的数值，可以用literal函数去表示。
4. tableName 表名， u为别名。
5. 建立关联关系时，如果外键关联的是主键则不用写targetKey,否则需要。

查询数据

products.findAll({attributes: ['prdName', 'price'],include: [{model: user,as: 'u',attributes: ['userName']}],//raw:true
}).then(result => {console.log(JSON.stringify(result))
}).catch(err => {console.log(err)
})

//结果1：

[{"prdName": "ipad","price": 4.99,"u": { "userName": "张三" }},{"prdName": "iphone","price": 3.658,"u": { "userName": "张三" }},{"prdName": "联想笔记本","price": 9.32,"u": { "userName": "李四" }}
]

我们换个写法

products.findAll({attributes: ['prdName', 'price'],include: [{model: user,as: 'u',attributes: ['userName']}],raw:true
}).then(result => {console.log(JSON.stringify(result))
}).catch(err => {console.log(err)
})

结果2

[{"prdName":"ipad","price":4.99,"u.userName":"张三"},{"prdName":"iphone","price":3.658,"u.userName":"张三"},{"prdName":"联想笔记本","price":9.32,"u.userName":"李四"}
]

换个写法

products.findAll({attributes: [Sequelize.col('u.userName'),'prdName', 'price'],include: [{model: user,as: 'u',attributes: []}],raw:true
}).then(result => {console.log(JSON.stringify(result))
}).catch(err => {console.log(err)
})

结果3：

[{"userName":"张三","prdName":"ipad","price":4.99},{"userName":"张三","prdName":"iphone","price":3.658},{"userName":"李四","prdName":"联想笔记本","price":9.32}
]

可以看出来结果3是我们想要的结果

加条件的写法：

products.findAll({attributes: [Sequelize.col('u.userName'), 'prdName', 'price'],include: [{model: user,as: 'u',attributes: []}],where: {prdName: 'ipad','$u.userId$': 1},raw: true
}).then(result => {console.log(JSON.stringify(result))
}).catch(err => {console.log(err)
})

对应sql:

SELECT `u`.`userName`, `p`.`prdName`, `p`.`price` FROM `products` AS `p` LEFT OUTER JOIN `user` AS `u` ON `p`.`userId` = `u`.`userId` WHERE `p`.`prdName` = ‘ipad’ AND `u`.`userId` = 1;

如果给include 表加where条件 须使用'$u.userId$'这种写法;也可在include加where条件

事务

function doit() {//启用事务(自动提交)return sequelize.transaction(function (t) {return user.create({userName: '黄晓明',birthDay: '1991-06-23',gender: 0}, {transaction: t}).then(result => {return user.update({userName: '李四',}, {where: { userId: result.userId },transaction: t  //注意（事务transaction 须和where同级）second parameter is "options", so transaction must be in it})})}).then(result => {// Transaction 会自动提交// result 是事务回调中使用promise链中执行结果// console.log(result.length)console.log("ok")}).catch(err => {// Transaction 会自动回滚// err 是事务回调中使用promise链中的异常结果console.log(err)})
}

循环

const Op = Sequelize.Op;
const Promise = require('bluebird');
function recycle() {let tranArray = [];products.findAll({attributes: ['prdId', 'prdName', 'userId', 'price'],raw: true}).then(result => {result.forEach(rec => {tranArray.push(products.create({prdName: rec.prdName,userId: rec.userId,price: rec.price}))})return Promise.all(tranArray)}).then(result => {console.log('result' + result)}).catch(err => {console.log('err' + err)})
}

一般配合事务使用。

Nodejs ORM框架Sequelize相关推荐

Node.js ORM框架-sequelize
Node.js ORM框架-sequelize 什么是ORM 什么是"持久化" 什么是持久层 ORM技术特点什么是Sequelize Sequelize特点使用方式安装库配 ...
Node.js ORM 框架 Sequelize 重要更新 v5 发布
Node.js ORM 框架 Sequelize v5 已正式发布,这也是 v4 推出一年多后的主要版本. Sequelize 是一个基于 promise 的 Node.js ORM,目前支持 Pos ...
nestjs 优秀的ORM框架sequelize操作数据库
奉上最新代码: nestjs服务demo代码=>gitee地址.github地址 nodejs的ORM–sequelize 笔者在使用koa2开发后端服务的时候用的ORM框架是sequelize ...
php sequelize,egg.js整合数据库ORM框架Sequelize
在上篇文章中我们写了egg.js怎么连接mysql数据库, 而在一些较为复杂的应用中,我们可能会需要一个 ORM 框架来帮助我们管理数据层的代码.Java中有Mybatis.Hibernate.Spr ...
koa+ts+mysql后台开发——（五）使用orm框架sequelize操作数据库，自定义格式校验、统一处理返回信息、分页格式
文章目录前言一.引包二.初始化sequelize 三.添加模型层四.添加服务层五.添加控制层 (增删改查) 六.自定义数据校验七.统一处理返回信息八.统一处理分页格式九.在路由中引入导 ...
node本地连接服务器的数据库_基于Node.jsORM框架Sequelize的数据库迁移一
开课吧Web前端教程前言在日常的后端项目开发中,我们经常需要和数据库打交道.在这个过程中,我们需要创建数据库.表还有一些测试数据.许多时候,因为业务需求的变更导致的数据库结构的变化,需要修改数据库 ...
Sequelize 4.43.0 发布，基于 Nodejs 的异步 ORM 框架
Sequelize 4.43.0 发布了,Sequelize 是一款基于 Nodejs 的异步 ORM 框架,它同时支持 PostgreSQL.MySQL.SQLite 和 MSSQL 多种数据库,很 ...
Sequelize 4.42.1 发布，基于 Nodejs 的异步 ORM 框架
百度智能云云生态狂欢季热门云产品1折起>>> Sequelize 4.42.1 发布了,Sequelize 是一款基于 Nodejs 的异步 ORM 框架,它同时支持 Pos ...
Nodejs相关ORM框架分析
概述写这篇blog的原因,想找个node的ORM框架用用,确很难找到一篇对比分析这些ORM框架的文章,唯一找到了一篇,居然是通过star数来论英雄,我觉着很难服众,于是就找几个看看.后来又不想分析, ...

Nodejs ORM框架Sequelize

Nodejs ORM框架Sequelize

（模型，关联表，事务，循环，及常见问题）

建立连接

模型定义

查询数据

事务

循环

Nodejs ORM框架Sequelize相关推荐

最新文章

热门文章