提问者:小点点

UCP PoolDataSourceImpl与Connection初始化回调


我正在尝试使用ConnectionFirst alizationCallback配置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;
}

然而,从未调用过初始化方法。我将java1.7.0_51与以下Oracle jar一起使用:

ojdbc6.jar-v12.1.0.1.0 ucp. jar-v12.1.0.0.0

我已经设法使这项工作通过删除调用"checksterConnectionFirst alizationCallback"并将其替换为调用"regsterConnectionLabelingCallback",但从我的理解,这将执行ALTER SESSION每次从池请求连接,而不是当它实际创建时。

如果您能提供帮助,让ConnectionCentalizationCallback工作,我们将不胜感激。

亲切问候


共1个答案

匿名用户

ConnectionFirst alizationCallback机制似乎是12c发布的“应用程序连续性”功能的一部分。应用程序连续性要求您使用以下DataSource实现之一:

  • oracle. jd bc.replay.Oracle数据源I mpl
  • oracle. jd bc.replay.Oracle连接池数据源I mpl

我自己还没有尝试过,但我猜如果您使用这些DataSource实现之一,您的ConnectionFirst alizationCallback将起作用。

如果这是标准UCP实现的一部分,就像连接标签一样,那就太好了。