我正在尝试使用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.0ucp.jar-v12.1.0.0.0
我通过删除对"registerConnectionInitializationCallback"的调用并将其替换为对"registerConnectionLabeling回调"的调用来实现这一点,但据我所知,这将在每次从池中请求连接时(而不是在实际创建连接时)执行ALTER SESSION。
如果能为ConnectionInitializationCallback的工作提供任何帮助,我们将不胜感激。
亲切问候
- oracle.jdbc.replay.OracleDataSourceImpl
- oracle.jdbc.replay.OracleConnectionPoolDataSourceImpl
我自己还没有尝试过,但我猜如果您使用其中一个DataSource实现,那么ConnectionInitializationCallback就会起作用。
如果把它作为标准UCP实现的一部分,就像连接标签一样,那就太好了。