Node.js后端开发系列之sequelize零基础快速入门实战

时间  2020-01-23
标签 node.js node 后端 开发 系列 sequelize 零基础 快速 入门 实战 栏目 Node.js 繁體版
原文   原文链接

🎇🎇🎇新年快乐🎇🎇🎇

2020 鼠你最帅， 鼠你最强， 鼠你最棒， 鼠你最红， 鼠你最美， 鼠年吉祥node

问与答

❓:你能学到什么？
🙋:sequelize-cli的使用以及sequelize的基础操做。mysql

❓:为何要使用sequelize-cli?
🙋:就像你使用Git/SVN来管理源代码的更改同样,你可使用迁移来跟踪数据库的更改。git

❓:为何不将数据模型设计好再演示？
🙋:本文讲的是使用sequelize-cli和sequelize开发的过程。github

❓:怎么会有这么多的代码？
🙋:每一步的代码我都贴了出来，只要按照流程作就能快速的完成一个示例。眼见为实，我相信这样学习的效果更好。sql

❓:怎么没有事务、做用域、数据类型等知识点？
🙋:这篇是入门教程，不过学会了这篇，事务、做用域理解起来更容易。数据库

❓:为何没有源代码？
🙋:作一遍必定比看一遍的效果好。npm

准备工做

一、初始化项目json

cd 工程目录 
 npm init -y
复制代码

二、安装模块bash

npm i koa koa-body koa-router mysql2 sequelize sequelize-cli -S
复制代码

三、添加server.js文件app

const Koa = require('koa');
 const router = require('koa-router')();
 const koaBody = require('koa-body');
 const app = new Koa();
 app.use(koaBody());

 app.use(router.routes())
    .use(router.allowedMethods('*'));

 app.listen(3000, () => {
     console.log('server is listening on 3000...')
 });
复制代码

快速入门

一、新建.sequelizerc文件

const path = require('path');
 module.exports = {
   'config': path.resolve('config', 'config.json'), //数据库链接配置文件
   'models-path': path.resolve('db', 'models'),     //模型文件
   'seeders-path': path.resolve('db', 'seeders'),   //种子文件
   'migrations-path': path.resolve('db', 'migrations') //迁移文件
 }
复制代码

二、初始化

npx sequelize-cli init
复制代码

三、编辑./db/config.js

"development": {
    "username": "username",
    "password": "password",
    "database": "school", //数据库名称
    "host": "127.0.0.1",
    "dialect": "mysql",
    "timezone": "+08:00" //设置时区为'东八区'
  }
复制代码

四、建立数据库

npx sequelize-cli db:create
复制代码

五、生成student模型文件以及迁移文件

npx sequelize-cli model:generate --name student --attributes student_name:string,student_age:integer,student_sex:boolean
复制代码

六、编辑./db/migrations/xxxxx-create-student.js

'use strict';
 module.exports = {
   up: (queryInterface, Sequelize) => {
     return queryInterface.createTable('student', {
       id: {
         allowNull: false,
         autoIncrement: true,
         primaryKey: true,
         type: Sequelize.INTEGER
       },
       student_name: {
         type: Sequelize.STRING(10),
         allowNull:false 
       },
       student_age: {
         type: Sequelize.INTEGER,
         allowNull:false
       },
       student_sex: {
         type: Sequelize.BOOLEAN,
         allowNull:false
       }
     });
   },
   down: (queryInterface, Sequelize) => {
     return queryInterface.dropTable('student');
   }
};
复制代码

打开xxxxx-create-student.你会发现createTable方法的第一个参数为students,这是因为sequelize会默认将表名称转换为复数形式，这里我将其修改成student，后面全部表名或模型名称都会使用单数形式。

七、生成名称为student的数据表

npx sequelize-cli db:migrate
复制代码

八、生成student表种子文件

npx sequelize-cli seed:generate --name init-student
复制代码

九、编辑./db/seeders/xxxxx-init-student.js文件

'use strict';

 module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.bulkInsert('student', [{
      student_name: '孙悟空',
      student_age: 20,
      student_sex: 1
    },{
      student_name: '白骨精',
      student_age: 18,
      student_sex: 0
    },{
      student_name: '猪八戒',
      student_age: 16,
      student_sex: 1
    }])
  },

  down: (queryInterface, Sequelize) => {
    return queryInterface.bulkDelete('student', null, {});
  }
};
复制代码

十、student表初始化数据

npx sequelize-cli db:seed:all
复制代码

十一、编辑.db/models/student.js

