UCP PoolDataSourceImpl with ConnectionInitializationCallback



我正在尝试使用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的工作提供任何帮助,我们将不胜感激。

亲切问候

ConnectionInitializationCallback机制似乎是12c发布的"应用程序连续性"功能的一部分。应用程序连续性要求您使用以下DataSource实现之一:
  • oracle.jdbc.replay.OracleDataSourceImpl
  • oracle.jdbc.replay.OracleConnectionPoolDataSourceImpl

我自己还没有尝试过,但我猜如果您使用其中一个DataSource实现,那么ConnectionInitializationCallback就会起作用。

如果把它作为标准UCP实现的一部分,就像连接标签一样,那就太好了。

相关内容

  • 没有找到相关文章