Skip to content
Snippets Groups Projects
Commit 26711323 authored by Simon Künzel's avatar Simon Künzel
Browse files

Make migrate stats faster and fix missing delete

parent 573bf1a5
No related branches found
No related tags found
No related merge requests found
DELETE FROM lecture_daily_watch_stats; DELETE FROM lecture_daily_watch_stats;
DELETE FROM lecture_watch_stats; DELETE FROM lecture_watch_stats;
DELETE FROM publish_medium_watch_stats;
DELETE FROM unknown_video; DELETE FROM unknown_video;
CREATE OR REPLACE PROCEDURE temp_count_lecture_view(lec_id int, watch_timestamp timestamp) AS $$ CREATE OR REPLACE PROCEDURE temp_count_lecture_view(lec_id int, watch_timestamp timestamp) AS $$
...@@ -58,6 +59,7 @@ DO $$ ...@@ -58,6 +59,7 @@ DO $$
IF processed_count % 10000 = 0 THEN IF processed_count % 10000 = 0 THEN
RAISE NOTICE '(hlslog) Processed %/% (% %%)', processed_count, total_processing_count, (processed_count::double precision / total_processing_count * 100)::int; RAISE NOTICE '(hlslog) Processed %/% (% %%)', processed_count, total_processing_count, (processed_count::double precision / total_processing_count * 100)::int;
COMMIT;
END IF; END IF;
SELECT processed_count + 1 INTO processed_count; SELECT processed_count + 1 INTO processed_count;
...@@ -91,6 +93,7 @@ DO $$ ...@@ -91,6 +93,7 @@ DO $$
IF processed_count % 10000 = 0 THEN IF processed_count % 10000 = 0 THEN
RAISE NOTICE '(log) Processed %/% (% %%)', processed_count, total_processing_count, (processed_count::double precision / total_processing_count * 100)::int; RAISE NOTICE '(log) Processed %/% (% %%)', processed_count, total_processing_count, (processed_count::double precision / total_processing_count * 100)::int;
COMMIT;
END IF; END IF;
SELECT processed_count + 1 INTO processed_count; SELECT processed_count + 1 INTO processed_count;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment