数据库 - 985ch/egg-sachikawa GitHub Wiki

// config/sequelize.js
exports.sequelize = {
  dialect: 'mysql', // 连接的数据库类型，共支持： mysql, mariadb, postgres, mssql
  database: 'test', // 数据库名
  host: 'localhost', // 服务器地址
  port: 3306, // 服务器端口，默认3306
  username: 'root', // 连接到数据库的账号，实践中应避免将其直接写在配置中
  password: '', // 连接到数据库的密码，实践中应避免将其直接卸载配置中
  // delegate: 'myModel', // 加载对象名，用于生成同名的sequelize实例挂载到Application和Context对象下。可通过ctx[delegate]和app[delegate]访问，其默认值为`model`，即将对象挂载为ctx.model和app.model。
  // baseDir: 'my_model', // 数据模型文件相对于app文件夹的路径，指定目录下的脚本文件将会作为数据模型文件被解析并挂载到对饮的sequelize实例下。其默认值为`model`，即从app/model加载数据模型文件。
  // exclude: 'index.js', // 忽略的文件列表，指定的文件将不会作为数据模型文件被解析。可以是字符串或字符串数组。
  // 可以添加更多的sequelize选项
};

// config/config.{env}.js
  config.sequelize = require('./sequelize');

// config/sequelize.js
exports.sequelize = {
  datasources: [
    {
      delegate: 'model', // 设置对应sequelize实例为app.model和ctx.model
      baseDir: 'model/database1', // 从app/model/database1目录加载数据模型
      database: 'database1',
      // 其他sequelize配置
    },
    {
      delegate: 'admninModel', // 设置对应sequelize实例为app.admninModel和ctx.admninModel
      baseDir: 'model/database2', // 从app/model/database2目录加载数据模型
      database: 'database2',
      // 其他sequelize配置
    },
  ],
};

// config/config.{env}.js
  config.sequelize = require('./sequelize');

// config/plugin.js
  exports.sequelize = {
    enable: false,
    package: 'egg-sequelize',
  },

'use strict';
module.exports = app => {
  const DataTypes = app.Sequelize;
  const model = app.ksbaoDB.define('users', {
    id: { type: DataTypes.INTEGER(11), allowNull: false, primaryKey: true, autoIncrement: true }, // 用户ID
    name: { type: DataTypes.STRING(1024), allowNull: false }, // 用户名
    password: { type: DataTypes.STRING(100), allowNull: false }, // 密码
  }, {
    tableName: 'users',
  });
  return model;
};

// toolkit/gen-models.js
'use strict';

const path = require('path');
const generator = require('egg-sequelize-mg');
const config = require('../config/sequelize'); // 数据库配置脚本

const tables = { // 可以在这里配置每个数据库需要生成的数据模型，没有配置的数据库默认生成所有表的数据模型
  // sample: ['table1', 'table2']
}

const fileHead = `'use strict';

const utils = require('egg-sachikawa').Utils;

module.exports = app => {
  const DataTypes = app.Sequelize;
`;

const fileTail = `
  utils.extendModel(model);
  model.associate = function() {
  };

  return model;
};
`;
// 连接数据库，查询表信息并输出数据模型文件到指定目录
generator.generate(config, tables, path.join(__dirname, '../app/'), async (appRoot, config, tables) => {
  const result = await generator.readMysql(appRoot, config, tables);
  result.config.fileHead = fileHead;
  result.config.fileTail = fileTail;
  return result;
});

  "scripts": {
    "gen-models": "node ./toolkit/gen-models"
  },

  // -------- begin sequelize-mg replace --------
  // -------- end sequelize-mg replace --------

app.model.Users
ctx.model.Users

// 查询users表里所有name=985ch的数据，并返回其id字段
ctx.model.Users.findAll({
  attributes: [ 'id' ],
  where: { name: '985ch' },
  raw: true // 原始查询，实践中很多时候只需要获得查询结果而不需要进行后续操作，因此一般都会加上这条限制以降低数据处理成本
});

// 找到users表里id=1的数据并将其name设为985ch
ctx.model.Users.update({ name: '985ch' }, {
  where: { id: 1 }
});

// 往users添加一条name='985ch'并且password=''的数据
ctx.model.Users.create({ name: '985ch', password: '' });

const defAttr = [ 'id', 'name', 'config' ]; // 默认不查备注数据
// 对config字段执行JSON.parse方法。这样就能让出来的结果直接就是JSON而非字符串了
const remark = [{
  list: [ 'config' ],
  filter: raw => JSON.parse(raw),
}];
Utils.extendModel(Configs, defAttr, remark); // 执行之后，model就可以直接使用如下的simpleFind等方法进行查询了

const rows = await Configs.simpleFind(); // 查询configs表全表，并返回默认属性id,name和config，其中config是JSON对象

const result= await Configs.simpleFindOne({ name: [ 'default' ] }, [ 'id' ]); // 找到一条name='default'的数据并返回一个仅包含其id的JSON对象

const rows = await Configs.findAll({
  attributes: Configs.defaultAttributes,
  limit: 5,
  raw: true,
});
const result = Configs.filterAll(rows);

const rows = await Persons.findAll({
  attributes: [ 'name' ],
  where: PersonBooks.subQuery({
    prefix: 'EXISTS',
    attributes: [ sequelize.literal('1') ],
    where: {
      bookName: [ '高等数学', '线性代数' ],
      personID: { [sequelize.Op.eq]: sequelize.col('persons.id') },
    },
    limit: 1,
  }),
  raw: true,
});