Schema Overview

ETHEREUM_CORE (or ETHEREUM_PREMIUM)
├── ETHEREUM (Core schema)
├── DEFI (Premium only)
├── NFT (Premium only)
├── PRICE (Premium only)
├── STATS (Premium only)
└── [Protocol-specific schemas] (Premium only)

-- Core schema (available in free shares)
[BLOCKCHAIN].core.fact_transactions
[BLOCKCHAIN].core.dim_labels

-- Premium schemas (available in premium shares)
[BLOCKCHAIN].defi.ez_dex_swaps
[BLOCKCHAIN].nft.ez_nft_sales
[BLOCKCHAIN].price.ez_prices_hourly
[BLOCKCHAIN].stats.ez_core_metrics_daily

-- Find DEX swaps for specific transactions
SELECT
    t.tx_hash,
    t.from_address,
    t.block_timestamp,
    s.platform,
    s.amount_in_usd,
    s.token_in,
    s.token_out
FROM ethereum.core.fact_transactions t
JOIN ethereum.defi.ez_dex_swaps s
    ON t.tx_hash = s.tx_hash
WHERE t.block_timestamp >= CURRENT_DATE - 7
  AND s.block_timestamp >= CURRENT_DATE - 7
LIMIT 1000;

-- Token transfers with USD values and labels
SELECT
    tt.block_timestamp,
    tt.from_address,
    l_from.label AS from_label,
    tt.to_address,
    l_to.label AS to_label,
    tt.symbol,
    tt.amount,
    tt.amount_usd
FROM ethereum.core.ez_token_transfers tt
LEFT JOIN ethereum.core.dim_labels l_from
    ON tt.from_address = l_from.address
LEFT JOIN ethereum.core.dim_labels l_to
    ON tt.to_address = l_to.address
WHERE tt.block_timestamp >= CURRENT_DATE - 1
  AND tt.amount_usd > 10000
ORDER BY tt.amount_usd DESC
LIMIT 100;

-- Daily Ethereum metrics
SELECT
    date,
    transaction_count,
    active_addresses,
    avg_gas_price,
    total_fees_usd
FROM ethereum.stats.ez_core_metrics_daily
WHERE date >= CURRENT_DATE - 30
ORDER BY date DESC;