diff --git a/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSource.kt b/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSource.kt index 8c51ef1c28df..a52901595532 100644 --- a/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSource.kt +++ b/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSource.kt @@ -6,6 +6,6 @@ import io.airbyte.cdk.AirbyteSourceRunner object MyDbSource { @JvmStatic fun main(args: Array) { - AirbyteSoureRunner.run(*args) + AirbyteSourceRunner.run(*args) } } diff --git a/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSourceConfiguration.kt b/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSourceConfiguration.kt index ae408e2a0da3..a9c85f5de8ed 100644 --- a/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSourceConfiguration.kt +++ b/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSourceConfiguration.kt @@ -3,13 +3,28 @@ package io.airbyte.integrations.source.mydb import io.airbyte.cdk.command.ConfigurationSpecificationSupplier import io.airbyte.cdk.command.JdbcSourceConfiguration import io.airbyte.cdk.command.SourceConfigurationFactory +import io.airbyte.cdk.ssh.SshConnectionOptions +import io.airbyte.cdk.ssh.SshTunnelMethodConfiguration import io.micronaut.context.annotation.Factory import jakarta.inject.Singleton +import java.time.Duration +import kotlin.time.toDuration data class MyDbSourceConfiguration( override val realHost: String, override val realPort: Int, override val jdbcProperties: Map, + override val jdbcUrlFmt: String = "", + override val namespaces: Set = setOf(), + override val global: Boolean = false, + override val maxSnapshotReadDuration: Duration? = null, + override val checkpointTargetInterval: Duration = Duration.ZERO, + override val maxConcurrency: Int = 1, + override val resourceAcquisitionHeartbeat: Duration = Duration.ZERO, + override val sshTunnel: SshTunnelMethodConfiguration? = null, + override val sshConnectionOptions: SshConnectionOptions = SshConnectionOptions(kotlin.time.Duration.ZERO, + kotlin.time.Duration.ZERO, kotlin.time.Duration.ZERO + ), ) : JdbcSourceConfiguration { @Factory diff --git a/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSourceConfigurationSpecification.kt b/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSourceConfigurationSpecification.kt index 25ce8575280a..299dad35d2b9 100644 --- a/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSourceConfigurationSpecification.kt +++ b/airbyte-integrations/connectors/source-mydb/src/main/kotlin/MyDbSourceConfigurationSpecification.kt @@ -1,5 +1,18 @@ +/* Copyright (c) 2024 Airbyte, Inc., all rights reserved. */ package io.airbyte.integrations.source.mydb +import com.fasterxml.jackson.annotation.JsonProperty +import com.fasterxml.jackson.annotation.JsonPropertyDescription +import com.fasterxml.jackson.annotation.JsonPropertyOrder +import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaDefault +import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaInject +import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaTitle +import edu.umd.cs.findbugs.annotations.SuppressFBWarnings +import io.airbyte.cdk.command.CONNECTOR_CONFIG_PREFIX +import io.airbyte.cdk.command.ConfigurationSpecification +import io.micronaut.context.annotation.ConfigurationProperties +import jakarta.inject.Singleton + @JsonSchemaTitle("MyDb Source Spec") @JsonPropertyOrder( value =