使用 ResultSet 的 JDBC 超时我做得对吗？答案

【问题标题】：JDBC timeout with ResultSet am I doing it right?使用 ResultSet 的 JDBC 超时我做得对吗？
【发布时间】：2015-02-05 08:18:15
【问题描述】：

我有一个 JDBC ResultSet，它在只处理了几千行后给了我一个 TimeOut。我有几百万行要处理，所以我想调整我的程序以避免这种情况，只是不确定需要调整什么。

数据库表被索引并使用选择标准快速返回数据，所以我不相信它在数据库端。我返回了地址列和整数之间混合的 14 列。数据不多。

我正在执行 connection.createStatement()，然后从那里构建 SQL。答案可能是我应该使用准备好的语句。

        Statement stmt = null;
    ResultSet rs = null;
    try {
        stmt = conn.createStatement();
        String jobNameFilter = (Cli.getJobName() != null) ? " AND [JobName] = '" + Cli.getJobName() + "'" : "";
        String sortOrder = (Cli.isAscending()) ? "ASC" : "DESC";
        String orderByClause = Cli.isRandom() ? " ORDER BY [Randomizer] " + sortOrder + ",[RecordID] " + sortOrder : " ORDER BY [RecordID] " + sortOrder;
        String startingIdFilter = (Cli.getStartingId() != null) ? " AND [RecordId] > " + Cli.getStartingId() : "";
        String driverQuery = "SELECT [RecordID], [Column1] AS [TrackingID], [Address]" + ", [Suite] AS [AptSuiteOther], [City], [Building2Key]"
                + ", [ST] AS [State], [ZIPCode]" + ", [BusinessName], [ContactLastName], [Suite]" + ", [Phone], [EmailAddress]"
                + " FROM [Project].[TestSet] WITH (READUNCOMMITTED)"
                + " INNER JOIN [Project].[State] sttable ON sttable.[ST] = UPPER([Project].[TestSet].[ST]) AND [TerritoryFlag] = 0" + " WHERE [BuildingKey] = 0 " + jobNameFilter
                + startingIdFilter + " AND (([FirstResponse] IS NULL AND ([Building2Key] IS NULL OR [Building2Key] = 0)) OR ([Building2Key] > 0 AND [SecondResponse] IS NULL)) " + orderByClause;
        rs = stmt.executeQuery(driverQuery);
    } catch (SQLException e1) {
        logger.error("SQLException", e1);
    }

        try {
        while (rs.next()) {

            int recordId = rs.getInt("RecordID");
            // Process data
            numberProcessed++;

        }
    } catch (SQLException sqle) {
        logger.error("SQLException", sqle);
    }

我也在不同级别的 finally 语句中关闭所有 ResultSet、Connection 和 Statement。

我不确定是否需要将超时设置为更高的值，是否需要将 setFetchSize 设置为更大的值？陷阱超时并重新创建ResultSet？

将逻辑更改为一次只拉一行？

【问题讨论】：

标签： java sql-server jdbc

【解决方案1】：

您必须分析您的应用才能确定，但我猜“// 处理数据”部分是罪魁祸首。您在处理所有行时保持连接打开。

我建议您一次读取一批行，关闭语句，然后处理该批。然后选择下一批，冲洗并重复。

一次选择一行会带来很多开销，所以我不建议这样做。

另外，请确保您使用的是连接池，这样您实际上不必每次都建立一个新的连接。池将为您保持开放状态，并在它死/超时时回收它。

【讨论】：

我没有使用连接池，因为这是唯一的连接，但切换到使用连接池仍然得到相同的“java.sql.SQLException: I/O Error: Connection reset “ 错误。我想知道我是否应该设置 setFetchSize 之类的东西，或者添加 TOP ？到正在运行的 SQL？（SQL Server 2008 DB）或者如果我只需要捕获该异常并再次运行查询？然而，捕获连接重置错误似乎是错误的。