update TVM transfers

Author: DenisCarriere

src/sql/transfers/tvm.sql

@@ -9,107 +9,55 @@ arrayFilter(x -> x != '', {contract:Array(String)}) AS contracts,
 (length(from_addresses) > 0) AS has_from,
 (length(to_addresses) > 0) AS has_to,
 (length(contracts) > 0) AS has_contract,
-has_contract AND NOT has_from AND NOT has_to AS is_contract_only,
-has_from AND NOT has_to AND NOT has_contract AS is_from_only,
-has_to AND NOT has_from AND NOT has_contract AS is_to_only,
-has_contract AND has_to AND NOT has_from AS is_contract_to,
-has_contract AND has_from AND NOT has_to AS is_contract_from,
-has_contract AND has_from AND has_to AS is_contract_from_to,
-{start_time:UInt64} = 1420070400 AS no_start_time,
-{end_time:UInt64} = 2524608000 AS no_end_time,
-{start_block:UInt64} = 0 AS no_start_block,
-{end_block:UInt64} = 9999999999 AS no_end_block,
 
 tx_hash_timestamps AS (
     SELECT (minute, timestamp)
     FROM trc20_transfer
     WHERE has_tx_hash AND tx_hash IN {transaction_id:Array(String)}
     GROUP BY minute, timestamp
 ),
-/* single filters */
+/* minute filters */
 from_minutes AS (
     SELECT minute
     FROM trc20_transfer
-    WHERE
-        is_from_only
-        AND (no_start_time OR minute >= toRelativeMinuteNum(toDateTime({start_time:UInt64})))
-        AND `from` IN {from_address:Array(String)}
+    WHERE has_from AND `from` IN {from_address:Array(String)}
     GROUP BY minute
 ),
 to_minutes AS (
     SELECT minute
     FROM trc20_transfer
-    WHERE
-        is_to_only
-        AND (no_start_time OR minute >= toRelativeMinuteNum(toDateTime({start_time:UInt64})))
-        AND `to` IN {to_address:Array(String)}
-    GROUP BY minute
-),
-contract_hours AS (
-    SELECT toStartOfHour(toDateTime(minute * 60)) AS minute_hour
-    FROM trc20_transfer
-    WHERE
-        is_contract_only
-        AND (no_start_time OR minute >= toRelativeMinuteNum(toDateTime({start_time:UInt64})))
-        AND log_address IN {contract:Array(String)}
-    GROUP BY minute_hour
-),
-/* 2 filters */
-contract_from_minutes AS (
-    SELECT minute
-    FROM trc20_transfer
-    WHERE
-        is_contract_from
-        AND log_address IN {contract:Array(String)}
-        AND `from`      IN {from_address:Array(String)}
+    WHERE has_to AND `to` IN {to_address:Array(String)}
     GROUP BY minute
 ),
-contract_to_minutes AS (
+contract_minutes AS (
     SELECT minute
     FROM trc20_transfer
-    WHERE
-        is_contract_to
-        AND log_address IN {contract:Array(String)}
-        AND `to`        IN {to_address:Array(String)}
-    GROUP BY minute
-),
-/* 3 filters */
-contract_from_to_minutes AS (
-    SELECT minute
-    FROM trc20_transfer
-    WHERE
-        is_contract_from_to
-        AND log_address IN {contract:Array(String)}
-        AND `from`      IN {from_address:Array(String)}
-        AND `to`        IN {to_address:Array(String)}
+    WHERE has_contract AND log_address IN {contract:Array(String)}
+        AND ({start_time:UInt64} = 1420070400 OR timestamp >= toRelativeMinuteNum(toDateTime({start_time:UInt64})))
+        AND ({end_time:UInt64} = 2524608000 OR timestamp <= toRelativeMinuteNum(toDateTime({end_time:UInt64})))
     GROUP BY minute
+    ORDER BY minute DESC
+    LIMIT 100000
 ),
 transfers AS (
-    SELECT *, toStartOfHour(toDateTime(minute * 60)) AS minute_hour
+    SELECT *
     FROM trc20_transfer
     WHERE
         /* filter by timestamp and block_num early to reduce data scanned */
-            (no_start_time OR timestamp >= toDateTime({start_time:UInt64}))
-        AND (no_end_time OR timestamp <= toDateTime({end_time:UInt64}))
-        AND (no_start_block OR block_num >= {start_block:UInt64})
-        AND (no_end_block OR block_num <= {end_block:UInt64})
+            ({start_time:UInt64} = 1420070400 OR timestamp >= toDateTime({start_time:UInt64}))
+        AND ({end_time:UInt64} = 2524608000 OR timestamp <= toDateTime({end_time:UInt64}))
+        AND ({start_block:UInt64} = 0 OR block_num >= {start_block:UInt64})
+        AND ({end_block:UInt64} = 9999999999 OR block_num <= {end_block:UInt64})
 
         /* minute-based filters bound to single/double/triple mode */
 
         /* transaction ID filter */
         AND ( NOT has_tx_hash OR (minute, timestamp) IN tx_hash_timestamps AND tx_hash IN {transaction_id:Array(String)} )
 
-        /* 3-filters: from + to + contract */
-        AND ( NOT is_contract_from_to OR minute IN contract_from_to_minutes )
-
-        /* 2-filters: (from + contract) and (to + contract) */
-        AND ( NOT is_contract_from OR minute IN contract_from_minutes )
-        AND ( NOT is_contract_to OR minute IN contract_to_minutes )
-
-        /* 1-filter: from OR to OR contract alone */
-        AND ( NOT is_from_only OR minute IN from_minutes )
-        AND ( NOT is_to_only OR minute IN to_minutes )
-        AND ( NOT is_contract_only OR minute_hour IN contract_hours )
+        /* minute filters */
+        AND ( NOT has_from OR minute IN from_minutes )
+        AND ( NOT has_to OR minute IN to_minutes )
+        AND ( NOT has_contract OR minute IN contract_minutes )
 
         /* direct filters */
         AND ( NOT has_from OR `from` IN {from_address:Array(String)} )