Repodb_mariadb.Raw

module M = Mariadb.Blocking

type connection = {
  dbh : M.t;
  cache : M.Stmt.t Repodb.Stmt_cache.t;
  mutable last_insert_id : int64 option;
}

type error = M.error

val dialect : Repodb.Driver.dialect

val error_message : (int * string) -> string

val error_of_string : 'a -> int * 'a

type conn_params = {
  host : string option;
  port : int option;
  user : string option;
  pass : string option;
  db : string option;
  socket : string option;
  charset : string option;
}

val empty_conn_params : conn_params

val is_space : char -> bool

val skip_spaces : string -> int -> int

val read_quoted : string -> int -> Char.t -> (string * int, string) result

val read_unquoted : string -> int -> string * int

val set_conn_param : 
  conn_params ->
  string ->
  string ->
  (conn_params, string) result

val parse_conninfo : string -> (conn_params, string) result

val prepare_stmt : connection -> string -> (M.Stmt.t, int * string) result

val reset_cached_stmt : connection -> string -> M.Stmt.t -> unit

val connect : string -> (connection, M.error) result

val close : connection -> unit

val value_to_param : Repodb.Driver.Value.t -> M.Field.value

val format_time : M.Time.t -> string

val field_to_value : M.Field.t -> Repodb.Driver.Value.t

val row_of_fields : M.Field.t array -> Repodb.Driver.row

val remember_insert_id : connection -> M.Res.t -> unit

val exec_raw : 
  connection ->
  string ->
  params:Repodb.Driver.Value.t array ->
  (unit, Mariadb.Blocking.error) result

val query_raw : 
  connection ->
  string ->
  params:Repodb.Driver.Value.t array ->
  (Repodb.Driver.row list, Mariadb.Blocking.error) result

val placeholder : 'a -> string

val returning_supported : bool

val upsert_syntax : [> `Standard ]

val last_insert_id : connection -> (int64, int * string) result