用户:

业务背景

这是某个驾校管理系统的数据库片段。业务流程大致如下:学员注册后选择课程和班级进行报名,下单支付后可约课。约课时可以选择具体时间和教练,若是实践课,会使用特定的车辆进行实践学习。完成课程后参加考试。

数仓表格

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
-- 学员信息表
CREATE TABLE Student (
StudentID INT COMMENT '学员ID;主键;自增',
Name VARCHAR(100) COMMENT '姓名;例如:张三',
IDNumber VARCHAR(50) COMMENT '身份证号;例如:510***********1234',
Gender ENUM('男', '女', '其他') COMMENT '性别;值为:男/女/其他',
Phone VARCHAR(20) COMMENT '联系电话;例如:138********',
RegistrationDate DATE COMMENT '注册日期;格式为YYYY-MM-DD'
) COMMENT='学员信息表';

-- 教练信息表
CREATE TABLE Instructor (
InstructorID INT COMMENT '教练ID;主键;自增',
Name VARCHAR(100) COMMENT '姓名;例如:李四',
Gender ENUM('男', '女', '其他') COMMENT '性别;值为:男/女/其他',
Phone VARCHAR(20) COMMENT '联系电话;例如:139********',
DrivingExperience INT COMMENT '驾龄;单位:年'
) COMMENT='教练信息表';

-- 班级类型表
CREATE TABLE ClassType (
TypeID INT COMMENT '班级类型ID;主键;自增',
TypeName VARCHAR(100) COMMENT '类型名称;例如:"周末班", "集中培训班"',
Description TEXT COMMENT '描述'
) COMMENT='班级类型表';

-- 课程信息表
CREATE TABLE Course (
CourseID INT COMMENT '课程ID;主键;自增',
CourseName VARCHAR(100) COMMENT '课程名称;如:F本-轻便摩托车、C2-自动挡小汽车',
TheoryHours INT COMMENT '理论课时数',
PracticeHours INT COMMENT '实践课时数'
) COMMENT='课程信息表';

-- 班级信息表
CREATE TABLE Class (
ClassID INT COMMENT '班级ID;主键;自增',
CourseID INT COMMENT '课程ID;外键:课程ID',
ExpireDate DATE COMMENT '过期日期;格式为YYYY-MM-DD',
ClassTypeID INT COMMENT '班级类型ID;外键:班级类型ID'
) COMMENT='班级信息表';

-- 课节
CREATE TABLE Lesson (
LessonID INT COMMENT '课节ID;主键;自增',
StudentID INT COMMENT '学员ID;外键:学员ID',
ClassID INT COMMENT '班级ID;外键:班级ID',
InstructorID INT COMMENT '教练ID;外键:教练ID',
TheoryHours INT COMMENT '理论课时数',
PracticeHours INT COMMENT '实践课时数'
LessonStatusCode VARCHAR(31) COMMENT '课节状态代码;未开始/已完成/学员未赴约/教练未赴约'
VehicleID INT COMMENT '车辆ID;外键:车辆ID',
LessonDate DATE COMMENT '课节日期',
LessonTime TIME COMMENT '课节时间',
Rating INT COMMENT '学员打分;1-5分,5分满分',
Feedback VARCHAR(255) COMMENT '学员反馈'
);

-- 学习报名记录表
CREATE TABLE Enrollment (
EnrollmentID INT COMMENT '报名记录ID;主键;自增',
StudentID INT COMMENT '学员ID;外键:学员ID',
ClassID INT COMMENT '班级ID;外键:班级ID',
EnrollmentDate DATE COMMENT '报名日期;格式为YYYY-MM-DD',
CompletionStatus ENUM('未完成', '已完成', '进行中') COMMENT '完成状态;值为:未完成/已完成/进行中'
) COMMENT='学习报名记录表';

-- 车辆信息表
CREATE TABLE Vehicle (
VehicleID INT COMMENT '车辆ID;主键;自增',
LicensePlate VARCHAR(20) COMMENT '车牌号;例如:川A12345',
Model VARCHAR(50) COMMENT '车型;例如:奥迪A4',
PurchaseDate DATE COMMENT '购置日期;格式为YYYY-MM-DD',
Status ENUM('使用中', '维修中', '闲置') COMMENT '状态;值为:使用中/维修中/闲置'
) COMMENT='车辆信息表';

