PostgreSQL
 sql >> Database >  >> RDS >> PostgreSQL

Ottieni la differenza di un altro campo tra il primo e l'ultimo timestamp del raggruppamento

Fase 1:rilascia i freni a mano

SELECT to_char(MIN(ts)::timestamptz, 'YYYY-MM-DD HH24:MI:SS TZ') AS min_time
      ,SUM(CASE WHEN sensor_id = 572 THEN value ELSE 0.0 END) AS nickname1
      ,SUM(CASE WHEN sensor_id = 542 THEN value ELSE 0.0 END) AS nickname2
      ,SUM(CASE WHEN sensor_id = 571 THEN value ELSE 0.0 END) AS nickname3
FROM   sensor_values
-- LEFT JOIN sensor_values_cleaned s2 USING (sensor_id, ts)
WHERE  ts >= '2013-10-14T00:00:00+00:00'::timestamptz::timestamp
AND    ts <  '2013-10-18T00:00:00+00:00'::timestamptz::timestamp
AND    sensor_id IN (572, 542, 571, 540, 541, 573)
GROUP  BY ts::date AS day
ORDER  BY 1;

Punti principali

  • Sostituisci parole riservate (in SQL standard) nei tuoi identificatori.
    timestamp -> ts
    time -> min_time

  • Poiché il join è su nomi di colonna identici, puoi utilizzare il più semplice USING clausola nella condizione di unione:USING (sensor_id, ts)
    Tuttavia, dalla seconda tabella sensor_values_cleaned è al 100% irrilevante per questa query, l'ho rimossa completamente.

  • Come già consigliato da @joop, cambia min() e to_char() nella tua prima colonna di output. In questo modo, Postgres può determinare il minimo dal valore della colonna originale , che è generalmente più veloce e può essere in grado di utilizzare un indice. In questo caso specifico, ordina per date è anche più economico che ordinare con un text , che dovrebbe anche considerare le regole di confronto.

  • Una considerazione simile si applica al tuo WHERE condizione:
    WHERE ts::timestamptz>='2013-10-14T00:00:00+00:00'::timestamptz

    WHERE  ts >= '2013-10-14T00:00:00+00:00'::timestamptz::timestamp
    

    Il secondo è sargable e può utilizzare un semplice indice su ts - con grande effetto sulle prestazioni nei grandi tavoli!

  • Usando ts::date invece di date_trunc('day', ts) . Più semplice, più veloce, stesso risultato.

  • Molto probabilmente la tua seconda condizione WHERE è leggermente errata. In genere, escluderesti il ​​bordo superiore :

    AND    ts <=  '2013-10-18T00:00:00+00:00' ...

    AND    ts <   '2013-10-18T00:00:00+00:00' ...
  • Quando si mescola timestamp e timestamptz bisogna essere consapevoli degli effetti. Ad esempio, il tuo WHERE la condizione non viene ridotta alle 00:00 ora locale (tranne se l'ora locale coincide con UTC). Dettagli qui:
    Ignorando del tutto i fusi orari in Rails e PostgreSQL

Fase 2:la tua richiesta

E con questo suppongo tu intenda:
...la differenza tra il valore di gli ultimi e i primi timestamp ...
Altrimenti sarebbe molto più semplice.

Usa funzioni finestra per questo, in particolare first_value() e last_value() . Attento alla combinazione, vuoi un non -telaio della finestra standard per last_value() in questo caso. Confronta:
Funzione di aggregazione o finestra PostgreSQL per restituire solo l'ultimo valore

Lo combino con DISTINCT ON , che in questo caso è più conveniente di GROUP BY (che richiederebbe un altro livello di sottoquery):

SELECT DISTINCT ON (ts::date, sensor_id)
       ts::date AS day
      ,to_char((min(ts)  OVER (PARTITION BY ts::date))::timestamptz
              ,'YYYY-MM-DD HH24:MI:SS TZ') AS min_time
      ,sensor_id
      ,last_value(value)    OVER (PARTITION BY ts::date, sensor_id ORDER BY ts
                     RANGE BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING)
       - first_value(value) OVER (PARTITION BY ts::date, sensor_id ORDER BY ts)
                                                                   AS val_range
FROM   sensor_values
WHERE  ts >= '2013-10-14T00:00:00+0'::timestamptz::timestamp
AND    ts <  '2013-10-18T00:00:00+0'::timestamptz::timestamp
AND    sensor_id IN (540, 541, 542, 571, 572, 573)
ORDER  BY ts::date, sensor_id;

-> Demo di SQLfiddle.

Fase 3:tabella pivot

Basandosi sulla query precedente, utilizzo crosstab() dal modulo aggiuntivo tablefunc :

SELECT * FROM crosstab(
   $$SELECT DISTINCT ON (1,3)
            ts::date AS day
           ,to_char((min(ts) OVER (PARTITION BY ts::date))::timestamptz,'YYYY-MM-DD HH24:MI:SS TZ') AS min_time
           ,sensor_id
           ,last_value(value)    OVER (PARTITION BY ts::date, sensor_id ORDER BY ts RANGE BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING)
            - first_value(value) OVER (PARTITION BY ts::date, sensor_id ORDER BY ts) AS val_range
     FROM   sensor_values
     WHERE  ts >= '2013-10-14T00:00:00+0'::timestamptz::timestamp
     AND    ts <  '2013-10-18T00:00:00+0'::timestamptz::timestamp
     AND    sensor_id IN (540, 541, 542, 571, 572, 573)
     ORDER  BY 1, 3$$

   ,$$VALUES (540), (541), (542), (571), (572), (573)$$
   )
AS ct (day date, min_time text, s540 numeric, s541 numeric, s542 numeric, s571 numeric, s572 numeric, s573 numeric);

Resi (e molto più veloce di prima):

    day     |         min_time         | s540  | s541  | s542  | s571  | s572  | s573
------------+--------------------------+-------+-------+-------+-------+-------+-------
 2013-10-14 | 2013-10-14 03:00:00 CEST | 18.82 | 18.98 | 19.97 | 19.47 | 17.56 | 21.27
 2013-10-15 | 2013-10-15 00:15:00 CEST | 22.59 | 24.20 | 22.90 | 21.27 | 22.75 | 22.23
 2013-10-16 | 2013-10-16 00:16:00 CEST | 23.74 | 22.52 | 22.23 | 23.22 | 23.03 | 22.98
 2013-10-17 | 2013-10-17 00:17:00 CEST | 21.68 | 24.54 | 21.15 | 23.58 | 23.04 | 21.94