diff options
author | yvesf <yvesf-git@xapek.org> | 2011-07-24 13:12:14 +0200 |
---|---|---|
committer | yvesf <yvesf-git@xapek.org> | 2011-07-24 13:12:14 +0200 |
commit | 02f48f7a905973428fc7766cf92bb04614e1fdca (patch) | |
tree | d80aa26d4fec9b293ae135c29b10fc071df8ef71 /trigger.sql | |
parent | 75017423563a18986aa096566d8a2969c32c3588 (diff) | |
download | ebus-alt-02f48f7a905973428fc7766cf92bb04614e1fdca.tar.gz ebus-alt-02f48f7a905973428fc7766cf92bb04614e1fdca.zip |
cleanup, tag version 0.3v0.3
Diffstat (limited to 'trigger.sql')
-rw-r--r-- | trigger.sql | 49 |
1 files changed, 0 insertions, 49 deletions
diff --git a/trigger.sql b/trigger.sql deleted file mode 100644 index fb60617..0000000 --- a/trigger.sql +++ /dev/null @@ -1,49 +0,0 @@ --- createlang pgpgsql ebus - -CREATE TABLE value_cache ( LIKE value ); - -DELETE FROM value_cache; - --- Create a function that always returns the first non-NULL item -CREATE OR REPLACE FUNCTION public.first_agg ( anyelement, anyelement ) RETURNS anyelement AS $$ - SELECT CASE WHEN $1 IS NULL THEN $2 ELSE $1 END; -$$ LANGUAGE SQL STABLE; - --- And then wrap an aggreagate around it -CREATE AGGREGATE public.first ( - sfunc = public.first_agg, - basetype = anyelement, - stype = anyelement -); - -DROP FUNCTION value_insert_trigger_func() CASCADE; - -CREATE FUNCTION value_insert_trigger_func() RETURNS trigger AS $$ - BEGIN - DELETE FROM value_cache - WHERE date_trunc('hour', timestamp) = - (SELECT date_trunc('hour', max(timestamp)) FROM value) - AND sensor_id = (SELECT sensor_id from value where id = (select max(id) from value)); - - INSERT INTO value_cache - SELECT - COALESCE(0, (select max(id)+1 from value_cache)) as "id" --XXX use seq - ,date_trunc('hour', timestamp) AS "timestamp" - ,sensor_id AS "sensor_id" - ,type AS "type" - ,AVG(value_float) AS "value_float" - ,AVG(value_int) AS "value_int" - ,first(value_string) AS "value_string" - FROM value - WHERE date_trunc('hour', timestamp) = (SELECT date_trunc('hour', max(timestamp)) FROM value) - AND sensor_id = (SELECT sensor_id FROM value WHERE id = (SELECT MAX(id) FROM value)) - GROUP BY type, sensor_id, date_trunc('hour', timestamp); - - RETURN NULL; - END; -$$ LANGUAGE plpgsql; - --- DROP TRIGGER value_insert_trigger ON value; - -CREATE TRIGGER value_insert_trigger - AFTER INSERT ON value FOR EACH STATEMENT EXECUTE PROCEDURE value_insert_trigger_func(); |