flip/solana-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/solana-models.git synced 2026-02-06 13:56:50 +00:00
Code Issues Actions 14 Packages Projects Releases Wiki Activity

get distinct txs (#718)

Browse Source
This commit is contained in:
tarikceric 2024-11-27 09:46:27 -06:00 committed by GitHub
parent 0caeaca6ae
commit e88c33fb1b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 50 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

89
models/silver/swaps/raydium/silver__swaps_intermediate_raydium_v4_amm.sql
View File

@ -10,47 +10,58 @@
{% if execute %}
{% set base_query %}
CREATE
OR REPLACE temporary TABLE silver.swaps_intermediate_raydium_v4_amm__intermediate_tmp AS
CREATE OR REPLACE TEMPORARY TABLE silver.swaps_intermediate_raydium_v4_amm__intermediate_tmp AS
WITH distinct_entities AS (
SELECT DISTINCT
tx_id
FROM
{{ ref('silver__decoded_instructions_combined') }}
WHERE
program_id = '675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8'
AND event_type IN (
'swapBaseIn',
'swapBaseOut'
)
SELECT
block_timestamp,
block_id,
tx_id,
signers,
succeeded,
INDEX,
inner_index,
program_id,
event_type,
decoded_instruction,
_inserted_timestamp
FROM
{{ ref('silver__decoded_instructions_combined') }}
WHERE
program_id = '675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8'
AND event_type IN (
'swapBaseIn',
'swapBaseOut'
{% if is_incremental() %}
AND _inserted_timestamp >= (
SELECT
MAX(_inserted_timestamp) - INTERVAL '1 hour'
FROM
{{ this }}
)
{% else %}
AND _inserted_timestamp :: DATE >= '2024-05-14'
{% endif %}
)
{% if is_incremental() %}
AND _inserted_timestamp >= (
SELECT
MAX(_inserted_timestamp) - INTERVAL '1 hour'
FROM
{{ this }}
)
{% else %}
AND _inserted_timestamp :: DATE >= '2024-05-14'
{% endif %}
{% endset %}
{% do run_query(base_query) %}
{% set between_stmts = fsc_utils.dynamic_range_predicate(
"silver.swaps_intermediate_raydium_v4_amm__intermediate_tmp",
"block_timestamp::date"
) %}
/* need to re-select all decoded instructions from all tx_ids in incremental subset
in order for the window function to output accurate values */
SELECT
d.block_timestamp,
d.block_id,
d.tx_id,
d.signers,
d.succeeded,
d.INDEX,
d.inner_index,
d.program_id,
d.event_type,
d.decoded_instruction,
d._inserted_timestamp
FROM
{{ ref('silver__decoded_instructions_combined') }} d
JOIN
distinct_entities
USING(tx_id)
WHERE
program_id = '675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8'
AND event_type IN (
'swapBaseIn',
'swapBaseOut'
)
{% endset %}
{% do run_query(base_query) %}
{% set between_stmts = fsc_utils.dynamic_range_predicate("silver.swaps_intermediate_raydium_v4_amm__intermediate_tmp","block_timestamp::date") %}
{% endif %}
WITH base AS (