Class AbstractDbSink

    • Constructor Detail

      • AbstractDbSink

        public AbstractDbSink()
    • Method Detail

      • getDefaultDatabaseConnection

        protected abstract AbstractDatabaseConnection getDefaultDatabaseConnection()
        Returns the default database connection.
        Returns:
        the default database connection
      • getDatabaseConnection

        protected abstract AbstractDatabaseConnection getDatabaseConnection()
        Determines the database connection in the flow.
        Returns:
        the database connection to use
      • setUpDatabaseConnection

        protected String setUpDatabaseConnection()
        Configures the database connection if necessary.
        Returns:
        null if successful, otherwise error message
      • queryDatabase

        protected abstract String queryDatabase()
        Performs the actual database query.
        Returns:
        null if everything is fine, otherwise error message
      • doExecute

        protected String doExecute()
        Executes the flow item.
        Specified by:
        doExecute in class AbstractActor
        Returns:
        null if everything is fine, otherwise error message
      • wrapUp

        public void wrapUp()
        Cleans up after the execution has finished. Graphical output is left untouched.
        Specified by:
        wrapUp in interface Actor
        Overrides:
        wrapUp in class AbstractSink