Hive SQL 题求教

[wloverine]

已知价格会随着时间发生变化，想要求得每款产品的每个价格的起始时间,示例数据如下。 需要注意的是当价格发生变动后又恢复了原价的话，起始日期需重新计算，如 item_id 为 2 ，price 为 399 的数据，就产出了两条起始时间。只能编写 SQL 实现

input:
item_id price dt
1 100 2020-01-01
1 100 2020-01-02
1 120 2020-01-03
2 399 2020-01-01
2 399 2020-01-02
2 399 2020-01-03
2 499 2020-01-04
2 399 2020-01-05

output:
item_id price start_date end_date
1       100     2020-01-01      2020-01-02
1       120     2020-01-03      2020-01-03
2       399     2020-01-01      2020-01-03
2       499     2020-01-04      2020-01-04
2       399     2020-01-05      9999-12-31

[saluton]

可以搜一下 [SQL 连续签到天数] 的题，看起来差不多的思路。

[liprais]

按价格分组之后连续的日期有啥特征?
连续的日期减去一个自增的数列是一个定值，按这个分组不就完了

[wloverine]

@liprais 没明白你的意思

[wloverine]

@saluton 谢谢，有点连续签到的意思，但还是有些差异的

[tinywhale]

这个是典型的 gaps and islands 类型问题，技巧是要先分组，然后每个组的 min/max date 就是开始和结束日期。

[jiangwei2222]

select price,max (dt),min (dt) from xxx group price

[cau1iflower]

ChatGPT 了解一下

[cau1iflower]

@cau1iflower
```
SELECT item_id, price,
-- 如果当前价格和前一个价格不同，那么这个价格的起始时间就是当前日期。
-- 否则，起始时间就是前一个价格的起始时间。
CASE WHEN price != LAG(price) OVER (PARTITION BY item_id ORDER BY date)
THEN date
ELSE LAG(start_date) OVER (PARTITION BY item_id ORDER BY date)
END AS start_date,
-- 如果当前价格和后一个价格不同，那么这个价格的结束时间就是后一个价格的起始时间。
-- 否则，这个价格的结束时间就是 NULL 。
CASE WHEN price != LEAD(price) OVER (PARTITION BY item_id ORDER BY date)
THEN LEAD(start_date) OVER (PARTITION BY item_id ORDER BY date)
ELSE NULL
END AS end_date
FROM prices

```

[wloverine]

@jiangwei2222 直接 group by 的话就会造成 item_id 为 2 ，price 为 399 的起始日期变成了 2020-01-01~2020-01-05 ，这显然是不合理的

[wxf666]

@cau1iflower 有啥数据库支持直接引用别名的吗？

比如 `LAG(start_date)`、`LEAD(start_date)` 这些

[SbloodyS]

@wxf666 比如 Clickhouse 支持直接引用别名

[wxf666]

@SbloodyS 数据库新手问下，现在基本都不用 PostgreSQL 、MySQL 、SQL Server 、Oracle 、SQLite 这些数据库了是吗？

[blue7wings]

以下是 OpenAI 给出的答案，不知道对不对，你可以参考一下:)
Here is one possible solution using SQL:

```sql
SELECT item_id, price, MIN(dt) as start_date,
(SELECT MIN(dt) FROM prices AS p2
WHERE p2.item_id = p1.item_id AND p2.price != p1.price AND p2.dt > p1.dt)
as end_date
FROM prices as p1
GROUP BY item_id, price
```

This query groups the prices for each item_id and price combination and finds the minimum dt (the start date) for each group. Then, for each group, it uses a subquery to find the minimum dt for the next price change (the end date) for the same item_id. If there is no next price change, the end date is set to the maximum date value.

You can use this query as a starting point and modify it to fit your specific needs.

[wxf666]

@SbloodyS 突然很好奇，如果 Clickhouse 支持直接用别名的话，下面这种 SQL 会计算成什么？

```sql
SELECT IF(id % 2, LEAD(a) OVER (...), LAG(a) OVER (...)) AS a
FROM ...
```

大意：若 id 为奇数，则取下一行的值，否则取上一行的值

[SbloodyS]

@wxf666 有语法限制的，AS 后面的别名和 AS 前面的字段别名不能一致，这样来避免冲突

[wxf666]

@SbloodyS 是说，没法在 `... AS a` 内使用 `a`，是吧？

但可以 `... AS a, (a + 1) AS b`？

[SbloodyS]

@wxf666 是的

[wxf666]

@SbloodyS 那 8 楼的 SQL ，应该没有哪款数据库能运行了。因为：

```sql
SELECT ... LAG(start_date) ... AS start_date
...
```