usr_count INTEGER DEFAULT 0;
migrated_count INTEGER DEFAULT 0;
pending_count INTEGER DEFAULT 0;
+ has_pending BOOLEAN;
BEGIN
FOR cur_usr IN
WITH history_users AS (
) SELECT users.id FROM history_users users ORDER BY users.id
LOOP
usr_count := usr_count + 1;
+ has_pending := FALSE;
FOR cur_circ IN SELECT * FROM action.usr_visible_circs(cur_usr) LOOP
PERFORM TRUE FROM action.usr_circ_history
WHERE source_circ = cur_circ.id;
IF FOUND THEN
migrated_count := migrated_count + 1;
ELSE
- RAISE NOTICE 'User % [offset = %] has pending circs',
- cur_usr, (usr_count - 1);
+ has_pending := TRUE;
pending_count := pending_count + 1;
END IF;
END LOOP;
+ IF has_pending THEN
+ RAISE NOTICE 'User % [offset = %] has pending circs',
+ cur_usr, (usr_count - 1);
+ END IF;
+
IF (usr_count % 10000) = 0 THEN
RAISE NOTICE 'Processed % patrons', usr_count;
RAISE NOTICE 'Pending circs: %', pending_count;