fazibear/defql

if Code.ensure_loaded?(Ecto) do
  defmodule Defql.Adapter.Ecto.Postgres do
    @moduledoc """
    Adapter for postgres connection thru ecto.
    """

    @behaviour Defql.Adapter
    @repo Application.get_env(:defql, :connection)[:repo]

    alias Defql.Adapter.Postgres
    alias Defql.Adapter.Postgres.Query

    def start(_type, _args), do: @repo.start_link

    def select(table, params, columns) do
      {query, params} = Query.select(table, params, columns)
      query(query, params)
    end

    def insert(table, params) do
      {query, params} = Query.insert(table, params)
      query(query, params)
    end

    def delete(table, params) do
      {query, params} = Query.delete(table, params)
      query(query, params)
    end

    def update(table, params, conds) do
      {query, params} = Query.update(table, params, conds)
      query(query, params)
    end

    def query(query, params) do
      @repo
      |> Ecto.Adapters.SQL.query(query, params)
      |> Postgres.query_result
    end
  end
end