使用JDBC执行多个SQL语句(CRUD)

Question

我正在使用Java (JDBC)创建一个命令行实用程序来执行SQL语句。脚本被定义为一个文本文件，有许多查询。每个查询由查询分隔符("；"分隔).输出被路由到stdout。

SELECT * FROM table1;
UPDATE table1 SET field1='' WHERE field2='';
SELECT * FROM table1;
INSERT INTO table1 VALUES(...)
SELECT * FROM table1;

由于JDBC可以批量执行语句，只有当它们不返回ResultSet时，我才需要另一种方法。

截至目前，我将读取带有查询的脚本文件，按分隔符拆分它们，并分析每个查询，无论是“SELECT”查询，还是“INSERT”，“更新”，“删除”查询。之后，我会在它自己的语句中执行每个查询。返回某些内容的查询将写入 stdout，将执行操作数据库的查询。而且，当然，我会保留文件中查询的顺序。

我的问题是：如果文件中的某个查询是错误的，我无法回滚，因为每个查询都是单独执行的。我该如何处理这个问题？

Answer 1

此代码可能对您有帮助。

 String Query1 = "SELECT * FROM Tablename1";
        stmt1 = con.createStatement();
        ResultSet rs = stmt1.executeQuery(Query1);
        rs.next();
        int totalQuery1Count = rs.getInt("TOTAL_Item");

    String Query2 = "SELECT * FROM Tablename2";
        rs = stmt1.executeQuery(Query2);
        rs.next();
        int totalQuery2Count = rs.getInt("TOTAL_Item2");

Answer 2

这是用于向批处理添加查询的代码。

Statement stmt = conn.createStatement();
conn.setAutoCommit(false);

String SQL = "INSERT INTO table1 VALUES(...)";
stmt.addBatch(SQL);

String SQL = "INSERT INTO Employees (id, first, last, age) " +
         "VALUES(201,'Raj', 'Kumar', 35)";
stmt.addBatch(SQL);

String SQL = "UPDATE Employees SET age = 35 " +
         "WHERE id = 100";
stmt.addBatch(SQL);


 int[] count = stmt.executeBatch();

//显式提交语句以应用更改

 conn.commit();

试试这个.....

Answer 3

对于数据库连接，只需调用连接即可。setAutoCommit（false）然后执行语句并调用连接。完成后提交（），或连接。如果遇到错误，请回滚（）。