我正在尝试使用 ConnectionInitializationCallback 配置 UCP PoolDataSourceImpl。这是我的配置:
private static DataSource createDataSource(Properties properties) throws SQLException, UniversalConnectionPoolException {
UniversalConnectionPoolManager ucpm = UniversalConnectionPoolManagerImpl.getUniversalConnectionPoolManager();
PoolDataSource pds = PoolDataSourceFactory.getPoolDataSource();
final String editionName = properties.getProperty("jdbc.editionName", "ora$base");
pds.registerConnectionInitializationCallback(new oracle.ucp.jdbc.ConnectionInitializationCallback() {
public void initialize(Connection connection) throws SQLException {
LOG.debug("Attempting to set edition to: {}", editionName);
try (Statement statement = connection.createStatement()) {
statement.executeUpdate("ALTER SESSION SET EDITION = " + editionName);
}
LOG.debug("Edition set to: {}", editionName);
}
});
pds.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
pds.setUser(properties.getProperty("jdbc.username"));
pds.setPassword(properties.getProperty("jdbc.password"));
pds.setURL(properties.getProperty("jdbc.url"));
pds.setConnectionPoolName("demo-pool");
pds.setInitialPoolSize(3);
pds.setMaxPoolSize(3);
pds.setValidateConnectionOnBorrow(true);
LOG.debug("Created DataSource Pool");
ucpm.createConnectionPool((UniversalConnectionPoolAdapter)pds);
ucpm.startConnectionPool("demo-pool");
return pds;
}
然而,initialize 方法永远不会被调用。我将 java 1.7.0_51 与以下 Oracle jar 一起使用:
ojdbc6.jar - v12.1.0.1.0 ucp.jar - v12.1.0.0.0
我已经设法通过删除对“registerConnectionInitializationCallback”的调用并将其替换为对“registerConnectionLabelingCallback”的调用来完成这项工作,但据我了解,这将在每次从池中请求连接时执行 ALTER SESSION,而不是在实际请求连接时创建的。
任何有关使 ConnectionInitializationCallback 工作的帮助将不胜感激。
亲切的问候