不同行中的值之间的差异，基于 timediff

Question

MariaDB 版本 10.4.10。

我有一个股票抓取脚本，它每小时获取股票数据并将其插入 MySQL 数据库。我想要一种方法来获取每只股票之间的价格差异，例如：

• 在 2020 年 3 月 25 日 07:00 和 2020 年 3 月 25 日 19:00（12 小时）提取的股票
• 在 2020 年 3 月 25 日 07:00 和 2020 年 3 月 26 日 07:00（24 小时）提取的股票
• 在 2020 年 3 月 25 日 08:00 和 2020 年 3 月 25 日 20:00（12 小时）提取的股票
• 2020-03-25 08:00 和 2020-03-26 08:00 (24 小时) 提取的股票 等等

数据库结构如下所示：

stocks( time_fetched DATETIME, name VARCHAR, price INT )

一些示例数据：

**time_fetched          name        price**
2020-03-25 07:00:00     stock_A     10
2020-03-25 07:00:00     stock_B     14
2020-03-25 08:00:00     stock_A     12
2020-03-25 08:00:00     stock_B     20
...
2020-03-25 19:00:00     stock_A     28
2020-03-25 19:00:00     stock_B     32
2020-03-25 20:00:00     stock_A     40
2020-03-25 20:00:00     stock_B     36
...
2020-03-26 07:00:00     stock_A     12
2020-03-26 07:00:00     stock_B     16
2020-03-26 08:00:00     stock_A     18
2020-03-26 08:00:00     stock_B     16

预期结果：

**time_fetched            name        current_price     price_12h_ago     price_24h_ago**
2020-03-25 19:00:00     stock_A     28                10                NULL
2020-03-25 19:00:00     stock_B     32                14                NULL
2020-03-25 20:00:00     stock_A     40                12                NULL
2020-03-25 20:00:00     stock_B     36                20                NULL
2020-03-26 07:00:00     stock_A     12                28                10
2020-03-26 07:00:00     stock_B     16                32                14
2020-03-26 08:00:00     stock_A     18                40                12
2020-03-26 08:00:00     stock_B     16                36                20

目前我正在使用类似这样的 SQL：

WITH prices AS (
  SELECT time_fetched, name, price,
         LAG(price, 12) OVER(PARTITION BY name ORDER BY time_fetched) AS price_12h_ago,
         LAG(price, 24) OVER(PARTITION BY name ORDER BY time_fetched) AS price_24h_ago
  FROM stocks
)
SELECT time_fetched, name, price AS current_price, price_12h_ago, price_24h_ago
FROM prices

这是可行的，因为所有股票都获取了所有时间的价格数据。 实际上，有时在几个小时之间存在间隔，并且股票数据库中缺少几个小时的价格数据和一些股票。

这意味着上面获取当前行前 12 行价格的代码并不总是代表当前行前 12 小时。

所以我需要一种方法来根据实际 timediff 获得价格差异。

希望这对任何人都有意义:)

Answer 1

您可以使用range() 子句。如果您的时间准确：

SELECT time_fetched, name, price,
       MIN(price) OVER (PARTITION BY name
                        ORDER BY time_fetched
                        RANGE BETWEEN INTERVAL 12 hour AND INTERVAL 12 hour
                       ) as price_12h_ago,
       MIN(price) OVER (PARTITION BY name
                        ORDER BY time_fetched
                        RANGE BETWEEN INTERVAL 24 hour AND INTERVAL 24 hour
                       ) as price_24h_ago
FROM stocks;

除非您将分钟和秒设置为精确的0，否则您可能需要比瞬间更宽的范围。例如：

SELECT time_fetched, name, price,
       MIN(price) OVER (PARTITION BY name
                        ORDER BY time_fetched
                        RANGE BETWEEN INTERVAL '12:05' HOUR_MINUTE AND INTERVAL '11:55' HOUR_MINUTE
                       ) as price_12h_ago,
       MIN(price) OVER (PARTITION BY name
                        ORDER BY time_fetched
                        RANGE BETWEEN INTERVAL '24:05' HOUR_MINUTE AND INTERVAL '23:55' HOUR_MINUTE
                       ) as price_24h_ago
FROM stocks;