diff options
author | Ebus-at-dockstar <ebus@dockstar> | 2013-03-25 10:24:28 +0100 |
---|---|---|
committer | Ebus-at-dockstar <ebus@dockstar> | 2013-03-25 10:24:43 +0100 |
commit | 862282ce99760832d3e9e5b4b1171b861105e004 (patch) | |
tree | 0e229418e391917b79d42a8bdee46fb7a8612895 /sql/populate_cache.sql | |
parent | 9522cdffa94f278eb5e1894600535986e22c2890 (diff) | |
download | ebus-alt-862282ce99760832d3e9e5b4b1171b861105e004.tar.gz ebus-alt-862282ce99760832d3e9e5b4b1171b861105e004.zip |
move old stuff away
Diffstat (limited to 'sql/populate_cache.sql')
-rw-r--r-- | sql/populate_cache.sql | 45 |
1 files changed, 0 insertions, 45 deletions
diff --git a/sql/populate_cache.sql b/sql/populate_cache.sql deleted file mode 100644 index 2733cbb..0000000 --- a/sql/populate_cache.sql +++ /dev/null @@ -1,45 +0,0 @@ -drop table value_cache cascade; - -CREATE TABLE value_cache ( - value_real integer, - timestamp timestamp, - sensor_id integer -); - -create or replace view vi_value_cache as - SELECT timestamp, sensor_id, value_real, 'CACHE' - FROM value_cache -UNION - SELECT date_trunc('hour', timestamp), sensor_id, COALESCE(avg(value_int),avg(value_float)), 'LIVE' - FROM value - WHERE date_trunc('hour', timestamp) > coalesce((select max(timestamp) from value_cache), - CURRENT_TIMESTAMP - interval '2 days') -GROUP BY date_trunc('hour', timestamp), sensor_id; -; - - -CREATE OR REPLACE FUNCTION value_cache_aktualisieren() RETURNS timestamp AS $value_cache_aktualisieren$ -DECLARE - last_update timestamp = CURRENT_TIMESTAMP; -BEGIN - select max(date_trunc('hour'::text, "timestamp")) - into last_update - from value_cache; - - RAISE NOTICE 'last update=%', last_update; - if last_update is NULL then - last_update = CURRENT_TIMESTAMP - interval '20 days'; - RAISE NOTICE 'last update set to %', last_update; - end if; - - delete from value_cache where timestamp >= last_update; - - insert into value_cache - select COALESCE(avg(value_float),avg(value_int)), date_trunc('hour', timestamp), sensor_id - from value - where date_trunc('hour', timestamp) > last_update - group by date_trunc('hour', timestamp), sensor_id; - - RETURN last_update; -END; -$value_cache_aktualisieren$ LANGUAGE plpgsql; |