From 479683a7004c8822c799521b69d3fbc845abe148 Mon Sep 17 00:00:00 2001 From: Jonathan Pearlin Date: Thu, 19 Dec 2024 12:51:52 -0500 Subject: [PATCH] Refactor from PR feedback --- .../destination/mssql/v2/convert}/AirbyteTypeToSqlType.kt | 4 +++- .../destination/mssql/v2/convert}/AirbyteValueToSqlValue.kt | 2 +- .../destination/mssql/v2/model}/SqlModels.kt | 2 +- .../destination/mssql/v2/convert}/AirbyteTypeToSqlTypeTest.kt | 2 +- .../mssql/v2/convert}/AirbyteValueToSqlValueTest.kt | 2 +- 5 files changed, 7 insertions(+), 5 deletions(-) rename airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/{cdk/load/data/sql => integrations/destination/mssql/v2/convert}/AirbyteTypeToSqlType.kt (94%) rename airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/{cdk/load/data/sql => integrations/destination/mssql/v2/convert}/AirbyteValueToSqlValue.kt (98%) rename airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/{cdk/load/data/sql => integrations/destination/mssql/v2/model}/SqlModels.kt (95%) rename airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/{cdk/load/data/sql => integrations/destination/mssql/v2/convert}/AirbyteTypeToSqlTypeTest.kt (98%) rename airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/{cdk/load/data/sql => integrations/destination/mssql/v2/convert}/AirbyteValueToSqlValueTest.kt (99%) diff --git a/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/AirbyteTypeToSqlType.kt b/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteTypeToSqlType.kt similarity index 94% rename from airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/AirbyteTypeToSqlType.kt rename to airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteTypeToSqlType.kt index 29edcd6193ac..0f4a50ac7e6c 100644 --- a/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/AirbyteTypeToSqlType.kt +++ b/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteTypeToSqlType.kt @@ -2,7 +2,7 @@ * Copyright (c) 2024 Airbyte, Inc., all rights reserved. */ -package io.airbyte.cdk.load.data.sql +package io.airbyte.integrations.destination.mssql.v2.convert import io.airbyte.cdk.load.data.AirbyteType import io.airbyte.cdk.load.data.ArrayType @@ -21,6 +21,8 @@ import io.airbyte.cdk.load.data.TimestampTypeWithTimezone import io.airbyte.cdk.load.data.TimestampTypeWithoutTimezone import io.airbyte.cdk.load.data.UnionType import io.airbyte.cdk.load.data.UnknownType +import io.airbyte.integrations.destination.mssql.v2.model.SqlColumn +import io.airbyte.integrations.destination.mssql.v2.model.SqlTable import java.sql.Types /** CDK pipeline [AirbyteType] to SQL [Types] converter. */ diff --git a/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/AirbyteValueToSqlValue.kt b/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteValueToSqlValue.kt similarity index 98% rename from airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/AirbyteValueToSqlValue.kt rename to airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteValueToSqlValue.kt index 060a77bd98be..c3c1fede77e9 100644 --- a/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/AirbyteValueToSqlValue.kt +++ b/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteValueToSqlValue.kt @@ -2,7 +2,7 @@ * Copyright (c) 2024 Airbyte, Inc., all rights reserved. */ -package io.airbyte.cdk.load.data.sql +package io.airbyte.integrations.destination.mssql.v2.convert import io.airbyte.cdk.load.data.AirbyteValue import io.airbyte.cdk.load.data.ArrayValue diff --git a/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/SqlModels.kt b/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/model/SqlModels.kt similarity index 95% rename from airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/SqlModels.kt rename to airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/model/SqlModels.kt index 875850df9b80..59f4457b61e1 100644 --- a/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/cdk/load/data/sql/SqlModels.kt +++ b/airbyte-integrations/connectors/destination-mssql-v2/src/main/kotlin/io/airbyte/integrations/destination/mssql/v2/model/SqlModels.kt @@ -2,7 +2,7 @@ * Copyright (c) 2024 Airbyte, Inc., all rights reserved. */ -package io.airbyte.cdk.load.data.sql +package io.airbyte.integrations.destination.mssql.v2.model import java.sql.Types diff --git a/airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/cdk/load/data/sql/AirbyteTypeToSqlTypeTest.kt b/airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteTypeToSqlTypeTest.kt similarity index 98% rename from airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/cdk/load/data/sql/AirbyteTypeToSqlTypeTest.kt rename to airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteTypeToSqlTypeTest.kt index 9ffc75691f0a..24ec8aea1da3 100644 --- a/airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/cdk/load/data/sql/AirbyteTypeToSqlTypeTest.kt +++ b/airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteTypeToSqlTypeTest.kt @@ -2,7 +2,7 @@ * Copyright (c) 2024 Airbyte, Inc., all rights reserved. */ -package io.airbyte.cdk.load.data.sql +package io.airbyte.integrations.destination.mssql.v2.convert import com.fasterxml.jackson.databind.JsonNode import io.airbyte.cdk.load.data.ArrayType diff --git a/airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/cdk/load/data/sql/AirbyteValueToSqlValueTest.kt b/airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteValueToSqlValueTest.kt similarity index 99% rename from airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/cdk/load/data/sql/AirbyteValueToSqlValueTest.kt rename to airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteValueToSqlValueTest.kt index 06d35ff4f2d1..0fa25c1624f5 100644 --- a/airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/cdk/load/data/sql/AirbyteValueToSqlValueTest.kt +++ b/airbyte-integrations/connectors/destination-mssql-v2/src/test/kotlin/io/airbyte/integrations/destination/mssql/v2/convert/AirbyteValueToSqlValueTest.kt @@ -2,7 +2,7 @@ * Copyright (c) 2024 Airbyte, Inc., all rights reserved. */ -package io.airbyte.cdk.load.data.sql +package io.airbyte.integrations.destination.mssql.v2.convert import io.airbyte.cdk.load.data.ArrayValue import io.airbyte.cdk.load.data.DateValue