Interface ExtractionContext
-
- All Known Implementing Classes:
ExtractionContext.EmptyExtractionContext,ExtractionContextImpl,ImprovedExtractionContextImpl
@Incubating public interface ExtractionContext
Defines a context for performing extraction including providing access to information about ongoing extraction as well as to delegates needed in performing extraction.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceExtractionContext.DatabaseObjectAccessIn conjunction withgetDatabaseObjectAccess()provides access to information about known database objects to the extractor.static classExtractionContext.EmptyExtractionContextstatic interfaceExtractionContext.ResultSetProcessor<T>
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description voidcleanup()ExtractionContext.DatabaseObjectAccessgetDatabaseObjectAccess()IdentifiergetDefaultCatalog()IdentifiergetDefaultSchema()ConnectiongetJdbcConnection()DatabaseMetaDatagetJdbcDatabaseMetaData()JdbcEnvironmentgetJdbcEnvironment()default <T> TgetQueryResults(String queryString, Object[] positionalParameters, ExtractionContext.ResultSetProcessor<T> resultSetProcessor)ServiceRegistrygetServiceRegistry()SqlStringGenerationContextgetSqlStringGenerationContext()
-
-
-
Method Detail
-
getServiceRegistry
ServiceRegistry getServiceRegistry()
-
getJdbcEnvironment
JdbcEnvironment getJdbcEnvironment()
-
getSqlStringGenerationContext
SqlStringGenerationContext getSqlStringGenerationContext()
-
getJdbcConnection
Connection getJdbcConnection()
-
getJdbcDatabaseMetaData
DatabaseMetaData getJdbcDatabaseMetaData()
-
getQueryResults
@Incubating default <T> T getQueryResults(String queryString, Object[] positionalParameters, ExtractionContext.ResultSetProcessor<T> resultSetProcessor) throws SQLException
- Throws:
SQLException
-
getDefaultCatalog
Identifier getDefaultCatalog()
-
getDefaultSchema
Identifier getDefaultSchema()
-
getDatabaseObjectAccess
ExtractionContext.DatabaseObjectAccess getDatabaseObjectAccess()
-
cleanup
void cleanup()
-
-