数据库表与查询

15 张表的字段说明与常用 ClickHouse 查询 —— 复权计算、板块 / 指数成分、逐笔资金流。

tdp sync / tdp import 会把数据写入你自己的本地 ClickHouse，库名由 DSN 决定。一份订阅落地后共 15 张表（raw_ 前缀），本页说明每张表的字段与常用查询。客户端用法见 tdp 客户端手册。

通用约定

• symbol 格式：A 股为 sz / sh / bj + 6 位代码（如 sz000001、sh600519、bj430047）；港股为 hk + 5 位（如 hk00700）。指数、ETF、板块同样以 symbol 表示。

• 品种分类（class）：stock 股票 / index 指数 / etf 基金 / block 板块 / unknown。日线表混放四类，按 raw_symbol_class 过滤。

• 单位：open/high/low/close/price 为价格（元）；amount 为成交额（元）；volume 为成交量（股）。

• 时间类型：date 为 Date（YYYY-MM-DD），datetime 为 DateTime（YYYY-MM-DD HH:MM:SS）。

• 引擎与排序键：所有表均为 MergeTree，按各表 ORDER BY 排序（多为 symbol + 日期）。客户端用上游 SHOW CREATE TABLE 建表，结构与源端一致 —— 查看本机实际 DDL（引擎 / 排序键 / 分区）：

  SHOW CREATE TABLE tdp.raw_ticks;

• 去重：普通 MergeTree 不自动去重，重复导入同一段会产生重复行。重拉某段请先 ALTER TABLE ... DROP PARTITION 再 tdp sync，详见手册。

下文 SQL 中的库名统一用 tdp，按你的实际库名替换。

行情 K 线

日线（A 股 / 港股）与 1min / 5min 分时，列结构一致：原始非聚合 OHLC + 成交额 / 量。日线表 raw_kline_daily 混放股票 / 指数 / ETF / 板块，用 raw_symbol_class 区分。

日线（raw_kline_daily / raw_hk_kline_daily）字段：

分时（raw_kline_1min / raw_kline_5min）字段与日线相同，仅把 date 换为 datetime（DateTime，K 线起始时刻）。

逐笔成交（tick）

raw_ticks —— 全市场 3 秒级逐笔成交，含主动买卖方向。排序键 (symbol, datetime)。

复权与股本变迁

复权因子表稀疏存储：只在因子变化的那天落一条，并保留首日一条（hfq_factor = 1.0）作锚点。因此还原逐日因子要用 ASOF JOIN 取「日期 ≤ 当前的最近一条」。

raw_adjust_factor / raw_hk_factor 字段：

raw_gbbq（股本变迁，供需要还原除权除息事件的高级用户；普通复权用因子表即可）：

category 编号与 c1..c4 含义（最常用为 1 除权除息）：

参考维表

代码↔名称、品种分类、指数成分、板块成分等维度表（快照，随订阅刷新）。

raw_symbol_name：symbol / name（中文名）/ class（品种分类）。

raw_stocks_info：symbol / name / list_date（Date 上市日）/ delist_date（Date，在市为 NULL）。

raw_symbol_class：symbol / class（stock / index / etf / block / unknown）。

raw_csindex：index_name（指数英文名，CSI300 / CSI500 / CSI1000 / CSI2000）/ stock_name（成分股中文名）/ stock_symbol（统一 symbol）。仅当前成分。

raw_tdx_blocks_info：

raw_tdx_blocks_member：block_code / stock_symbol（成分股代码）。

raw_hk_symbol：symbol / name / board（main 主板 / gem 创业板 / equity / etf / lni / reit）。

查询示例

不复权日线

SELECT date, open, high, low, close, volume
FROM tdp.raw_kline_daily
WHERE symbol = 'sh600519'
ORDER BY date;

按 class 取某类全部标的（如全部 ETF）：

SELECT k.*
FROM tdp.raw_kline_daily AS k
JOIN tdp.raw_symbol_class AS c ON k.symbol = c.symbol
WHERE c.class = 'etf' AND k.date = '2024-12-31';

复权计算（前复权 / 后复权）

后复权（hfq）= 原始价 × hfq_factor。因子稀疏，用 ASOF LEFT JOIN 取最近一条：

SELECT
    k.date,
    round(k.open  * f.hfq_factor, 2) AS open,
    round(k.high  * f.hfq_factor, 2) AS high,
    round(k.low   * f.hfq_factor, 2) AS low,
    round(k.close * f.hfq_factor, 2) AS close
FROM tdp.raw_kline_daily AS k
ASOF LEFT JOIN tdp.raw_adjust_factor AS f
    ON k.symbol = f.symbol AND k.date >= f.date
WHERE k.symbol = 'sh600519'
ORDER BY k.date;

前复权（qfq）= 后复权 ÷ 最新因子，使最近一日价格等于不复权价：

WITH latest AS (
    SELECT symbol, argMax(hfq_factor, date) AS latest_hfq
    FROM tdp.raw_adjust_factor
    GROUP BY symbol
)
SELECT
    k.date,
    round(k.close * f.hfq_factor / l.latest_hfq, 2) AS close_qfq
FROM tdp.raw_kline_daily AS k
ASOF LEFT JOIN tdp.raw_adjust_factor AS f
    ON k.symbol = f.symbol AND k.date >= f.date
LEFT JOIN latest AS l ON k.symbol = l.symbol
WHERE k.symbol = 'sh600519'
ORDER BY k.date;

指数成分

SELECT stock_symbol, stock_name
FROM tdp.raw_csindex
WHERE index_name = 'CSI300';

板块 / 概念成分

某概念板块的成分股及名称：

SELECT m.stock_symbol, n.name
FROM tdp.raw_tdx_blocks_member AS m
JOIN tdp.raw_tdx_blocks_info  AS i ON m.block_code = i.block_code
LEFT JOIN tdp.raw_symbol_name AS n ON m.stock_symbol = n.symbol
WHERE i.block_type = 'concept' AND i.block_name = '白酒';

逐笔资金流（主买 / 主卖）

按主动方向聚合某股某日的成交额与成交量：

SELECT
    direction,
    round(sum(price * volume)) AS amount,
    sum(volume)                AS volume
FROM tdp.raw_ticks
WHERE symbol = 'sh600519'
  AND toDate(datetime) = '2024-01-02'
GROUP BY direction;

净主动买额（B − S）：

SELECT
    sumIf(price * volume, direction = 'B')
  - sumIf(price * volume, direction = 'S') AS net_active_buy
FROM tdp.raw_ticks
WHERE symbol = 'sh600519' AND toDate(datetime) = '2024-01-02';

代码 → 名称

SELECT symbol, name, class
FROM tdp.raw_symbol_name
WHERE symbol = 'sh600519';