Upload onchain.sql with huggingface_hub

onchain.sql

@@ -1,4 +1,4 @@
-CREATE TABLE trades
+CREATE TABLE IF NOT EXISTS trades
 (
     timestamp           DateTime('UTC'),
     signature           String,
@@ -53,7 +53,7 @@ ENGINE = MergeTree()
 ORDER BY (base_address, timestamp, maker, signature);
 
 --- mint
-CREATE TABLE mints
+CREATE TABLE IF NOT EXISTS mints
 (
     -- === Transaction Details ===
     -- Solana signature is usually 88 characters, but we use String for flexibility.
@@ -95,7 +95,7 @@ CREATE TABLE mints
 ENGINE = MergeTree() 
 ORDER BY (timestamp, creator_address, mint_address);
 
-CREATE TABLE migrations
+CREATE TABLE IF NOT EXISTS migrations
 (
     -- Transaction Details
     timestamp           DateTime('UTC'),
@@ -121,7 +121,7 @@ CREATE TABLE migrations
 ENGINE = MergeTree()
 ORDER BY (mint_address, virtual_pool_address, pool_address, timestamp);
 
-CREATE TABLE fee_collections
+CREATE TABLE IF NOT EXISTS fee_collections
 (
     -- Transaction Details
     timestamp           DateTime('UTC'),
@@ -148,7 +148,7 @@ CREATE TABLE fee_collections
 ENGINE = MergeTree()
 ORDER BY (vault_address, recipient_address, timestamp);
 
-CREATE TABLE liquidity
+CREATE TABLE IF NOT EXISTS liquidity
 (
       -- Transaction Details --
     signature String,
@@ -173,7 +173,7 @@ CREATE TABLE liquidity
 ENGINE = MergeTree()
 ORDER BY (timestamp, pool_address, lp_provider);
 
-CREATE TABLE pool_creations (
+CREATE TABLE IF NOT EXISTS pool_creations (
     -- Transaction Details --
     signature String,
     timestamp Datetime('UTC'),
@@ -201,7 +201,7 @@ CREATE TABLE pool_creations (
 ENGINE = MergeTree()
 ORDER BY (base_address, creator_address);
 
-CREATE TABLE transfers
+CREATE TABLE IF NOT EXISTS transfers
 (
     -- Transaction Details
     timestamp           DateTime('UTC'),
@@ -227,7 +227,7 @@ CREATE TABLE transfers
 ENGINE = MergeTree()
 ORDER BY (source, destination, mint_address, timestamp);
 
-CREATE TABLE supply_locks
+CREATE TABLE IF NOT EXISTS supply_locks
 (
     -- === Transaction Details ===
     timestamp           DateTime('UTC'),
@@ -252,7 +252,7 @@ CREATE TABLE supply_locks
 ENGINE = MergeTree()
 ORDER BY (timestamp, mint_address, sender, recipient);
 
-CREATE TABLE supply_lock_actions
+CREATE TABLE IF NOT EXISTS supply_lock_actions
 (
     -- === Transaction Details ===
  
@@ -276,7 +276,7 @@ CREATE TABLE supply_lock_actions
 ENGINE = MergeTree()
 ORDER BY (timestamp, mint_address, user);
 
-CREATE TABLE burns
+CREATE TABLE IF NOT EXISTS burns
 (
     -- Transaction Details
     timestamp DateTime('UTC'),
@@ -299,7 +299,7 @@ ORDER BY (mint_address, source, timestamp);
 
 -------- Wallet schema
 
-CREATE TABLE wallet_profiles
+CREATE TABLE IF NOT EXISTS wallet_profiles
 (
     updated_at DateTime('UTC'),
     first_seen_ts DateTime('UTC'),
@@ -318,7 +318,7 @@ ENGINE = ReplacingMergeTree(updated_at)
 PRIMARY KEY (wallet_address)
 ORDER BY (wallet_address);
 
-CREATE TABLE wallet_profile_metrics
+CREATE TABLE IF NOT EXISTS wallet_profile_metrics
 (
     updated_at DateTime('UTC'),
     wallet_address                  String,
@@ -384,7 +384,7 @@ CREATE TABLE wallet_profile_metrics
 ENGINE = MergeTree
 ORDER BY (wallet_address, updated_at);
 
-CREATE TABLE wallet_holdings
+CREATE TABLE IF NOT EXISTS wallet_holdings
 (
     updated_at DateTime('UTC'),
     start_holding_at DateTime('UTC'),
@@ -408,7 +408,7 @@ CREATE TABLE wallet_holdings
 ENGINE = MergeTree
 ORDER BY (wallet_address, mint_address, updated_at);
 
-CREATE TABLE tokens (
+CREATE TABLE IF NOT EXISTS tokens (
     updated_at DateTime('UTC'),
     created_at DateTime('UTC'),
 
@@ -439,7 +439,7 @@ PRIMARY KEY (token_address)
 ORDER BY (token_address, updated_at);
 
 -- Latest tokens (one row per token_address)
-CREATE TABLE tokens_latest
+CREATE TABLE IF NOT EXISTS tokens_latest
 (
     updated_at DateTime('UTC'),
     created_at DateTime('UTC'),
@@ -465,7 +465,7 @@ CREATE TABLE tokens_latest
 ENGINE = ReplacingMergeTree(updated_at)
 ORDER BY (token_address);
 
-CREATE TABLE token_metrics (
+CREATE TABLE IF NOT EXISTS token_metrics (
     updated_at DateTime('UTC'),
     token_address           String,
     total_volume_usd        Float64,
@@ -483,7 +483,7 @@ ORDER BY (token_address, updated_at);
 -- Keep full history in the base tables above, but read fast from these ReplacingMergeTree snapshots.
 
 -- Latest wallet profile metrics (one row per wallet_address)
-CREATE TABLE wallet_profile_metrics_latest
+CREATE TABLE IF NOT EXISTS wallet_profile_metrics_latest
 (
     updated_at DateTime('UTC'),
     wallet_address                  String,
@@ -550,7 +550,7 @@ ENGINE = ReplacingMergeTree(updated_at)
 ORDER BY (wallet_address);
 
 -- Latest wallet holdings (one row per wallet_address + mint_address)
-CREATE TABLE wallet_holdings_latest
+CREATE TABLE IF NOT EXISTS wallet_holdings_latest
 (
     updated_at DateTime('UTC'),
     start_holding_at DateTime('UTC'),
@@ -575,7 +575,7 @@ ENGINE = ReplacingMergeTree(updated_at)
 ORDER BY (wallet_address, mint_address);
 
 -- Latest token metrics (one row per token_address)
-CREATE TABLE token_metrics_latest
+CREATE TABLE IF NOT EXISTS token_metrics_latest
 (
     updated_at DateTime('UTC'),
     token_address           String,
@@ -589,7 +589,7 @@ ENGINE = ReplacingMergeTree(updated_at)
 ORDER BY (token_address);
 
 
-CREATE TABLE known_wallets
+CREATE TABLE IF NOT EXISTS known_wallets
 (
     `wallet_address` String,
     `name` String, -- e.g., "Pump.fun Fee Vault", "Raydium CPMM Authority V4", "KOL - Ansem"