test.java

public class JDBCTxOp extends AbstractJDBCAction<Void> {

  private final TxCommand op;

  public JDBCTxOp(JDBCStatementHelper helper, TxCommand op, SQLOptions options) {
    super(helper, options);
    this.op = op;
  }

  @Override
  public Void execute(Connection conn) throws SQLException {
    if (op == TxCommand.BEGIN) {
      conn.setAutoCommit(false);
    } else {
      try {
        if (op == TxCommand.COMMIT) {
          conn.commit();
        } else {
          conn.rollback();
        }
      } finally {
        conn.setAutoCommit(false);
      }
    }
    return null;
  }
}