123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101 |
- Erlang PostgreSQL Database Client
- * Connect
- {ok, C} = pgsql:connect(Host, [Username], [Password], Opts).
- Host - host to connect to.
- Username - username to connect as, defaults to $USER.
- Password - optional password to authenticate with.
- Opts - property list of extra options. Supported properties:
- + database
- + port
- + ssl (true | false | required)
- + ssl_opts (see ssl docs in OTP)
- + timeout (milliseconds, defaults to 5000)
- {ok, C} = pgsql:connect("localhost", "username", [{database, "test_db"}]).
- ok = pgsql:close(C).
- The timeout parameter is applied to all operations. In the case of equery
- this means that total execution time may exceed the timeout value.
- * Simple Query
- {ok, Columns, Rows} = pgsql:squery(C, Sql).
- {error, #error{}} = pgsql:squery(C, InvalidSql).
- Columns - list of column records, see pgsql.hrl for definition.
- Rows - list of tuples, one for each row.
- The simple query protocol returns all columns as text (Erlang binaries)
- and does not support binding parameters.
- * Extended Query
- {ok, Columns, Rows} = pgsql:equery(C, "select ...", [Parameters]).
- {ok, Count} = pgsql:equery(C, "update ...", [Parameters]).
- {ok, Count, Columns, Rows} = pgsql:equery(C, "insert ... returning ...", [Parameters]).
- {error, #error{}} = pgsql:equery(C, "invalid SQL", [Parameters]).
- Parameters - optional list of values to be bound to $1, $2, $3, etc.
- The extended query protocol combines parse, bind, and execute using
- the unnamed prepared statement and portal. A "select" statement returns
- {ok, Columns, Rows}, "insert/update/delete" returns {ok, Count} or
- {ok, Count, Columns, Rows} when a "returning" clause is present. When
- an error occurs, all statements result in {error, #error{}}.
- PostgreSQL's binary format is used to return integers as Erlang
- integers, floats as floats, bytea/text/varchar columns as binaries,
- bools as true/false, etc. For details see pgsql_binary.erl and the
- Data Representation section below.
- * Parse/Bind/Execute
- {ok, Statement} = pgsql:parse(C, [StatementName], Sql, [ParameterTypes]).
- StatementName - optional, reusable, name for the prepared statement.
- ParameterTypes - optional list of PostgreSQL types for each parameter.
- For valid type names see pgsql_types.erl.
- ok = pgsql:bind(C, Statement, [PortalName], ParameterValues).
- PortalName - optional name for the result portal.
- {ok | partial, Rows} = pgsql:execute(C, Statement, [PortalName], [MaxRows]).
- {ok, Count} = pgsql:execute(C, Statement, [PortalName]).
- {ok, Count, Rows} = pgsql:execute(C, Statement, [PortalName]).
- PortalName - optional portal name used in bind/4.
- MaxRows - maximum number of rows to return (0 for all rows).
- execute returns {partial, Rows} when more rows are available.
- ok = pgsql:close(C, Statement).
- ok = pgsql:close(C, statement | portal, Name).
- ok = pgsql:sync(C).
- All functions return {error, #error{}} when an error occurs.
- * Data Representation
- null = null
- bool = true | false
- char = $A
- intX = 1
- floatX = 1.0
- date = {Year, Month, Day}
- time = {Hour, Minute, Second.Microsecond}
- timetz = {time, Timezone}
- timestamp = {date, time}
- timestamptz = {date, time}
- interval = {time, Days, Months}
- text = <<"a">>
- varchar = <<"a">>
- bytea = <<1, 2>>
- record = {int2, time, text, ...} (decode only)
|