Module Pgx_asyncSource

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
Sourceval 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
val close : t -> unit Io.t
val ping : t -> unit Io.t
val alive : t -> bool Io.t
val begin_work : ?isolation:Isolation.t -> ?access:Access.t -> ?deferrable:bool -> t -> t Io.t
val commit : t -> unit Io.t
val rollback : t -> unit Io.t
val with_transaction : ?isolation:Isolation.t -> ?access:Access.t -> ?deferrable:bool -> t -> (t -> 'b Io.t) -> 'b Io.t
module Prepared : sig ... end
val execute : ?params:Types.row -> t -> string -> Types.row list Io.t
val execute_unit : ?params:Types.row -> t -> string -> unit Io.t
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
val simple_query : t -> string -> Types.row list list Io.t
Sourcemodule Thread : Pgx.Io with type 'a t = 'a Async_kernel.Deferred.t
Sourceval 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
Sourceval 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.

Sourcemodule Value = Pgx_value_core

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