Package org.springframework.cloud.dataflow.server.db.migration

Class AbstractBaselineCallback

java.lang.Object
org.springframework.cloud.dataflow.common.flyway.AbstractCallback
org.springframework.cloud.dataflow.server.db.migration.AbstractBaselineCallback
All Implemented Interfaces:
org.flywaydb.core.api.callback.Callback
Direct Known Subclasses:
Db2BeforeBaseline, MariadbBeforeBaseline, MsSqlBeforeBaseline, MysqlBeforeBaseline, OracleBeforeBaseline, PostgresBeforeBaseline
public abstract class AbstractBaselineCallback extends org.springframework.cloud.dataflow.common.flyway.AbstractCallback
Base implementation for baselining schema setup.
Author:
Janne Valkealahti

  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractBaselineCallback(AbstractInitialSetupMigration initialSetupMigration)
    Instantiates a new abstract baseline callback.

  • Method Summary

    Modifier and Type
    Method
    Description
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    changeAppRegistrationTable()
    Change app registration table.
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    changeAuditRecordsTable()
    Change audit records table.
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    changeStreamDefinitionsTable()
    Change stream definitions table.
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    changeTaskDefinitionsTable()
    Change task definitions table.
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    changeUriRegistryTable()
    Change uri registry table.
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    createIndexes()
    Creates the indexes.
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    createTaskDeploymentTable()
    Create the task deployment table.
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    createTaskLockTable()
    Creates the task lock table.
    protected boolean
    doTableExists(org.flywaydb.core.api.callback.Context context, String name)
     
    abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    dropIndexes()
    Drop indexes.
    List<org.springframework.cloud.dataflow.common.flyway.SqlCommand>
    getCommands(org.flywaydb.core.api.callback.Event event, org.flywaydb.core.api.callback.Context context)
     

    Methods inherited from class org.springframework.cloud.dataflow.common.flyway.AbstractCallback

    canHandleInTransaction, getCallbackName, handle, supports

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AbstractBaselineCallback

      public AbstractBaselineCallback(AbstractInitialSetupMigration initialSetupMigration)
      Instantiates a new abstract baseline callback.
      Parameters:
      initialSetupMigration - the initial setup migration

  • Method Details

    • getCommands

      public List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> getCommands(org.flywaydb.core.api.callback.Event event, org.flywaydb.core.api.callback.Context context)
      Overrides:
      getCommands in class org.springframework.cloud.dataflow.common.flyway.AbstractCallback

    • doTableExists

      protected boolean doTableExists(org.flywaydb.core.api.callback.Context context, String name)

    • dropIndexes

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> dropIndexes()
      Drop indexes.
      Returns:
      the list of sql commands

    • changeAppRegistrationTable

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> changeAppRegistrationTable()
      Change app registration table.
      Returns:
      the list of sql commands

    • changeUriRegistryTable

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> changeUriRegistryTable()
      Change uri registry table.
      Returns:
      the list of sql commands

    • changeStreamDefinitionsTable

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> changeStreamDefinitionsTable()
      Change stream definitions table.
      Returns:
      the list of sql commands

    • changeTaskDefinitionsTable

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> changeTaskDefinitionsTable()
      Change task definitions table.
      Returns:
      the list of sql commands

    • changeAuditRecordsTable

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> changeAuditRecordsTable()
      Change audit records table.
      Returns:
      the list of sql commands

    • createIndexes

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> createIndexes()
      Creates the indexes.
      Returns:
      the list of sql commands

    • createTaskLockTable

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> createTaskLockTable()
      Creates the task lock table.
      Returns:
      the list of sql commands

    • createTaskDeploymentTable

      public abstract List<org.springframework.cloud.dataflow.common.flyway.SqlCommand> createTaskDeploymentTable()
      Create the task deployment table.
      Returns:
      the list of sql commands