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 interface
ExtractionContext.DatabaseObjectAccess
In conjunction withgetDatabaseObjectAccess()
provides access to information about known database objects to the extractor.static class
ExtractionContext.EmptyExtractionContext
static interface
ExtractionContext.ResultSetProcessor<T>
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
cleanup()
ExtractionContext.DatabaseObjectAccess
getDatabaseObjectAccess()
Identifier
getDefaultCatalog()
Identifier
getDefaultSchema()
Connection
getJdbcConnection()
DatabaseMetaData
getJdbcDatabaseMetaData()
JdbcEnvironment
getJdbcEnvironment()
default <T> T
getQueryResults(String queryString, Object[] positionalParameters, ExtractionContext.ResultSetProcessor<T> resultSetProcessor)
ServiceRegistry
getServiceRegistry()
SqlStringGenerationContext
getSqlStringGenerationContext()
-
-
-
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()
-
-