JDBC事务和批处理

package 作业171121;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import 连接池.DBCPDemo;

public class First {

public static void main(String[] args) {
Connection connection = DBCPDemo.getConnection();
String sql = "update emp set sal=sal*? where empno= (select empno from dept  where deptname =?)";
PreparedStatement ps = null;
boolean autoCommit = true;
try {
System.out.println("是否可以自动提交"+connection.getAutoCommit());
connection.setAutoCommit(false);
ps=connection.prepareStatement(sql);
ps.setDouble(1, 1.2);
ps.setString(2, "ANALYST");
ps.addBatch();
ps.setDouble(1, 1.3);
ps.setString(2, "MANAGER");
ps.addBatch();
ps.executeBatch();
connection.setAutoCommit(autoCommit);
} catch (SQLException e) {
try {
System.err.println("发生错误，回滚");
connection.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}
}
}