'use strict';
module.exports = (sequelize, DataTypes) => {
  const student = sequelize.define('student', {
    student_name: DataTypes.STRING,
    student_age: DataTypes.INTEGER,
    student_sex: DataTypes.BOOLEAN,
    class_id:DataTypes.INTEGER
  }, {
    timestamps: false,//不自动添加时间字段(updatedAt,createdAt)
    freezeTableName: true,// 使用模型名称的单数形式
    underscored: true //列名添加下划线
  });
  student.associate = function(models) {};
  return student;
};
复制代码

十二、编辑server.js文件

.....
 const Student  = require('./db/models').student;
 //添加学生信息
 router.post('/student', async ctx => {
     ctx.body = await Student.create(ctx.request.body);
 });
 //更新学生信息
 router.put('/student', async ctx => {
    const { id } = ctx.request.body;
    ctx.body = await Student.update(ctx.request.body, { where: { id } });
 });
 //获取学生列表
 router.get('/students', async ctx => {
    ctx.body = await Student.findAll();
 });
 //根据id删除学生信息
 router.delete('/student/:id', async ctx => {
    const { id } = ctx.params;
    ctx.body = await Student.destroy({ where: { id } });
});
.....
复制代码

1三、启动服务并使用Postman测试

node server.js
复制代码

模型关连

hasMany(一对多)

一个班级里面能够有多个学生，班级与学生的关系就是一对多。为了完成这个例子咱们会作如下几件事情:

  1. 建立名称为_class的班级表
  2. _class班级表初始化数据
  3. student表添加列名为class_id的列
  4. 从新初始化student表数据
  5. 查询某个班级全部学生

让咱们开始吧！

一、生成**_class**模型以及迁移文件

npx sequelize-cli model:generate --name _class --attributes class_name:string
复制代码

二、修改./db/migrations/xxxxx-create-class.js

'use strict';
 module.exports = {
   up: (queryInterface, Sequelize) => {
     return queryInterface.createTable('_class', {
       id: {
         allowNull: false,
         autoIncrement: true,
          primaryKey: true,
         type: Sequelize.INTEGER
       },
       class_name: {
         type: Sequelize.STRING(10),
          allowNull:false
       }
     });
   },
   down: (queryInterface, Sequelize) => {
     return queryInterface.dropTable('_class');
   }
 };
复制代码

三、生成**_class**表

npx sequelize-cli db:migrate
复制代码

四、生成**_class**表种子文件

npx sequelize-cli seed:generate --name init-class
复制代码

五、编辑./db/seeders/xxxxx-init-class.js

'use strict';
module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.bulkInsert('_class', [{
      class_name: '一班'
    }, {
      class_name: '二班'
    }, {
      class_name: '三班'
    }]);
  },

  down: (queryInterface, Sequelize) => {
    return queryInterface.bulkDelete('_class', null, {});
  }
};
复制代码

六、_class表初始化数据

npx sequelize-cli db:seed  --seed  xxxxx-init-class.js
复制代码

七、生成修改studnet表的迁移文件

npx sequelize-cli migration:generate  --name add-column-class_id-to-student.js
复制代码

八、编辑./db/migrations/xxxxx-add-column-class_id-to-student.js

'use strict';

module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.addColumn('student', 'class_id', {
      type: Sequelize.INTEGER,
      allowNull:false
    })
  },

  down: (queryInterface, Sequelize) => {
     queryInterface.removeColumn('student', 'class_id', {});
  }
};
复制代码

九、修改student表

npx sequelize-cli db:migrate
复制代码

十、从新生成student表种子文件

npx sequelize-cli seed:generate --name init-student-after-add-column-class_id
复制代码

十一、编辑./db/seeders/xxxxx-init-student-after-add-column-class_id.js文件

'use strict';

 module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.bulkInsert('student', [{
      student_name: '孙悟空',
      student_age: 20,
      student_sex: 1,
      class_id: 1
    }, {
      student_name: '白骨精',
      student_age: 18,
      student_sex: 0,
      class_id: 1
    }, {
      student_name: '猪八戒',
      student_age: 16,
      student_sex: 1,
      class_id: 2
    }, {
      student_name: '唐僧',
      student_age: 22,
      student_sex: 1,
      class_id: 1
    }, {
      student_name: '沙和尚',
      student_age: 25,
      student_sex: 1,
      class_id: 1
    }, {
      student_name: '红孩儿',
      student_age: 13,
      student_sex: 1,
      class_id: 2
    }, {
      student_name: '黑熊怪',
      student_age: 26,
      student_sex: 1,
      class_id: 2
    }, {
      student_name: '太白金星',
      student_age: 66,
      student_sex: 1,
      class_id: 3
    }, {
      student_name: '嫦娥',
      student_age: 18,
      student_sex: 0,
      class_id: 3
    }])
  },

  down: (queryInterface, Sequelize) => {
    return queryInterface.bulkDelete('student', null, {});
  }
};
复制代码

