插入操作后，CachedRowset acceptChanges 不起作用

Question

我正在使用 MySQL 数据库，我有一个表 Employee 有 2 列：Id（整数；主键）和 Name（字符串）。我已经编写了一些代码来在Employee 表中插入一行，但是acceptChanges 不起作用并且代码在acceptChanges 处停止。代码如下：

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

import javax.sql.rowset.CachedRowSet;
import javax.sql.rowset.RowSetFactory;
import javax.sql.rowset.RowSetProvider;

public class InsertSynchronizer {

    static CachedRowSet crs = null;

    public static void main(String[] args) {

        try {
            Class.forName("com.mysql.jdbc.Driver");
            Connection c = DriverManager.getConnection("jdbc:mysql://localhost:3306/", "root", "");
            c.setAutoCommit(false);
            RowSetFactory myRowSetFactory = null;
            myRowSetFactory = RowSetProvider.newFactory();
            crs = myRowSetFactory.createCachedRowSet();
            crs.setUrl("jdbc:mysql://localhost:3306/test");
            crs.setUsername("root");
            crs.setPassword("");
            crs.setConcurrency(CachedRowSet.CONCUR_UPDATABLE);
            crs.setCommand("select * from employee");
            crs.execute();
            while (crs.next()) {
                System.out.println(crs.getString("Name"));
            }

            // Inserting rows
            crs.moveToInsertRow();
            crs.updateInt("Id", 5);
            crs.updateString("Name", "E");
            crs.insertRow();

            //Thread.sleep(60000);
            crs.acceptChanges(c); // Updating Data Sources

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Answer 1

您会发现打印出有关异常的所有信息很有帮助。如果您捕获的是 SQLException 而不是一般的异常（通常您应该捕获特定的异常），您将可以访问更多信息，包括 SQL state and error codes。

我相信在这种情况下，您会发现这是与连接设置为自动提交更改有关的错误。我相信 CachedRowSet 在您初始化并执行其命令时正在建立自己的连接。它不知道您创建的连接“c”，直到您将它传递给acceptChanges。我认为这意味着 crs 的连接同时将 autoCommit 设置为 true。

尝试将 ?relaxAutoCommit=true 添加到您的 url 字符串中，如下所示：

crs.setUrl("jdbc:mysql://localhost:3306/test?relaxAutoCommit=true");

您无需向其传递 Connection 即可接受更改，因为它有自己的。事实上，您不需要创建另一个连接，它会一直保持打开状态。 CachedRowSet 的全部意义在于您在进行更改时不会保持连接打开。

Answer 2

声明crs.moveToCurrentRow()必须添加在crs.insertRow()之后和crs.acceptChanges(c)之前

例如：

 // Inserting rows
crs.moveToInsertRow();
crs.updateInt("Id", 5);
crs.updateString("Name", "E");
crs.insertRow();
crs.moveToCurrentRow(); // NEW STATEMENT
crs.acceptChanges(c); // Updating Data Sources

欲了解更多信息，请访问：http://docs.oracle.com/javase/tutorial/jdbc/basics/cachedrowset.html#inserting-and-deleting-rows