diff --git a/libs/common/src/sql/queries/fact_hourly_energy_consumed/fact_hourly_energy_consumed.sql b/libs/common/src/sql/queries/fact_hourly_energy_consumed/fact_hourly_energy_consumed.sql index 60de9fe..a3dd854 100644 --- a/libs/common/src/sql/queries/fact_hourly_energy_consumed/fact_hourly_energy_consumed.sql +++ b/libs/common/src/sql/queries/fact_hourly_energy_consumed/fact_hourly_energy_consumed.sql @@ -1,3 +1,22 @@ +CREATE OR REPLACE FUNCTION get_energy_consumption( + input_device_id UUID DEFAULT NULL, + input_start_date DATE DEFAULT NULL, + input_end_date DATE DEFAULT NULL, + input_hour INT DEFAULT NULL, + min_energy_kW INT DEFAULT NULL +) +RETURNS TABLE ( + device_id UUID, + date DATE, + hour INT, + energy_consumed_kW INT, + energy_consumed_A INT, + energy_consumed_B INT, + energy_consumed_C INT +) AS $$ +BEGIN +RETURN QUERY + WITH total_energy AS ( SELECT device_id,