Cayenne 4.1：单一运行时中配置多个数据节点的高级指南

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

public class MultiDataNodeConfig {

    public static void main(String[] args) {
        ServerRuntime runtime = ServerRuntime.builder()
                .addModule(b -> ServerModule.contributeProperties(b)
                        // 配置 project 项目下 node1 数据节点的 JDBC URL
                        .put("cayenne.jdbc.url.project.node1", "jdbc:mysql://localhost:3306/db1?useSSL=false")
                        // 配置 project 项目下 node1 数据节点的驱动类
                        .put("cayenne.jdbc.driver.project.node1", "com.mysql.cj.jdbc.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:postgresql://localhost:5432/db2")
                        // 配置 project 项目下 node2 数据节点的驱动类
                        .put("cayenne.jdbc.driver.project.node2", "org.postgresql.Driver")
                        // 配置 project 项目下 node2 数据节点的用户名
                        .put("cayenne.jdbc.username.project.node2", "user2")
                        // 配置 project 项目下 node2 数据节点的密码
                        .put("cayenne.jdbc.password.project.node2", "secure_pass")
                )
                .build();

        // 此时，runtime 实例已包含配置好的两个数据节点
        // 可以通过 DataContext 获取并使用它们
        // DataContext dataContext = runtime.newDataContext();
        // ...
        runtime.shutdown();
    }
}

import org.apache.cayenne.configuration.server.DataSourceFactory;
import org.apache.cayenne.configuration.server.ServerRuntime;
import org.apache.cayenne.di.Inject;
import org.apache.cayenne.map.DataNodeDescriptor;
import org.apache.cayenne.map.DataSourceInfo;
import org.apache.cayenne.util.Util;
import org.apache.cayenne.di.Injector; // 可能需要，取决于如何获取对象工厂

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

// 假设我们使用一个简单的连接池构建器
// 实际生产环境可能使用 HikariCP, c3p0, Druid等
class DataSourceBuilder {
    private String url;
    private Driver driver;
    private String userName;
    private String password;
    private int minConnections = 1;
    private int maxConnections = 10;
    private long maxQueueWaitTime = 30000; // 30 seconds
    private String validationQuery;

    public static DataSourceBuilder url(String url) {
        DataSourceBuilder builder = new DataSourceBuilder();
        builder.url = url;
        return builder;
    }

    public DataSourceBuilder driver(Driver driver) {
        this.driver = driver;
        return this;
    }

    public DataSourceBuilder userName(String userName) {
        this.userName = userName;
        return this;
    }

    public DataSourceBuilder password(String password) {
        this.password = password;
        return this;
    }

    public DataSourceBuilder pool(int min, int max) {
        this.minConnections = min;
        this.maxConnections = max;
        return this;
    }

    public DataSourceBuilder maxQueueWaitTime(long time) {
        this.maxQueueWaitTime = time;
        return this;
    }

    public DataSourceBuilder validationQuery(String query) {
        this.validationQuery = query;
        return this;
    }

    public DataSource build() {
        // 这是一个简化的示例，实际中会使用成熟的连接池库
        // 例如 HikariCP, c3p0, Druid等
        org.apache.commons.dbcp2.BasicDataSource basicDataSource = new org.apache.commons.dbcp2.BasicDataSource();
        basicDataSource.setUrl(url);
        basicDataSource.setDriver(driver);
        basicDataSource.setUsername(userName);
        basicDataSource.setPassword(password);
        basicDataSource.setMinIdle(minConnections);
        basicDataSource.setMaxTotal(maxConnections);
        basicDataSource.setValidationQuery(validationQuery);
        // 其他连接池配置...
        return basicDataSource;
    }
}


public class MyDataSourceFactory implements DataSourceFactory {

    @Inject
    private Injector injector; // 用于获取其他DI对象，如ObjectFactory

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

        // 可以使用 DataSourceInfo 中的配置，也可以根据 DataNodeDescriptor 的名称或其他属性进行自定义
        // 例如，根据 nd.getName() 来决定连接到哪个数据库
        String url = info.getDataSourceUrl();
        String driverClass = info.getJdbcDriver();
        String username = info.getUserName();
        String password = info.getPassword();

        // 假设我们想为特定的数据节点覆盖一些配置
        if ("specialNode".equals(nd.getName())) {
            url = "jdbc:special:db";
            username = "specialUser";
            password = "specialPassword";
        }

        // 动态加载驱动
        Driver driver = (Driver) Class.forName(driverClass).newInstance();

        // 使用连接池构建器创建 DataSource
        return DataSourceBuilder
            .url(url)
            .driver(driver)
            .userName(username)
            .password(password)
            .pool(info.getMinConnections(), info.getMaxConnections()) // 从Modeler配置中获取连接池参数
            .maxQueueWaitTime(info.getMaxQueueWaitTime())
            .validationQuery(info.getValidationQuery())
            .build();
    }
}