Spring Boot+MongoDB如何根据产品选择在运行时切换数据库？

这问题我之前在多租户API场景里碰过，刚好能给你一套落地的方案！核心逻辑就是通过用户访问的域名，动态匹配对应的数据库实例，完全适配你共用同一个App Engine API的需求，下面拆解具体实现步骤：

本质上是利用请求的Host头信息，把域名和数据库做一一映射，在请求处理前完成数据库连接的切换，确保每个域名的请求都对应到正确的数据库。

2.1 提取请求域名 #

不管你用Python/Java/Go等哪种语言开发App Engine API，都能从请求对象里拿到访问域名：

• Python（Flask/Flask-RESTful）：request.host（记得去掉端口号，比如request.host.split(':')[0]）
• Java（Spring Boot/Servlet）：request.getServerName()
• Go：r.Host（r是*http.Request对象）

2.2 建立域名-数据库映射表 #

把你的域名和对应的数据库信息（连接字符串/实例ID）做成一个配置映射，推荐放在环境变量里（App Engine支持通过app.yaml配置环境变量），方便后续修改不用改代码：
比如Python里的配置示例：

# 可以从环境变量加载，更灵活
DOMAIN_TO_DB = {
    "product1.com": "cloudsql-project:region:Productdb1",
    "product2.com": "cloudsql-project:region:Productdb2",
    "product3.com": "cloudsql-project:region:Productdb3"
}

2.3 请求预处理时切换数据库 #

在每个请求处理前，通过钩子/拦截器完成数据库连接的切换：

Python Flask 示例（用before_request钩子） #

from flask import Flask, request, abort
import sqlalchemy

app = Flask(__name__)
DOMAIN_TO_DB = {
    "product1.com": "mysql+pymysql://user:password@/Productdb1?unix_socket=/cloudsql/project:region:Productdb1",
    "product2.com": "mysql+pymysql://user:password@/Productdb2?unix_socket=/cloudsql/project:region:Productdb2",
    "product3.com": "mysql+pymysql://user:password@/Productdb3?unix_socket=/cloudsql/project:region:Productdb3"
}

# 全局数据库连接引擎（复用连接池）
db_engine = None

@app.before_request
def setup_db():
    global db_engine
    current_domain = request.host.split(':')[0].lower()  # 统一转小写避免大小写问题
    db_url = DOMAIN_TO_DB.get(current_domain)
    
    if not db_url:
        # 处理未知域名，返回404或默认逻辑
        abort(404, description="Invalid domain")
    
    # 如果引擎不存在或者对应数据库变更，重新创建引擎（复用连接池）
    if not db_engine or db_engine.url != db_url:
        db_engine = sqlalchemy.create_engine(db_url)

# 后续接口直接使用db_engine操作对应数据库
@app.route('/api/data')
def get_data():
    with db_engine.connect() as conn:
        result = conn.execute(sqlalchemy.text("SELECT * FROM some_table"))
        return {"data": [dict(row) for row in result]}

Java Spring Boot 示例（用拦截器切换多数据源） #

如果用Spring Boot，可以配置多数据源，然后通过拦截器根据域名切换：

1. 配置多数据源：

spring:
  datasource:
    product1:
      url: jdbc:mysql:///Productdb1?cloudSqlInstance=project:region:Productdb1&socketFactory=com.google.cloud.sql.mysql.SocketFactory
      username: user
      password: password
    product2:
      url: jdbc:mysql:///Productdb2?cloudSqlInstance=project:region:Productdb2&socketFactory=com.google.cloud.sql.mysql.SocketFactory
      username: user
      password: password
    product3:
      url: jdbc:mysql:///Productdb3?cloudSqlInstance=project:region:Productdb3&socketFactory=com.google.cloud.sql.mysql.SocketFactory
      username: user
      password: password

2. 实现动态数据源切换：

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDataSourceKey();
    }
}

public class DataSourceContextHolder {
    private static final ThreadLocal<String> CONTEXT_HOLDER = new ThreadLocal<>();
    public static void setDataSourceKey(String key) { CONTEXT_HOLDER.set(key); }
    public static String getDataSourceKey() { return CONTEXT_HOLDER.get(); }
    public static void clearDataSourceKey() { CONTEXT_HOLDER.remove(); }
}

3. 拦截器处理域名匹配：

public class DomainDataSourceInterceptor implements HandlerInterceptor {
    private final Map<String, String> domainToDbMap;

    public DomainDataSourceInterceptor(Map<String, String> domainToDbMap) {
        this.domainToDbMap = domainToDbMap;
    }

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        String domain = request.getServerName().toLowerCase();
        String dbKey = domainToDbMap.get(domain);
        if (dbKey == null) {
            response.sendError(HttpServletResponse.SC_NOT_FOUND, "Invalid domain");
            return false;
        }
        DataSourceContextHolder.setDataSourceKey(dbKey);
        return true;
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        DataSourceContextHolder.clearDataSourceKey();
    }
}

• 权限配置：确保App Engine服务账号拥有对应Cloud SQL实例的Cloud SQL Client角色，否则无法连接数据库
• 连接复用：一定要用连接池（比如SQLAlchemy的连接池、HikariCP），避免每次请求新建连接导致性能问题
• 本地测试：可以修改本地hosts文件，把product1.com等域名指向127.0.0.1，模拟线上请求场景

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