-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathqueries.sql
More file actions
78 lines (66 loc) · 1.78 KB
/
queries.sql
File metadata and controls
78 lines (66 loc) · 1.78 KB
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
-- Q1: City Performance
SELECT start_city AS city,
COUNT(*) total_rides,
ROUND(SUM(CASE WHEN ride_status='Canceled' THEN 1 ELSE 0 END)*100/COUNT(*),2) cancel_rate,
ROUND(AVG(rating),2) avg_rating
FROM rides
GROUP BY start_city;
-- Q2: Revenue Leakage
SELECT r.ride_id, r.fare
FROM rides r
LEFT JOIN payments p ON r.ride_id = p.ride_id
WHERE r.ride_status='Completed' AND p.payment_id IS NULL;
-- Q3: Cancellation Analysis
SELECT start_city,
COUNT(*) total_rides,
SUM(CASE WHEN ride_status='Canceled' THEN 1 ELSE 0 END) canceled
FROM rides
GROUP BY start_city;
-- Q4: Time Analysis
SELECT HOUR(start_time) hour,
COUNT(*) total,
SUM(CASE WHEN ride_status='Canceled' THEN 1 ELSE 0 END) canceled
FROM rides
GROUP BY hour;
-- Q5: Seasonal Analysis
SELECT
CASE
WHEN MONTH(ride_date) IN (12,1,2) THEN 'Winter'
WHEN MONTH(ride_date) IN (3,4,5) THEN 'Spring'
END AS season,
AVG(fare) avg_fare
FROM rides
GROUP BY season;
-- Q6: Ride Duration
SELECT start_city,
AVG(TIMESTAMPDIFF(MINUTE,start_time,end_time)) avg_duration
FROM rides
GROUP BY start_city;
-- Q7: Index
CREATE INDEX idx_ride_date ON rides(ride_date);
-- Q8: View
CREATE VIEW vw_avg_fare AS
SELECT start_city, AVG(fare) avg_fare
FROM rides
GROUP BY start_city;
-- Q9: Trigger for Ride Status Change Logging
-- Step 1: Create log table
CREATE TABLE ride_status_log (
log_id INT AUTO_INCREMENT PRIMARY KEY,
ride_id VARCHAR(50),
old_status VARCHAR(20),
new_status VARCHAR(20),
changed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
-- Step 2: Create trigger
DELIMITER $$
CREATE TRIGGER trg_ride_status_change
AFTER UPDATE ON rides
FOR EACH ROW
BEGIN
IF OLD.ride_status <> NEW.ride_status THEN
INSERT INTO ride_status_log (ride_id, old_status, new_status)
VALUES (NEW.ride_id, OLD.ride_status, NEW.ride_status);
END IF;
END$$
DELIMITER ;