Skip to content

Commit 07806e7

Browse files
Konstantin KalinovskyBrutus5000
authored andcommitted
Starting event immediately after it's created
1 parent 6e7624e commit 07806e7

File tree

4 files changed

+4
-73
lines changed

4 files changed

+4
-73
lines changed

migrations/V89__global_rating_distribution_view_to_event.sql

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -8,20 +8,10 @@ CREATE TABLE IF NOT EXISTS `global_rating_distribution` (
88
ALTER TABLE `global_rating`
99
ADD INDEX `global_rating_idx_for_rating_distribution` (`is_active`, `numGames`, `mean`, `deviation`);
1010

11-
INSERT INTO global_rating_distribution
12-
SELECT `subq`.`rating`, COUNT(*)
13-
FROM (
14-
SELECT floor((`global_rating`.`mean` - 3 * `global_rating`.`deviation`) / 100) * 100 AS `rating`
15-
FROM `global_rating`
16-
WHERE `global_rating`.`is_active` = 1 AND `global_rating`.`numGames` > 0
17-
) AS `subq`
18-
GROUP BY `subq`.`rating`
19-
ORDER BY `subq`.`rating`;
20-
2111
DELIMITER $$
2212

2313
CREATE EVENT IF NOT EXISTS `global_rating_distribution`
24-
ON SCHEDULE EVERY 1 HOUR
14+
ON SCHEDULE EVERY 1 HOUR STARTS CURRENT_TIMESTAMP
2515
COMMENT 'Recompute the global_rating_distribution table every hour'
2616
DO
2717
BEGIN

migrations/V90__map_reviews_summary_view_to_event.sql

Lines changed: 1 addition & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -11,35 +11,10 @@ CREATE TABLE IF NOT EXISTS `map_reviews_summary` (
1111
) ENGINE=InnoDB;
1212

1313

14-
INSERT INTO map_reviews_summary
15-
SELECT `map_version`.`map_id` AS `id`,
16-
`map_version`.`map_id` AS `map_id`,
17-
sum(`summary`.`positive`) AS `positive`,
18-
sum(`summary`.`negative`) AS `negative`,
19-
sum(`summary`.`score`) AS `score`,
20-
sum(`summary`.`reviews`) AS `reviews`,
21-
IF(sum(`summary`.`reviews`) = 0, NULL, sum(`summary`.`weighted_bound`) / sum(`summary`.`reviews`)) AS `lower_bound`
22-
FROM (
23-
(
24-
SELECT `map_version_reviews_summary`.`id` AS `id`,
25-
`map_version_reviews_summary`.`map_version_id` AS `map_version_id`,
26-
`map_version_reviews_summary`.`positive` AS `positive`,
27-
`map_version_reviews_summary`.`negative` AS `negative`,
28-
`map_version_reviews_summary`.`score` AS `score`,
29-
`map_version_reviews_summary`.`reviews` AS `reviews`,
30-
`map_version_reviews_summary`.`lower_bound` AS `lower_bound`,
31-
`map_version_reviews_summary`.`reviews` * `map_version_reviews_summary`.`lower_bound` AS `weighted_bound`
32-
FROM `map_version_reviews_summary`
33-
) `summary`
34-
JOIN `map_version` on `map_version`.`id` = `summary`.`map_version_id`
35-
)
36-
GROUP BY `map_version`.`map_id`;
37-
38-
3914
DELIMITER $$
4015

4116
CREATE EVENT IF NOT EXISTS `map_reviews_summary`
42-
ON SCHEDULE EVERY 10 MINUTE
17+
ON SCHEDULE EVERY 10 MINUTE STARTS CURRENT_TIMESTAMP
4318
COMMENT 'Recompute the map_reviews_summary table every 10 minutes'
4419
DO
4520
BEGIN

migrations/V91__ladder1v1_rating_distribution_view_to_event.sql

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -8,20 +8,10 @@ CREATE TABLE IF NOT EXISTS `ladder1v1_rating_distribution` (
88
ALTER TABLE `ladder1v1_rating`
99
ADD INDEX `ladder1v1_rating_idx_for_rating_distribution` (`is_active`, `numGames`, `mean`, `deviation`);
1010

11-
INSERT INTO ladder1v1_rating_distribution
12-
SELECT `subq`.`rating`, COUNT(*)
13-
FROM (
14-
SELECT floor((`ladder1v1_rating`.`mean` - 3 * `ladder1v1_rating`.`deviation`) / 100) * 100 AS `rating`
15-
FROM `ladder1v1_rating`
16-
WHERE `ladder1v1_rating`.`is_active` = 1 AND `ladder1v1_rating`.`numGames` > 0
17-
) AS `subq`
18-
GROUP BY `subq`.`rating`
19-
ORDER BY `subq`.`rating`;
20-
2111
DELIMITER $$
2212

2313
CREATE EVENT IF NOT EXISTS `ladder1v1_rating_distribution`
24-
ON SCHEDULE EVERY 1 HOUR
14+
ON SCHEDULE EVERY 1 HOUR STARTS CURRENT_TIMESTAMP
2515
COMMENT 'Recompute the ladder1v1_rating_distribution table every hour'
2616
DO
2717
BEGIN

migrations/V92__mod_review_summary_view_to_event.sql

Lines changed: 1 addition & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -11,34 +11,10 @@ CREATE TABLE IF NOT EXISTS `mod_reviews_summary` (
1111
lower_bound DOUBLE NULL
1212
) ENGINE=InnoDB;
1313

14-
15-
INSERT INTO mod_reviews_summary
16-
SELECT `mod_version`.`mod_id` AS `id`,
17-
`mod_version`.`mod_id` AS `mod_id`,
18-
sum(`summary`.`positive`) AS `positive`,
19-
sum(`summary`.`negative`) AS `negative`,
20-
sum(`summary`.`score`) AS `score`,
21-
sum(`summary`.`reviews`) AS `reviews`,
22-
IF(sum(`summary`.`reviews`) = 0, NULL, sum(`summary`.`weighted_bound`) / sum(`summary`.`reviews`)) AS `lower_bound`
23-
FROM (
24-
(SELECT `mod_version_reviews_summary`.`id` AS `id`,
25-
`mod_version_reviews_summary`.`mod_version_id` AS `mod_version_id`,
26-
`mod_version_reviews_summary`.`positive` AS `positive`,
27-
`mod_version_reviews_summary`.`negative` AS `negative`,
28-
`mod_version_reviews_summary`.`score` AS `score`,
29-
`mod_version_reviews_summary`.`reviews` AS `reviews`,
30-
`mod_version_reviews_summary`.`lower_bound` AS `lower_bound`,
31-
`mod_version_reviews_summary`.`reviews` * `mod_version_reviews_summary`.`lower_bound` AS `weighted_bound`
32-
FROM `mod_version_reviews_summary`
33-
) `summary`
34-
JOIN `mod_version` ON `mod_version`.`id` = `summary`.`mod_version_id`
35-
)
36-
GROUP BY `mod_version`.`mod_id`;
37-
3814
DELIMITER $$
3915

4016
CREATE EVENT IF NOT EXISTS `mod_reviews_summary`
41-
ON SCHEDULE EVERY 10 MINUTE
17+
ON SCHEDULE EVERY 10 MINUTE STARTS CURRENT_TIMESTAMP
4218
COMMENT 'Recompute the mod_reviews_summary table every 10 minutes'
4319
DO
4420
BEGIN

0 commit comments

Comments
 (0)