Update data in batches while deleting a user

User pending deletion can have plenty of
associated data. We need to update that data
to a ghost user. To do it without query timeouts
we update it in batches.

Changelog: other
EE: true

app/services/users/migrate_to_ghost_user_service.rb

@@ -57,20 +57,20 @@ def migrate_records
 
     # rubocop: disable CodeReuse/ActiveRecord
     def migrate_issues
-      user.issues.update_all(author_id: ghost_user.id)
-      Issue.where(last_edited_by_id: user.id).update_all(last_edited_by_id: ghost_user.id)
+      batched_migrate(Issue, :author_id)
+      batched_migrate(Issue, :last_edited_by_id)
     end
     # rubocop: enable CodeReuse/ActiveRecord
 
     # rubocop: disable CodeReuse/ActiveRecord
     def migrate_merge_requests
-      user.merge_requests.update_all(author_id: ghost_user.id)
-      MergeRequest.where(merge_user_id: user.id).update_all(merge_user_id: ghost_user.id)
+      batched_migrate(MergeRequest, :author_id)
+      batched_migrate(MergeRequest, :merge_user_id)
     end
     # rubocop: enable CodeReuse/ActiveRecord
 
     def migrate_notes
-      user.notes.update_all(author_id: ghost_user.id)
+      batched_migrate(Note, :author_id)
     end
 
     def migrate_abuse_reports
@@ -87,8 +87,17 @@ def migrate_snippets
     end
 
     def migrate_reviews
-      user.reviews.update_all(author_id: ghost_user.id)
+      batched_migrate(Review, :author_id)
     end
+
+    # rubocop:disable CodeReuse/ActiveRecord
+    def batched_migrate(base_scope, column)
+      loop do
+        update_count = base_scope.where(column => user.id).limit(100).update_all(column => ghost_user.id)
+        break if update_count == 0
+      end
+    end
+    # rubocop:enable CodeReuse/ActiveRecord
   end
 end
 

ee/app/services/ee/users/migrate_to_ghost_user_service.rb

@@ -14,8 +14,8 @@ def migrate_records
 
       # rubocop: disable CodeReuse/ActiveRecord
       def migrate_epics
-        user.epics.update_all(author_id: ghost_user.id)
-        ::Epic.where(last_edited_by_id: user.id).update_all(last_edited_by_id: ghost_user.id)
+        batched_migrate(::Epic, :author_id)
+        batched_migrate(::Epic, :last_edited_by_id)
       end
       # rubocop: enable CodeReuse/ActiveRecord