javascript - 如何根据每个客户端动态连接mysql数据库?
问题描述
我在这里使用 MEAN 堆栈构建 SaaS 产品 M = mysql
我正在使用 sequelize 作为 mysql 的 ORM,我的连接:
const sequelize = new Sequelize('smallscale_superapp', 'root', 'root1', {
host: '127.0.0.1',
port: 3306,
dialect: 'mysql',
logging: false,
});
例如,我有一个管理员超级应用程序,所以我创建了一个业务,例如名为“001abcd”的业务代码,该业务代码存储在我的主管理数据库中,然后我告诉我的所有客户转到一个名为“example.com”的特定网址.
因此,如果他们输入 url,主页将看起来像 slack.com 有一个输入框,在硬编码后的值称为 example.com
所以现在我的客户在输入框中输入了我创建的业务代码并存储在我的主数据库中。
将业务代码放入输入框中后,将打开一个名为“001abcd.example.com”的新子域(我正在检查业务代码是否在我的主数据库中匹配,如果匹配我正在创建动态子域)
所以如果一切顺利,在创建子域客户端页面后将显示为登录屏幕,他们需要在其中注册,并且注册详细信息需要动态存在 db
注意:我在创建业务时在我的主数据库表中获取客户端数据库、用户名、主机、密码。
如何使用 sequelize mysql 做到这一点?
如何获得续集连接以根据客户端登录动态连接?
正如我之前所说,我的数据库中有客户端 dbname..etc 我正在尝试创建这样的连接:
exports.dynamicDatabase = (req, res) => {
const { code } = req.params;
Business.find({
where: { code },
raw: true,
})
.then((data) => {
const sequelizeClient = new Sequelize(data.dbname, data.dbusername, data.dbpassword, {
host: data.dbhost,
port: 3306,
dialect: 'mysql',
logging: false,
});
})
.catch((err) => { res.status(400).send(err.message); });
};
现在在我的这个函数之外,我正在尝试同步表,如下所示:
sequelizeClient.authenticate().then((err) => {
if (err) {
console.log('There is connection in ERROR.');
} else {
console.log('Dynamic MYSQL Connection has been established successfully');
}
});
sequelizeClient.sync().then(() => {
console.log('Dynamic Missing Table Created');
}, (err) => {
console.log('An error occurred while creating the table:', err.message);
});
变量sequelizeClient在函数内部,所以我无法访问?全球范围内。
所以我在全局范围内创建变量,但有一个问题
我在函数中有 sequelizeClient 变量,这将在仅在 url 中输入我的域后执行,
但是 sequelizeClient.sync() 不在函数内部,所以当我启动节点 server.js 时,它会抛出错误:
sequelizeClient.authenticate().then((err) => {
[0] ^
[0]
[0] TypeError: Cannot read property 'authenticate' of undefined
解决方案
是的,经过大量搜索,我发现构建 SaaS 产品有三种数据库方法,
- 每个租户的单独数据库
- 为所有租户提供单独的模式(表)和通用的一个数据库
- 所有租户的共享表和一个数据库
最后我决定使用选项 2,我转向 Postgresql 而不是 mysql,因为 Postgresql 有基于模式的方法!
现在我的最终代码:
const postgresDB = new Sequelize('postgres://localhost:5432/test_enduser');
postgresDB.authenticate().then((err) => {
if (err) {
console.log('There is connection in ERROR.');
} else {
console.log('Postgres Connection has been established successfully');
}
});
postgresDB.define('inventory', {
name: Sequelize.STRING,
});
const createSchema = () => {
Business.findAll({
raw: true,
}).then((data) => {
data.forEach((client) => {
postgresDB.createSchema(client.code).then(() => {
Object.keys(postgresDB.models).forEach((currentItem) => {
postgresDB.models[currentItem].schema(client.code).sync();
});
// new schema is created
console.log('Postgres schema created');
}).catch((err) => {
console.log(err.message);
});
});
});
};
createSchema();
// apis
exports.getAllBusiness = (req, res) => {
postgresDB.models.inventory.schema(req.user.code).findAll()
.then((results) => {
res.send(results);
});
};
exports.postBusiness = (req, res) => {
const user = {
name: req.body.name,
};
postgresDB.models.inventory.schema(req.user.code).create(user)
.then(data => res.status(200).send(data))
.catch(Sequelize.ValidationError, err => res.status(422).send(err.errors[0].message))
.catch(err => res.status(400).send(err.message));
};
- 我正在设置我的 postgres 连接
- 只是为了测试我正在创建一个名为“库存”的表
在我的应用程序中,在线来了他注册,而注册时我将业务代码存储到我的业务表中(业务表来自单独的数据库,这是一个超级主应用程序数据库),所以我正在查找业务代码并循环和在 postgres 中制作动态模式
现在看看我的 api,我正在根据 req.user.code(来自登录会话)进行 CRUD,我最终根据特定模式匹配显示数据,
所以最后我为每个客户都有干净的单独模式
谢谢!
推荐阅读
- kubernetes - 如何通过执行来自 master 的命令列出在特定工作节点中运行的所有 pod?
- signalr - 引发 Asp Net Core SignalR 异常:Microsoft.AspNetCore.SignalR.Protocols.Json.dll 中的“System.IO.InvalidDataException”
- html - 有没有办法让对象以悬停为中心但不使用变换?
- pandas - 将不同长度的列表添加到新数据帧
- c++ - 我正在尝试用 C++ 制作菜单,但我不明白为什么它不循环
- list - 如何以与 SQL 类似的方式对 C# 中的数据“测试测试测试测试”列表进行排序
- ios - 日历与设置无关
- r - R:粘贴两个没有空格的字符串
- c - 指针中的 *p=var 和 p = var 有什么区别?
- python - 如何有条件地更改熊猫系列中的值?