with q_temp as ( select p.product_id,product_name,sum(quantity) as total_quantity from products_underline p join sales_underline s on s.product_id=p.product_id group by p.product_id ) select q.product_id,product_name,total_quantity,round(avg(rating) ,2) as average_rating from q_temp q join reviews_u...

with per_temp as ( SELECT e.employee_id,employee_name,performance_score,project_id,department from employees e left join performance pe on pe.employee_id=e.employee_id ), pro_temp as ( SELECT employee_id,employee_name,performance_score,pr.project_id,project_name,start_date,department, rank() over(pa...

SELECT ei.EMPLOYEE_ID, -- 如果 eu.EMPLOYEE_ID 是 NULL (表示该员工无更新记录)，则直接用主表职位。 -- 否则，比较日期，决定使用新职位还是旧职位。 CASE WHEN eu.EMPLOYEE_ID IS NULL THEN ei.POSITION WHEN eu.update_dt > ei.LAST_UPDATE_DT THEN eu.NEW_POSITION ELSE ei.POSITION END AS POSITION, -- 日期的逻辑与上面类似 CASE WHEN eu.EMPLOYEE_ID IS NULL THEN ei....

-- 1. 将播放记录的起止时间(start/end)拆解为+1和-1的离散事件流。 WITH events AS ( SELECT cid, start_time as event_time, 1 as event_type FROM play_record_tb UNION ALL SELECT cid, end_time as event_time, -1 as event_type FROM play_record_tb ), -- 2. 利用窗口函数计算每个时间点的并发数。 running_totals AS ( SELECT cid, event_time, -- 通过累加事件(+...

WITH time_points AS ( -- 收集所有可能的关键时间点 SELECT DISTINCT cid, start_time as check_time FROM play_record_tb UNION SELECT DISTINCT cid, end_time as check_time FROM play_record_tb ), concurrent_at_each_time AS ( -- 对每个时间点计算该时刻的并发数 SELECT tp.cid, tp.check_time, COUNT(pr.id) as concurrent_count FROM time_po...

with temp1 as ( select avg(score) over ( partition by exam_id ) as avg_score, avg(timestampdiff(minute, start_time, submit_time)) over ( partition by exam_id ) as avg_time, timestampdiff(minute, start_time, submit_time) as time, emp_id, score, tag, e.exam_id from exam_record e join examination_info ...

with temp as ( select follower_id from follow where user_id=1 ), temp1 as ( SELECT DISTINCT music_id from music_likes ml join temp f on ml.user_id=f.follower_id ), temp2 as ( Select m.id as id, music_name from music m join temp1 t on t.music_id=m.id ), temp3 as ( select id, music_name, ROW_NUMBER() ...

with temp as ( select department,sum(case when timestampdiff(second,first_clockin,last_clockin)/3600>9.5 then 1 else 0 end) as ot_count ,count(*) as staff_count from attendent_tb a join staff_tb s on s.staff_id =a.staff_id group by department) select department ,concat(round(ot_count/staff_count*...

with temp as (select user_id,sum( order_price) as add_point from order_tb where order_price>100 group by user_id) select t.user_id,add_point+point as point from temp t join uservip_tb u on u.user_id=t.user_id order by point desc;

with temp as (select date(visit_time) as date_visit,count(distinct user_id) as visit_count from visit_tb group by date(visit_time) ), temp2 as ( select date(order_time) as date_order,count(distinct user_id) as order_count from order_tb group by date(order_time) ) select t1.date_visit as date,concat(...

SELECT user_id, COUNT(*) as visit_nums FROM visit_tb WHERE user_id IN ( SELECT DISTINCT user_id FROM order_tb WHERE DATE(order_time) = '2022-09-02' ) AND DATE(visit_time) = '2022-09-02' GROUP BY user_id ORDER BY visit_nums DESC;

with temp as ( select user_id,log_date, case when datediff(log_date,lag(log_date,1,log_date) over(partition by user_id order by log_date)) >1 then 1 else 0 end as break from ( select distinct l.user_id, date(log_time) as log_date from login_tb l join register_tb r on r.user_id=l.user_id ) t ), te...

with temp as ( select user_id,log_date, case when datediff(log_date,lag(log_date,1,log_date) over(partition by user_id order by log_date)) >1 then 1 else 0 end as break from ( select l.user_id, date(log_time) as log_date from login_tb l join register_tb r on r.user_id=l.user_id ) t ), temp2 as ( ...

with temp as ( select distinct user_id, score from recommend_tb r join user_action_tb u on u.user_id = r.rec_user where rec_info_l = hobby_l ) select sum(score) / count(*) as avg_score from temp;