Airbyte Kotlin Bulk CDK

0.1.92

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

Package-level declarations

Types

data object AnyAccessor : JdbcAccessor<Any>

data class AnySetter(val sqlType: Int) : JdbcSetter<Any>

data class ArrayFieldType<T>(val elementFieldType: JdbcFieldType<T>) : JdbcFieldType<List<T>>

data class ArrayGetter<T>(val elementGetter: JdbcGetter<T>) : JdbcGetter<List<T>>

data class ArraySetter(val elementSqlTypeName: String) : JdbcSetter<List<Any?>>

BigDecimalAccessor

data object BigDecimalAccessor : JdbcAccessor<BigDecimal>

BigDecimalFieldType

data object BigDecimalFieldType : SymmetricJdbcFieldType<BigDecimal>

BigIntegerFieldType

data object BigIntegerFieldType : SymmetricJdbcFieldType<BigDecimal>

BinaryStreamAccessor

data object BinaryStreamAccessor : JdbcAccessor<ByteBuffer>

BinaryStreamAccessor uses a ByteBuffer instead of a ByteArray so that Micronaut doesn't go crazy.

BinaryStreamFieldType

data object BinaryStreamFieldType : SymmetricJdbcFieldType<ByteBuffer>

BooleanAccessor

data object BooleanAccessor : JdbcAccessor<Boolean>

BooleanFieldType

data object BooleanFieldType : SymmetricJdbcFieldType<Boolean>

data object ByteAccessor : JdbcAccessor<Byte>

data object ByteFieldType : SymmetricJdbcFieldType<Byte>

data object BytesAccessor : JdbcAccessor<ByteBuffer>

BytesAccessor uses a ByteBuffer instead of a ByteArray so that Micronaut doesn't go crazy.

data object BytesFieldType : SymmetricJdbcFieldType<ByteBuffer>

CharacterStreamAccessor

data object CharacterStreamAccessor : JdbcAccessor<String>

CharacterStreamFieldType

data object CharacterStreamFieldType : SymmetricJdbcFieldType<String>

data object ClobAccessor : JdbcAccessor<String>

data object ClobFieldType : SymmetricJdbcFieldType<String>

data object DateAccessor : JdbcAccessor<LocalDate>

DefaultJdbcConstants

@ConfigurationProperties(value = "airbyte.connector.extract.jdbc")

data class DefaultJdbcConstants(val withSampling: Boolean = WITH_SAMPLING, val maxSampleSize: Int = TABLE_SAMPLE_SIZE, val expectedThroughputBytesPerSecond: Long = THROUGHPUT_BYTES_PER_SECOND, val minFetchSize: Int = FETCH_SIZE_LOWER_BOUND, val defaultFetchSize: Int = DEFAULT_FETCH_SIZE, val maxFetchSize: Int = FETCH_SIZE_UPPER_BOUND, val memoryCapacityRatio: Double = MEM_CAPACITY_RATIO, val estimatedRecordOverheadBytes: Long = RECORD_OVERHEAD_BYTES, val estimatedFieldOverheadBytes: Long = FIELD_OVERHEAD_BYTES, val maxMemoryBytesForTesting: Long? = null, val namespaceKind: DefaultJdbcConstants.NamespaceKind = NamespaceKind.SCHEMA)

data object DoubleAccessor : JdbcAccessor<Double>

DoubleFieldType

data object DoubleFieldType : SymmetricJdbcFieldType<Double>

data object FloatAccessor : JdbcAccessor<Float>

data object FloatFieldType : SymmetricJdbcFieldType<Float>

data object IntAccessor : JdbcAccessor<Int>

data object IntFieldType : SymmetricJdbcFieldType<Int>

interface JdbcAccessor<T> : JdbcGetter<T> , JdbcSetter<T>

Combination of JdbcGetter and JdbcSetter.

JdbcConnectionFactory

@Singleton

class JdbcConnectionFactory(val config: JdbcSourceConfiguration) : Supplier<Connection>

Factory for creating java.sql.Connection, with possible SSH tunneling.

