Cayenne 4.1：单运行时配置多数据节点与异构连接信息

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

public class MultiDataNodeConfigByProperties {

    public static void main(String[] args) {
        ServerRuntime runtime = ServerRuntime.builder()
                // 假设你的Cayenne项目名为 'project'
                // node1 和 node2 是你在Modeler中定义的数据节点名称
                .addModule(b -> ServerModule.contributeProperties(b)
                        // 配置第一个数据节点的JDBC URL
                        .put("cayenne.jdbc.url.project.node1", "jdbc:postgresql://localhost:5432/db1")
                        // 配置第一个数据节点的驱动
                        .put("cayenne.jdbc.driver.project.node1", "org.postgresql.Driver")
                        // 配置第一个数据节点的用户
                        .put("cayenne.jdbc.username.project.node1", "user1")
                        // 配置第一个数据节点的密码
                        .put("cayenne.jdbc.password.project.node1", "password123")

                        // 配置第二个数据节点的JDBC URL
                        .put("cayenne.jdbc.url.project.node2", "jdbc:mysql://localhost:3306/db2")
                        // 配置第二个数据节点的驱动
                        .put("cayenne.jdbc.driver.project.node2", "com.mysql.cj.jdbc.Driver")
                        // 配置第二个数据节点的用户
                        .put("cayenne.jdbc.username.project.node2", "user2")
                        // 配置第二个数据节点的密码
                        .put("cayenne.jdbc.password.project.node2", "password456")
                )
                .build();

        // 应用程序逻辑...
        // runtime.newContext().select(new SelectQuery<>(MyEntity.class));

        runtime.shutdown();
    }
}

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

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

public class MyDataSourceFactory implements DataSourceFactory {

    @Inject
    private ObjectFactory objectFactory; // Cayenne DI 注入，用于创建对象

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

        // 示例：根据数据节点名称提供不同的连接信息
        String nodeName = nd.getName();
        String url, driverClass, username, password;

        if ("node1".equals(nodeName)) {
            url = "jdbc:postgresql://localhost:5432/db1";
            driverClass = "org.postgresql.Driver";
            username = "user1";
            password = "password123";
        } else if ("node2".equals(nodeName)) {
            url = "jdbc:mysql://localhost:3306/db2";
            driverClass = "com.mysql.cj.jdbc.Driver";
            username = "user2";
            password = "password456";
        } else {
            // 可以使用Modeler中配置的默认值，或者抛出异常
            url = info.getJdbcUrl();
            driverClass = info.getDriver();
            username = info.getUserName();
            password = info.getPassword();
            // 如果需要，可以从系统属性或环境变量覆盖这些值
        }

        // 创建 JDBC Driver 实例
        Driver driver = (Driver) objectFactory.getJavaClass(driverClass).newInstance();

        // 使用 Cayenne 的 DataSourceBuilder 构建一个带连接池的数据源
        // 这里的参数可以根据DataSourceInfo中的配置或自定义值来设置
        return DataSourceBuilder
                .url(url)
                .driver(driver)
                .userName(username)
                .password(password)
                .pool(1, 5) // 示例：最小连接数1，最大连接数5
                .maxQueueWaitTime(2000) // 示例：连接等待超时2秒
                .validationQuery(nd.getAdapter().getValidationQuery()) // 使用适配器的验证查询
                .build();
    }
}