Class ConnectorRepositoryImpl
- java.lang.Object
-
- de.akquinet.jbosscc.guttenbase.repository.impl.ConnectorRepositoryImpl
-
- All Implemented Interfaces:
ConnectorRepository,Serializable
public class ConnectorRepositoryImpl extends Object implements ConnectorRepository
The main repository containing all configured connectors.© 2012-2034 akquinet tech@spree
- Author:
- M. Dahm
Hint is used by
RepositoryTableFilterHintwhen returning table metadata - See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ConnectorRepositoryImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddConnectionInfo(String connectorId, ConnectorInfo connectionInfo)Add connection info to repository with symbolic ID for data base such as "source db", e.g.<T> voidaddConnectorHint(String connectorId, ConnectorHint<T> hint)Add configuration hint for connector.voidaddSourceDatabaseConfiguration(DatabaseType databaseType, SourceDatabaseConfiguration sourceDatabaseConfiguration)Define configuration for given data base type when reading data.voidaddTargetDatabaseConfiguration(DatabaseType databaseType, TargetDatabaseConfiguration targetDatabaseConfiguration)Define configuration for given data base type when writing data.ConnectorcreateConnector(String connectorId)Create connectorConnectorInfogetConnectionInfo(String connectorId)Get connection info<T> ConnectorHint<T>getConnectorHint(String connectorId, Class<T> connectionInfoHintType)Get configuration hint for connector.List<String>getConnectorIds()Get all currently configured connector IDs.DatabaseMetaDatagetDatabaseMetaData(String connectorId)Get all meta data from data base.SourceDatabaseConfigurationgetSourceDatabaseConfiguration(String connectorId)Get configuration.TargetDatabaseConfigurationgetTargetDatabaseConfiguration(String connectorId)Get configuration.voidrefreshDatabaseMetaData(String connectorId)Reset table data, i.e. it will be reread from the data base.voidremoveConnectionInfo(String connectorId)Remove all information about connector<T> voidremoveConnectorHint(String connectorId, Class<T> connectionInfoHintType)Remove configuration hint for connector.
-
-
-
Method Detail
-
addConnectionInfo
public void addConnectionInfo(String connectorId, ConnectorInfo connectionInfo)
Add connection info to repository with symbolic ID for data base such as "source db", e.g.- Specified by:
addConnectionInfoin interfaceConnectorRepository
-
removeConnectionInfo
public void removeConnectionInfo(String connectorId)
Remove all information about connector- Specified by:
removeConnectionInfoin interfaceConnectorRepository
-
addConnectorHint
public <T> void addConnectorHint(String connectorId, ConnectorHint<T> hint)
Add configuration hint for connector.- Specified by:
addConnectorHintin interfaceConnectorRepository
-
removeConnectorHint
public <T> void removeConnectorHint(String connectorId, Class<T> connectionInfoHintType)
Remove configuration hint for connector.- Specified by:
removeConnectorHintin interfaceConnectorRepository
-
getConnectorHint
public <T> ConnectorHint<T> getConnectorHint(String connectorId, Class<T> connectionInfoHintType)
Get configuration hint for connector.- Specified by:
getConnectorHintin interfaceConnectorRepository
-
getConnectionInfo
public ConnectorInfo getConnectionInfo(String connectorId)
Get connection info- Specified by:
getConnectionInfoin interfaceConnectorRepository
-
getDatabaseMetaData
public DatabaseMetaData getDatabaseMetaData(String connectorId)
Get all meta data from data base.- Specified by:
getDatabaseMetaDatain interfaceConnectorRepository
-
refreshDatabaseMetaData
public void refreshDatabaseMetaData(String connectorId)
Reset table data, i.e. it will be reread from the data base.- Specified by:
refreshDatabaseMetaDatain interfaceConnectorRepository
-
createConnector
public Connector createConnector(String connectorId)
Create connector- Specified by:
createConnectorin interfaceConnectorRepository
-
getSourceDatabaseConfiguration
public SourceDatabaseConfiguration getSourceDatabaseConfiguration(String connectorId)
Get configuration.- Specified by:
getSourceDatabaseConfigurationin interfaceConnectorRepository
-
addSourceDatabaseConfiguration
public void addSourceDatabaseConfiguration(DatabaseType databaseType, SourceDatabaseConfiguration sourceDatabaseConfiguration)
Define configuration for given data base type when reading data.- Specified by:
addSourceDatabaseConfigurationin interfaceConnectorRepository
-
addTargetDatabaseConfiguration
public void addTargetDatabaseConfiguration(DatabaseType databaseType, TargetDatabaseConfiguration targetDatabaseConfiguration)
Define configuration for given data base type when writing data.- Specified by:
addTargetDatabaseConfigurationin interfaceConnectorRepository
-
getTargetDatabaseConfiguration
public TargetDatabaseConfiguration getTargetDatabaseConfiguration(String connectorId)
Get configuration.- Specified by:
getTargetDatabaseConfigurationin interfaceConnectorRepository
-
getConnectorIds
public List<String> getConnectorIds()
Get all currently configured connector IDs.- Specified by:
getConnectorIdsin interfaceConnectorRepository
-
-