-- 修复前：过滤条件下 VARIANT 读取错误行
-- 修复后：确保过滤条件下 VARIANT 正确读取

CREATE TABLE variant_data AS
SELECT * FROM read_json_auto('data.json');

-- 现在这个查询将返回正确的结果
SELECT 
    variant_col:field1::VARCHAR AS field1,
    variant_col:field2::INTEGER AS field2
FROM variant_data
WHERE variant_col:field1 IS NOT NULL;

-- 修复：WHEN NOT MATCHED 现在只考虑目标表
-- WHEN NOT MATCHED BY TARGET 现在只考虑源表

MERGE INTO target_table t
USING source_table s
ON t.id = s.id
WHEN MATCHED THEN UPDATE SET t.value = s.value
WHEN NOT MATCHED THEN INSERT VALUES (s.id, s.value);

-- 修复：json_keys 现在正确处理通配符路径
SELECT json_keys('{"a": {"b": 1, "c": 2}}', '$.a.*');

-- 修复：ignore_errors 参数不再静默接受无效 JSON
SELECT * FROM read_json_auto('data.json', ignore_errors => true);

-- 修复：NULL JSON key 现在被正确拒绝
SELECT json_extract('{"key": "value"}', 'null_key');

# Python 中使用 DuckDB 的稳健性测试示例
import duckdb

# 修复后，以下操作不再崩溃
con = duckdb.connect(':memory:')
con.execute("INSTALL parquet; LOAD parquet;")

# 处理大型 Parquet 文件
result = con.execute("""
    SELECT 
        COUNT(*) as total_rows,
        SUM(amount) as total_amount
    FROM read_parquet('large_data/*.parquet')
""").fetchdf()

print(result)

-- 修复：原生几何 Parquet 统计信息剪枝
-- 现在可以更有效地跳过不需要的 Parquet 行组
SELECT * FROM read_parquet('geo_data.parquet')
WHERE ST_Intersects(geometry, ST_Polygon(...));

-- 新增：OPERATOR_ROW_GROUPS_SCANNED 统计信息
-- 帮助诊断 Parquet 读取性能
SHOW ALL SETTINGS LIKE 'operator_row_groups_scanned';

# 内存使用对比（jemalloc 构建）
import duckdb
import tracemalloc

tracemalloc.start()

# 执行大量 Parquet 读取
con = duckdb.connect("benchmark.duckdb")
con.execute("CREATE TABLE big_data AS SELECT * FROM read_parquet('data/*.parquet');")

current, peak = tracemalloc.get_traced_memory()
print(f"当前内存: {current / 1024 / 1024:.2f} MB")
print(f"峰值内存: {peak / 1024 / 1024:.2f} MB")

tracemalloc.stop()

# 显式指定暗色模式
duckdb -dark-mode

# 显式指定亮色模式
duckdb -light-mode

# 自动检测终端背景颜色（已改进）
duckdb

-- 附加数据库时重建索引
ATTACH 'other.db' AS other_db (vacuum_rebuild_indexes);

# 1. 检查当前版本
duckdb --version

# 2. 备份现有数据库
cp production.duckdb production_backup_$(date +%Y%m%d).duckdb

# 3. 升级 DuckDB CLI
curl -L https://github.com/duckdb/duckdb/releases/download/v1.5.4/duckdb_cli-linux-amd64.zip -o duckdb.zip
unzip -o duckdb.zip
sudo mv duckdb /usr/local/bin/

# 4. 验证升级
duckdb --version
duckdb -c "SELECT version();"

# pip 升级
pip install --upgrade duckdb

# 或使用 uv
uv pip install --upgrade duckdb

# 验证
import duckdb
print(duckdb.__version__)  # 应显示 1.5.4