java - eclipse : Intermittent com. mysql.jdbc.exceptions.jdbc4.CommunicationsException:通信链路故障

Question

对此有很多问题，但似乎没有任何问题可以解决我的问题。我收到“com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:通信链接失败”错误，但仅在成功处理大约 32000 条记录之后。我已经成功连接到 MySQL。我成功地读写，所以它不是本地主机/端口/绑定(bind)地址/等问题。

我有一个应用程序，可以读取 CSV 文件并处理每一行数据，读取一些数据库表，插入其他表并更新其他表。我仔细检查了我的代码，并关闭了与数据库的每个连接。我可以通过MySQL Workbench观察MySQL服务器状态，负载相当稳定在0.5，连接范围从2 - 15并且似乎关闭得很好，其他一切看起来都相当稳定并且在正常范围内。

但是将 32000 到 34000 条记录放入 75000 条记录的 CSV 文件中时，我收到上述错误。它并不总是在同一个记录上结束，而且它结束的记录似乎没有任何异常。

我有什么想法可以诊断这个问题吗？

这是我用于所有 MySQL 连接的代码:

public class MySQLAccess {
    private Connection connect = null;
    private Statement statement = null;
    private ResultSet resultSet = null;
    public String query = null;
    public int lastId = 0;

    private Connection getConnection() throws Exception {
        // reads a config properties file
        AWBConfig Config = new AWBConfig();
        String host = Config.Data.getProperty("mysql.host");
        if (!Config.Data.getProperty("mysql.port").isEmpty()) host += ":" + Config.Data.getProperty("mysql.port");
        Class.forName("com.mysql.jdbc.Driver");
        return DriverManager.getConnection("jdbc:mysql://"+host+"/" + Config.Data.getProperty("mysql.name") + "?user=" + 
            Config.Data.getProperty("mysql.user") + "&password=" + Config.Data.getProperty("mysql.pass"));
    }

    public ResultSet readDataBase() throws Exception {
        if (connect == null || connect.isClosed()) connect = getConnection();
        statement = connect.createStatement();
        resultSet = statement.executeQuery(query);
        return resultSet;
    }

    public ResultSet readDataBase(String _query) throws Exception {
        this.query = _query;
        resultSet = this.readDataBase();
        return resultSet;
    }

    public void writeData() throws Exception {
        if (connect == null || connect.isClosed()) connect = getConnection();
        statement = connect.createStatement();
        if (query.substring(0, 6).equals("INSERT")) {
            statement.executeUpdate(query, Statement.RETURN_GENERATED_KEYS);
            ResultSet rs = statement.getGeneratedKeys();
            if (rs.next()){
                this.lastId=rs.getInt(1);
            }
            rs.close();
        } else {
            statement.executeUpdate(query);
            this.lastId = -1;
        }
    }

    public void close() {
        try {
            if (resultSet != null) resultSet.close();
            if (statement != null) statement.close();
            if (connect != null) connect.close();
        } catch (Exception e) {
        }
    }
}

然后为了与数据库交互，我使用以下格式:

    protected void getCampaignById() throws Exception {
        _dba = new MySQLAccess();
        _dba.query = "SELECT * FROM table WHERE id = '" + String.valueOf(id) + "'";
        ResultSet rs = _dba.readDataBase();
        if (rs.next()) {
            ... do stuff with rs
        }
        _dba.close();
    }

Answer 1

嗯，我不确定问题到底是什么，但我将 _dba 更改为核心应用程序的 main() 方法中的静态变量，然后将以下行添加到每个类构造函数:

_dba = MyMainClass._dba;

然后从所有地方删除这些行(除了 MyMainClass.main()):

_dba = new MySQLAccess();
...
_dba.close();

将数据库连接设置为全局持久连接，不仅解决了我的错误，而且还给我带来了巨大的性能提升。