如何基于Sails.js动态切换查询数据库？datastore.driver使用疑问

核心思路：动态注册数据存储 #

无需在config.datastores.js中预先配置空的datastore，而是在需要查询时动态注册带实时连接参数的datastore，直接获取其driver进行原生查询。

实现步骤 #

1. 封装动态注册工具

在Sails的服务（services/目录）中封装工具函数，用于生成带动态参数的datastore：

// services/DynamicDbService.js
module.exports = {
  getMysqlDriver: async (connParams) => {
    // 生成唯一名称，避免重复注册冲突
    const dsName = `mysql_dynamic_${Date.now()}_${Math.random().toString(36).slice(2, 8)}`;
    
    try {
      // 注册新的datastore
      await sails.registerDatastore({
        name: dsName,
        adapter: 'sails-mysql',
        ...connParams // 传入动态连接参数：host、user、password、database等
      });

      // 获取注册后的datastore实例，返回其driver和名称
      const datastore = sails.getDataStore(dsName);
      return { driver: datastore.driver, dsName };
    } catch (err) {
      sails.log.error('动态注册数据库失败:', err);
      throw err;
    }
  }
};

2. 调用工具执行动态查询

在控制器或业务逻辑中，传入实时连接参数，获取driver后执行原生查询：

// 示例：控制器中使用
async function queryMysql(req, res) {
  try {
    // 从请求或其他渠道获取动态连接参数
    const connParams = {
      host: req.body.dbHost,
      user: req.body.dbUser,
      password: req.body.dbPassword,
      database: req.body.dbName
    };

    // 获取动态driver和datastore名称
    const { driver, dsName } = await sails.services.dynamicdbservice.getMysqlDriver(connParams);

    // 执行原生SQL查询
    const results = await new Promise((resolve, reject) => {
      driver.query('SELECT * FROM target_table', (err, data) => {
        if (err) reject(err);
        else resolve(data);
      });
    });

    // 可选：查询完成后注销datastore，释放资源
    await sails.unregisterDatastore(dsName);

    return res.ok(results);
  } catch (err) {
    return res.serverError(err.message);
  }
}

3. 关键注意事项

• 确保传入的connParams包含数据库适配器要求的所有必填字段（如sails-mysql需host、user、password、database）
• 使用唯一的datastore名称，避免重复注册导致的冲突
• 对于频繁创建的动态datastore，建议在查询完成后注销，避免资源占用
• 异常处理要覆盖注册、查询、注销全流程，防止未捕获错误影响服务

内容的提问来源于stack exchange，提问作者SM1312