批处理未运行，JDBC

Question

我在运行批处理时遇到了一点问题..

首先，我还在学习JDBC等，如果我的错误真的很愚蠢，请见谅..

我必须在我的数据库中插入一些 SQL 查询。因此，我正在像这样构建我的 PreparedStatements：

String add = "INSERT INTO company_type VALUES (?,?)";
PreparedStatement company = write.getConnection().prepareStatement(add);

ResultSet com = types.getCompanyType();

while(com.next()) {
    System.out.print("1");
    company.setInt(1, com.getInt(1));
    company.setString(2, com.getString(2));
    company.addBatch();

    if(i > size) {
        company.executeBatch();
        i = 0;
    }
    i++;
} 

company.executeBatch();

通过调试器后，我知道company.executeBatch(); 行出了点问题。

它只是没有执行，我的程序似乎陷入了循环或静止不动。

有没有人，怎么能看出错误？

谢谢

附：我没有得到任何异常。

public Connection getConnection(){

    Connection connection = null;

    try{
        Class.forName( "oracle.jdbc.driver.OracleDriver" );
    } catch(ClassNotFoundException e) {
        this.loginmessage.setText("Fehler beim Laden des Oracle JDBC Treibers!");
        e.printStackTrace();
        return connection;
    }

    try {
        connection = DriverManager.getConnection("j******************);
    } catch (SQLException e) {
        this.loginmessage.setText("Verbindung fehlgeschlagen!");
        e.printStackTrace();
        return connection;
    }

    if (connection != null) {
        loginmessage.setText("Verbindung hergestellt!");
        return connection;
    } else {
        loginmessage.setText("Verbindung fehlgeschlagen!");
        System.out.print("huaha");
    }
    return connection;
}

Answer 1

你必须像这样提交事务，

write.getConnection().commit();

以下是批处理中涉及的步骤，

1. 先关闭autocommit，让所有Batch语句执行 在单个事务中，并且没有提交批处理中的操作 分别。毕竟这是我们需要的。
2. 使用addBatch 向批处理中添加所需数量的语句。
3. 然后通过调用 executeBatch()
4. 最后commit 或roll-back 交易。

下面给出了一个示例代码。

public void saveLogEntries(List<LogEntry> entries) {
    try (Connection connObj = DriverManager.getConnection(JDBC_DB_URL, JDBC_USER, JDBC_PASS);
        PreparedStatement prepareStatement = connObj
            .prepareStatement("INSERT INTO logentry (date, ip, request) values(?, ?,?)")) {
                connObj.setAutoCommit(false);
                for(LogEntry entry : entries) {
                    try {
                        prepareStatement.setString(1, entry.getDate());
                        prepareStatement.setString(2, entry.getIp());
                        prepareStatement.setString(3, entry.getRequest());
                        prepareStatement.addBatch();
                    } catch (SQLException e) {
                        // Handle SQL exception here.
                    }
                };

                prepareStatement.executeBatch();
                connObj.commit();
    } catch (SQLException e) {
        // Handle SQL exception here.
    }
}

但是 Class.forName() 不再需要。查看此post 了解更多详情。您可以更改获取连接的方式，然后重试。代码对我来说似乎有点笨拙。

Answer 2

一种可能性是您尚未提交，因此服务器端事务超时并回滚。