Packages

arke_postgres

0.1.1
0.5.0 0.4.1 0.4.0 0.4.0-bulk.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.14 0.2.13 0.2.12 0.2.11 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.2 0.1.1 0.1.0

Arke postgres

HexDocs

Current section

Files

Jump to
Readme
36 Versions
4 Dependencies
Dependants
Files
Activity
arke_postgres lib arke_postgres table.ex
Raw

lib/arke_postgres/table.ex 

defmodule ArkePostgres.Table do

  import Ecto.Query, only: [from: 2]



  def get_all(project, schema, fields, where \\ []) do

    query = from(Atom.to_string(schema.id), select: ^fields, where: ^where)

    ArkePostgres.Repo.all(query, prefix: project)

  end



  def get_by(project, schema, fields, where) do

    query = from(Atom.to_string(schema.id), select: ^fields, where: ^where)

    ArkePostgres.Repo.one(query, prefix: project)

  end



  def insert(project, schema, data) do

    ArkePostgres.Repo.insert_all(Atom.to_string(schema.id), [data], prefix: project)

  end



  def update(project, schema, data, where \\ []) do

    query = from(Atom.to_string(schema.id), where: ^where, update: [set: ^data])

    ArkePostgres.Repo.update_all(query, [], prefix: project)

  end



  def delete(project, schema, where) do

    query = from(a in Atom.to_string(schema.id), where: ^where)

    {1, _} = ArkePostgres.Repo.delete_all(query, prefix: project)

  end

end