Method handleTransactStatement

src/java/simpledb/Parser.java:426–464

(ZTransactStmt s)

    }

    public void handleTransactStatement(ZTransactStmt s)
            throws IOException,
            simpledb.ParsingException {
        switch (s.getStmtType()) {
            case "COMMIT":
                if (curtrans == null)
                    throw new ParsingException(
                            "No transaction is currently running");
                curtrans.commit();
                curtrans = null;
                inUserTrans = false;
                System.out.println("Transaction " + curtrans.getId().getId()
                        + " committed.");
                break;
            case "ROLLBACK":
                if (curtrans == null)
                    throw new ParsingException(
                            "No transaction is currently running");
                curtrans.abort();
                curtrans = null;
                inUserTrans = false;
                System.out.println("Transaction " + curtrans.getId().getId()
                        + " aborted.");

                break;
            case "SET TRANSACTION":
                if (curtrans != null)
                    throw new ParsingException(
                            "Can't start new transactions until current transaction has been committed or rolledback.");
                curtrans = new Transaction();
                curtrans.start();
                inUserTrans = true;
                System.out.println("Started a new transaction tid = "
                        + curtrans.getId().getId());
                break;
            default:
                throw new ParsingException("Unsupported operation");
        }
    }

    public LogicalPlan generateLogicalPlan(TransactionId tid, String s)
            throws simpledb.ParsingException, IOException {