应用程序在执行 pds.getConnection() 时挂起

问题描述 投票:0回答:2

我正在使用 Oracle 11g XE 和 Java 8。我正在开发一个桌面应用程序,想要进行连接池。应用程序在执行时挂起

pds.getConnection();
我尝试使用简单的 JDBC,效果很好,所以这不是网络/数据库问题。

这是我调用的代码:

/**
 * This returns DB connection from the DB Connection Pool
 * 
 * @return
 * @throws IOException
 * @throws SQLException
 */
public static Connection getConnection() throws IOException, SQLException {
    if (pds == null) {
        initConnectionPool();
    }
    Connection conn = pds.getConnection();
    System.out.println("Available connections after checkout: " + pds.getAvailableConnectionsCount());
    System.out.println("Borrowed connections after checkout: " + pds.getBorrowedConnectionsCount());
    return conn;
}


/**
 * init DB Connection Pool
 * 
 * @return
 * @throws IOException
 * @throws SQLException
 */
private static void initConnectionPool() throws IOException, SQLException {
    Properties configProperties = Utils.getConfig();

    // Get the PoolDataSource for UCP
    PoolDataSource pds = PoolDataSourceFactory.getPoolDataSource();

    // Set the connection factory first before all other properties
    System.out.println("Class name :" + configProperties.getProperty("CONNECTION_FACTORY_CLASS_NAME"));
    pds.setConnectionFactoryClassName(configProperties.getProperty("CONNECTION_FACTORY_CLASS_NAME"));

    System.out.println("DB URL ==" + configProperties.getProperty("DB_URL"));
    pds.setURL(configProperties.getProperty("DB_URL"));

    System.out.println("DB User ==" + configProperties.getProperty("DB_USER"));
    pds.setUser(configProperties.getProperty("DB_USER"));

    System.out.println("Password==" + configProperties.getProperty("DB_PSWD"));
    pds.setPassword(configProperties.getProperty("DB_PSWD"));

    pds.setConnectionPoolName("JDBC_UCP_POOL");

    // Default is 0. Set the initial number of connections to be created
    // when UCP is started.
    pds.setInitialPoolSize(Integer.parseInt(configProperties.getProperty("INITIAL_POOL_SIZE")));

    // Default is 0. Set the minimum number of connections
    // that is maintained by UCP at runtime.
    pds.setMinPoolSize(Integer.parseInt(configProperties.getProperty("MIN_POOL_SIZE")));

    // Default is Integer.MAX_VALUE (2147483647). Set the maximum number of
    // connections allowed on the connection pool.
    pds.setMaxPoolSize(Integer.parseInt(configProperties.getProperty("MAX_POOL_SIZE")));
}



/**
 * Loads the config file and return instance of Properties
 * 
 * @return Proterties
 * @throws IOException
 */

public static Properties getConfig() throws IOException {

    if (configProps != null)
        return configProps;
    configProps = new Properties();
    FileInputStream in;
    in = new FileInputStream("bin/resources/config.properties");
    configProps.load(in);
    in.close();
    return configProps;
}

使用的属性有:

 DB_URL=jdbc:oracle:thin:@//localhost:1521/XE

 INITIAL_POOL_SIZE=5

 MIN_POOL_SIZE=5

 MAX_POOL_SIZE=10

 CONNECTION_FACTORY_CLASS_NAME=oracle.jdbc.pool.OracleDataSource
java jdbc oracle11g connection-pooling ojdbc
2个回答
0
投票

我发现了错误。在initialize()中我声明了一个局部变量pds。我删除了它并让类变量初始化,代码开始工作。我很惊讶为什么在这种情况下我没有得到 NullPointerException.. 这可以节省很多时间。


0
投票

您没有初始化

pds
类变量。当您拨打
getConnection()
时,它始终是
null

为了确保一旦可以使用静态初始化块就调用初始化池的方法。

static {
  initConnectionPool();
}
© www.soinside.com 2019 - 2024. All rights reserved.