Packages

walex

4.4.0
4.8.0 4.7.1 4.7.0 4.6.0 4.5.0 4.4.0 4.3.0 4.2.0 4.1.0 4.0.0 3.8.0 3.7.0 3.6.0 3.5.0 3.4.0 3.2.0 3.1.2 3.1.0 3.0.6 3.0.5 3.0.4 3.0.2 3.0.0 2.3.2 2.3.0 2.2.0 2.1.1 2.1.0 2.0.0 1.0.1 1.0.0 0.9.0 0.8.2 0.8.1 0.8.0 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

Listen to change events on your Postgres tables then perform callback-like actions with the data.

HexDocs

Current section

Files

Jump to
Readme
46 Versions
4 Dependencies
Dependants
Files
Activity
walex lib walex replication query_builder.ex
Raw

lib/walex/replication/query_builder.ex 

defmodule WalEx.Replication.QueryBuilder do

  def publication_exists(%{publication: publication}) do

    "SELECT 1 FROM pg_publication WHERE pubname = '#{publication}' LIMIT 1;"

  end



  def slot_exists(%{slot_name: slot_name}) do

    "SELECT active FROM pg_replication_slots WHERE slot_name = '#{slot_name}' LIMIT 1;"

  end



  def create_temporary_slot(%{slot_name: slot_name}) do

    "CREATE_REPLICATION_SLOT #{slot_name} TEMPORARY LOGICAL pgoutput NOEXPORT_SNAPSHOT;"

  end



  def create_durable_slot(%{slot_name: slot_name}) do

    "CREATE_REPLICATION_SLOT #{slot_name} LOGICAL pgoutput NOEXPORT_SNAPSHOT;"

  end



  def start_replication_slot(%{slot_name: slot_name, publication: publication}) do

    "START_REPLICATION SLOT #{slot_name} LOGICAL 0/0 (proto_version '1', publication_names '#{publication}')"

  end

end