Module Nonblocking.MakeSource

Functor that generates a nonblocking database interface, given a nonblocking IO monad and a way to wait for connection socket events.

Parameters

module W : Wait

Signature

Sourcetype error = int * string
Sourcetype 'a result = ('a, error) result
Sourcemodule Time : sig ... end
Sourcemodule Field : sig ... end
Sourcemodule Row : sig ... end
Sourcemodule Res : sig ... end
Sourcemodule Stmt : sig ... end
Sourcetype t
Sourcetype flag =
  1. | Compress
  2. | Found_rows
  3. | Ignore_sigpipe
  4. | Ignore_space
  5. | Interactive
  6. | Local_files
  7. | Multi_results
  8. | Multi_statements
  9. | No_schema
  10. | Odbc
  11. | Ssl
  12. | Remember_options
Sourcetype protocol =
  1. | Default
  2. | Tcp
  3. | Socket
  4. | Pipe
  5. | Memory
Sourcetype client_option =
  1. | Connect_timeout of int
  2. | Compress
  3. | Named_pipe of string
  4. | Init_command of string
  5. | Read_default_file of string
  6. | Read_default_group of string
  7. | Set_charset_dir of string
  8. | Set_charset_name of string
  9. | Local_infile of bool
  10. | Protocol of protocol
  11. | Shared_memory_base_name of string
  12. | Read_timeout of int
  13. | Write_timeout of int
  14. | Secure_auth of bool
  15. | Report_data_truncation of bool
  16. | Reconnect of bool
  17. | Ssl_verify_server_cert of bool
  18. | Plugin_dir of string
  19. | Default_auth of string
  20. | Bind of string
  21. | Ssl_key of string
  22. | Ssl_cert of string
  23. | Ssl_ca of string
  24. | Ssl_capath of string
  25. | Ssl_cipher of string
  26. | Ssl_crl of string
  27. | Ssl_crlpath of string
  28. | Connect_attr_reset
  29. | Connect_attr_add of string * string
  30. | Connect_attr_delete of string
  31. | Server_public_key of string
  32. | Enable_cleartext_plugin of bool
Sourcetype server_option =
  1. | Multi_statements of bool
Sourceval connect : ?host:string -> ?user:string -> ?pass:string -> ?db:string -> ?port:int -> ?socket:string -> ?flags:flag list -> ?options:client_option list -> unit -> t result W.IO.future
Sourceval close : t -> unit W.IO.future
Sourceval library_end : unit -> unit
Sourceval set_character_set : t -> string -> unit result W.IO.future
Sourceval select_db : t -> string -> unit result W.IO.future
Sourceval change_user : t -> string -> string -> string option -> unit result W.IO.future
Sourceval get_server_info : t -> string
Sourceval get_server_version : t -> int
Sourceval get_host_info : t -> string
Sourceval get_proto_info : t -> int
Sourceval set_client_option : t -> client_option -> unit
Sourceval set_server_option : t -> server_option -> unit result W.IO.future
Sourceval ping : t -> unit result W.IO.future
Sourceval autocommit : t -> bool -> unit result W.IO.future
Sourceval start_txn : t -> unit result W.IO.future
Sourceval commit : t -> unit result W.IO.future
Sourceval rollback : t -> unit result W.IO.future
Sourceval prepare : t -> string -> Stmt.t result W.IO.future