-- 演示：LTS 版本现在会正确报告溢出错误
CREATE TABLE test_int AS SELECT range AS id FROM range(100);
SELECT * FROM test_int WHERE id > 2147483647;
-- 在旧版本中可能静默返回错误结果，现在会抛出明确的溢出异常

-- 过滤不符合特定模式的字符串
SELECT product_name
FROM products
WHERE product_name NOT SIMILAR TO '%[0-9]%';

-- 找出名称中不包含数字的产品
-- 结果：['Widget Alpha', 'Gadget Beta', 'Tool Gamma']

# Python 多进程并发写入示例（LTS 版本更安全）
from multiprocessing import Process
import duckdb

def write_data(conn_path, data_id):
    conn = duckdb.connect(conn_path)
    conn.execute(f"INSERT INTO events VALUES ({data_id}, '{data_id}')")
    conn.close()

# 多个进程安全地写入同一个 DuckDB 数据库
processes = [Process(target=write_data, args=("test.db", i)) for i in range(10)]
for p in processes: p.start()
for p in processes: p.join()

-- 现在可以可靠地读取大型 CSV 文件
CREATE TABLE sales AS
SELECT * FROM read_csv_auto('large_dataset.csv');

-- 即使文件很大，也不会出现边界情况导致的解析错误
SELECT COUNT(*) FROM sales;  -- 精确计数，无数据丢失

-- 模拟 ETL 循环：加载 + 插入
LOAD DATA FROM 'batch_001.csv';
INSERT INTO analytics SELECT * FROM staging;

LOAD DATA FROM 'batch_002.csv';
INSERT INTO analytics SELECT * FROM staging;

-- 在旧版本中，反复执行会导致内存和磁盘占用持续增长
-- LTS 版本现在会正确管理 Row Group 的生命周期

-- 多次调用 CREATE SECRET 现在会复用已有凭证
CREATE SECRET (TYPE S3, KEY_ID 'xxx', SECRET 'xxx');
-- 再次执行不会创建新的 secret 实例
SELECT * FROM secrets();  -- 只显示唯一的 secret

-- 处理不受信任的 Parquet 文件现在更安全
SELECT * FROM parquet_scan('suspicious_file.parquet');
-- 即使文件格式异常，也不会导致崩溃或安全漏洞

-- zstd 压缩的 Parquet 文件读写更快
CREATE TABLE compressed_data AS
SELECT * FROM read_parquet('data.zst.parquet');

-- 写入时也受益于改进的压缩算法
COPY compressed_data TO 'output.zst.parquet' (COMPRESSION ZSTD);

-- AsOf Join：按时间戳匹配最近的前值
SELECT 
    t.timestamp,
    t.price AS current_price,
    b.price AS bid_price
FROM trades t
ASOF JOIN bids b ON t.timestamp >= b.timestamp
WHERE t.symbol = 'AAPL';

-- LTS 版本在此类时间序列查询上表现更优

# Python
pip install duckdb==1.4.5

# CLI
wget https://github.com/duckdb/duckdb/releases/download/v1.4.5/duckdb_cli-linux-amd64.zip
unzip duckdb_cli-linux-amd64.zip
chmod +x duckdb

# Docker
docker pull duckdb/duckdb:1.4.5