diff options
| -rw-r--r-- | priv/repo/migrations/20171109091239_add_actor_to_activity.exs | 17 |
1 files 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 |