Packages

ecto_psql_extras

0.8.7
0.8.8 0.8.7 0.8.6 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.15 0.7.14 0.7.13 0.7.12 0.7.11 0.7.10 0.7.9 0.7.8 0.7.7 0.7.6 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.0 0.1.4 0.1.3 0.1.2 0.0.2 0.0.1

Ecto PostgreSQL database performance insights. Locks, index usage, buffer cache hit ratios, vacuum stats and more.

HexDocs

Current section

Files

Jump to
Readme
47 Versions
3 Dependencies
Dependants
Files
Activity
ecto_psql_extras lib ecto_psql_extras missing_fk_indexes_logic.ex
Raw

lib/ecto_psql_extras/missing_fk_indexes_logic.ex 

defmodule EctoPSQLExtras.MissingFkIndexesLogic do

  @moduledoc """

  Detect missing foreign key indexes

  """



  require Logger



  def run(repo, table_name \\ nil) do

    all_indexes = EctoPSQLExtras.indexes(repo, format: :raw).rows



    all_tables =

      EctoPSQLExtras.table_size(repo, format: :raw).rows

      |> Enum.map(fn [_, table_name, _] -> table_name end)



    tables =

      if table_name do

        [to_string(table_name)]

      else

        all_tables

      end



    rows =

      Enum.reduce(tables, [], fn table, agg ->

        indexed_columns =

          all_indexes

          |> Enum.filter(fn [_, _, index_table_name, _] -> index_table_name == table end)

          |> Enum.map(fn [_, _, _, column_name] ->

            column_name

            |> String.split(",")

            |> List.first()

          end)



        fk_columns =

          EctoPSQLExtras.table_schema(repo, args: [table_name: table], format: :raw).rows

          |> Enum.map(fn [column_name, _, _, _, _] -> column_name end)

          |> Enum.filter(fn column_name ->

            EctoPSQLExtras.DetectFkColumn.call(column_name, all_tables)

          end)



        missing_indexes =

          Enum.reduce(fk_columns, agg, fn column_name, agg ->

            if !Enum.member?(indexed_columns, column_name) do

              [[table, column_name] | agg]

            else

              agg

            end

          end)



        missing_indexes

      end)



    %{

      rows: rows,

      columns: ["table", "column_name"]

    }

  end

end