from blockdb import Table

t = Table("demo.event_log")

# 写：实时写入
job_id = t.upsert_rows([{"id": "evt_001", "name": "login", "value": 1}])

# 读：单行 / 批量 / 条件筛选
row = t.get_row("evt_001")
rows = t.batch_get_rows(["evt_001", "evt_002"])
hits = t.filter_rows(filters="value > 0", order_by="value desc", limit=100)

# 扫描：全表 / 流式，返回 list[dict]
all_rows = t.scan("SELECT * FROM demo.event_log")
for row in t.scan_iter("SELECT * FROM demo.event_log WHERE name = 'login'"):
    ...  # 大表逐行 yield，内存恒定

# 删除
t.delete_rows(["evt_001"])

from blockdb import BlockTable, Block

bt = BlockTable("token.token.eth")
block = Block(id="0xabc...", height=18000000, timestamp=1712345678)

# 读：按区块时刻读状态 / 事件 / 某一高度整块数据
state = bt.get_state("acct_1", block)
event = bt.get_event("evt_1", block)
rows = bt.get_block_rows(block)

# 写：按区块原子写入
bt.upsert_block(block, [{"id": "acct_1", "balance": 1000}])

from blockdb import TimeTable

tt = TimeTable("token_time_demo")

# 写：往时间桶批量写入（time_at 自动向后取整到整分钟）
tt.upsert_time_rows("2026-05-18 17:04:35", [{"id": "0xabc...", "value": 2543.12}])

# 读：某个对象在某个时间桶的状态
row = tt.get_value("0xabc...", "2026-05-18 17:04:40")