🐛 Change null cursor value query to not use IIF sql function (#35405)

airbytehq · Feb 21, 2024 · c9ba9df · c9ba9df
1 parent 875df79
commit c9ba9df
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/airbyte-integrations/connectors/source-mssql/metadata.yaml b/airbyte-integrations/connectors/source-mssql/metadata.yaml
@@ -9,7 +9,7 @@ data:
   connectorSubtype: database
   connectorType: source
   definitionId: b5ea17b1-f170-46dc-bc31-cc744ca984c1
-  dockerImageTag: 3.7.0
+  dockerImageTag: 3.7.1
   dockerRepository: airbyte/source-mssql
   documentationUrl: https://docs.airbyte.com/integrations/sources/mssql
   githubIssueLabel: source-mssql

diff --git a/...nnectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlSource.java b/...nnectors/source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlSource.java
@@ -108,7 +108,7 @@ public class MssqlSource extends AbstractJdbcSource<JDBCType> implements Source
       """;
   public static final String NULL_CURSOR_VALUE_WITH_SCHEMA_QUERY =
       """
-        SELECT CAST(IIF(EXISTS(SELECT TOP 1 1 FROM "%s"."%s" WHERE "%s" IS NULL), 1, 0) AS BIT) AS %s
+        SELECT CASE WHEN (SELECT TOP 1 1 FROM "%s"."%s" WHERE "%s" IS NULL)=1 then 1 else 0 end as %s
       """;
   public static final String DRIVER_CLASS = DatabaseDriver.MSSQLSERVER.getDriverClassName();
   public static final String MSSQL_CDC_OFFSET = "mssql_cdc_offset";

diff --git a/docs/integrations/sources/mssql.md b/docs/integrations/sources/mssql.md
@@ -342,6 +342,7 @@ WHERE actor_definition_id ='b5ea17b1-f170-46dc-bc31-cc744ca984c1' AND (configura
 
 | Version | Date       | Pull Request                                                                                                      | Subject                                                                                                                                         |
 |:--------|:-----------|:------------------------------------------------------------------------------------------------------------------|:------------------------------------------------------------------------------------------------------------------------------------------------|
+| 3.7.1   | 2024-02-20 | [35405](https://github.com/airbytehq/airbyte/pull/35405)                                                          | Change query syntax to make it compatible with Azure Synapse.                                                                                   |
 | 3.7.0   | 2024-01-30 | [33311](https://github.com/airbytehq/airbyte/pull/33311)                                                          | Source mssql with checkpointing initial sync.                                                                                                   |
 | 3.6.1   | 2024-01-26 | [34573](https://github.com/airbytehq/airbyte/pull/34573)                                                          | Adopt CDK v0.16.0.                                                                                                                              |
 | 3.6.0   | 2024-01-10 | [33700](https://github.com/airbytehq/airbyte/pull/33700)                                                          | Remove CDC config options for data_to_sync and snapshot isolation.                                                                              |