source-mssql: convert to bulk CDK

airbyte-cdk/bulk/toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/CdcPartitionsCreatorFactory.kt

@@ -9,6 +9,7 @@ import io.airbyte.cdk.read.FeedBootstrap
 import io.airbyte.cdk.read.GlobalFeedBootstrap
 import io.airbyte.cdk.read.PartitionsCreator
 import io.airbyte.cdk.read.PartitionsCreatorFactory
+import io.github.oshai.kotlinlogging.KotlinLogging
 import io.micronaut.core.annotation.Order
 import jakarta.inject.Singleton
 import java.util.concurrent.atomic.AtomicReference

airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/discover/JdbcAirbyteStreamFactory.kt

@@ -8,6 +8,7 @@ import io.airbyte.cdk.jdbc.JsonStringFieldType
 import io.airbyte.cdk.jdbc.NCharacterStreamFieldType
 import io.airbyte.cdk.jdbc.NClobFieldType
 import io.airbyte.protocol.models.v0.SyncMode
+import io.github.oshai.kotlinlogging.KotlinLogging
 
 /** [JdbcAirbyteStreamFactory] implements [createGlobal] and [createNonGlobal] for JDBC sourcesx. */
 interface JdbcAirbyteStreamFactory : AirbyteStreamFactory, MetaFieldDecorator {

airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/JdbcPartitionsCreatorFactory.kt

@@ -5,6 +5,7 @@
 package io.airbyte.cdk.read
 
 import io.airbyte.cdk.jdbc.JDBC_PROPERTY_PREFIX
+import io.github.oshai.kotlinlogging.KotlinLogging
 import io.micronaut.context.annotation.Requires
 import jakarta.inject.Singleton
 

airbyte-integrations/connectors/source-mssql-v1/README.md

@@ -0,0 +1,33 @@
+# MsSQL (SQL Server) Source
+
+## Performance Test
+
+To run performance tests in commandline:
+
+```shell
+./gradlew :airbyte-integrations:connectors:source-mssql:performanceTest [--cpulimit=cpulimit/<limit>] [--memorylimit=memorylimit/<limit>]
+```
+
+In pull request:
+
+```shell
+/test-performance connector=connectors/source-mssql [--cpulimit=cpulimit/<limit>] [--memorylimit=memorylimit/<limit>]
+```
+
+- `cpulimit`: Limit the number of CPUs. The minimum is `2`. E.g. `--cpulimit=cpulimit/2`.
+- `memorylimit`: Limit the size of the memory. Must include the unit at the end (e.g. `MB`, `GB`). The minimum size is `6MB`. E.g. `--memorylimit=memorylimit/4GB`.
+- When none of the CPU or memory limit is provided, the performance tests will run without memory or CPU limitations. The available resource will be bound that those specified in `ResourceRequirements.java`.
+
+### Use MsSQL script to populate the benchmark database
+
+In order to create a database with a certain number of tables, and a certain number of records in each of them,
+you need to follow a few simple steps.
+
+1. Create a new database.
+2. Follow the TODOs in [create_mssql_benchmarks.sql](src/test-performance/sql/create_mssql_benchmarks.sql) to change the number of tables, and the number of records of different sizes.
+3. Execute the script with your changes for the new database. You can run the script with the MySQL client:
+   ```bash
+   cd airbyte-integrations/connectors/source-mssql
+   sqlcmd -S Serverinstance -E -i src/test-performance/sql/create_mssql_benchmarks.sql
+   ```
+4. After the script finishes its work, you will receive the number of tables specified in the script, with names starting with **test_0** and ending with **test\_(the number of tables minus 1)**.

airbyte-integrations/connectors/source-mssql-v1/acceptance-test-config.yml

@@ -0,0 +1,9 @@
+# See [Connector Acceptance Tests](https://docs.airbyte.com/connector-development/testing-connectors/connector-acceptance-tests-reference)
+# for more information about how to configure these tests
+connector_image: airbyte/source-mssql:dev
+tests:
+  spec:
+    - spec_path: "src/test-integration/resources/expected_spec.json"
+      config_path: "src/test-integration/resources/dummy_config.json"
+      backward_compatibility_tests_config:
+        disable_for_version: "0.4.25"

airbyte-integrations/connectors/source-mssql-v1/build.gradle

@@ -0,0 +1,41 @@
+plugins {
+    id 'airbyte-java-connector'
+}
+
+airbyteJavaConnector {
+    cdkVersionRequired = '0.45.1'
+    features = ['db-sources']
+    useLocalCdk = false
+}
+
+java {
+    // TODO: rewrite code to avoid javac warnings in the first place
+    compileJava {
+        options.compilerArgs += "-Xlint:-try,-rawtypes"
+    }
+    compileTestFixturesJava {
+        options.compilerArgs += "-Xlint:-this-escape"
+    }
+}
+
+application {
+    mainClass = 'io.airbyte.integrations.source.mssql.MssqlSource'
+    applicationDefaultJvmArgs = ['-XX:+ExitOnOutOfMemoryError', '-XX:MaxRAMPercentage=75.0']
+}
+
+dependencies {
+    implementation 'com.microsoft.sqlserver:mssql-jdbc:12.6.1.jre11'
+    implementation 'io.debezium:debezium-embedded:2.7.1.Final'
+    implementation 'io.debezium:debezium-connector-sqlserver:2.6.2.Final'
+    implementation 'org.codehaus.plexus:plexus-utils:3.4.2'
+
+    testFixturesImplementation 'org.testcontainers:mssqlserver:1.19.0'
+
+    testImplementation 'org.awaitility:awaitility:4.2.0'
+    testImplementation 'org.hamcrest:hamcrest-all:1.3'
+    testImplementation 'org.testcontainers:mssqlserver:1.19.0'
+}
+
+compileKotlin {
+
+}

airbyte-integrations/connectors/source-mssql-v1/gradle.properties

@@ -0,0 +1,2 @@
+testExecutionConcurrency=-1
+JunitMethodExecutionTimeout=5 m

airbyte-integrations/connectors/source-mssql-v1/integration_tests/acceptance.py

@@ -0,0 +1,16 @@
+#
+# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+#
+
+
+import pytest
+
+pytest_plugins = ("connector_acceptance_test.plugin",)
+
+
+@pytest.fixture(scope="session", autouse=True)
+def connector_setup():
+    """This fixture is a placeholder for external resources that acceptance test might require."""
+    # TODO: setup test dependencies if needed. otherwise remove the TODO comments
+    yield
+    # TODO: clean up test dependencies