fix(clickhouse): Fix clickhouse strings (#1680)

* fix(clickhouse): fix strings from json * cache is back
getlago · Feb 8, 2024 · 5c4bcaa · 5c4bcaa
1 parent 4b738f9
commit 5c4bcaa
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/db/clickhouse_migrate/20231030163703_create_events_raw_mv.rb b/db/clickhouse_migrate/20231030163703_create_events_raw_mv.rb
@@ -10,7 +10,7 @@ def change
         transaction_id,
         toDateTime64(timestamp, 3) as timestamp,
         code,
-        cast(JSONExtractKeysAndValuesRaw(properties), 'Map(String, String)') as properties
+        JSONExtract(properties, 'Map(String, String)') as properties
       FROM events_raw_queue
     SQL
 

diff --git a/db/clickhouse_schema.rb b/db/clickhouse_schema.rb
@@ -37,8 +37,8 @@
   end
 
   # TABLE: events_raw_mv
-  # SQL: CREATE MATERIALIZED VIEW default.events_raw_mv TO default.events_raw ( `organization_id` String, `external_customer_id` String, `external_subscription_id` String, `transaction_id` String, `timestamp` DateTime64(3), `code` String, `properties` Map(String, String) ) AS SELECT organization_id, external_customer_id, external_subscription_id, transaction_id, toDateTime64(timestamp, 3) AS timestamp, code, CAST(JSONExtractKeysAndValuesRaw(properties), 'Map(String, String)') AS properties FROM default.events_raw_queue
-  create_table "events_raw_mv", view: true, materialized: true, id: false, as: "SELECT organization_id, external_customer_id, external_subscription_id, transaction_id, toDateTime64(timestamp, 3) AS timestamp, code, CAST(JSONExtractKeysAndValuesRaw(properties), 'Map(String, String)') AS properties FROM default.events_raw_queue", force: :cascade do |t|
+  # SQL: CREATE MATERIALIZED VIEW default.events_raw_mv TO default.events_raw ( `organization_id` String, `external_customer_id` String, `external_subscription_id` String, `transaction_id` String, `timestamp` DateTime64(3), `code` String, `properties` Map(String, String) ) AS SELECT organization_id, external_customer_id, external_subscription_id, transaction_id, toDateTime64(timestamp, 3) AS timestamp, code, JSONExtract(properties, 'Map(String, String)') AS properties FROM default.events_raw_queue
+  create_table "events_raw_mv", view: true, materialized: true, id: false, as: "SELECT organization_id, external_customer_id, external_subscription_id, transaction_id, toDateTime64(timestamp, 3) AS timestamp, code, JSONExtract(properties, 'Map(String, String)') AS properties FROM default.events_raw_queue", force: :cascade do |t|
   end
 
 end