use replace function only when null is present (#21523)

* use replace function only when null is present

* upgrade version

* auto-bump connector version

Co-authored-by: Octavia Squidington III <[email protected]>

Author: subodh1810

airbyte-config/init/src/main/resources/seed/source_definitions.yaml

@@ -1341,7 +1341,7 @@
 - name: Postgres
   sourceDefinitionId: decd338e-5647-4c0b-adf4-da0e75f5a750
   dockerRepository: airbyte/source-postgres
-  dockerImageTag: 1.0.41
+  dockerImageTag: 1.0.42
   documentationUrl: https://docs.airbyte.com/integrations/sources/postgres
   icon: postgresql.svg
   sourceType: database

airbyte-config/init/src/main/resources/seed/source_specs.yaml

@@ -11606,7 +11606,7 @@
     supportsNormalization: false
     supportsDBT: false
     supported_destination_sync_modes: []
-- dockerImage: "airbyte/source-postgres:1.0.41"
+- dockerImage: "airbyte/source-postgres:1.0.42"
   spec:
     documentationUrl: "https://docs.airbyte.com/integrations/sources/postgres"
     connectionSpecification:

airbyte-integrations/connectors/source-postgres-strict-encrypt/Dockerfile

@@ -16,5 +16,5 @@ ENV APPLICATION source-postgres-strict-encrypt
 
 COPY --from=build /airbyte /airbyte
 
-LABEL io.airbyte.version=1.0.41
+LABEL io.airbyte.version=1.0.42
 LABEL io.airbyte.name=airbyte/source-postgres-strict-encrypt

airbyte-integrations/connectors/source-postgres/Dockerfile

@@ -16,5 +16,5 @@ ENV APPLICATION source-postgres
 
 COPY --from=build /airbyte /airbyte
 
-LABEL io.airbyte.version=1.0.41
+LABEL io.airbyte.version=1.0.42
 LABEL io.airbyte.name=airbyte/source-postgres

airbyte-integrations/connectors/source-relational-db/src/main/java/io/airbyte/integrations/source/relationaldb/StateDecoratingIterator.java

@@ -88,7 +88,14 @@ public StateDecoratingIterator(final Iterator<AirbyteMessage> messageIterator,
 
   private String getCursorCandidate(final AirbyteMessage message) {
     final String cursorCandidate = message.getRecord().getData().get(cursorField).asText();
-    return (cursorCandidate != null ? cursorCandidate.replaceAll("\u0000", "") : null);
+    return (cursorCandidate != null ? replaceNull(cursorCandidate) : null);
+  }
+
+  private String replaceNull(final String cursorCandidate) {
+    if (cursorCandidate.contains("\u0000")) {
+      return cursorCandidate.replaceAll("\u0000", "");
+    }
+    return cursorCandidate;
   }
 
   /**

docs/integrations/sources/postgres.md

@@ -411,6 +411,7 @@ The root causes is that the WALs needed for the incremental sync has been remove
 
 | Version | Date       | Pull Request                                             | Subject                                                                                                                                                                    |
 |:--------|:-----------|:---------------------------------------------------------|:---------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| 1.0.42  | 2022-01-23 | [21523](https://github.com/airbytehq/airbyte/pull/21523) | Check for null in cursor values before replacing.                                                                                                                          |  
 | 1.0.41  | 2022-01-25 | [20939](https://github.com/airbytehq/airbyte/pull/20939) | Adjust batch selection memory limits databases.                                                                                                                            |  
 | 1.0.40  | 2023-01-24 | [21825](https://github.com/airbytehq/airbyte/pull/21825) | Put back the original change that will cause an incremental sync to error if table contains a NULL value in cursor column.                                                 |
 | 1.0.39  | 2023-01-20 | [21683](https://github.com/airbytehq/airbyte/pull/21683) | Speed up esmtimates for trace messages in non-CDC mode.                                                                                                                    |