java - 每个查询的 java c3po 语句

Question

我是 JDBC 的初学者，在我的研究中，我发现了 C3PO 的最佳评论，因为我已经尝试过 BoneCP，但发现它并没有关闭连接。

我需要一个连接池，也可能是一个语句池，用于多线程软实时软件（交易系统）

这是“选择”的一个例子：

1. 好吗？
2. 我是否需要 getConn() 然后为每个查询创建语句并关闭两者？

3. 任何一般性意见或建议？

           Connection conn = null;
   ResultSet rs = null;
   Statement st = null;
   String query = null;
   try {
   
       query = " SELECT id " +
                 " FROM " + DBTables.PandaSources;
   
       //rs = DB.ConnPool.invoke(conn, query, rs);
       st = DB.ConnPool.getSt();
       rs = st.executeQuery(query);
   
       if (rs != null) {
           while (rs.next()) {
               .....
                                   ......
           }
       }
   } 
   catch (Exception e) { 
       e.printStackTrace(); 
       Util.logException(e);
   }
   finally {
       if (rs != null) try { rs.close(); } catch (SQLException e) { e.printStackTrace(); Util.logException(e); }
       if (st != null) try { st.close(); } catch (SQLException e) { e.printStackTrace(); Util.logException(e); }
       if (conn != null) try { conn.close(); } catch (SQLException e) { e.printStackTrace(); Util.logException(e); }
   }
   
   query = null;
   st = null;
   rs = null;
   conn = null;
   }
   
     public static synchronized Statement getSt() throws SQLException {
   return getConn().createStatement();
     }
   
    public static synchronized Connection getConn() throws SQLException {
      if (connectionPoolDatasource == null) {
         initPool();
      }
      return connectionPoolDatasource.getConnection();
   

   }

    public static synchronized void initPool() throws SQLException {
   
   DBLocation loc = null;
   try {
   
       loc = GTMain.DBConn.get(Util.DB_GURUSTRADE);
   
       // C3PO
       connectionPoolDatasource = new ComboPooledDataSource();
       connectionPoolDatasource.setDriverClass(loc.driver);
       connectionPoolDatasource.setJdbcUrl(loc.url);
       connectionPoolDatasource.setUser(loc.user);
       connectionPoolDatasource.setPassword(loc.password);
   
       // properties
       connectionPoolDatasource.setAcquireIncrement(5);
       connectionPoolDatasource.setMaxIdleTime(3600);
       connectionPoolDatasource.setMaxIdleTimeExcessConnections(300);
       connectionPoolDatasource.setMaxPoolSize(100);
       connectionPoolDatasource.setMinPoolSize(20);
       connectionPoolDatasource.setNumHelperThreads(6);
       connectionPoolDatasource.setUnreturnedConnectionTimeout(3600);
   
   }
   catch (Exception e) {
       e.printStackTrace(); 
   }
   

   }