-- 考试记录表
CREATE TABLE Exam (
ExamID INT COMMENT '考试记录ID;主键;自增',
StudentID INT COMMENT '学员ID;外键:学员ID',
ClassID INT COMMENT '班级ID;外键:班级ID',
ExamType ENUM('科目一', '科目二', '科目三', '科目四') COMMENT '考试类型;值为:科目一/科目二/科目三/科目四',
ExamDate DATE COMMENT '考试日期;格式为YYYY-MM-DD',
Score DECIMAL(5, 2) COMMENT '成绩;例如:85.50',
Passed INT COMMENT '是否通过;1为通过,0为未通过'
) COMMENT='考试记录表';

-- 订单信息表
CREATE TABLE Order (
OrderID INT COMMENT '订单ID;主键;自增',
StudentID INT COMMENT '学员ID;外键:学员ID',
ClassID INT COMMENT '班级ID;外键:班级ID',
OrderDate DATE COMMENT '下单日期;格式为YYYY-MM-DD',
TotalAmount DECIMAL(10, 2) COMMENT '总金额;例如:2000.00',
Status ENUM('待支付', '已支付', '已取消') COMMENT '状态;值为:待支付/已支付/已取消'
) COMMENT='订单信息表';

-- 支付记录表
CREATE TABLE Payment (
PaymentID INT COMMENT '支付记录ID;主键;自增',
OrderID INT COMMENT '订单ID;外键:订单ID',
PaymentDate DATE COMMENT '支付日期;格式为YYYY-MM-DD',
Amount DECIMAL(10, 2) COMMENT '支付金额;例如:2000.00',
PaymentMethod ENUM('现金', '信用卡', '在线支付') COMMENT '支付方式;值为:现金/信用卡/在线支付'
) COMMENT='支付记录表';

数据查询

对每个教练,统计两个指标以评估其绩效。一是其所授课学员打分的均值,二是上过该教练课程的学员有多大比例会再次选择该教练。

任务描述

请将上述数据查询在给定的数仓表格之上实现为SQL语句。该SQL语句必须能在该数仓上执行并得到正确的结果。如果发现给定的数仓表格缺少SQL实现所需要的表和字段,请报告错误,给出原因,并终止任务。
注意,该数仓仅支持MySQL的SQL方言。

助手:

我们先对查询的目标结果做结构分析,然后对查询的计算方案展开分析,然后将计算方案拆解为子任务并依次实现,最后给出完整的SQL实现。

查询目标结果结构分析

我们假设查询的目标结果可以用一个数据表表示,我们从如下三个方面分析该数据表的结构。

  1. 行粒度是什么?
  2. 包含哪些行?是否有明确的范围要求?
  3. 包含哪些列?是已经存在的属性字段,还是需要计算的字段?

该查询目标结果的行粒度是教练,其范围没有明确的要求。

该查询目标结果的列需要包含:“教练ID”、“教练姓名”、“该教练所授课学员打分的均值”、“上过该教练课程的学员再次选择该教练的比例”。

其中“教练ID”、“教练姓名”是数仓中已存在的属性字段。“该教练所授课学员打分的均值”、“上过该教练课程的学员再次选择该教练的比例”两个字段需要计算。

查询计算方案分析

我们尝试分析上述目标结果如何计算得到,将其计算过程拆解为一系列简单的子任务。计算方案分析一方面需要分析计算的逻辑和步骤顺序,一方面需要分析计算所需的输入字段和表格、以及表格之间的连接方式。

要计算“每个教练所授课学员打分的均值”和“上过该教练课程的学员再次选择该教练的比例”,我们需要分别计算每个教练所授课的学员打分的均值,以及每个教练所授课的学员中再次选择该教练的学员数和总学员数,在此基础上,再计算上过该教练课程的学员再次选择该教练的比例,最后提取所需的属性字段。

如何计算“每个教练所授课学员打分的均值”

要计算“每个教练所授课学员打分的均值”,需要用到课节表Lesson,按照教练ID分组,对学员打分进行平均计算即可。计算的输入需要用到课节表Lesson

如何计算“每个教练所授课的学员数”

要计算“每个教练所授课的学员数”,可以直接按照教练ID分组,对学员ID进行去重计数即可。计算的输入需要用到课节表Lesson

如何计算“上过该教练课程的学员中再次选择该教练的学员数”

要计算“上过该教练课程的学员中再次选择该教练的学员数”,可以用课节表Lesson自连接,左表记录第一次选择该教练的课节,右表记录再次选择该教练的课节,然后按照教练ID分组,统计右表中的学员ID数量即可。计算的输入需要用到课节表Lesson自连接的表。

在此基础上,如何计算“上过该教练课程的学员再次选择该教练的比例”

