destination-mysql: convert prod code to kotlin

airbytehq · Jun 26, 2024 · 8ba9753 · 8ba9753
1 parent ee1c21c
commit 8ba9753
Show file tree

Hide file tree

Showing 20 changed files with 584 additions and 589 deletions.
diff --git a/airbyte-integrations/connectors/destination-mysql-strict-encrypt/metadata.yaml b/airbyte-integrations/connectors/destination-mysql-strict-encrypt/metadata.yaml
@@ -7,7 +7,7 @@ data:
   connectorSubtype: database
   connectorType: destination
   definitionId: ca81ee7c-3163-4246-af40-094cc31e5e42
-  dockerImageTag: 1.0.1
+  dockerImageTag: 1.0.2
   dockerRepository: airbyte/destination-mysql-strict-encrypt
   githubIssueLabel: destination-mysql
   icon: mysql.svg

diff --git a/...rc/main/java/io/airbyte/integrations/destination/mysql/MySQLDestinationStrictEncrypt.java b/...rc/main/java/io/airbyte/integrations/destination/mysql/MySQLDestinationStrictEncrypt.java
diff --git a/...rc/main/kotlin/io/airbyte/integrations/destination/mysql/MySQLDestinationStrictEncrypt.kt b/...rc/main/kotlin/io/airbyte/integrations/destination/mysql/MySQLDestinationStrictEncrypt.kt
@@ -0,0 +1,39 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+package io.airbyte.integrations.destination.mysql
+
+import com.fasterxml.jackson.databind.node.ObjectNode
+import io.airbyte.cdk.db.jdbc.JdbcUtils
+import io.airbyte.cdk.integrations.base.Destination
+import io.airbyte.cdk.integrations.base.IntegrationRunner
+import io.airbyte.cdk.integrations.base.spec_modification.SpecModifyingDestination
+import io.airbyte.commons.json.Jsons
+import io.airbyte.protocol.models.v0.ConnectorSpecification
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+
+class MySQLDestinationStrictEncrypt : SpecModifyingDestination(MySQLDestination.sshWrappedDestination()), Destination {
+    override fun modifySpec(originalSpec: ConnectorSpecification): ConnectorSpecification {
+        val spec: ConnectorSpecification = Jsons.clone(originalSpec)
+        (spec.connectionSpecification["properties"] as ObjectNode).remove(JdbcUtils.SSL_KEY)
+        return spec
+    }
+
+    companion object {
+        private val LOGGER: Logger = LoggerFactory.getLogger(MySQLDestinationStrictEncrypt::class.java)
+
+        @Throws(Exception::class)
+        @JvmStatic
+        fun main(args: Array<String>) {
+            val destination: Destination = MySQLDestinationStrictEncrypt()
+            LOGGER.info("starting destination: {}", MySQLDestinationStrictEncrypt::class.java)
+            try {
+                IntegrationRunner(destination).run(args)
+            } catch (e: Exception) {
+                MySQLDestination.handleException(e)
+            }
+            LOGGER.info("completed destination: {}", MySQLDestinationStrictEncrypt::class.java)
+        }
+    }
+}
diff --git a/...o/airbyte/integrations/destination/mysql/MySQLStrictEncryptDestinationAcceptanceTest.java b/...o/airbyte/integrations/destination/mysql/MySQLStrictEncryptDestinationAcceptanceTest.java
@@ -33,6 +33,7 @@
 import java.util.HashSet;
 import java.util.List;
 import java.util.stream.Collectors;
+import io.airbyte.integrations.destination.mysql.MySQLNameTransformer;
 import org.jooq.DSLContext;
 import org.jooq.SQLDialect;
 import org.junit.jupiter.api.Disabled;

diff --git a/...t-integration/java/io/airbyte/integrations/destination/mysql/MySqlTestDataComparator.java b/...t-integration/java/io/airbyte/integrations/destination/mysql/MySqlTestDataComparator.java
@@ -10,6 +10,7 @@
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.List;
+import io.airbyte.integrations.destination.mysql.MySQLNameTransformer;
 
 public class MySqlTestDataComparator extends AdvancedTestDataComparator {
 

diff --git a/airbyte-integrations/connectors/destination-mysql/metadata.yaml b/airbyte-integrations/connectors/destination-mysql/metadata.yaml
@@ -2,7 +2,7 @@ data:
   connectorSubtype: database
   connectorType: destination
   definitionId: ca81ee7c-3163-4246-af40-094cc31e5e42
-  dockerImageTag: 1.0.1
+  dockerImageTag: 1.0.2
   dockerRepository: airbyte/destination-mysql
   githubIssueLabel: destination-mysql
   icon: mysql.svg

diff --git a/...ation-mysql/src/main/java/io/airbyte/integrations/destination/mysql/MySQLDestination.java b/...ation-mysql/src/main/java/io/airbyte/integrations/destination/mysql/MySQLDestination.java
diff --git a/...n-mysql/src/main/java/io/airbyte/integrations/destination/mysql/MySQLNameTransformer.java b/...n-mysql/src/main/java/io/airbyte/integrations/destination/mysql/MySQLNameTransformer.java