public class DefaultStagingManager extends LoggingBean implements StagingManager, org.springframework.beans.factory.InitializingBean
STAGING_TABLES_PREFIX
Constructor and Description |
---|
DefaultStagingManager() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
protected void |
createStagingDatabase(org.springframework.core.io.Resource creationScriptPath)
Creates the staging database.
|
void |
dropAllStagingDatabases()
Drop all staging databases.
|
void |
dropStagingDatabase(java.lang.String databaseName)
Drop staging database.
|
LexEvsDatabaseOperations |
getLexEvsDatabaseOperations() |
java.lang.String |
getPrefix() |
java.util.Map<java.lang.String,org.springframework.core.io.Resource> |
getRegisteredStagingDatabases()
Gets the registered staging databases.
|
void |
initializeStagingSupport()
Initialize staging support.
|
boolean |
isRetry()
Checks if is retry.
|
void |
setLexEvsDatabaseOperations(LexEvsDatabaseOperations lexEvsDatabaseOperations) |
void |
setPrefix(java.lang.String prefix) |
void |
setRegisteredStagingDatabases(java.util.Map<java.lang.String,org.springframework.core.io.Resource> registeredStagingDatabases)
Sets the registered staging databases.
|
void |
setRetry(boolean retry)
Sets the retry.
|
getLogger, setLogger
public java.util.Map<java.lang.String,org.springframework.core.io.Resource> getRegisteredStagingDatabases()
public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
public void initializeStagingSupport() throws java.lang.Exception
StagingManager
initializeStagingSupport
in interface StagingManager
java.lang.Exception
- the exceptionprotected void createStagingDatabase(org.springframework.core.io.Resource creationScriptPath) throws java.lang.Exception
creationScriptPath
- the creation script pathjava.lang.Exception
- the exceptionpublic void dropAllStagingDatabases() throws java.lang.Exception
StagingManager
dropAllStagingDatabases
in interface StagingManager
java.lang.Exception
- the exceptionpublic void dropStagingDatabase(java.lang.String databaseName) throws java.lang.Exception
StagingManager
dropStagingDatabase
in interface StagingManager
databaseName
- the database namejava.lang.Exception
- the exceptionpublic void setRegisteredStagingDatabases(java.util.Map<java.lang.String,org.springframework.core.io.Resource> registeredStagingDatabases)
registeredStagingDatabases
- the registered staging databasespublic LexEvsDatabaseOperations getLexEvsDatabaseOperations()
public void setLexEvsDatabaseOperations(LexEvsDatabaseOperations lexEvsDatabaseOperations)
public boolean isRetry()
public void setRetry(boolean retry)
retry
- the new retrypublic void setPrefix(java.lang.String prefix)
public java.lang.String getPrefix()