Class ExecutorService

All Implemented Interfaces:
PluginFactory, SingletonObject

public class ExecutorService extends AbstractPluginFactory<Executor>
  • Method Details

    • getPluginClass

      protected Class<Executor> getPluginClass()
      Specified by:
      getPluginClass in class AbstractPluginFactory<Executor>
    • getPriority

      protected int getPriority(Executor executor, Object... args)
      Description copied from class: AbstractPluginFactory
      Returns the priority of the given object based on the passed args array. The args are created as part of the custom public getPlugin method in implementations are passed through AbstractPluginFactory.getPlugin(Object...)
      Specified by:
      getPriority in class AbstractPluginFactory<Executor>
    • getExecutor

      public Executor getExecutor(String name, Database database)
      Retrieves a named executor for the specified database.
      Parameters:
      name - the name of the executor
      database - the database for which to retrieve the executor
      Returns:
      the Executor associated with the given name and database
      Throws:
      UnexpectedLiquibaseException - if there was an error retrieving the executor
    • executorExists

      public boolean executorExists(String name, Database database)
      Checks if an executor exists for the given name and database.
      Parameters:
      name - the name of the executor
      database - the database to which the executor is connected
      Returns:
      true if an executor exists for the given name and database, false otherwise
    • getExecutor

      public Executor getExecutor(Database database)
      Deprecated.
      Please use getExecutor(String, Database) instead.
      Returns an Executor for the specified database and name. This method is deprecated; please use getExecutor(String, Database) instead.
      Parameters:
      database - the Database to execute the statements on
      Returns:
      Executor for the specified database and name
    • setExecutor

      public void setExecutor(Database database, Executor executor)
      Sets the executor for the given database with the default name "jdbc". If an executor with the same name and database already exists, it will be replaced by the new one.
      Parameters:
      database - the Database for which the executor is set
      executor - the Executor to set
    • setExecutor

      public void setExecutor(String name, Database database, Executor executor)
    • clearExecutor

      public void clearExecutor(Database database)
      Deprecated.
      Please use clearExecutor(name, database)
      Parameters:
      database -
    • clearExecutor

      public void clearExecutor(String name, Database database)
    • reset

      public void reset()