package liquibase.changelog.visitor;

 import liquibase.changelog.ChangeSet;

 import liquibase.changelog.DatabaseChangeLog;

 import liquibase.database.Database;

 import liquibase.exception.LiquibaseException;

 import liquibase.logging.LogFactory;

 import liquibase.logging.Logger;

 public class UpdateVisitor implements ChangeSetVisitor {

     private Database database;

     private Logger log = LogFactory.getLogger();

     public UpdateVisitor(Database database) {

         this.database = database;

     }

     public Direction getDirection() {

         return ChangeSetVisitor.Direction.FORWARD;

     }

     public void visit(ChangeSet changeSet, DatabaseChangeLog databaseChangeLog, Database database)

             throws LiquibaseException {

         ChangeSet.RunStatus runStatus = this.database.getRunStatus(changeSet);

         log.debug("Running Changeset:" + changeSet);

         ChangeSet.ExecType execType = changeSet.execute(databaseChangeLog, this.database);

         if (!runStatus.equals(ChangeSet.RunStatus.NOT_RAN)) {

             execType = ChangeSet.ExecType.RERAN;

         }

         this.database.markChangeSetExecStatus(changeSet, execType);

         this.database.commit();

     }

 }