Massage index until it actually does the stuff we want.
Also makes the index a lot smoler.
This commit is contained in:
parent
89762ad230
commit
f3c8b02d65
|
@ -521,7 +521,7 @@ defp restrict_actor(query, %{"actor_id" => actor_id}) do
|
||||||
defp restrict_actor(query, _), do: query
|
defp restrict_actor(query, _), do: query
|
||||||
|
|
||||||
defp restrict_type(query, %{"type" => type}) when is_binary(type) do
|
defp restrict_type(query, %{"type" => type}) when is_binary(type) do
|
||||||
restrict_type(query, %{"type" => [type]})
|
from(activity in query, where: fragment("?->>'type' = ?", activity.data, ^type))
|
||||||
end
|
end
|
||||||
|
|
||||||
defp restrict_type(query, %{"type" => type}) do
|
defp restrict_type(query, %{"type" => type}) do
|
||||||
|
|
|
@ -0,0 +1,30 @@
|
||||||
|
defmodule Pleroma.Repo.Migrations.AddCorrectDMIndex do
|
||||||
|
use Ecto.Migration
|
||||||
|
@disable_ddl_transaction true
|
||||||
|
|
||||||
|
def up do
|
||||||
|
drop_if_exists(
|
||||||
|
index(:activities, ["activity_visibility(actor, recipients, data)"],
|
||||||
|
name: :activities_visibility_index
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
create(
|
||||||
|
index(:activities, ["activity_visibility(actor, recipients, data)", "id DESC NULLS LAST"],
|
||||||
|
name: :activities_visibility_index,
|
||||||
|
concurrently: true,
|
||||||
|
where: "data->>'type' = 'Create'"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
end
|
||||||
|
|
||||||
|
def down do
|
||||||
|
drop(
|
||||||
|
index(:activities, ["activity_visibility(actor, recipients, data)", "id DESC"],
|
||||||
|
name: :activities_visibility_index,
|
||||||
|
concurrently: true,
|
||||||
|
where: "data->>'type' = 'Create'"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
end
|
||||||
|
end
|
Loading…
Reference in New Issue