From 20b8b8774345d07537687ad5dd2fdb6f809e684f Mon Sep 17 00:00:00 2001 From: Roger Braun Date: Thu, 9 Nov 2017 12:33:38 +0100 Subject: [PATCH] Update in chunks. --- .../20171109091239_add_actor_to_activity.exs | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) diff --git a/priv/repo/migrations/20171109091239_add_actor_to_activity.exs b/priv/repo/migrations/20171109091239_add_actor_to_activity.exs index bac53972c..c04922c76 100644 --- a/priv/repo/migrations/20171109091239_add_actor_to_activity.exs +++ b/priv/repo/migrations/20171109091239_add_actor_to_activity.exs @@ -1,6 +1,8 @@ defmodule Pleroma.Repo.Migrations.AddActorToActivity do use Ecto.Migration + alias Pleroma.{Repo, Activity} + @disable_ddl_transaction true def up do @@ -8,9 +10,18 @@ defmodule Pleroma.Repo.Migrations.AddActorToActivity do add :actor, :string end - execute """ - update activities set actor = data->>'actor'; - """ + max = Repo.aggregate(Activity, :max, :id) + IO.puts("#{max} activities") + chunks = 0..(round(max / 10_000)) + + Enum.each(chunks, fn (i) -> + min = i * 10_000 + max = min + 10_000 + IO.puts("Updating #{min}") + execute """ + update activities set actor = data->>'actor' where id > #{min} and id <= #{max}; + """ + end) create index(:activities, [:actor, "id DESC NULLS LAST"], concurrently: true) end -- 2.45.2