0

我用 Java 编写了一个运行 MySQL 查询并返回结果的函数。我在这里使用这种方法实现了连接池：http ://www.kodejava.org/how-do-i-create-a-database-connection-pool/ 。该功能正在运行，但连接时间仍然与没有池的情况相同约 190 毫秒。有人可以告诉我我做错了什么吗？

这是我的代码：

public static ArrayList<Map<String,Object>> query(String q) throws Exception {

    long start, end;

    GenericObjectPool connectionPool = null;

    String DRIVER = "com.mysql.jdbc.Driver"; 
    String URL = "jdbc:mysql://localhost/dbname";
    String USER = "root";
    String PASS = "";

    Class.forName(DRIVER).newInstance();

    connectionPool = new GenericObjectPool();
    connectionPool.setMaxActive(10);

    ConnectionFactory cf = new DriverManagerConnectionFactory(URL, USER, PASS);

    PoolableConnectionFactory pcf = new PoolableConnectionFactory(cf, connectionPool, null, null, false, true);

    DataSource ds = new PoolingDataSource(connectionPool);

    //create statement
    Statement Stm = null;

    try {

        Connection Con = null;
        PreparedStatement stmt = null;

        start = System.currentTimeMillis();

        Con = ds.getConnection();

        end = System.currentTimeMillis();
        System.out.println("DB Connection: " + Long.toString(end - start) + " ms");

        //fetch out rows
        ArrayList<Map<String, Object>> Rows = new ArrayList<Map<String,Object>>();

        Stm = Con.createStatement();

        //query
        ResultSet Result = null;

        boolean Returning_Rows = Stm.execute(q);

        if (Returning_Rows) {
            Result = Stm.getResultSet();
        } else {
            return new ArrayList<Map<String,Object>>();
        }

        //get metadata
        ResultSetMetaData Meta = null;
        Meta = Result.getMetaData();

        //get column names
        int Col_Count = Meta.getColumnCount();
        ArrayList<String> Cols = new ArrayList<String>();
        for (int Index=1; Index<=Col_Count; Index++) {
            Cols.add(Meta.getColumnName(Index));
        }

        while (Result.next()) {
            HashMap<String,Object> Row = new HashMap<String,Object>();
            for (String Col_Name:Cols) {
                Object Val = Result.getObject(Col_Name);
                Row.put(Col_Name,Val);
            }
            Rows.add(Row);
        }

        //close statement
        Stm.close();


        //pass back rows
        return Rows;

    } catch (Exception Ex) {

        System.out.print(Ex.getMessage());
        return new ArrayList<Map<String,Object>>();

    } finally {

        if (Stm != null) {
            Stm.close();
        }
        if (Stm != null) {
            Stm.close();
        }

        System.out.println("Max connections: " + connectionPool.getMaxActive());
        System.out.println("Active connections: " + connectionPool.getNumActive());
        System.out.println("Idle connections: " + connectionPool.getNumIdle());

    }

}

每次都是控制台输出：

DB Connection: 186 ms
Max connections: 10 
Active connections: 1 
Idle connections: 0

更新：我应该注意，使用它的 Java 应用程序是这样工作的：执行，只运行一个查询并关闭。我想如果 PHP 是这样工作的，并且默认情况下它使用连接池，那么 Java 也应该如此吗？如我错了请纠正我。

4

4 回答 4

2

你创建了一个连接池，但你没有往里面放任何东西。您的连接池在创建时是空的，因此您对它的第一个请求保证会创建一个新连接，并且与手动获取连接一样慢。

尝试将您的代码放入一个循环中，在其中您反复从池中获取连接。尝试一次、五次、十次和十五次。注意结果如何变化。

一些连接池支持自动创建和保存最小数量的连接以供使用，以及最大数量。初始化池时，它将预取连接，因此前几个调用不会延迟。

于 2013-08-07T12:59:34.623 回答
0

您的用例不保证连接池。它只是您需要的一种连接。您正在使用的池类GenericObjectPool有一个方法addObject();。这将创建对象并将其添加到池中。这将避免以后创建连接。

于 2013-08-07T13:15:23.397 回答
0

您不会看到对数据库的单个请求有什么不同。您必须使用多个（并发）请求对此进行测试。

顺便说一句：您遵守 Java 命名约定并以小写字母开头所有对象。

于 2013-08-07T13:01:24.163 回答
0

您可以通过调用预加载池connectionPool.addObject()。一开始它是空的，只有在您发布查询后才会创建连接。

于 2013-08-07T13:14:03.720 回答