0

我有以下代码：

 public Object RunQuery(String query) throws Exception{
    System.out.println("Trying to run query");
    Statement stmt = null;
    ResultSet rs = null;
    try {
        stmt = conn.createStatement();
        System.out.println("Got Statement");
        rs = stmt.executeQuery(query);
        System.out.println("Query executed");
        ...


    } catch (SQLException ex) {
        // handle any errors
        System.out.println("SQLException: " + ex.getMessage());
        System.out.println("SQLState: " + ex.getSQLState());
        System.out.println("VendorError: " + ex.getErrorCode());
    }
    catch (Exception ex) {
        System.out.println("Exception: " + ex.getMessage());
    }
    finally {
       if (rs != null) {
            try {
                rs.close();
            } catch (SQLException sqlEx) {
            } // ignore
            rs = null;
        }
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException sqlEx) {
            } // ignore
            stmt = null;
        }
       return ret;
    }
}

运行时效果很好

query = "SELECT * FROM smalltable"

但是失败了

query = "SELECT * FROM bigtable"

其中有大约 20 万条记录。调试器优雅地忽略了 catch 块，直接进入 finally 块；当我将 stmt.executeQuery(query) 添加到监视列表时，NetBeans 给了我这个堆栈帧：

>Exception occurred in target VM: Communications link failure  Last packet sent to the server was 0 ms ago.  
com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure  Last packet sent to the server was 0 ms ago.

at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)

at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)

at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)

at java.lang.reflect.Constructor.newInstance(Constructor.java:513)

at com.mysql.jdbc.Util.handleNewInstance(Util.java:406)

at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1074)

at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3009)

at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:2895)

at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3438)

at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:1951)

at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2101)

at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2548)

at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2477)

at com.mysql.jdbc.StatementImpl.executeQuery(StatementImpl.java:1422)

at RunQuery
Caused by: java.net.SocketException: Software caused connection abort: recv failed

at java.net.SocketInputStream.socketRead0(Native Method)

at java.net.SocketInputStream.read(SocketInputStream.java:129)

at com.mysql.jdbc.util.ReadAheadInputStream.readFromUnderlyingStreamIfNecessary(ReadAheadInputStream.java:157)

at com.mysql.jdbc.util.ReadAheadInputStream.read(ReadAheadInputStream.java:188)

at com.mysql.jdbc.MysqlIO.readFully(MysqlIO.java:2452)

at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:2962)

... 9 more




如何在这个框架中进行大型查询？



编辑：我正在使用 J 连接器和 mysql 服务器 5.1；连接字符串是

jdbc:mysql://localhost?user=root&password=password

是的，我知道 select * 是一种不好的做法，但是正如您所见，我才刚刚开始，这或多或少是我正在做的第二次测试

4

3 回答 3

1

我的直接想法是获取所有数据可能存在内存问题。我不知道如何为此目的设置 MySQL，但您可能想尝试在 ResultSet 中设置获取大小或通过选择更少的列来限制 ResultSet 大小。JDBC 驱动程序可能试图在一次操作中获取整个表。

作为旁注，请永远不要执行 stmt.executeQuery(query)。始终使用 PreparedStatement 并绑定您的查询参数。在您的示例中，没有参数，但这是一种对安全目的至关重要的做法。切勿将 SQL 与“文字”参数一起使用（例外情况是当您的文字是受信任的字符串时，例如代码中的常量或非字符串类型，例如您已经解析的数字）。

于 2009-01-21T14:31:28.050 回答
1

我能想到的唯一会导致差异的是某种网络级超时，Netbeans 输出肯定会指向这个方向。您使用的 JDBC 连接字符串是什么；也许有一个可以提高的超时参数？

如果问题仍然存在，则可能值得插入网络数据包嗅探器并查看该级别的通信情况。通过短查询和长查询来“找出差异”，您可能会很好地了解是什么导致一个失败而另一个成功。

（通常select *是一个坏主意，因为它不必要地带回了所有额外的数据。在这种情况下，与从较小的表中选择相比，从大表中的所有行中选择所有列显然会给连接带来麻烦。我知道在这种情况下您的问题仍然有效，因为有时您可能需要这样做，并且除了选择更大表的子集可能会做同样的事情，但我只是指出这一点作为一般准则以防万一您在生产中使用它作为快捷方式。）

于 2009-01-21T12:53:10.323 回答
0

如果它直接跳到finally，那么在其他代码中抛出的“异常”实际上是Error的后代吗？那将完全避免你的捕获。

你可能得到了 OutOfMemoryError，然后因为 OOME 关闭了一些东西而得到了网络异常？

于 2009-01-28T01:46:37.830 回答