liquibase.executor

Class AbstractExecutor

java.lang.Object

liquibase.executor.AbstractExecutor

All Implemented Interfaces:

Executor, Plugin

Direct Known Subclasses:

JdbcExecutor, LoggingExecutor

public abstract class AbstractExecutor
extends Object
implements Executor

Code common to all Executor services / blueprint for Executor service classes.

Field Summary

Fields

Modifier and Type	Field and Description
protected Database	database
protected ResourceAccessor	resourceAccessor

Fields inherited from interface liquibase.plugin.Plugin

PRIORITY_DEFAULT, PRIORITY_NOT_APPLICABLE, PRIORITY_SPECIALIZED

Constructor Summary

Constructors

Constructor and Description
AbstractExecutor()

Method Summary

Modifier and Type	Method and Description
protected String[]	applyVisitors(SqlStatement statement, List<SqlVisitor> sqlVisitors)
void	execute(Change change) Write methods
void	execute(Change change, List<SqlVisitor> sqlVisitors)
abstract String	getName() Return the name of the Executor
abstract int	getPriority() Return the Executor priority
void	modifyChangeSet(ChangeSet changeSet) Allow this Executor to make any needed changes to the changeset.
void	setDatabase(Database database) Configures the Executor for the Database to run statements/queries against.
void	setResourceAccessor(ResourceAccessor resourceAccessor) Set a ResourceAccessor on this Executor to be used in file access
ValidationErrors	validate(ChangeSet changeSet) Validate if the changeset can be executed by this Executor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface liquibase.executor.Executor

comment, execute, execute, queryForInt, queryForInt, queryForList, queryForList, queryForList, queryForList, queryForLong, queryForLong, queryForObject, queryForObject, supports, update, update, updatesDatabase

Field Detail

database

protected Database database

resourceAccessor

protected ResourceAccessor resourceAccessor

Constructor Detail

AbstractExecutor

public AbstractExecutor()

Method Detail

getName

public abstract String getName()

Return the name of the Executor

Specified by:

getName in interface Executor

Returns:

String The Executor name

getPriority

public abstract int getPriority()

Return the Executor priority

Specified by:

getPriority in interface Executor

Returns:

int The Executor priority

validate

public ValidationErrors validate(ChangeSet changeSet)

Validate if the changeset can be executed by this Executor

Specified by:

validate in interface Executor

Parameters:

changeSet - The changeset to validate

Returns:

boolean Always true for abstract class

modifyChangeSet

public void modifyChangeSet(ChangeSet changeSet)

Allow this Executor to make any needed changes to the changeset. The base class sets splitStatements to 'true' if it is not set

Specified by:

modifyChangeSet in interface Executor

Parameters:

changeSet - The changeset to operate on

setResourceAccessor

public void setResourceAccessor(ResourceAccessor resourceAccessor)

Set a ResourceAccessor on this Executor to be used in file access

Specified by:

setResourceAccessor in interface Executor

Parameters:

resourceAccessor -

setDatabase

public void setDatabase(Database database)

Description copied from interface: Executor

Configures the Executor for the Database to run statements/queries against.

Specified by:

setDatabase in interface Executor

Parameters:

database - The database

applyVisitors

protected String[] applyVisitors(SqlStatement statement,
                                 List<SqlVisitor> sqlVisitors)
                          throws DatabaseException

Throws:

DatabaseException

execute

public void execute(Change change)
             throws DatabaseException

Description copied from interface: Executor

Write methods

Specified by:

execute in interface Executor

Throws:

DatabaseException

execute

public void execute(Change change,
                    List<SqlVisitor> sqlVisitors)
             throws DatabaseException

Specified by:

execute in interface Executor

Throws:

DatabaseException