0

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

亲切的问候

4

1 回答 1

0

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

  • oracle.jdbc.replay.OracleDataSourceImpl
  • oracle.jdbc.replay.OracleConnectionPoolDataSourceImpl

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

如果将其作为标准 UCP 实现的一部分包括在内,那就太好了,就像连接标签一样。

于 2015-04-07T13:19:15.847 回答