package pgx_async

You can search for identifiers within the package.

in-package search v0.2.0

package pgx_async

pgx_async
- Pgx_async
  - Io
  - Prepared
  - Thread
    
    Sequencer
- Pgx_async_test

Legend:
Library
Module
Module type
Parameter
Class
Class type

Async based Postgres client based on Pgx.

include Pgx.S with type 'a Io.t = 'a Async_kernel.Deferred.t

type t

module Io : sig ... end

val connect : 
  ?host:string ->
  ?port:int ->
  ?user:string ->
  ?password:string ->
  ?database:string ->
  ?unix_domain_socket_dir:string ->
  ?verbose:int ->
  ?max_message_length:int ->
  unit ->
  t Io.t

Connect to the database. The normal $PGDATABASE, etc. environment variables are available.

max_message_length is the maximum message length accepted from the back-end. The default is Sys.max_string_length, which means that we will try to read as much data from the back-end as we can, and this may cause us to run out of memory (particularly on 64 bit machines), causing a possible denial of service. You may want to set this to a smaller size to avoid this happening.

val close : t -> unit Io.t

Close the database handle. You must call this after you have finished with the handle, or else you will get leaked file descriptors.

val ping : t -> unit Io.t

Ping the database. If the database is not available, some sort of exception will be thrown.

val alive : t -> bool Io.t

This function is a wrapper of ping that returns a boolean instead of raising an exception.

val begin_work : 
  ?isolation:Isolation.t ->
  ?access:Access.t ->
  ?deferrable:bool ->
  t ->
  t Io.t

Start a transaction.

val commit : t -> unit Io.t

Commit a transaction. Throws an exception if no transaction is open. Use with_transaction when possible.

val rollback : t -> unit Io.t

Rollback a transaction. Throws an exception if no transaction is open. Use with_transaction when possible.

val with_transaction : 
  ?isolation:Isolation.t ->
  ?access:Access.t ->
  ?deferrable:bool ->
  t ->
  (t -> 'b Io.t) ->
  'b Io.t

with_transaction db ?isolation ?access ?deferrable f wraps your function f inside a transactional block. See begin_work for a description of isolation, access, and deferrable. If f throws an exception, the transaction will be rolled back. Otherwise the transaction will be commited. It is an error to call commit or rollback manually inside of this function.

module Prepared : sig ... end

val execute : ?params:Types.row -> t -> string -> Types.row list Io.t

execute conn ?params query prepares and executes the statement query and returns the result.

val execute_unit : ?params:Types.row -> t -> string -> unit Io.t

execute_unit conn ?params query same as execute, but intended for database calls that have side-affects rather than returning results

val execute_fold : 
  ?params:Types.param list ->
  t ->
  string ->
  init:'accum ->
  f:('accum -> Types.row -> 'accum Io.t) ->
  'accum Io.t

val execute_map : 
  ?params:Types.param list ->
  t ->
  string ->
  f:(Types.row -> 'a Io.t) ->
  'a list Io.t

val execute_iter : 
  ?params:Types.param list ->
  t ->
  string ->
  f:(Types.row -> unit Io.t) ->
  unit Io.t

val execute_many : 
  t ->
  query:string ->
  params:Types.param list list ->
  Types.row list list Io.t

Prepares a query as in execute and then executes it once per set of parameters in params. This is more efficient than calling execute in a loop because the query is only prepared once.

val simple_query : t -> string -> Types.row list list Io.t

simple_query conn query executes the command(s) in the given query and returns a list of query results (i.e. if you run two queries, you will get a list with two elements: the results of the first query followed by the results of the second query.

module Thread : Pgx.Io with type 'a t = 'a Async_kernel.Deferred.t

val with_conn : 
  ?host:string ->
  ?port:int ->
  ?user:string ->
  ?password:string ->
  ?database:string ->
  ?unix_domain_socket_dir:string ->
  ?verbose:int ->
  ?max_message_length:int ->
  (t -> 'a Async_kernel.Deferred.t) ->
  'a Async_kernel.Deferred.t

val execute_pipe : 
  ?params:Pgx.row ->
  t ->
  string ->
  Pgx.row Async_kernel.Pipe.Reader.t

Like execute but returns a pipe so you can operate on the results before they have all returned. Note that execute_iter and execute_fold can perform significantly better because they don't have as much overhead.

module Value = Pgx_value_core

Exposed for backwards compatiblity. New code should use Pgx_value_core directly.