Cayenne 4.1：单一运行时管理多个异构数据源

import org.apache.cayenne.configuration.server.ServerModule;
import org.apache.cayenne.configuration.server.ServerRuntime;

public class MultiDataNodeConfig {

    public static ServerRuntime createRuntime() {
        return ServerRuntime.builder()
                .addModule(b -> ServerModule.contributeProperties(b)
                        // 配置 project.node1 的 JDBC URL
                        .put("cayenne.jdbc.url.project.node1", "jdbc:postgresql://localhost:5432/database1")
                        // 配置 project.node1 的驱动类
                        .put("cayenne.jdbc.driver.project.node1", "org.postgresql.Driver")
                        // 配置 project.node1 的用户名
                        .put("cayenne.jdbc.username.project.node1", "user1")
                        // 配置 project.node1 的密码
                        .put("cayenne.jdbc.password.project.node1", "password123")

                        // 配置 project.node2 的 JDBC URL
                        .put("cayenne.jdbc.url.project.node2", "jdbc:mysql://localhost:3306/database2")
                        // 配置 project.node2 的驱动类
                        .put("cayenne.jdbc.driver.project.node2", "com.mysql.cj.jdbc.Driver")
                        // 配置 project.node2 的用户名
                        .put("cayenne.jdbc.username.project.node2", "user2")
                        // 配置 project.node2 的密码
                        .put("cayenne.jdbc.password.project.node2", "password456")

                        // 可以继续添加其他如连接池大小等属性
                        // .put("cayenne.jdbc.min_connections.project.node1", "5")
                        // .put("cayenne.jdbc.max_connections.project.node1", "20")
                )
                .build();
    }

    public static void main(String[] args) {
        ServerRuntime runtime = createRuntime();
        try {
            System.out.println("Cayenne ServerRuntime with multiple data nodes initialized successfully.");
            // 在这里可以执行数据库操作
            // ObjectContext context1 = runtime.newContext("node1"); // 根据DataNode名称获取上下文
            // ObjectContext context2 = runtime.newContext("node2");
        } finally {
            runtime.shutdown();
        }
    }
}

import org.apache.cayenne.configuration.server.DataSourceFactory;
import org.apache.cayenne.configuration.server.ServerRuntime;
import org.apache.cayenne.dba.DataSourceBuilder;
import org.apache.cayenne.di.Inject;
import org.apache.cayenne.di.ObjectFactory;
import org.apache.cayenne.map.DataNodeDescriptor;
import org.apache.cayenne.map.DataSourceInfo;

import javax.sql.DataSource;
import java.sql.Driver;

public class MyCustomDataSourceFactory implements DataSourceFactory {

    // Cayenne 会自动注入 ObjectFactory
    @Inject
    private ObjectFactory objectFactory;

    @Override
    public DataSource getDataSource(DataNodeDescriptor nd) throws Exception {
        DataSourceInfo info = nd.getDataSourceDescriptor();

        // 从 DataNodeDescriptor 获取基本配置信息
        // 可以根据 DataNodeDescriptor 的名称或其他属性来区分不同的数据源
        String nodeName = nd.getName();
        String url;
        String driverClass;
        String username;
        String password;

        if ("node1".equals(nodeName)) {
            url = "jdbc:postgresql://customhost1:5432/db_custom1";
            driverClass = "org.postgresql.Driver";
            username = "custom_user1";
            password = "custom_password1";
            // 可以在这里加载 node1 特有的配置
        } else if ("node2".equals(nodeName)) {
            url = "jdbc:mysql://customhost2:3306/db_custom2";
            driverClass = "com.mysql.cj.jdbc.Driver";
            username = "custom_user2";
            password = "custom_password2";
            // 可以在这里加载 node2 特有的配置
        } else {
            // 默认或从 info 中获取配置
            url = info.getDataSourceUrl();
            driverClass = info.getJdbcDriver();
            username = info.getUserName();
            password = info.getPassword();
        }

        // 可以根据需要从外部配置源（如Spring配置文件、JNDI、环境变量等）获取这些值
        // 例如：
        // String externalUrl = System.getenv("DB_URL_" + nodeName.toUpperCase());
        // if (externalUrl != null) { url = externalUrl; }

        // 使用 Cayenne 的 DataSourceBuilder 构建 DataSource
        // 注意：Driver 实例需要通过反射或DI容器获取
        Driver driver = (Driver)objectFactory.getJavaClass(driverClass).newInstance();

        return DataSourceBuilder
            .url(url)
            .driver(driver)
            .userName(username)
            .password(password)
            .pool(5, 20) // 设置连接池大小
            .maxQueueWaitTime(5000) // 最大等待时间
            .validationQuery("SELECT 1") // 连接验证查询
            .build();
    }
}