Sails 0.12版本如何在应用启动后动态创建用户指定的数据库连接

当然可以实现！针对Sails 0.12版本，我给你整理了一套可行的实现方案，核心思路是先阻止默认的自动数据库连接，再通过用户输入动态注册新连接并初始化：

1. 调整默认配置，避免启动时自动连接 #

Sails默认会在启动时加载config/connections.js里的连接并初始化，所以我们先设置一个占位连接，让启动过程不报错也不建立实际连接：

修改config/models.js #

module.exports.models = {
  // 用占位连接替代默认连接，避免自动初始化
  connection: 'placeholder',
  migrate: 'safe' // 禁用自动迁移，防止误操作
};

修改config/connections.js #

添加一个基于磁盘适配器的占位连接，保证Sails启动正常：

module.exports.connections = {
  placeholder: {
    adapter: 'sails-disk'
  }
};

2. 创建用户输入接口，接收连接信息 #

你可以做一个简单的表单页面或者API接口，让用户提交数据库连接字符串和适配器类型（比如sails-mysql、sails-postgresql）。下面是一个示例控制器接口：

创建api/controllers/DynamicDbController.js #

module.exports = {
  setupConnection: function(req, res) {
    // 从请求体获取用户输入的参数
    const { connectionString, adapterName } = req.body;

    // 验证必填参数
    if (!connectionString || !adapterName) {
      return res.badRequest('请提供完整的连接字符串和适配器类型');
    }

    // 根据适配器类型解析连接字符串（以MySQL为例）
    let connectionConfig;
    try {
      if (adapterName === 'sails-mysql') {
        const url = require('url');
        const parsed = url.parse(connectionString);
        connectionConfig = {
          adapter: adapterName,
          host: parsed.hostname,
          port: parsed.port || 3306,
          user: parsed.auth.split(':')[0],
          password: parsed.auth.split(':')[1],
          database: parsed.pathname.slice(1)
        };
      } else if (adapterName === 'sails-postgresql') {
        // PostgreSQL连接字符串解析逻辑，可使用pg库的内置方法或自行处理
        const { Client } = require('pg');
        const client = new Client(connectionString);
        connectionConfig = client.connectionParameters;
        connectionConfig.adapter = adapterName;
      } else {
        return res.badRequest('不支持的适配器类型');
      }
    } catch (err) {
      return res.badRequest('连接字符串格式错误：' + err.message);
    }

    // 生成唯一的连接名称
    const newConnectionName = `dynamic_${Date.now()}`;
    // 将新连接添加到Sails配置
    sails.config.connections[newConnectionName] = connectionConfig;

    // 动态创建Waterline模型并关联新连接
    const DynamicModel = Waterline.Collection.extend({
      identity: 'dynamicDbModel',
      connection: newConnectionName,
      // 这里可以根据需求定义属性，或者留空自动映射现有表
      attributes: {}
    });

    // 初始化模型并绑定适配器
    sails.models.dynamicDbModel = new DynamicModel();
    sails.models.dynamicDbModel._adapter = sails.adapters[adapterName];

    // 测试连接是否成功
    sails.models.dynamicDbModel.query('SELECT 1', function(err) {
      if (err) {
        return res.serverError(`数据库连接失败：${err.message}`);
      }
      res.ok({
        message: '数据库连接成功！',
        connectionName: newConnectionName,
        tip: '后续操作可通过sails.models.dynamicDbModel访问该数据库'
      });
    });
  }
};

3. 关键注意事项 #

• 适配器依赖：确保已经安装对应的数据库适配器，比如npm install sails-mysql --save或npm install sails-postgresql --save
• 连接字符串解析：不同数据库的连接字符串格式不同，需要针对性处理解析逻辑
• 模型复用：如果需要操作多个表，可以动态创建多个模型，或者基于新连接重新加载现有模型
• 安全性：要对用户输入的连接字符串做校验和过滤，避免注入风险；同时不要存储敏感的连接信息在前端或日志中
• 持久化：如果需要重启后保留连接配置，可以将连接信息存储到本地文件或默认数据库中，启动时自动加载

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