Sequelize:使用多个数据库

IT技术 javascript mysql node.js sequelize.js
2021-02-21 18:37:53

如果我想使用两个数据库,是否需要创建多个 Sequelize 实例?即同一台机器上的两个数据库。

如果没有,这样做的正确方法是什么?对我来说,必须连接两次才能使用两个数据库似乎有点矫枉过正。

例如,对于不同的功能,我有不同的数据库,例如,假设我在一个数据库中有客户数据,而在另一个数据库中有统计数据。

所以在 MySQL 中:

MySQL [customers]> show databases;
+--------------------+
| Database           |
+--------------------+
| customers          |
| stats              |
+--------------------+

我有这个与续集联系起来

// Create a connection....
var Sequelize = require('sequelize');
var sequelize = new Sequelize('customers', 'my_user', 'some_password', {
    host: 'localhost',
    dialect: 'mysql',

    pool: {
        max: 5,
        min: 0,
        idle: 10000
    },
    logging: function(output) {
        if (opts.log_queries) {
            log.it("sequelize_log",{log: output});
        }
    }

});

// Authenticate it.
sequelize.authenticate().nodeify(function(err) {

    // Do stuff....

});

我试图在使用点符号的模型定义中“欺骗”它

var InterestingStatistics = sequelize.define('stats.interesting_statistics', { /* ... */ });

但这会创建 table customers.stats.interesting_statistics我需要使用统计数据库中的现有表。

实现这一目标的正确方法是什么?谢谢。

3个回答

您需要为要创建的每个数据库连接创建不同的 sequelize 实例:

const Sequelize = require('Sequelize');
const userDb = new Sequelize(/* ... */);
const contentDb = new Sequelize(/* ... */);

从 sequelize 创建的每个实例都有自己的数据库信息(db host, url, user, pass, etc...),并且这些值不打算更改,因此没有“正确”的方法来创建多个连接与一个续集的实例。

从他们的文档

Sequelize 将在初始化时设置一个连接池,因此理想情况下您应该只为每个数据库创建一个实例。

每个数据库一个实例

执行此操作的“常见”方法是将您的数据库放在一个config.json文件中并循环遍历它以动态创建连接,可能是这样的:

配置文件

{
    /*...*/
    databases: {
        user: {
            path: 'xxxxxxxx'
        },
        content: {
            path: 'xxxxxxxx'
        }
    }
}

你的应用

const Sequelize = require('sequelize');
const config = require('./config.json');

// Loop through
const db = {};
const databases = Object.keys(config.databases);
for(let i = 0; i < databases.length; ++i) {
    let database = databases[i];
    let dbPath = config.databases[database];
    db[database] = new Sequelize( dbPath );
}

// Or a one liner
const db = Object.entries(config).reduce((r, db) => (r[db[0]] = db[1].path) && r, {});

// Sequelize instances:
// db.user
// db.content

您需要做更多的编码才能启动并运行它,但这是一个总体思路。

@dougBTV 你能分享片段来表示它们之间的关系吗?
2021-04-22 18:37:53
这是可扩展的吗?如果我要处理 100 多个数据库,这会导致任何问题吗?1000 ? 10 000 ?
2021-05-01 18:37:53
我在多个数据库访问上有类似的问题。在我的应用程序中,有一个 db 连接池,它处理具有相同架构的多个数据库上的所有 db 连接。所以,我还没有找到完美的解决方案。
2021-05-03 18:37:53
很好的答案,谢谢。已确认,完美运行。我已经创建了多个实例,然后在创建我的模型时引用了这些实例,它很有魅力。感谢健全性检查,以确保我没有以黑客风格的方式做这件事。
2021-05-06 18:37:53
@尼古拉斯B。好吧,一个数组最多可以存储 2^32 个元素,所以我们可以假设你永远不会遇到关于可扩展性的问题
2021-05-17 18:37:53

如果您尝试跨多个数据库关联同一 RDS 中的对象,则可以使用schema.

http://docs.sequelizejs.com/class/lib/model.js~Model.html#static-method-schema

这会将数据库名称添加到表名称之前,因此,大概,您的查询将如下所示: SELECT A.ColA, B.ColB FROM SchemaA.ATable A INNER JOIN SchemaB.BTable B ON B.BId = A.BId

是的..只要为每个数据库加载模型,我就可以使用点符号进入不同的数据库和模式
2021-04-25 18:37:53
这很有趣,因为 PG 使用的模式与 MSSQL 有所不同。我目前正在研究多数据库 MSSQL,我想我会看看模式点表示法是否可以应用于数据库。
2021-04-27 18:37:53

为什么不使用原始查询?有了这个,您可以连接到一个数据库并查询另一个。请参阅下面的示例代码。

const sequelize = require('db_config');
function test(req, res){
  const qry = `SELECT * FROM db1.affiliates_order co
LEFT JOIN db2.affiliates m ON m.id = co.campaign_id`;
  sequelize.query(qry, null, {  raw: true}).then(result=>{
    console.log(result);
  })
}
@alfasin 这个答案包括 dbs,语法是 DB.Table,其中 DB 是你的数据库名称。
2021-04-28 18:37:53
我们可以在 Postgres 中放置查询以从两个数据库中获取数据吗?
2021-05-12 18:37:53
OP 询问查询不同的数据库而不是不同的表!
2021-05-13 18:37:53
db 没有这样的语法:这schema.table不是db.table
2021-05-17 18:37:53