Java程序在执行批处理时抛出异常

Question

我正在实现一个 JAVA 应用程序，它从不同的 URL 获取数据并将这些数据存储到数据库中。每个表都有自己的 URL 集合，从中接收数据。我通过为每个表实现一个准备好的语句、从 URL 获取数据、将数据绑定(bind)到准备语句并批量添加数据，直到完成表的所有 URL 来完成此操作。然后在准备语句上执行executeBatch。我确实有一些 6-8 个表，每个表大约有 200 行。我对每个表执行相同的过程，但在更新 3-4 个表后，我的 executeBacth 出现异常，其中显示:

 java.sql.SQLException: SQL Exception : [Microsoft][ODBC Driver
 Manager] Invalid string or buffer length   at
 sun.jdbc.odbc.JdbcOdbcPreparedStatement.setObject(JdbcOdbcPreparedStatement.java:1438)
    at
 sun.jdbc.odbc.JdbcOdbcPreparedStatement.setObject(JdbcOdbcPreparedStatement.java:1073)
    at
 sun.jdbc.odbc.JdbcOdbcPreparedStatement.emulateExecuteBatch(JdbcOdbcPreparedStatement.jjva:2104)
    at
 sun.jdbc.odbc.JdbcOdbcPreparedStatement.executeBatchUpdate(JdbcOdbcPreparedStatement.java:1782)
    at
 sun.jdbc.odbc.JdbcOdbcStatement.executeBatch(JdbcOdbcStatement.java:911)
    at FaoClient.CFaoTable.InsertFromPartialSource(CFaoTable.java:174)

我通过更改获取表数据的顺序来测试相同的程序，但在插入数据 4-5 个表后它总是抛出异常。我觉得这就像一些内存泄漏的情况，但据我所知，JAVA 抓取收集器永远不会让这种情况发生。我对这个 JAVA 世界很陌生，所以我可能是错的。我粘贴了使用 java.sql.* 的代码部分来插入记录。

  private boolean BindValueToStmt(PreparedStatement ps, int index, TableCol.ColType type, String ColVal) {
        if ((ps == null) || (ColVal == "")) {
            return false;
        }
        try {
            switch (type) {
                case INTEGERT: {
                    ps.setInt(index, Integer.parseInt(ColVal));
                    return true;
                }
                case STRINGT: {
                    ps.setString(index, ColVal);
                    return true;
                }
                case REALT: {
                    ps.setFloat(index, Float.parseFloat(ColVal));
                    return true;
                }
                case DOUBLET: {
                    ps.setDouble(index, Double.parseDouble(ColVal));
                    return true;
                }
                default:
                    ps.setNull(index, java.sql.Types.NULL);
            }
            return true;
        } catch (SQLException E) {
            System.out.println("Error in Setting the value of the col in table: " + Name + E);
            E.printStackTrace();
            return false;
        }
    }



   private String CreatePreparedInsertStatement() {
        StringBuilder insertStmt = new StringBuilder("insert into " + Name + "(");
        String val = " values (";
        for (int index = 0; index < Columns.size(); index++) {
            TableCol col = Columns.get(index);
            if (index != Columns.size() - 1) {
                String Stmt = col.GetColName() + ", ";
                insertStmt.append(Stmt);
                val += "?, ";
            } else {
                String Stmt = col.GetColName() + ")";
                insertStmt.append(Stmt);
                val += "?)";
            }
        }
        insertStmt.append(val);
        return insertStmt.toString();
    }

下面是实际插入数据的代码。

  private boolean InsertFromPartialSource(Connection conn, SAXReader reader) {
        try {
            if (conn == null || reader == null) {
                return false;
            }
           //Some Code not realted to java.sql

            conn.setAutoCommit(false);
            String strPs= CreatePreparedInsertStatement();
            PreparedStatement ps = conn.prepareStatement(strPs);

            //Some Code not realted to java.sql

            for (int index = 0; index < Columns.size(); index++) {
                    TableCol col = Columns.get(index);
                    //Some Code not realted to java.sql
                    if (!BindValueToStmt(ps, index + 1, col.GetColType(), colVal)) {
                        ps.setNull(index + 1, TableCol.GetSqlColTypeFrmType(col.GetColType()));
                    }
                }
                rowCount++;
                System.out.println(rowCount + "rows has been extracted for table \" " + Name);
                ps.addBatch();

            }
            if (rowCount > 0) {
                int RecordsUpdated[] = ps.executeBatch();
            }
            conn.commit();
            conn.setAutoCommit(true);
            ps.close();
            return true;
}

为了清楚起见，我只粘贴了函数 InsertFromPartialSource 与数据库更新相关的部分。有人可以指出这里出了什么问题吗？

上述问题的解决方案是: 将您的 MySql 连接器或驱动程序更改为 MySqlJDBC 驱动程序。有可能 在下面的链接中找到: http://dev.mysql.com/downloads/connector/j/5.1.html

Answer 1

考虑切换到适合您的数据库的真正 JDBC 驱动程序(如果有)。 JdbcOdbc 桥相当糟糕，特定的 JDBC 驱动程序通常工作得更好。