sequelize迁移服务器连接两个数据库

bpsygsoo 于 2021-06-23 发布在 Mysql

关注(0)|答案(1)|浏览(401)

我已经创建了一个sequalize迁移服务器，并通过引用这个文档使用sequelize cli连接了一个mysql数据库。现在我想知道，是否可以使用同一个迁移服务器在另一个mysql数据库上运行迁移，或者是否需要创建另一个迁移服务器在另一个数据库上运行迁移。提前谢谢。
配置.js

{
  "development": {
    "username": "root",
    "password": null,
    "database": "xxxx",
    "host": "127.0.0.1",
    "dialect": "mysql"
  },
  "test": {
    "username": "root",
    "password": null,
    "database": "yyy",
    "host": "127.0.0.1",
    "dialect": "mysql"
  },
  "production": {
    "username": "root",
    "password": null,
    "database": "zzz",
    "host": "127.0.0.1",
    "dialect": "mysql"
  }
}

模型/索引.js

'use strict';

var fs        = require('fs');
var path      = require('path');
var Sequelize = require('sequelize');
var basename  = path.basename(__filename);
var env       = process.env.NODE_ENV || 'development';
var config    = require(__dirname + '/..\config\config.json')[env];
var db        = {};

if (config.use_env_variable) {
  var sequelize = new Sequelize(process.env[config.use_env_variable], config);
} else {
  var sequelize = new Sequelize(config.database, config.username, config.password, config);
}

fs
  .readdirSync(__dirname)
  .filter(file => {
    return (file.indexOf('.') !== 0) && (file !== basename) && (file.slice(-3) === '.js');
  })
  .forEach(file => {
    var model = sequelize['import'](path.join(__dirname, file));
    db[model.name] = model;
  });

Object.keys(db).forEach(modelName => {
  if (db[modelName].associate) {
    db[modelName].associate(db);
  }
});

db.sequelize = sequelize;
db.Sequelize = Sequelize;

module.exports = db;

迁移/创建用户.js

module.exports = {
  up: (queryInterface, Sequelize) => {
    return queryInterface.createTable('Users', {
      id: {
        allowNull: false,
        autoIncrement: true,
        primaryKey: true,
        type: Sequelize.INTEGER
      },
      firstName: {
        type: Sequelize.STRING
      },
      lastName: {
        type: Sequelize.STRING
      },
      email: {
        type: Sequelize.STRING
      }
    });
  },
  down: (queryInterface, Sequelize) => {
    return queryInterface.dropTable('Users');
  }
};

mysql node.js sequelize.js sequelize-cli

来源：https://stackoverflow.com/questions/51718676/sequelize-migration-server-connect-with-two-databases

1条答案

按热度按时间

a0zr77ik1#

使用此命令更改config.js文件。

const DB_DETAILS = {
    "development" : {
        "pg_db_host" : "127.0.0.1",
        "pg_db_name" : "zzz",
        "pg_db_username" : "root",
        "pg_db_passoword" : "", 
        "pg_db_dialect" : "mysql",
        "db_host" : "127.0.0.1",
        "db_name" : "xxx",
        "db_username" : "root",
        "db_passoword" : "", 
        "db_dialect" : "mysql",
        "multipleStatements": true                      
    },
    "local" : {
        "pg_db_host" : "localhost",
        "pg_db_name" : "collaboration",
        "pg_db_username" : "postgres",
        "pg_db_passoword" : "postgres", 
        "pg_db_dialect" : "postgres",
        "db_host" : "localhost",
        "db_name" : "colloboration",
        "db_username" : "colloboration",
        "db_passoword" : "s6K2q2W509gx",
        "db_dialect" : "postgres",
        "multipleStatements": true                      
    },
    "production" : {
        "pg_db_host" : "localhost",
        "pg_db_name" : "collaboration",
        "pg_db_username" : "postgres",
        "pg_db_passoword" : "postgres", 
        "pg_db_dialect" : "postgres",
        "db_host" : "localhost",
        "db_name" : "colloboration",
        "db_username" : "colloboration",
        "db_passoword" : "s6K2q2W509gx",
        "db_dialect" : "postgres",
        "multipleStatements": true
    }
}

const env_db = DB_DETAILS[process.env.NODE_ENV];

const sequelize = new Sequelize(env_db.pg_db_name, env_db.pg_db_username, env_db.pg_db_passoword, {
      host: env_db.pg_db_host,
      dialect: env_db.pg_db_dialect,
      pool: {
        max: 5,
        min: 0,
        idle: 10000
      }
});

const sequelize1 = new Sequelize(env_db.db_name, env_db.db_username, env_db.db_passoword, {
    host: env_db.db_host,
    dialect: env_db.db_dialect,
    pool: {
      max: 5,
      min: 0,
      idle: 10000
    }
});

sequelize.authenticate().then(() => {
    console.log('Connection has been established successfully.');
})
.catch(err => {
    console.error('Unable to connect to the database:', err);
});

sequelize1.authenticate().then(() => {
    console.log('Connection has been established successfully.');
})
.catch(err => {
    console.error('Unable to connect to the database:', err);
});

module.exports = { Sequelize , sequelize };

module.exports = { Sequelize1 , sequelize1 };

还将var db={}替换为global.db=require（'./config.js'）；//在index.js文件中配置文件路径。
不，您可以相应地使用db.sequelize和db.sequelize1

赞(0）回复(0）举报 2021-06-23

我来回答

sequelize迁移服务器连接两个数据库

1条答案

相关问题

热门标签

最新问答