如何在SQL中利用LEAD()和LAG()分析股票市场的K线走势数据?

小浩小哥_4441

小浩小哥_4441

2026-06-05

967人浏览

原创

lag()和lead()在k线分析中用于高效提取相邻k线的open、close、high、low等字段,从而计算涨跌幅、实体方向、突破信号及多根组合形态(如启明星),必须配合精确时间排序的over子句,避免自连接,一行sql实现时序逻辑。

如何在sql中利用lead()和lag()分析股票市场的k线走势数据?

LEAD() 和 LAG() 在 K 线分析中到底能干什么?

它们不能直接画出 K 线图,但能高效提取「前一根」或「后一根」K 线的关键字段(如 open、close、high、low),从而计算涨跌幅、突破信号、连续阳线计数等指标。核心价值在于:避免自连接,一行 SQL 表达时序逻辑。

必须按时间排序,且不能用 GROUP BY

LEAD() 和 LAG() 是窗口函数,依赖 ORDER BY 定义“前后”。股票数据必须用精确到秒/毫秒的 datetime 排序,不能只用日期;否则同日多根 K 线顺序不确定,结果随机。常见错误是漏写 ORDER BY 或仅按 date 排序:

SELECT 
  datetime,
  close,
  LAG(close, 1) OVER (ORDER BY datetime) AS prev_close
FROM kline_1min;

以下写法是错的(会导致非确定性结果):

  • LAG(close) OVER () —— 没有 ORDER BY
  • LAG(close) OVER (ORDER BY date) —— 同日多条记录顺序未定义

用 LAG() 计算单根 K 线的涨跌幅和实体方向

实体方向(阳线/阴线)和相对前一日的涨跌幅是最基础信号。注意:K 线的 close 与 open 比较判断当日方向,而涨跌幅通常用 close / LAG(close) - 1。

Facetune
Facetune

Facetune是一款集自拍修图、AI 头像和创意照片编辑于一体的移动影像工具。

下载
SELECT
  datetime,
  open,
  close,
  high,
  low,
  CASE WHEN close > open THEN '阳线' ELSE '阴线' END AS body_type,
  ROUND((close / LAG(close) OVER (ORDER BY datetime) - 1) * 100, 2) AS change_pct
FROM kline_1min;

关键细节:

  • LAG(close) 默认取前 1 行,第 1 条记录返回 NULL,需用 COALESCE(..., 0) 处理
  • 除零风险不存在(LAG(close) 为 0 才会出问题,但股价不会为 0),但空值必须显式处理
  • 若用分钟级数据算“日涨跌幅”,需先按日聚合再开窗,不能直接在分钟表上 LAG() 跨日

用 LEAD() + LAG() 组合识别典型 K 线形态

例如“启明星”(三根K线:大阴线 + 小实体十字星 + 大阳线)需要同时看前1根、当前、后1根。此时需两个窗口函数并存:

SELECT
  datetime,
  close,
  LAG(close, 1) OVER w AS prev_close,
  LEAD(close, 1) OVER w AS next_close,
  LAG(high, 1) OVER w AS prev_high,
  LAG(low, 1) OVER w AS prev_low
FROM kline_1min
WINDOW w AS (ORDER BY datetime);

注意点:

  • 重复写 OVER (ORDER BY datetime) 很冗余,用 WINDOW w AS (...) 命名窗口更清晰(PostgreSQL / MySQL 8.0+ / SQL Server 支持)
  • 形态识别逻辑(如“第二根实体长度 WHERE 或 CASE,不在窗口子句里做计算
  • 跨多根 K 线的形态(如“五连阳”)更适合用 COUNT(*) OVER (ORDER BY datetime ROWS BETWEEN 4 PRECEDING AND CURRENT ROW),而非嵌套多个 LAG()

真正难的不是函数语法,而是对 K 线定义的理解是否和你的交易系统一致——比如“十字星”的上下影线比例阈值、是否排除停牌日、复权状态是否统一。这些业务规则一旦错,窗口函数算得再快也没用。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
数据分析工具有哪些
数据分析工具有哪些

数据分析工具有Excel、SQL、Python、R、Tableau、Power BI、SAS、SPSS和MATLAB等。详细介绍:1、Excel,具有强大的计算和数据处理功能;2、SQL,可以进行数据查询、过滤、排序、聚合等操作;3、Python,拥有丰富的数据分析库;4、R,拥有丰富的统计分析库和图形库;5、Tableau,提供了直观易用的用户界面等等。

2023.10.12

3943

8

SQL中distinct的用法
SQL中distinct的用法

SQL中distinct的语法是“SELECT DISTINCT column1, column2,...,FROM table_name;”。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.27

851

4

SQL中months_between使用方法
SQL中months_between使用方法

在SQL中,MONTHS_BETWEEN 是一个常见的函数,用于计算两个日期之间的月份差。想了解更多SQL的相关内容,可以阅读本专题下面的文章。

2024.02.23

1029

5

SQL出现5120错误解决方法
SQL出现5120错误解决方法

SQL Server错误5120是由于没有足够的权限来访问或操作指定的数据库或文件引起的。想了解更多sql错误的相关内容,可以阅读本专题下面的文章。

2024.03.06

5801

10

sql procedure语法错误解决方法
sql procedure语法错误解决方法

sql procedure语法错误解决办法:1、仔细检查错误消息;2、检查语法规则;3、检查括号和引号;4、检查变量和参数;5、检查关键字和函数;6、逐步调试;7、参考文档和示例。想了解更多语法错误的相关内容,可以阅读本专题下面的文章。

2024.03.06

2723

4

oracle数据库运行sql方法
oracle数据库运行sql方法

运行sql步骤包括:打开sql plus工具并连接到数据库。在提示符下输入sql语句。按enter键运行该语句。查看结果,错误消息或退出sql plus。想了解更多oracle数据库的相关内容,可以阅读本专题下面的文章。

2024.04.07

5780

11

sql中where的含义
sql中where的含义

sql中where子句用于从表中过滤数据,它基于指定条件选择特定的行。想了解更多where的相关内容,可以阅读本专题下面的文章。

2024.04.29

7641

6

sql中删除表的语句是什么
sql中删除表的语句是什么

sql中用于删除表的语句是drop table。语法为drop table table_name;该语句将永久删除指定表的表和数据。想了解更多sql的相关内容,可以阅读本专题下面的文章。

2024.04.29

1050

5

sql中删除一列的命令是什么
sql中删除一列的命令是什么

在sql中,使用alter table语句可以删除一列,语法为:alter table table_name drop column column_name。想了解更多sql的相关内容,可以阅读本专题下面的文章。

2024.04.29

912

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
热门推荐
/
最新课程
phpStudy极速入门视频教程
phpStudy极速入门视频教程

共6课时 | 54.6万人学习

独孤九贱(4)_PHP视频教程
独孤九贱(4)_PHP视频教程

共89课时 | 133.4万人学习