destination-mysql: convert prod code to kotlin

airbyte-integrations/connectors/destination-mssql-strict-encrypt/src/main/java/io/airbyte/integrations/destination/mssql_strict_encrypt/MssqlStrictEncryptDestination.java

@@ -1,41 +1,37 @@
 /*
  * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
  */
-
-package io.airbyte.integrations.destination.mssql_strict_encrypt;
-
-import com.fasterxml.jackson.databind.node.ArrayNode;
-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.integrations.destination.mssql.MSSQLDestination;
-import io.airbyte.protocol.models.v0.ConnectorSpecification;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class MssqlStrictEncryptDestination extends SpecModifyingDestination implements Destination {
-
-  private static final Logger LOGGER = LoggerFactory.getLogger(MssqlStrictEncryptDestination.class);
-
-  public MssqlStrictEncryptDestination() {
-    super(MSSQLDestination.sshWrappedDestination());
-  }
-
-  public static void main(final String[] args) throws Exception {
-    final Destination destination = new MssqlStrictEncryptDestination();
-    LOGGER.info("starting destination: {}", MssqlStrictEncryptDestination.class);
-    new IntegrationRunner(destination).run(args);
-    LOGGER.info("completed destination: {}", MssqlStrictEncryptDestination.class);
-  }
-
-  @Override
-  public ConnectorSpecification modifySpec(final ConnectorSpecification originalSpec) {
-    final ConnectorSpecification spec = Jsons.clone(originalSpec);
-    // Remove the first element in the "ssl_method" array, because it allows users to choose an
-    // unencrypted connection.
-    ((ArrayNode) spec.getConnectionSpecification().get("properties").get("ssl_method").get("oneOf")).remove(0);
-    return spec;
-  }
-
+package io.airbyte.integrations.destination.mssql_strict_encrypt
+
+import com.fasterxml.jackson.databind.node.ArrayNode
+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.integrations.destination.mssql.MSSQLDestination
+import io.airbyte.protocol.models.v0.ConnectorSpecification
+import org.apache.http.client.utils.CloneUtils
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+
+class MssqlStrictEncryptDestination : SpecModifyingDestination(MSSQLDestination.sshWrappedDestination()), Destination {
+    override fun modifySpec(originalSpec: ConnectorSpecification): ConnectorSpecification {
+        val spec: ConnectorSpecification = CloneUtils.cloneObject(originalSpec)
+        // Remove the first element in the "ssl_method" array, because it allows users to choose an
+        // unencrypted connection.
+        (spec.connectionSpecification["properties"]["ssl_method"]["oneOf"] as ArrayNode).remove(0)
+        return spec
+    }
+
+    companion object {
+        private val LOGGER: Logger = LoggerFactory.getLogger(MssqlStrictEncryptDestination::class.java)
+
+        @Throws(Exception::class)
+        @JvmStatic
+        fun main(args: Array<String>) {
+            val destination: Destination = MssqlStrictEncryptDestination()
+            LOGGER.info("starting destination: {}", MssqlStrictEncryptDestination::class.java)
+            IntegrationRunner(destination).run(args)
+            LOGGER.info("completed destination: {}", MssqlStrictEncryptDestination::class.java)
+        }
+    }
 }

airbyte-integrations/connectors/destination-mysql-strict-encrypt/src/main/java/io/airbyte/integrations/destination/mysql/MySQLDestinationStrictEncrypt.kt

@@ -0,0 +1,37 @@
+/*
+ * 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.integrations.base.Destination
+import io.airbyte.cdk.integrations.base.IntegrationRunner
+import io.airbyte.cdk.integrations.base.spec_modification.SpecModifyingDestination
+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 = clone.clone<ConnectorSpecification>(originalSpec)
+        (spec.connectionSpecification["properties"] as ObjectNode).remove(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)
+        }
+    }
+}

airbyte-integrations/connectors/destination-mysql-strict-encrypt/src/test-integration/java/io/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;

airbyte-integrations/connectors/destination-mysql-strict-encrypt/src/test-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 {