2

我正在使用命名管道通过 Connector/J 连接到 Java 中的 MySQL。我的连接和查询成功，但是当我尝试关闭连接时收到警告。我想知道除了删除connection.close（）（或删除try-with-resources连接块而不添加connection.close（））之外，我应该做什么来修复导致警告的任何东西。

这是我的查询代码：

public static List<List> QueryDB(int RowValue) {
    List<Long> ValueList = new ArrayList();

        try {
            try (Connection Connection_T = MySQLConnectionResources.createConnection()) {
                try (Statement Statement_T = Connection_T.createStatement()) {
                    String String_T = "SELECT AColumn FROM ATable WHERE BColumn = " + RowValue + ";";
                    try (ResultSet ResultSet_T = Statement_T.executeQuery(String_T)) {
                        while (ResultSet_T.next()) {
                            ValueList.add(ResultSet_T.getLong("AColumn"));
                        }
                    }
                }
            }
        } catch(SQLException SQLException_P) {
            System.err.println("ERROR: Failed to query the database.");
            ValueList.clear();
        }

    List<List> Result_M = new ArrayList();
    Result_M.add(ValueList);
    return Result_M;
}

“MySQLConnectionResources”只是一个带有“createConnection()”方法的自定义类。类/方法没有什么特别之处；它只是创建并返回一个连接。

方法完成后（或技术上，Java 7 try-with-resources 连接块完成后）我收到以下错误/警告：

Thu Sep 22 00:31:54 EDT 2011 WARN: Caught while disconnecting...

EXCEPTION STACK TRACE:



** BEGIN NESTED EXCEPTION ** 

java.net.SocketException
MESSAGE: Socket is not connected

STACKTRACE:

java.net.SocketException: Socket is not connected
    at java.net.Socket.shutdownInput(Socket.java:1456)
    at com.mysql.jdbc.MysqlIO.quit(MysqlIO.java:1687)
    at com.mysql.jdbc.ConnectionImpl.realClose(ConnectionImpl.java:4368)
    at com.mysql.jdbc.ConnectionImpl.close(ConnectionImpl.java:1557)
    at ... my class/method here (my class.java:#)


** END NESTED EXCEPTION **

如果我删除 try-with-resources 块（并且不添加 connection.close()），则警告永远不会出现。此外，如果我切换到 TCP/IP 连接，则永远不会出现错误。但是，这些解决方案都不适合我的情况。我想确保连接正确关闭，并且我将使用命名管道连接。

有任何想法吗？

-- （编辑） -- 另外：连接器/J 中的日志正在引发错误。我的错误捕获与如何捕获和打印错误无关。我试图研究如何禁用 WARN 问题并让它只打印出严重的问题（在连接器/J 的日志中），但我没有成功。此外，我想解决 WARN 问题，而不是忽略/隐藏它。

-- (edit 2) -- 我监控了 MySQL 数据库并且连接没有被关闭。如果我使用 TCP/IP 连接字符串而不是我的命名管道连接字符串（并且不更改任何其他内容），则连接关闭就好了。

-- (edit 3) -- 忽略我的原始代码......只需尝试下面的代码，它就会引发警告。对我来说似乎是一个错误。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public final class main {
    public static void main(String[] args) {
        Connection conn = null;
        try {
            conn =

DriverManager.getConnection("jdbc:mysql:///database?socketFactory=com.mysql.jdbc.NamedPipeSocketFactory&namedPipePath=\\\\.\\Pipe\\mysql.sock",
"root", "password");

            conn.close();


        } catch (SQLException ex) {
            // handle any errors
        }
    }
}
4

1 回答 1

0

由于这似乎是一个错误，我已向 MySQL 错误论坛提交了一份官方错误报告。

每当我收到更新时，我都会在这里发帖。

更新：

MySQL 编码人员分析了我的错误报告。他们认为这是一个 JAVA 错误。

错误报告

于 2011-09-26T15:42:15.213 回答