Change null cursor value query to not use IIF sql function

airbytehq · Feb 19, 2024 · 8324933 · 8324933
1 parent 27abc6d
commit 8324933
Showing 1 changed file with 1 addition and 1 deletion.
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";