liquibase.hub

Class HubUpdater

java.lang.Object

liquibase.hub.HubUpdater

public class HubUpdater
extends Object

This class handles updating Hub during Liquibase operations

Constructor Summary

Constructors

Constructor and Description
HubUpdater(Date startTime, Database database)
HubUpdater(Date startTime, DatabaseChangeLog changeLog, Database database)

Method Summary

Modifier and Type	Method and Description
boolean	hubIsNotAvailable(String changeLogId) Determine if the Hub is not available
void	postUpdateHub(Operation updateOperation, BufferedLogService bufferLog) Update the Hub after the operation
void	postUpdateHubExceptionHandling(Operation operation, BufferedLogService bufferLog, String originalExceptionMessage) Handle Hub exceptions thrown during the operation
Operation	preUpdateHub(String operationType, String operationCommand, Connection connection) This method performs a syncHub and returns a new Operation instance If there is an error or the Hub is not available it returns null
Operation	preUpdateHub(String operationType, String operationCommand, Connection connection, String changeLogFile, Contexts contexts, LabelExpression labelExpression, ChangeLogIterator changeLogIterator) This method performs a syncHub and returns a new Operation instance If there is an error or the Hub is not available it returns null
void	syncHub(String changeLogFile, Connection hubConnection)

Methods inherited from class java.lang.Object

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

Constructor Detail

HubUpdater

public HubUpdater(Date startTime,
                  DatabaseChangeLog changeLog,
                  Database database)

HubUpdater

public HubUpdater(Date startTime,
                  Database database)

Method Detail

preUpdateHub

public Operation preUpdateHub(String operationType,
                              String operationCommand,
                              Connection connection)
                       throws LiquibaseException,
                              SQLException

This method performs a syncHub and returns a new Operation instance If there is an error or the Hub is not available it returns null

Parameters:

operationType - Operation type (UPDATE or ROLLBACK)

connection - Connection for this operation

Returns:

Operation Valid Operation object or null

Throws:

LiquibaseHubException - Thrown by HubService

DatabaseException - Thrown by Liquibase core

LiquibaseException - Thrown by Liquibase core

SQLException

preUpdateHub

public Operation preUpdateHub(String operationType,
                              String operationCommand,
                              Connection connection,
                              String changeLogFile,
                              Contexts contexts,
                              LabelExpression labelExpression,
                              ChangeLogIterator changeLogIterator)
                       throws LiquibaseHubException,
                              DatabaseException,
                              LiquibaseException,
                              SQLException

This method performs a syncHub and returns a new Operation instance If there is an error or the Hub is not available it returns null

Parameters:

operationType - Operation type (UPDATE, ROLLBACK, or CHANGELOGSYNC)

operationCommand - Specific command which is executing (update, update-count, etc.)

connection - Connection for this operation

changeLogFile - Path to DatabaseChangelog for this operation

contexts - Contexts to use for filtering

labelExpression - Labels to use for filtering

changeLogIterator - Iterator to use for going through changesets

Returns:

Operation Valid Operation object or null

Throws:

LiquibaseHubException - Thrown by HubService

DatabaseException - Thrown by Liquibase core

LiquibaseException - Thrown by Liquibase core

SQLException

postUpdateHub

public void postUpdateHub(Operation updateOperation,
                          BufferedLogService bufferLog)

Update the Hub after the operation

Parameters:

updateOperation - Operation object used in the update

bufferLog - Log output

postUpdateHubExceptionHandling

public void postUpdateHubExceptionHandling(Operation operation,
                                           BufferedLogService bufferLog,
                                           String originalExceptionMessage)

Handle Hub exceptions thrown during the operation

Parameters:

operation - Operation object

bufferLog - Log output

originalExceptionMessage - Exception thrown by the operation

hubIsNotAvailable

public boolean hubIsNotAvailable(String changeLogId)

Determine if the Hub is not available

Parameters:

changeLogId - Changelog ID

Returns:

boolean

syncHub

public void syncHub(String changeLogFile,
                    Connection hubConnection)
             throws CommandExecutionException

Throws:

CommandExecutionException