在上篇文章中我们写了egg.js怎么连接mysql数据库, 而在一些较为复杂的应用中，我们可能会需要一个 ORM 框架来帮助我们管理数据层的代码。Java中有Mybatis、Hibernate、Spring Data Jpa, 在Php中Thinkphp框架也集成ORM框架功能, 而在 Node.js 中，sequelize 是一个我们广泛使用的 ORM 框架，它支持 MySQL、PostgreSQL、SQLite 和 MSSQL 等多个数据源
安装
cnpm i -S egg-sequelize mysql2
开启sequelize插件
config/plugin.js
module.exports = {
sequelize: {
enable: true,
package: 'egg-sequelize',
}
};
配置sequelize
我们这里连接mysql数据库
/* eslint valid-jsdoc: "off" */
'use strict';
/**
* @param {Egg.EggAppInfo} appInfo app info
*/
module.exports = appInfo => {
/**
* built-in config
* @type {Egg.EggAppConfig}
**/
const config = exports = {
// sequelize配置
sequelize: {
dialect: 'mysql',
host: 'ip地址',
port: 3306,
database: 'test',
username: 'root',
password: '123456'
}
};
// use for cookie sign key, should change to your own and keep security
config.keys = appInfo.name + '_1565058424941_6691';
// add your middleware config here
config.middleware = [];
// add your user config here
const userConfig = {
// myAppName: 'egg',
};
return {
...config,
...userConfig,
};
};
数据库迁移(Migrations)
在实际开发中, 大部分情况下是多人协作的， 在项目的演进过程中， 每一次迭代都可能对数据库结构做变更, 怎么解决这个问题? 这时候我们就需要Migrations来帮我们管理数据结构的变更了
sequelize提供了sequelize-cli工具来实现Migrations
- 先安装sequelize-cli
cnpm i --save-dev sequelize-cli
- 在根目录创建.sequelizerc文件
'use strict';
const path = require('path');
module.exports = {
config: path.join(__dirname, 'database/config.json'),
'migrations-path': path.join(__dirname, 'database/migrations'),
'seeders-path': path.join(__dirname, 'database/seeders'),
'models-path': path.join(__dirname, 'app/model'),
};
- 初始化 Migrations 配置文件和目录
// 执行下面两条命令, 会根据根目录下我们刚才创建的.sequelizerc生成Migrations 配置文件和目录
npx sequelize init:config
npx sequelize init:migrations
执行完上面两条命令, 根目录多了个database文件夹
database
├── migrations
└── config.json
到这里, sequelize-cli和相关配置都初始化好了
创建表
在 Migration 文件来创建我们的表users
执行下面的命令
npx sequelize migration:generate --name=init-users
执行完后会在 database/migrations 目录下生成一个 migration 文件(${timestamp}-init-users.js)，我们修改它来处理初始化 users 表
我这里生成的是20190806050532-init-users.js, 修改该文件内容
'use strict';
module.exports = {
// 在执行数据库升级时调用的函数，创建 users 表
up: async (queryInterface, Sequelize) => {
const { INTEGER, DATE, STRING } = Sequelize;
await queryInterface.createTable('users', {
id: { type: INTEGER, primaryKey: true, autoIncrement: true },
name: STRING(30),
age: INTEGER,
created_at: DATE,
updated_at: DATE,
});
},
// 在执行数据库降级时调用的函数，删除 users 表
down: async queryInterface => {
await queryInterface.dropTable('users');
},
};
执行 migrate 进行数据库变更
# 升级数据库
npx sequelize db:migrate
# 如果有问题需要回滚，可以通过 `db:migrate:undo` 回退一个变更
# npx sequelize db:migrate:undo
# 可以通过 `db:migrate:undo:all` 回退到初始状态
# npx sequelize db:migrate:undo:all
执行npx sequelize db:migrate之后, 我们现在去查看数据库多两张表SequelizeMeta和users
接下来我们就可以编写代码进行数据库操作了
创建app/model/user.js
'use strict';
module.exports = app => {
const { STRING, INTEGER, DATE } = app.Sequelize;
const User = app.model.define('users', {
id: { type: INTEGER, primaryKey: true, autoIncrement: true },
name: STRING(30),
age: INTEGER,
created_at: DATE,
updated_at: DATE,
});
return User;
};
这里创建的Model模型可以在Controller和Service中通过app.model.User或ctx.model.User访问
我们创建一个app/controller/user.js
const Controller = require('egg').Controller;
class UserController extends Controller {
async index() {
// 查询所有用户信息
ctx.body = await this.ctx.model.User.findAll();
}
}
module.exports = UserController;
最后一步配置路由
app/router.js
module.exports = app => {
const { router, controller } = app;
router.get('/user', controller.user.index);
};
