如何根据每个客户端动态连接mysql数据库?

kpbwa7wx  于 2021-06-23  发布在  Mysql
关注(0)|答案(2)|浏览(375)

我正在使用mean stack here m=mysql构建一个saas产品
我使用sequelize作为mysql的orm,我的连接:

const sequelize = new Sequelize('smallscale_superapp', 'root', 'root1', {
  host: '127.0.0.1',
  port: 3306,
  dialect: 'mysql',
  logging: false,
});

例如,我有一个管理超级应用程序,所以我创建了一个业务,例如业务代码“001d”,这个业务代码存储在我的主管理数据库中,然后我告诉我的所有客户转到一个特定的url,名为“example.com”。
因此,如果他们输入url,主页将看起来像slack.com有一个输入框和一个硬编码后的值称为example.com
所以现在我的客户机在输入框中输入了我创建的业务代码并存储在我的主数据库中。
将业务代码放入输入框后,将打开一个名为“001d.example.com”的新子域(如果匹配,我将在主数据库中检查业务代码是否匹配,如果匹配,我将创建动态子域)
因此,如果一切顺利,创建子域后,客户端页面将显示为登录屏幕,其中他们需要注册和注册的详细信息需要在那里动态
注意:在创建业务时,我在我的主db表中获取客户机db、用户名、主机、密码。
如何使用sequelizemysql实现这一点?
如何使sequelize连接基于客户端登录动态连接?
正如我之前所说,在我的数据库中有client 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
bnlyeluc

bnlyeluc1#

是的,经过大量搜索,我发现构建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”的表
在我的应用程序中,一个在线的人来注册,注册的时候我把业务代码存储到我的业务表中(业务表来自单独的数据库,这是一个超级主应用程序数据库),所以我在postgres中查找业务代码和循环并生成动态模式
现在看一下我的api,我正在基于req.user.code(来自登录会话)执行crud,最后根据特定的模式匹配显示数据,
最后,我为每个客户机提供了干净的独立模式?
谢谢!

htzpubme

htzpubme2#

最后,我尝试了这个方法,使它工作,但我不知道这是好办法或不是,所以告诉我,这是否是好办法?
我通过用户请求参数获取准确数据:

let sequelizeClient;
let Login;
exports.getDomain = (req, res) => {
  const { code } = req.params;
  Business.find({
    raw: true,
    where: { code },
  }).then((data) => {
    if (data === null) {
      res.status(400).send(data);
    } else {
      sequelizeClient = new Sequelize(data.dbname, data.dbusername, data.dbpassword, {
        host: data.dbhost,
        port: 3306,
        dialect: 'mysql',
        logging: false,
      });

      // end user connections
      sequelizeClient.authenticate().then((err) => {
        if (err) {
          console.log('There is connection in ERROR.');
        } else {
          console.log(`${data.code} MYSQL Connection has been established successfully`);
        }
      });

      sequelizeClient.sync().then(() => {
        console.log(`${data.code} Missing Table Created`);
      }, (err) => {
        console.log('An error occurred while creating the table:', err.message);
      });

      // mysql tables;
      Login = sequelizeClient.define('login', {
        username: Sequelize.STRING,
        firstName: Sequelize.STRING,
        lastName: Sequelize.STRING,
      });
    }
  });
};

我将表模式变量声明为全局变量,并在代码中使用:

// api
exports.signUp = (req, res) => {
  const user = {
    username: req.body.username,
    firstName: req.body.firstName,
    lastName: req.body.lastName,

  };
  Login.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));
};

相关问题