datavortexminimum-cyan
Updated 2025-04-18Copy Reference Fork
99
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
›
⌄
WITH daily_volume AS (
SELECT
DATE_TRUNC('day', block_timestamp) AS day,
symbol_in,
SUM(amount_in_usd) AS daily_volume
FROM polygon.defi.ez_dex_swaps
WHERE symbol_in IN ('USDT', 'USDC', 'EURS', 'DAI', 'UST', 'BUSD', 'TUSD')
AND block_timestamp >= '{{ start_date }}'
AND block_timestamp < '{{ end_date }}'
GROUP BY day, symbol_in
),
volume_with_previous AS (
SELECT
dv.day,
dv.symbol_in,
dv.daily_volume,
LAG(dv.daily_volume) OVER (PARTITION BY dv.symbol_in ORDER BY dv.day) AS previous_day_volume
FROM daily_volume dv
)
SELECT
day,
symbol_in,
daily_volume,
previous_day_volume,
CASE
WHEN previous_day_volume IS NULL OR previous_day_volume = 0 THEN NULL
ELSE ROUND((daily_volume - previous_day_volume) * 100.0 / previous_day_volume, 2)
END AS volume_change_percentage
FROM volume_with_previous
ORDER BY day, symbol_in;
QueryRunArchived: QueryRun has been archived