这在网上不是很少见的问题，但我用 MySQL 服务器做了一些优化工作来解决这个问题，但没有得到结果。所以一开始我使用maven的包mysql:mysql-connector-java:6.0.6。 我试着运行这段代码:

try {
            mysqlConnection = DriverManager.getConnection(DatabaseUtils.mysqlUrl, DatabaseUtils.mysqlUser, DatabaseUtils.mysqlPassword);
            PreparedStatement valuesStatement = "SELECT * FROM `test` ORDER BY `id`"
            ResultSet cursor = valuesStatement.executeQuery();
            double value = 0;
            if (cursor.next())
                value = cursor.getDouble("value");
        } catch (SQLException sqlEx) {
            sqlEx.printStackTrace();
        } finally {
            cursor.close();
            pricesStatement.close();
        }

我的表里有很多记录。它大约是百万，但每天都会添加大约一千条记录。所以当这个简单的例子执行了 30 秒时，我感到非常惊讶。我用谷歌搜索我的问题，我只找到“使用池”、“调整 mysql 服务器”、“尝试解释选择”。但我注意到执行时间与行数有关。所以我查看了驱动程序的代码，发现:

TextResultsetReader::read():

        while(true) {
            if(row == null) {
                rows = new ResultsetRowsStatic(rowList, cdef);
                break;
            }

            if(maxRows == -1 || rowList.size() < maxRows) {
                rowList.add(row);
            }

            row = (ResultsetRow)this.protocol.read(ResultsetRow.class, trf);
        }

这意味着即使我只想获取一个行，驱动程序也会获取所有查询的行并让我先获取它。手册建议使用“setFetchSize”来仅获取 n 条记录。但它不起作用。无论如何，驱动程序代码都在获取所有数据。然后我发现有两个记录集:ResultRowsStatic 和ResultSetStreaming。第二个似乎只在我需要查询时才获取数据。如何使用 ResultRowsStreaming？我发现它只进入代码。参数“fetchSize”必须等于 -2147483648。我确实尝试过并且有效! “executeQuery()”的执行时间现在大约为 0.0007 秒。这对我来说非常快。但是等等.. 我的脚本无论如何需要 30 秒。为什么？我在执行查询后调试了代码。之后只有两个“关闭”方法。什么会出错？没错，“cursor.close()”占用了剩下的时间。我再次查看了库代码并找到了 ResultsetRowsStreaming::close():

boolean hadMore = false;
int howMuchMore = 0;
synchronized(mutex) {
    while(this.next() != null) {
        hadMore = true;
        ++howMuchMore;
        if(howMuchMore % 100 == 0) {
            Thread.yield();
        }
    }

    if(conn != null) {
        if(!((Boolean)this.protocol.getPropertySet().getBooleanReadableProperty("clobberStreamingResults").getValue()).booleanValue() && ((Integer)this.protocol.getPropertySet().getIntegerReadableProperty("netTimeoutForStreamingResults").getValue()).intValue() > 0) {
            int oldValue = this.protocol.getServerSession().getServerVariable("net_write_timeout", 60);
            this.protocol.clearInputStream();

            try {
                this.protocol.sqlQueryDirect((StatementImpl)null, "SET net_write_timeout=" + oldValue, (String)this.protocol.getPropertySet().getStringReadableProperty("characterEncoding").getValue(), (PacketPayload)null, -1, false, (String)null, (ColumnDefinition)null, (GetProfilerEventHandlerInstanceFunction)null, this.resultSetFactory);
            } catch (Exception var9) {
                throw ExceptionFactory.createException(var9.getMessage(), var9, this.exceptionInterceptor);
            }
        }

        if(((Boolean)this.protocol.getPropertySet().getBooleanReadableProperty("useUsageAdvisor").getValue()).booleanValue() && hadMore) {
            ProfilerEventHandler eventSink = ProfilerEventHandlerFactory.getInstance(conn.getSession());
            eventSink.consumeEvent(new ProfilerEventImpl(0, "", this.owner.getCurrentCatalog(), this.owner.getConnectionId(), this.owner.getOwningStatementId(), -1, System.currentTimeMillis(), 0L, Constants.MILLIS_I18N, (String)null, (String)null, Messages.getString("RowDataDynamic.2") + howMuchMore + Messages.getString("RowDataDynamic.3") + Messages.getString("RowDataDynamic.4") + Messages.getString("RowDataDynamic.5") + Messages.getString("RowDataDynamic.6") + this.owner.getPointOfOrigin()));
        }
    }
}

此代码无条件获取所有其余数据，仅用于记录我未获取的记录数。真的很奇怪。如果附加了记录器，那将是合理的。但在我的例子中，这段代码计算了 30 秒内未获取的行，并且……什么都不做。这个问题我无法解决，因为没有参数可以告诉代码不要计算行数。

现在我不知道下一步该做什么。查询时间对我来说很慢。例如，php 的 mysql 驱动程序在 0.0004-0.001 秒内执行此查询。

那么使用 mysql-connector for Java 的人，请告诉我你有没有遇到这些问题？如果没有，您能否发布任何示例我应该怎么做才能绕过上述问题？也许您使用其他连接器。那么请告诉我，该怎么做？

最佳答案

你的 SQL 查询说

SELECT * FROM test ORDER BY id

您通过该查询指示您的 MySQL 服务器序列化您的 test 表的每一行的每一列并将其发送到你的 Java 程序。所以，MySQL服从了。你有一张大 table 。所以你对 MySQL 的指令需要时间。是的，表格中的行越多，花费的时间就越长。这不是 JDBC 或驱动程序的问题；这是您使用的 SQL 的问题。

从您的示例代码看来，您想要一列——名为 value——来自表中的一行——第一行。您可以使用此 SQL 语句完成此操作:

 SELECT value FROM test ORDER BY id LIMIT 1

如果您的 id 列是您表的主键，这会很快。

SQL 的重点 是允许您的表包含如此多的行，以至于在短时间内将它们全部提取到您的 Java(或其他)程序中是不合理的。这就是 SQL 具有 WHERE 和 LIMIT 子句的原因。

关于java - SELECT 上的 JDBC 连接器太慢，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/44069889/