diff --git a/database/load/002-dim_inventory.sql b/database/load/002-dim_inventory.sql index 5a79a811e6b472d088ae9e217699efea94b3fc44..a6b62d4bb4584f32d7659c70d8ee5e022d3648dd 100644 --- a/database/load/002-dim_inventory.sql +++ b/database/load/002-dim_inventory.sql @@ -35,7 +35,8 @@ BEGIN s.disk2_model = d.disk2_model AND s.disk2_size >= d.disk2_size * 0.9 AND s.disk2_size <= d.disk2_size * 1.1 AND - s.disk2_used = d.disk2_used) LOOP + s.disk2_used = d.disk2_used) + WHERE valid = '1' LOOP -- IF .... THEN diff --git a/database/load/003-fact_contact.sql b/database/load/003-fact_contact.sql index c9cb914448b614ed35a2a7a99902a1221a795895..8fc92365f6ce2048a75e8db679ac1754c7655ec4 100644 --- a/database/load/003-fact_contact.sql +++ b/database/load/003-fact_contact.sql @@ -16,7 +16,7 @@ BEGIN -- INSERT INTO fact_contact (sch_id, cit_id, dat_id, macaddr) - (SELECT sch_id, cit_id, contact_date, macaddr::macaddr FROM sa_inventory) + (SELECT sch_id, cit_id, contact_date, macaddr::macaddr FROM sa_inventory WHERE valid = '1') EXCEPT (SELECT sch_id, cit_id, dat_id, macaddr FROM fact_contact WHERE dat_id >= result.min_date AND dat_id <= result.max_date);