Usa aggregato definito dall'utente
Test dal vivo:http://sqlfiddle.com/#!17/03ee7/1
DDL
CREATE TABLE t
(grop varchar(1), month_year text, something int)
;
INSERT INTO t
(grop, month_year, something)
VALUES
('a', '201901', -2),
('a', '201902', -4),
('a', '201903', -6),
('a', '201904', 60),
('a', '201905', -2),
('a', '201906', 9),
('a', '201907', 11),
('b', '201901', 100),
('b', '201902', -200),
('b', '201903', 300),
('b', '201904', -50),
('b', '201905', 30),
('b', '201906', -88),
('b', '201907', -86)
;
Aggregato definito dall'utente
create or replace function negative_accum(_accumulated_b numeric, _current_b numeric)
returns numeric as
$$
select case when _accumulated_b < 0 then
_accumulated_b + _current_b
else
_current_b
end
$$ language 'sql';
create aggregate negative_summer(numeric)
(
sfunc = negative_accum,
stype = numeric,
initcond = 0
);
select
*,
negative_summer(something) over (order by grop, month_year) as result
from t
Il primo parametro (_accumulated_b) contiene il valore accumulato della colonna. Il secondo parametro (_current_b) contiene il valore della colonna della riga corrente.
Uscita:
Per quanto riguarda il tuo pseudo-codice B3 = A3 + MIN(0, B2)
Ho usato questo codice tipico:
select case when _accumulated_b < 0 then
_accumulated_b + _current_b
else
_current_b
end
Questo può essere scritto in modo idiomatico in Postgres come:
select _current_b + least(_accumulated_b, 0)
Test dal vivo:http://sqlfiddle.com/#!17/70fa8/1
create or replace function negative_accum(_accumulated_b numeric, _current_b numeric)
returns numeric as
$$
select _current_b + least(_accumulated_b, 0)
$$ language 'sql';
Puoi anche usare un altro linguaggio con la funzione accumulatore, ad esempio plpgsql. Tieni presente che plpgsql (o forse la citazione $$) non è supportato in http://sqlfiddle.com . Quindi nessun collegamento di test dal vivo, questo funzionerebbe sulla tua macchina però:
create or replace function negative_accum(_accumulated_b numeric, _current_b numeric)
returns numeric as
$$begin
return _current_b + least(_accumulated_b, 0);
end$$ language 'plpgsql';
AGGIORNAMENTO
Ho perso la partition by
, ecco un esempio di dati (modificato da 11 a -11) in cui senza partition by
e con partition by
produrrebbe risultati diversi:
Test dal vivo:http://sqlfiddle.com/#!17/87795/4
INSERT INTO t
(grop, month_year, something)
VALUES
('a', '201901', -2),
('a', '201902', -4),
('a', '201903', -6),
('a', '201904', 60),
('a', '201905', -2),
('a', '201906', 9),
('a', '201907', -11), -- changed this from 11 to -11
('b', '201901', 100),
('b', '201902', -200),
('b', '201903', 300),
('b', '201904', -50),
('b', '201905', 30),
('b', '201906', -88),
('b', '201907', -86)
;
Uscita:
| grop | month_year | something | result_wrong | result |
|------|------------|-----------|--------------|--------|
| a | 201901 | -2 | -2 | -2 |
| a | 201902 | -4 | -6 | -6 |
| a | 201903 | -6 | -12 | -12 |
| a | 201904 | 60 | 48 | 48 |
| a | 201905 | -2 | -2 | -2 |
| a | 201906 | 9 | 7 | 7 |
| a | 201907 | -11 | -11 | -11 |
| b | 201901 | 100 | 89 | 100 |
| b | 201902 | -200 | -200 | -200 |
| b | 201903 | 300 | 100 | 100 |
| b | 201904 | -50 | -50 | -50 |
| b | 201905 | 30 | -20 | -20 |
| b | 201906 | -88 | -108 | -108 |
| b | 201907 | -86 | -194 | -194 |