Packages

walex

4.3.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 mix tasks helpers.ex
Raw

lib/mix/tasks/helpers.ex 

defmodule Mix.Tasks.Walex.Helpers do

  @config %{

    hostname: "localhost",

    username: "postgres",

    password: "postgres",

    port: 5432

  }



  @moduledoc false

  def create_database(database_name) do

    "-c \"CREATE DATABASE #{database_name};\""

    |> database_cmd()

  end



  def drop_database(database_name) do

    "-c \"DROP DATABASE #{database_name};\""

    |> database_cmd()

  end



  def create_extension(pid, extension) do

    extension_query = "CREATE EXTENSION IF NOT EXISTS \"#{extension}\";"



    Postgrex.query!(pid, extension_query, [])

  end



  def database_cmd(cmd) do

    db_cmd = "psql " <> cmd



    env = [

      {"PGHOST", @config.hostname},

      {"PGUSER", @config.username},

      {"PGPASSWORD", @config.password},

      {"PGPORT", Integer.to_string(@config.port)}

    ]



    case System.shell(db_cmd, env: env) do

      {output, 0} ->

        output



      {output, _status} ->

        output

    end

  end

end