Airbyte Kotlin Bulk CDK

1.0.4

bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.discover/JdbcMetadataQuerier

JdbcMetadataQuerier

class JdbcMetadataQuerier(val constants: DefaultJdbcConstants, val config: JdbcSourceConfiguration, val selectQueryGenerator: SelectQueryGenerator, val fieldTypeMapper: JdbcMetadataQuerier.FieldTypeMapper, val checkQueries: JdbcCheckQueries, jdbcConnectionFactory: JdbcConnectionFactory) : MetadataQuerier

Default implementation of MetadataQuerier.

Constructors

JdbcMetadataQuerier

constructor(constants: DefaultJdbcConstants, config: JdbcSourceConfiguration, selectQueryGenerator: SelectQueryGenerator, fieldTypeMapper: JdbcMetadataQuerier.FieldTypeMapper, checkQueries: JdbcCheckQueries, jdbcConnectionFactory: JdbcConnectionFactory)

Types

data class ColumnMetadata(val name: String, val label: String, val type: SourceDatabaseType, val nullable: Boolean? = null, val ordinal: Int? = null)

@Singleton

class Factory(val selectQueryGenerator: SelectQueryGenerator, val fieldTypeMapper: JdbcMetadataQuerier.FieldTypeMapper, val checkQueries: JdbcCheckQueries, val constants: DefaultJdbcConstants) : MetadataQuerier.Factory<JdbcSourceConfiguration>

Default implementation of MetadataQuerier.Factory.

FieldTypeMapper

fun interface FieldTypeMapper

Stateless connector-specific object for mapping a ColumnMetadata to a FieldType during DISCOVER.

data class PrimaryKeyRow(val name: String, val ordinal: Int, val columnName: String)

Properties

val checkQueries: JdbcCheckQueries

val config: JdbcSourceConfiguration

val conn: Connection

val constants: DefaultJdbcConstants

effectiveNamespaces

val effectiveNamespaces: Set<String>

The set of namespaces to discover against. When JdbcSourceConfiguration.namespaces is non-empty this is just that set; otherwise it is resolved at discovery time to every schema/catalog the JDBC user can see, minus DefaultJdbcConstants.ignoredNamespaces.

fieldTypeMapper

val fieldTypeMapper: JdbcMetadataQuerier.FieldTypeMapper

memoizedColumnMetadata

val memoizedColumnMetadata: Map<TableName, List<JdbcMetadataQuerier.ColumnMetadata>>

memoizedPrimaryKeys

val memoizedPrimaryKeys: MutableMap<TableName, List<List<String>>>

memoizedTableNames

val memoizedTableNames: List<TableName>

memoizedUserDefinedTypes

val memoizedUserDefinedTypes: List<UserDefinedType>

memoizedUserDefinedTypes is not directly used by JdbcMetadataQuerier. Instead, it's provided for use by other MetadataQuerier implementations which delegate to this.

selectQueryGenerator

val selectQueryGenerator: SelectQueryGenerator

tableFiltersBySchema

val tableFiltersBySchema: Map<String, List<String>>

Functions

open override fun close()

fun columnMetadata(table: TableName): List<JdbcMetadataQuerier.ColumnMetadata>

columnMetadataFromResultSet

fun columnMetadataFromResultSet(rs: ResultSet, isPseudoColumn: Boolean): Pair<TableName, JdbcMetadataQuerier.ColumnMetadata>

open override fun extraChecks()

open override fun fields(streamID: StreamIdentifier): List<EmittedField>

fun findTableName(streamID: StreamIdentifier): TableName?

fun TableName.namespace(): String?

open override fun primaryKey(streamID: StreamIdentifier): List<List<String>>

fun selectLimit0(table: TableName, columnIDs: List<String>): String

Generates SQL query used to discover ColumnMetadata and to verify table access permissions.

open override fun streamNames(streamNamespace: String?): List<StreamIdentifier>

streamNamespaces

open override fun streamNamespaces(): List<String>

fun <T> swallow(supplier: () -> T): T?