“上过该教练课程的学员再次选择该教练的比例”可以按照以下公式计算:

“上过该教练课程的学员再次选择该教练的比例”=“上过该教练课程的学员中再次选择该教练的学员数”/“每个教练所授课的学员数”

其中“上过该教练课程的学员中再次选择该教练的学员数”和“每个教练所授课的学员数”可复用上面的计算结果。

如何做全连接整合结果

每个教练所授课学员打分的均值和上过该教练课程的学员再次选择该教练的比例有一个不为0,该月份和班级类型就应该保留在结果中。所以需要对前面两个计算结果通过教练ID做全连接。全连接的结果定义了该查询的目标结果的行范围。

MySQL中不支持FULL JOIN,需要用UNION+LEFT JOIN代替。先对前面两个计算结果教练ID求并集,再反过来左连接前面两个计算结果。左连接后要处理NULL值,如果每个教练所授课学员打分的均值或上过该教练课程的学员再次选择该教练的比例为NULL,将其改成0。

如何提取所需属性字段

“教练ID”字段,在行范围计算中就会给出,无需再加考虑。

其余属性字段只有“教练名称”。“教练名称”仅存在于教练表Instructor中,需要在行范围计算完成后,左连接Instructor提取该字段。

子任务拆解与实现

基于上述分析,我们尝试将该数据查询的SQL实现拆解成一系列简单的子任务。其中后面的子任务可以使用前面的子任务的计算结果。每个子任务都可以用一个简单的SQL语句实现。这些SQL语句中没有嵌套子查询或者只有非常简单的嵌套子查询。为了SQL实现的简洁性,提取各剩余属性字段的工作会尽量合并到一个子任务中。我们会给子任务的结果起名字,方便后续依赖方引用。

按照这种思路,我们将计算方案拆解成如下子任务(按照拓扑序列出):

  • 子任务1:计算“教练所授课学员打分的均值”。结果记为T1。
  • 子任务2:计算“每个教练的总学员数量”。结果记为T2。
  • 子任务3:计算“每个教练的重复学员数量”。结果记为T3。
  • 子任务4:计算“每个教练的上过该教练课程的学员再次选择该教练的比例”。结果记为T4。
  • 子任务5:对T1与T4的“教练ID”求并集。结果记为T5。T5定义了查询结果的数据范围。
  • 子任务6:以T5左连接T1和T4,处理NULL值,并左连接教练信息表,提取剩余所需属性字段。所得即完整的查询结果。

下面依次实现各个子任务,所有子任务的SQL片段可以拼装出原查询完整的SQL实现。构造子任务的SQL实现时,需要遵守以下要求:

  1. 在写SQL之前,将计算逻辑和所用表格字段重述一遍。
  2. 后面的子任务若要使用前面子任务的结果,直接用名字引用,不要重复实现。
  3. SQL中不要给表取别名,尽量使用表的原名。大家熟悉原名,这样写SQL更容易理解。
  4. 构造SQL查询条件时,要考虑索引利用的有效性,尽量避免对字段做转换后再做比较。比如要表达“订单日期大于等于2022年”的查询条件,应使用order_date>='2022-01-01',而不是YEAR(order_date)>='2022'

子任务1:计算“每个教练所授课学员打分的均值”。结果记为T1。

如前文分析,要计算“每个教练所授课学员打分的均值”,需要用到课节表Lesson,按照教练ID分组,对学员打分进行平均计算即可。计算的输入需要用到课节表Lesson

  • “教练ID”对应字段Lesson.InstructorID
  • “学员打分”对应字段Lesson.Rating

SQL实现如下:

1
2
3
4
SELECT InstructorID, AVG(Rating) AS average_rating
FROM Lesson
WHERE Rating IS NOT NULL
GROUP BY InstructorID

子任务2:计算“每个教练所授课的学员数”。结果记为T2。

如前文分析,要计算“每个教练所授课的学员数”,可以直接按照教练ID分组,对学员ID进行去重计数即可。计算的输入需要用到课节表Lesson

  • “教练ID”对应字段Lesson.InstructorID
  • “学员ID”对应字段Lesson.StudentID

SQL实现如下:

1
2
3
SELECT InstructorID, COUNT(DISTINCT StudentID) AS total_students
FROM Lesson
GROUP BY InstructorID

子任务3:计算“上过该教练课程的学员中再次选择该教练的学员数”。结果记为T3。

