From be1557716f2666c8fcd8252a3ec4ba92d5caadae Mon Sep 17 00:00:00 2001 From: Dmitrii Date: Fri, 7 Nov 2025 16:31:23 +0300 Subject: [PATCH] =?UTF-8?q?=D0=97=D0=B0=D0=B1=D1=8B=D0=BB=D0=B8=20=D0=B7?= =?UTF-8?q?=D0=B0=D0=BF=D0=BE=D0=BB=D0=BD=D0=B8=D1=82=D1=8C=20dds.orders?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dwh-modeling/sql/02_dim.sql | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/dwh-modeling/sql/02_dim.sql b/dwh-modeling/sql/02_dim.sql index 3b3d5ae..e606904 100644 --- a/dwh-modeling/sql/02_dim.sql +++ b/dwh-modeling/sql/02_dim.sql @@ -37,6 +37,14 @@ INSERT INTO stg.products_raw (product_id, name) VALUES TRUNCATE ods.customers, ods.orders, ods.order_items, ods.products; +INSERT INTO ods.orders (order_id, order_date, customer_id) +SELECT + order_id::INT, + TO_DATE(order_date, 'YYYY-MM-DD'), + customer_id::INT +FROM stg.orders_raw +WHERE order_date IS NOT NULL AND customer_id ~ '^\d+$'; + -- берём по BK самую позднюю запись (event_ts > _load_ts > _load_id) WITH src AS ( SELECT @@ -191,5 +199,5 @@ JOIN dds.dim_customer dc -- 7. Проверка — вывод итогов (не часть ETL, но полезно для отладки) -- В реальном пайплайне такие SELECT выносятся в отдельные скрипты или дашборды --- SELECT 'dim_customer count = ' || COUNT(*) FROM dds.dim_customer; --- SELECT 'fact_sales count = ' || COUNT(*) FROM dds.fact_sales; + SELECT 'dim_customer count = ' || COUNT(*) FROM dds.dim_customer WHERE is_current ; + SELECT 'fact_sales count = ' || COUNT(*) FROM dds.fact_sales;