From aa351b566ad4d70d2c6b4f18d409994a64505dae Mon Sep 17 00:00:00 2001 From: StewKI Date: Sun, 17 May 2026 18:22:55 +0200 Subject: [PATCH] organization load sql fix --- nifi/sql/load/05_dim_organization.sql | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/nifi/sql/load/05_dim_organization.sql b/nifi/sql/load/05_dim_organization.sql index 3a4f809..09e63a0 100644 --- a/nifi/sql/load/05_dim_organization.sql +++ b/nifi/sql/load/05_dim_organization.sql @@ -2,9 +2,9 @@ INSERT INTO DIM_ORGANIZATION (org_id, name, region, country, club_partner_status VALUES ( ${organization_id}, '${name}', - ${region:isEmpty():ifElse('NULL', concat("'", ${region}, "'"))}, - ${country:isEmpty():ifElse('NULL', concat("'", ${country}, "'"))}, - ${club_partner_status:isEmpty():ifElse('NULL', concat("'", ${club_partner_status}, "'"))}, - ${founded_year:isEmpty():ifElse('NULL', ${founded_year})}, - ${social_media_followers_m:isEmpty():ifElse('NULL', ${social_media_followers_m})} + NULLIF('${region}', ''), + NULLIF('${country}', ''), + NULLIF('${club_partner_status}', ''), + TO_NUMBER(NULLIF('${founded_year}', '')), + TO_NUMBER(NULLIF('${social_media_followers_m}', '')) )