十二、撤销student表中已有的数据

npx sequelize-cli db:seed:undo --seed xxxxx-init-student.js
复制代码

1三、stuent表从新初始化数据

npx sequelize-cli db:seed --seed  xxxxx-init-student-after-add-column-class_id.js
复制代码

1四、编辑./db/models/_class.js文件

'use strict';
module.exports = (sequelize, DataTypes) => {
  const _class = sequelize.define('_class', {
    class_name: DataTypes.STRING
  }, {
    timestamps: false,
    freezeTableName: true,
    underscored: true
  });
  _class.associate = function (models) {
    _class.hasMany(models.student);
  };
  return _class;
};
复制代码

1五、编辑server.js

...
const Class = require('./db/models')._class;

//获取班级信息以及班级里的全部学生
router.get('/classes', async ctx => {
    //获取全部班级以及学生信息
     ctx.body = await Class.findAll({ include: [Student] });
});
...
复制代码

belongsTo（一对一）

一个学生只能属于一个班级，因此学生和班级的关系是一对一。

一、修改./db/models/student.js文件

...
  student.associate = function(models) {
    student.belongsTo(models._class); //一对一
  };
 ...
复制代码

二、修改server.js中获取学生列表的接口

...
//获取学生列表
router.get('/students', async ctx => {
    ctx.body = await Student.findAll({ include: [Class] });
});
...
复制代码

belongsTo VS hasOne

student.belongsTo(models._class)这里student叫作源模型，_class叫作目标模型。

student表中包含了_class表的外键class_id,也就是说外键在源模型上面因此咱们使用belongsTo来建立关联。

hasOne和belongsTo都是用来建立一对一关联的,正确使用它们的方法就是看外键在哪一个模型中。

  • belongsTo关联外键在源模型上
  • hasOne关联外键在目标模型上

belongsToMany(多对多)

一个班级能够有多名代课老师,一名代课老师能够带多个班级的课程。班级与老师的关系是多对多 为了完成此功能的演示，咱们将作如下工做:

  1. 建立名称

让咱们开始吧！

一、生成teacher模型以及迁移文件

npx sequelize-cli model:generate --name teacher --attributes teacher_name:string
复制代码

二、修改./db/migrations/xxxxx-teacher-class.js

'use strict';
module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.createTable('teacher', {
      id: {
        allowNull: false,
        autoIncrement: true,
        primaryKey: true,
        type: Sequelize.INTEGER
      },
      teacher_name: {
        type: Sequelize.STRING(10),
        allowNull: false
      }
    });
  },
  down: (queryInterface, Sequelize) => {
    return queryInterface.dropTable('teacher');
  }
};
复制代码

三、生成teacher表

npx sequelize-cli db:migrate
复制代码

四、生成teacher表种子文件

npx sequelize-cli seed:generate --name init-teacher
复制代码

五、编辑./db/seeders/xxxxx-init-teacher.js

'use strict';
module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.bulkInsert('teacher', [{
      teacher_name: '李老师'
    }, {
      teacher_name: '张老师'
    }]);
  },

  down: (queryInterface, Sequelize) => {
    return queryInterface.bulkDelete('teacher', null, {});
  }
};
复制代码

六、teacher表初始化数据

npx sequelize-cli db:seed  --seed  xxxxx-init-teacher.js
复制代码

七、生成teacher_class模型以及迁移文件

npx sequelize-cli model:generate --name teacher_class --attributes teacher_id:integer,class_id:integer
复制代码

八、编辑./db/migrations/xxxxx-create-teacher-class.js

'use strict';
module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.createTable('teacher_class', {
      id: {
        allowNull: false,
        autoIncrement: true,
        primaryKey: true,
        type: Sequelize.INTEGER
      },
      teacher_id: {
        type: Sequelize.INTEGER,
        allowNull: false,
      },
      class_id: {
        type: Sequelize.INTEGER,
        allowNull: false,
      }
    });
  },
  down: (queryInterface, Sequelize) => {
    return queryInterface.dropTable('teacher_class');
  }
};
复制代码

