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,
});

例如，我有一个管理员 super 应用程序，因此我创建了一项业务，例如名为的业务代码
“001abcd”，这个业务代码存储在我的主管理数据库中，然后我告诉我的所有客户转到一个名为“example.com”的特定网址。

因此，如果他们输入 url，主页将看起来像 slack.com 有一个输入框，并且在硬编码值之后称为 example.com

所以现在我的客户在输入框中输入了我创建的业务代码并存储在我的主数据库中。

将业务代码放入输入框中后，将打开一个名为“001abcd.example.com”的新子域(如果匹配，我正在检查主数据库中的业务代码是否匹配我正在创建动态子域)

所以如果一切顺利，在创建子域客户端页面后将显示为登录屏幕，他们需要在其中注册，并且注册详细信息需要动态存在数据库

注意 :我在创建业务时在我的主数据库表中获取客户端数据库、用户名、主机、密码。

如何使用 sequelize mysql 做到这一点？

如何根据客户端登录获得 Sequelize 连接以动态连接？

正如我之前所说，我的数据库中有客户端 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() 不在函数内部，所以当我启动 node 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 连接

只是为了测试，我正在创建一个名为“inventory”的表

在我的应用程序中，在线来了他注册，在注册时我将业务代码存储到我的业务表(业务表来自单独的数据库，这是一个 super 主应用程序数据库)，所以我正在查找业务代码并在 postgres

中循环并制作动态模式

现在看我的 api，我正在根据 req.user.code(来自登录 session )做 CRUD，我终于根据特定的模式匹配显示数据，

所以最后我为每个客户端都有干净的单独模式 😁

谢谢!

关于javascript - 如何根据每个客户端动态连接mysql数据库？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/50600858/