By default, the Monet.Result returned from a select will enumerate a list of lists (via the Enumerable protocol or Jason.encode).

The behavior can be changed to enumerate or encode to a list of maps:

    "select id, name from saiyans"
    |> Monet.query!()
    |> Monet.as_map()
    |> Jason.encode()  # or Enum.reduce/map/...

Note that calling as_map does not change the rows field of the result. It merely configures how the enumeration will operate. So, to get a list of all maps with columns as atoms, one would do:

    "select id, name from saiyans"
    |> Monet.query!()
    |> Monet.as_map(columns: :atoms)
    |> Enum.list()

as_map works on any value returned by query and query!. In the case of an error, the error is simply returned. As such, a safer usage would be:

case Monet.at_map(Monet.query("select id, name from saiyans")) do
    {:ok, result} -> ...
    {:error, err} -> ...
end

Returns a supervisor child specification for a pool of Monet.Connections.

Executes a query. Returns {:ok, %Monet.Result{}} or {:error, %Monet.Error{}} If no pool name is given, then the default name, Monet, is used. If no arguments are given, then a simple query is executed, otherwise, the query is prepared + executed + deallocated.

Same as query but returns a %Monet.Result{} or raises a %Monet.Error{}.

Starts the pool and establishes the specified number of connections

Options

• :connect_timeout - Timeout, in milliseconds, to conn10_000
• :database - Database to conenct to (default: "monetdb")
• :host - Hostname or IP of the server to connect to (default:"127.0.0.1")
• :name - The process name of the pool (default: Monet)
• :password - Password to use (default: "monetdb")
• :pool_size - Size of the conncetion pool (default: 10)
• :port - Port of the server to connect to (default: 50_000)
• :read_timeout - Timeout, in milliseconds, for individual tcp recv operations (default: 10_000)
• :send_timeout - Timeout, in milliseconds, for individual tcp send operatins (default: 10_000)
• :username - Username to use (default: "monetdb")

If a :name is given, that value must be provided as the first parameter to other functions in this module.

Checkouts a connection and runs fun within a transaction.

If fun returns {:rollback, res}, the transaction is rolled back and {:error, res} is returned. Alternatively, Monet.rollback/2 can be used to the same effect.

NOTE: The above means that, unlike other functions which only return {:ok, %Monet.Result{}} or {:error, %Monet.Error{}}, this function can also return {:error, term} where term is any value passed to Monet.rollback/2) or specified via {:rollback, value}.

Any other value returned by fun will result in the transaction being committed:

    Monet.transaction(fn tx ->
        Monet.query(tx, "....")
        Monet.query(tx, "....")
    end)

To be more explicit, fun can return {:commit, result} in which case the transaction will be commited and {:ok, result} will be returned.