java - ResultSet 的 JDBC 超时我做得对吗？

Question

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

数据库表已建立索引并使用选择标准快速返回数据，因此我不相信它是在数据库端。我返回了地址列和整数混合的 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？

更改逻辑以一次仅拉取一行？

Answer 1

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

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

一次选择一行会带来大量开销，因此我不建议这样做。

此外，请确保您正在使用连接池，这样您实际上就不必每次都构建新的连接。池将保持它为您打开，并在它死掉/超时时回收它。