lead-lag-scripts/check_db.py

import sqlite3
from datetime import datetime

conn = sqlite3.connect('data/trading_data_20251103.db')
cursor = conn.cursor()

print('=== Price Data (最新10条) ===')
cursor.execute('SELECT * FROM price_data ORDER BY timestamp DESC LIMIT 10')
rows = cursor.fetchall()
for row in rows:
    ts = datetime.fromtimestamp(row[1]).strftime('%Y-%m-%d %H:%M:%S')
    print(f"所有列: {row}")
    print(f"  时间: {ts}")
    print(f"  ID: {row[0]}, 时间戳: {row[1]}, 会话ID: {row[2]}, 标的: {row[3]}")
    print(f"  Lighter价格: {row[4]}, Binance价格: {row[5]}, 价差(bps): {row[6]}")
    print()

print('\n=== Trading Events (最新10条) ===')
cursor.execute('SELECT * FROM trading_events ORDER BY timestamp DESC LIMIT 10')
rows = cursor.fetchall()
if rows:
    for row in rows:
        ts = datetime.fromtimestamp(row[1]).strftime('%Y-%m-%d %H:%M:%S')
        print(f"所有列: {row}")
        print(f"  时间: {ts}")
        print(f"  ID: {row[0]}, 时间戳: {row[1]}, 会话ID: {row[2]}, 标的: {row[3]}")
        print(f"  事件类型: {row[4]}, 价格: {row[5]}, 数量: {row[6]}, 策略状态: {row[7]}")
        print(f"  价差(bps): {row[8]}, 成功: {row[9]}, 错误信息: {row[10]}")
        print()
else:
    print("  (无数据)")

print('\n=== 数据统计 ===')
cursor.execute('SELECT COUNT(*) FROM price_data')
print(f"价格数据总数: {cursor.fetchone()[0]}")

cursor.execute('SELECT COUNT(*) FROM trading_events')
print(f"交易事件总数: {cursor.fetchone()[0]}")

conn.close()