九、生成teacher_class表

npx sequelize-cli db:migrate
复制代码

十、生成teacher_class表种子文件

npx sequelize-cli seed:generate --name init-teacher_class
复制代码

十一、编辑./db/seeders/xxxxx-init-teacher_class.js

'use strict';

/* 李老师带的班级为一班和二班。张老师带的班级为三班 */
module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.bulkInsert('teacher_class', [{
      class_id: 1,
      teacher_id: 1
    }, {
      class_id: 2,
      teacher_id: 1
    }, {
      class_id: 3,
      teacher_id: 2
    }]);
  },

  down: (queryInterface, Sequelize) => {
    return queryInterface.bulkDelete('teacher_class', null, {});
  }
};
复制代码

十二、teacher_class表初始化数据

npx sequelize-cli db:seed  --seed  xxxxx-init-teacher_class.js
复制代码

1三、编辑./db/models/teacher.js

'use strict';
module.exports = (sequelize, DataTypes) => {
  const teacher = sequelize.define('teacher', {
    teacher_name: DataTypes.STRING
  }, {
    timestamps: false,
    freezeTableName: true,
    underscored: true
  });
  teacher.associate = function (models) {
    teacher.belongsToMany(models._class, {
      through: models.teacher_class,
      foreignKey: 'teacher_id',
    });
  };
  return teacher;
};
复制代码

1四、编辑./db/models/_class.js

'use strict';
module.exports = (sequelize, DataTypes) => {
  const _class = sequelize.define('_class', {
    class_name: DataTypes.STRING
  }, {
    timestamps: false,
    freezeTableName: true,
    underscored: true
  });
  _class.associate = function (models) {
    _class.hasMany(models.student);
    _class.belongsToMany(models.teacher, {
      through: models.teacher_class,
      foreignKey: 'class_id',
    });
  };
  return _class;
};
复制代码

1五、编辑server.js

const Teacher = require('./db/models').teacher;

//获取老师信息以及老师所带的班级
router.get('/teachers', async ctx => {
    //获取全部班级以及学生信息
     ctx.body = await Teacher.findAll({ include: [Class] });
})
复制代码

查询

基础查询

一、返回指定列

Student.findAll({
    attributes: ['id', 'student_name']
 });
 // select id,student_name from student
复制代码

二、单条件查询

Student.findAll({
    where: {
      id: 1
    }
 })
 // select * from student where id = 1
复制代码

三、AND

//返回id为1，姓名是`孙悟空`的学生信息
 Student.findAll({
        where: {
            id: 4,
            student_name:'孙悟空'
        }
    })
 // select * from student where id = 1 and student_name = '孙悟空'
复制代码

四、OR

//返回年龄等于12或者22的学生信息
 Student.findAll({
     where: {
            student_age: {
                [Op.or]: [12, 22]
            }
        }
 })
 // select * from student where studnet_age = 12 or studnet_age = 22
复制代码

五、条件查询- >,>=,<,<=,=

// 返回年龄大于等于20的学生
 Student.findAll({
     where: {
            student_age: {
                [Op.gte]: 20
            }
        }
 })
 // select * from student where studnet_age >= 20
复制代码
[Op.gt]: 6      //大于6
 [Op.gte]: 6     //大于等于6
 [Op.lt]: 10     //小于10
 [Op.lte]: 10    //小于等于10
 [Op.ne]: 20     //不等于20
 [Op.eq]: 3      //等于3
复制代码

六、IN

// 返回年龄是16和18的学生信息
 Student.findAll({
     where: {
        student_age: {
            [Op.in]: [16,18]
        }
    }
 })
 // select * from student where studnet_age in (16,18)
复制代码

七、LIKE

// 返回名称包含'孙'的学生信息
 Student.findAll({
     where: {
        student_name: {
           [Op.like]: '%孙%',
        }
    }
 })
 // select * from student where studnet_name like '%孙%'
复制代码

聚合函数

一、获取学生的平均年龄

Student.findAll({
    attributes: [[sequelize.fn('AVG', sequelize.col('student_age')), 'avg']]
 })
复制代码

二、获取学生总数

Student.findAll({
     attributes: [[sequelize.fn('COUNT', sequelize.col('id')), 'count']]
 })
复制代码

嵌套查询

一、获取一班全部的学生并根据年龄降序排列

Class.findAll({
    include: [{model: Student}],
    where:{id:1},
    order:[[Student,'student_age', 'DESC']]
    });
复制代码

参考

sequelize中文文档

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程