abstract class JdbcFieldType<R>(val airbyteSchemaType: AirbyteSchemaType, val jdbcGetter: JdbcGetter<out R>, val jsonEncoder: JsonEncoder<R>) : FieldType, JdbcGetter<JsonNode>

Convenience class for defining concrete FieldType objects.

fun interface JdbcGetter<T>

Thin wrapper around ResultSet get* methods, e.g. ResultSet.getString.

fun interface JdbcSetter<T>

Thin wrapper around PreparedStatement set* methods, e.g. PreparedStatement.setString.

JsonStringFieldType

data object JsonStringFieldType : SymmetricJdbcFieldType<String>

LocalDateFieldType

data object LocalDateFieldType : SymmetricJdbcFieldType<LocalDate>

LocalDateTimeFieldType

data object LocalDateTimeFieldType : SymmetricJdbcFieldType<LocalDateTime>

LocalTimeFieldType

data object LocalTimeFieldType : SymmetricJdbcFieldType<LocalTime>

data object LongAccessor : JdbcAccessor<Long>

data object LongFieldType : SymmetricJdbcFieldType<Long>

LosslessJdbcFieldType

abstract class LosslessJdbcFieldType<R, W>(airbyteSchemaType: AirbyteSchemaType, jdbcGetter: JdbcGetter<out R>, jsonEncoder: JsonEncoder<R>, val jsonDecoder: JsonDecoder<W>, val jdbcSetter: JdbcSetter<in W>) : JdbcFieldType<R> , LosslessFieldType, JdbcSetter<JsonNode>

Convenience class for defining concrete LosslessFieldType objects.

NCharacterStreamAccessor

data object NCharacterStreamAccessor : JdbcAccessor<String>

NCharacterStreamFieldType

data object NCharacterStreamFieldType : SymmetricJdbcFieldType<String>

data object NClobAccessor : JdbcAccessor<String>

data object NClobFieldType : SymmetricJdbcFieldType<String>

NStringAccessor

data object NStringAccessor : JdbcAccessor<String>

NStringFieldType

data object NStringFieldType : SymmetricJdbcFieldType<String>

data object NullFieldType : JdbcFieldType<Any?>

data class ObjectGetter<T>(val type: Class<T>) : JdbcGetter<T>

OffsetDateTimeFieldType

data object OffsetDateTimeFieldType : LosslessJdbcFieldType<OffsetDateTime, OffsetDateTime>

OffsetTimeFieldType

data object OffsetTimeFieldType : LosslessJdbcFieldType<OffsetTime, OffsetTime>

PokemonFieldType

data object PokemonFieldType : JdbcFieldType<Any>

SapHanaArrayFieldType

data class SapHanaArrayFieldType<T>(val elementFieldType: JdbcFieldType<T>) : JdbcFieldType<List<T>>

SapHanaArrayGetter

data class SapHanaArrayGetter<T>(val elementFieldType: JdbcFieldType<T>) : JdbcGetter<List<T>>

data object ShortAccessor : JdbcAccessor<Short>

data object ShortFieldType : SymmetricJdbcFieldType<Short>

SSLCertificateUtils

object SSLCertificateUtils

General SSL utilities used for certificate and keystore operations related to secured db connections.

data object StringAccessor : JdbcAccessor<String>

StringFieldType

data object StringFieldType : SymmetricJdbcFieldType<String>

SymmetricJdbcFieldType

abstract class SymmetricJdbcFieldType<T>(airbyteSchemaType: AirbyteSchemaType, jdbcAccessor: JdbcAccessor<T>, jsonCodec: JsonCodec<T>) : LosslessJdbcFieldType<T, T>

Convenience class for defining concrete LosslessFieldType objects.

data object TimeAccessor : JdbcAccessor<LocalTime>

TimestampAccessor

data object TimestampAccessor : JdbcAccessor<LocalDateTime>

data object UrlAccessor : JdbcAccessor<URL>

data object UrlFieldType : SymmetricJdbcFieldType<URL>

data object XmlAccessor : JdbcAccessor<String>

data object XmlFieldType : SymmetricJdbcFieldType<String>

Properties

JDBC_PROPERTY_PREFIX

const val JDBC_PROPERTY_PREFIX: String