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

ColumnMetadata

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

Factory

@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.

PrimaryKeyRow

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

Properties

checkQueries

val checkQueries: JdbcCheckQueries

config

val config: JdbcSourceConfiguration

conn

val conn: Connection

constants

val constants: DefaultJdbcConstants

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()

columnMetadata

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

columnMetadataFromResultSet

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

extraChecks

open override fun extraChecks()

fields

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

findTableName

fun findTableName(streamID: StreamIdentifier): TableName?

namespace

fun TableName.namespace(): String?

primaryKey

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

selectLimit0

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

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

streamNames

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

streamNamespaces

open override fun streamNamespaces(): List<String>

swallow

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