fix: integration ksql niscode to int

Informatievlaanderen · Dec 12, 2023 · ca0b4d5 · ca0b4d5
1 parent 379ca96
commit ca0b4d5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/.ksql/INTEGRATIONDB/INTEGRATIONDB_ADDRESS_CONNECTOR.sql b/.ksql/INTEGRATIONDB/INTEGRATIONDB_ADDRESS_CONNECTOR.sql
@@ -15,7 +15,7 @@ CREATE SINK CONNECTOR `AddressIntegrationDbConnector` with (
     "db.name"= 'postgres',
     "ssl.mode"= 'require',
     "insert.mode"= 'UPSERT',
-    "table.name.format"= 'Integration.Address',
+    "table.name.format"= 'Integration.Addresses',
     "table.types"= 'TABLE',
     "db.timezone"= 'UTC',
     "pk.mode"= 'record_key',

diff --git a/.ksql/INTEGRATIONDB/INTEGRATIONDB_ADDRESS_SNAPSHOT_OSLO_STREAM_FLATTEN.sql b/.ksql/INTEGRATIONDB/INTEGRATIONDB_ADDRESS_SNAPSHOT_OSLO_STREAM_FLATTEN.sql
@@ -5,8 +5,8 @@ SELECT
   CAST(REDUCE(SPLIT(URL_EXTRACT_PATH(MESSAGEKEY), '/'), '', (s,x) => x) AS INT) PersistentLocalId,
 
   CAST(GEMEENTE->OBJECTID AS INT) AS "NisCode",
-  IFNULL(POSTINFO->OBJECTID, '') as "PostalCode",
-  CAST(IFNULL(STRAATNAAM->OBJECTID, '') AS INT) as "StreetNamePersistentLocalId",
+  POSTINFO->OBJECTID as "PostalCode",
+  CAST(STRAATNAAM->OBJECTID AS INT) as "StreetNamePersistentLocalId",
   ADRESSTATUS as "Status",
   HUISNUMMER as "HouseNumber",
   BUSNUMMER as "BoxNumber",