forked from mirrors/akkoma
Fix migration for empty db.
This commit is contained in:
parent
6bf261589f
commit
9e60de695d
|
@ -5,18 +5,19 @@ defmodule Pleroma.Repo.Migrations.FillActorField do
|
||||||
|
|
||||||
def up do
|
def up do
|
||||||
max = Repo.aggregate(Activity, :max, :id)
|
max = Repo.aggregate(Activity, :max, :id)
|
||||||
IO.puts("#{max} activities")
|
if max do
|
||||||
chunks = 0..(round(max / 10_000))
|
IO.puts("#{max} activities")
|
||||||
|
chunks = 0..(round(max / 10_000))
|
||||||
|
|
||||||
Enum.each(chunks, fn (i) ->
|
Enum.each(chunks, fn (i) ->
|
||||||
min = i * 10_000
|
min = i * 10_000
|
||||||
max = min + 10_000
|
max = min + 10_000
|
||||||
IO.puts("Updating #{min}")
|
execute("""
|
||||||
execute("""
|
|
||||||
update activities set actor = data->>'actor' where id > #{min} and id <= #{max};
|
update activities set actor = data->>'actor' where id > #{min} and id <= #{max};
|
||||||
""")
|
""")
|
||||||
|> IO.inspect
|
|> IO.inspect
|
||||||
end)
|
end)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def down do
|
def down do
|
||||||
|
|
Loading…
Reference in a new issue