Vinduesfunktioner eller almindelige tabeludtryk:tæl tidligere rækker inden for rækkevidde

Jeg tror ikke, du kan gøre dette billigt med en almindelig forespørgsel, CTE'er og vinduesfunktioner - deres rammedefinition er statisk, men du har brug for en dynamisk ramme (afhængigt af kolonneværdier).

Generelt skal du omhyggeligt definere nedre og øvre grænse for dit vindue:Følgende forespørgsler ekskluderer den aktuelle række og inkluder den nederste kant.
Der er stadig en mindre forskel:Funktionen inkluderer tidligere peers i den aktuelle række, mens den korrelerede underforespørgsel udelukker dem ...

Testcase

Brug af ts i stedet for reserveret ord date som kolonnenavn.

CREATE TABLE test (
  id  bigint
, ts  timestamp
);
 

ROM - Romans forespørgsel

Brug CTE'er, samle tidsstempler i et array, unnest, tæl ...
Selvom det er korrekt, forringes ydeevnen drastisk med mere end en hånd fuld af rækker. Der er et par præstationsdræbere her. Se nedenfor.

ARR - tæl array-elementer

Jeg tog Romans forespørgsel og prøvede at strømline den lidt:

• Fjern 2. CTE, som ikke er nødvendigt.
• Omdan 1. CTE til underforespørgsel, hvilket er hurtigere.
• Direkte count() i stedet for at re-aggregere til en matrix og tælle med array_length() .

Men array-håndtering er dyrt, og ydeevnen forringes stadig dårligt med flere rækker.

SELECT id, ts
     , (SELECT count(*)::int - 1
        FROM   unnest(dates) x
        WHERE  x >= sub.ts - interval '1h') AS ct
FROM (
   SELECT id, ts
        , array_agg(ts) OVER(ORDER BY ts) AS dates
   FROM   test
   ) sub;
 

COR - korreleret underforespørgsel

Du kunne løse det med en simpel korreleret underforespørgsel. Meget hurtigere, men alligevel ...

CREATE OR REPLACE FUNCTION running_window_ct(_intv interval = '1 hour')
  RETURNS TABLE (id bigint, ts timestamp, ct int)
  LANGUAGE plpgsql AS
$func$
DECLARE
   cur   CURSOR FOR
         SELECT t.ts + _intv AS ts1, row_number() OVER (ORDER BY t.ts) AS rn
         FROM   test t ORDER BY t.ts;
   rec   record;
   rn    int;

BEGIN
   OPEN cur;
   FETCH cur INTO rec;
   ct := -1;  -- init

   FOR id, ts, rn IN
      SELECT t.id, t.ts, row_number() OVER (ORDER BY t.ts)
      FROM   test t ORDER BY t.ts
   LOOP
      IF rec.ts1 >= ts THEN
         ct := ct + 1;
      ELSE
         LOOP
            FETCH cur INTO rec;
            EXIT WHEN rec.ts1 >= ts;
         END LOOP;
         ct := rn - rec.rn;
      END IF;

      RETURN NEXT;
   END LOOP;
END
$func$;
 

SELECT * FROM running_window_ct();
 

SELECT * FROM running_window_ct('2 hour - 3 second');