MySQL对多个分组的最新值求和

Question

我需要一些帮助来生成 MySQL 版本 5.7.29 的 MySQL 查询

我拥有的数据集是这样的（示例数据）：

| id | serial_number | reading_value | reading_date        | register_type |
|----|---------------|---------------|---------------------|---------------|
| 1  | 123           | 7492.91       | 2019-11-20 15:37:55 | import        |
| 2  | 123           | 7783.3        | 2019-11-25 11:15:47 | import        |
| 3  | 123           | 0             | 2019-11-26 13:34:01 | export        |
| 4  | 123           | 4.01          | 2019-11-27 13:52:23 | export        |
| 5  | 456           | 7404.93       | 2019-11-24 13:31:06 | import        |
| 6  | 456           | 7758.23       | 2019-11-26 13:35:02 | import        |
| 7  | 456           | 0             | 2019-11-20 15:37:55 | export        |
| 8  | 456           | 0             | 2019-11-26 13:34:01 | export        |

我想获得 latest import 和 latest 的 reading_value 的 sum export 为每个 serial_number 生成如下数据集：

| serial_number | total_value | latest_reading_date |
|---------------|-------------|---------------------|
| 123           | 7787.31     | 2019-11-27 13:52:23 | <--- id 2 and 4 from above table
| 456           | 7758.23     | 2019-11-26 13:35:02 | <--- id 6 and 8 from above table

• 在这个结果数据集中，total_value 是 latest import 和 的 sum每个序列号的最新 导出 reading_value
• latest_reading_date 是 serial_number 的最新（最新）导入或导出（以最晚者为准）日期

我尝试了以下查询，但它给了我 all import 和 export 的 sum每个 serial_number 的值，而不仅仅是 latest import 和 latest 的 sum每个 serial_number 的 em>export 值。

select serial_number, sum(reading_value) as 'total_value', max(reading_date) as 'latest_reading_date'
from t1
group by serial_number

我们将不胜感激。

Answer 1

使用支持聚合值排序的 GROUP_CONCAT 函数有一个棘手的方法。

SELECT serial_number, 
    SUBSTRING_INDEX(GROUP_CONCAT(IF(register_type = 'import', total_value, NULL) ORDER BY reading_date DESC, id DESC), ',', 1) `latest_import`,
    SUBSTRING_INDEX(GROUP_CONCAT(IF(register_type = 'export', total_value, NULL) ORDER BY reading_date DESC, id DESC), ',', 1) `latest_export`
FROM t1
GROUP BY serial_number

解释：

• GROUP_CONCAT(IF(register_type = 'import', total_value, NULL) ORDER BY reading_date DESC, id DESC) - 将生成一个以逗号分隔的 total_values 列表，其中 import 类型按日期和 ID 排序
• SUBSTRING_INDEX() - 将从列表中获取第一个值
• 您想要的值是 latest_import + latest_export（+如果可能，请检查空值），为简洁起见，我省略了它

Answer 2

您可以使用 correlated 子查询进行聚合：

select t1_1.serial_number, sum(t1_1.reading_value) as total_value, 
       max(t1_1.reading_date) as latest_reading_date
from t1_1
where t1_1.reading_date = (select max(t1_2.reading_date) 
                           from t1 as t1_2
                           where t1_2.serial_number = t1_1.serial_number and 
                                 t1_2.register_type = t1_1.register_type
                          )
group by t1_1.serial_number;

Answer 3

如果我理解正确，您可以在聚合之前使用窗口函数：

select serial_number, sum(reading_value) as total_value, 
       max(reading_date) as latest_reading_date
from (select t1.*,
             row_number() over (partition by serial_number, register_type order by reading_date) as seqnum
      from t1
     ) t
group by serial_number;

在 MySQL 8.0 之前的版本中，您可以使用关联子查询：

select serial_number, sum(reading_value) as total_value, 
       max(reading_date) as latest_reading_date
from t1
where t1.reading_date = (select max(tt1.reading_date)
                         from t1 tt1
                         where tt1.serial_number = t1.serial_number and
                               tt1.register_type = t1.register_type
                        )
group by serial_number;