如前文分析,要计算“上过该教练课程的学员中再次选择该教练的学员数”,可以用课节表Lesson自连接,左表记录第一次选择该教练的课节,右表记录再次选择该教练的课节,然后按照教练ID分组,统计右表中的学员ID数量即可。计算的输入需要用到课节表Lesson自连接的表。

  • “教练ID”对应字段Lesson.InstructorID
  • “学员ID”对应字段Lesson.StudentID

SQL实现如下:

1
2
3
4
SELECT L1.InstructorID, COUNT(DISTINCT L2.StudentID) AS repeat_students
FROM Lesson AS L1
JOIN Lesson AS L2 ON L1.InstructorID = L2.InstructorID AND L1.StudentID = L2.StudentID AND L1.LessonID <> L2.LessonID
GROUP BY L1.InstructorID

子任务4:计算“每个教练的上过该教练课程的学员再次选择该教练的比例”,结果记为T4。

如前文分析,“上过该教练课程的学员再次选择该教练的比例”=“上过该教练课程的学员中再次选择该教练的学员数”/“每个教练所授课的学员数”。

SQL实现如下:

1
2
3
SELECT T2.InstructorID,T3.repeat_students / T2.total_students AS repeat_ratio
FROM T2
LEFT JOIN T3 ON T2.InstructorID = T3.InstructorID

子任务5:对T1与T4的“教练ID”求并集。结果记为T5。T5定义了查询结果的数据范围。

使用UNION关键字进行组合。SQL实现如下:

1
2
3
4
5
SELECT InstructorID
FROM T1
UNION
SELECT InstructorID
FROM T4

子任务6:以T5左连接T1和T4,处理NULL值,并左连接教练信息表,提取剩余所需属性字段。所得即完整的查询结果。

如果每个教练所授课学员打分的均值或上过该教练课程的学员再次选择该教练的比例为NULL,将其改成0。T5和T1的连接字段是教练ID,T5和T4的连接字段也是教练ID,T5和教练信息表的连接字段也是教练ID。

1
2
3
4
5
SELECT T5.InstructorID,Instructor.Name,IFNULL(T1.average_rating,0) average_rating,T4.repeat_ratio
FROM T5
LEFT JOIN T1 ON T1.InstructorID=T5.InstructorID
LEFT JOIN T4 ON T4.InstructorID = T5.InstructorID
LEFT JOIN Instructor ON Instructor.InstructorID = T5.InstructorID

答案

使用WITH子句拼装各个子任务的SQL片段,并添加注释保证易读性,得到对原数据查询的完整的SQL实现:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
WITH T1 AS (
-- 子任务1:计算“每个教练所授课学员打分的均值”。结果记为T1。
SELECT InstructorID, AVG(Rating) AS average_rating
FROM Lesson
WHERE Rating IS NOT NULL
GROUP BY InstructorID
),
T2 AS (
-- 子任务2:计算“每个教练所授课的学员数”。结果记为T2。
SELECT InstructorID, COUNT(DISTINCT StudentID) AS total_students
FROM Lesson
GROUP BY InstructorID
),
T3 AS (
-- 子任务3:计算“上过该教练课程的学员中再次选择该教练的学员数”。结果记为T3。
SELECT L1.InstructorID, COUNT(DISTINCT L1.StudentID) AS repeat_students
FROM Lesson AS L1
JOIN Lesson AS L2 ON L1.StudentID = L2.StudentID AND L1.InstructorID = L2.InstructorID AND L1.LessonID <> L2.LessonID
GROUP BY L1.InstructorID
),
T4 AS (
-- 子任务4:计算“每个教练的上过该教练课程的学员再次选择该教练的比例”,结果记为T4。
SELECT T2.InstructorID, IFNULL(T3.repeat_students, 0) / T2.total_students AS repeat_ratio
FROM T2
LEFT JOIN T3 ON T2.InstructorID = T3.InstructorID
),T5 AS (
-- 子任务5:对T1与T4的“教练ID”求并集。结果记为T5。T5定义了查询结果的数据范围。
SELECT InstructorID
FROM T1
UNION
SELECT InstructorID
FROM T4
)
-- 子任务6:以T5左连接T1和T4,处理NULL值,并左连接教练信息表,提取剩余所需属性字段。所得即完整的查询结果。
SELECT T5.InstructorID,Instructor.Name,IFNULL(T1.average_rating,0) average_rating,T4.repeat_ratio
FROM T5
LEFT JOIN T1 ON T1.InstructorID=T5.InstructorID
LEFT JOIN T4 ON T4.InstructorID = T5.InstructorID
LEFT JOIN Instructor ON Instructor.InstructorID = T5.InstructorID