Packages

integratedb

0.1.0
0.1.0

IntegrateDB is a database sharing system. It provides integration primitives and data ownership and migration controls. Use it to integrate applications directly through a Postgres database.

HexDocs

Current section

Files

Jump to
Readme
1 Version
17 Dependencies
Dependants
Files
Activity
integratedb lib mix tasks enable_logical_replication.ex
Raw

lib/mix/tasks/enable_logical_replication.ex 

defmodule Mix.Tasks.EnableLogicalReplication do

  use Mix.Task



  alias Ecto.Adapters.SQL

  alias Integrate.Repo



  @shortdoc "Enable logical replication in the postgres database."

  def run(_) do

    [:postgrex, :ecto] |> Enum.each(&Application.ensure_all_started/1)

    {:ok, pid} = Repo.start_link()



    {:ok, _} = SQL.query(Repo, "ALTER SYSTEM SET wal_level = 'logical'")



    Process.exit(pid, :normal)

    [:postgrex, :ecto] |> Enum.each(&Application.stop/1)



    log_file = "#{System.fetch_env!("PGDATA")}/server.log"

    System.cmd("pg_ctl", ["-l", log_file, "restart"])

  end

end