Cooperative-threaded access to relational data
Clone or download
Permalink
Failed to load latest commit information.
.circleci CI: opam remove needs --all. Sep 19, 2018
doc Add missing top-level documentation and seal drivers. Nov 20, 2017
lib-async Rearrange system and driver sigs for future non-unix drivers. Aug 26, 2018
lib-driver Rearrange system and driver sigs for future non-unix drivers. Aug 26, 2018
lib-dynload Upgrade to dune and adjust workspace. Aug 24, 2018
lib-lwt Rearrange system and driver sigs for future non-unix drivers. Aug 26, 2018
lib-type Upgrade to dune and adjust workspace. Aug 24, 2018
lib Rearrange system and driver sigs for future non-unix drivers. Aug 26, 2018
tests Fix SELECT clause in bikereg example. Aug 24, 2018
.gitignore Use configuration file to list DB URIs for testing. Nov 30, 2017
CHANGES.md Prefix version in change log with v. Aug 26, 2018
COPYING Start with build files and Cardinal_query. Mar 16, 2014
COPYING.LESSER Start with build files and Cardinal_query. Mar 16, 2014
README.md Improve documentation section in the README. Jul 3, 2018
caqti-async.opam Upgrade to opam 2. Sep 19, 2018
caqti-driver-mariadb.opam Upgrade to opam 2. Sep 19, 2018
caqti-driver-postgresql.opam Upgrade to opam 2. Sep 19, 2018
caqti-driver-sqlite3.opam Upgrade to opam 2. Sep 19, 2018
caqti-dynload.opam Upgrade to opam 2. Sep 19, 2018
caqti-lwt.opam Upgrade to opam 2. Sep 19, 2018
caqti-type-calendar.opam Upgrade to opam 2. Sep 19, 2018
caqti.opam Upgrade to opam 2. Sep 19, 2018
dune-project Upgrade to dune and adjust workspace. Aug 24, 2018
dune-workspace.dev Upgrade to dune and adjust workspace. Aug 24, 2018

README.md

CircleCI

Synopsis

Caqti provides a monadic cooperative-threaded OCaml connector API for relational databases.

The purpose of Caqti is further to help make applications independent of a particular database system. This is achieved by defining a common signature, which is implemented by the database drivers. Connection parameters are specified as an URI, which is typically provided at run-time. Caqti then loads a driver which can handle the URI, and provides a first-class module which implements the driver API and additional convenience functionality.

Caqti does not make assumptions about the structure of the query language, and only provides the type information needed at the edges of communication between the OCaml code and the database; i.e. for encoding parameters and decoding returned tuples. It is hoped that this agnostic choice makes it a suitable target for higher level interfaces and code generators.

Drivers

The following drivers are available.

  • MariaDB (mariadb://)
    • Implemented in terms of ocaml-mariadb using asynchronous calls.
    • Supports transactions.
    • Pools connections and caches statements.
  • PostgreSQL (postgresql://)
    • Implemented in terms of postgresql-ocaml using asynchronous calls.
    • Supports transactions.
    • Pools connections and caches statements.
  • SQLite3 (sqlite3://)
    • Implemented in terms of sqlite3-ocaml using preemtive threading for non-blocking operation.
    • Supports transactions.
    • Does not pool connections or cache statements.

If you link against caqti-dynload, then drivers are loaded dynamically based on the URI. If dynamic loading is unavailable on your platform, you may instead link against the caqti-driver-* libraries which you expect to use.

Documentation

For a gentle introduction I recommend reading Interfacing OCaml and PostgreSQL with Caqti by Bobby Priambodo. There is also a documented example in this repository.

A resent rendering of the full API reference is available online. You can also generate the API reference matching your installed version using odig. Finally, topkg doc builds the reference from a Git checkout using topkg-care.

As the main entry point, you would normally use either of

Caqti_lwt : Caqti_connection_sig.S with type 'a io = 'a Lwt.t
Caqti_async : Caqti_connection_sig.S with type 'a io = 'a Deferred.t

which is provided by caqti-lwt or caqti-async, respectively. These provide a connect functions which receives an URI, loads the appropriate driver, and returns a connection as a first-class module containing query functionality for the database.

The most important modules to know about are:

  • Caqti_type and Caqti_request for constructing prepared or one-shot queries.
  • Caqti_lwt and Caqti_async for connecting to the database and obtaining a first class module implementing Caqti_connection_sig.S.
  • Caqti_connection_sig.S and Caqti_response_sig.S for executing queries.

Running under utop

Dynamic linking does not work under utop. The workaround is to link against the needed database driver. E.g.

> #require "caqti-lwt";;
> #require "caqti-driver-postgresql";;
> open Lwt.Infix;;

(* Create a DB handle. *)
> module Db = (val Caqti_lwt.connect (Uri.of_string "postgresql://") >>= Caqti_lwt.or_fail |> Lwt_main.run);;
module Db : Caqti_lwt.CONNECTION

(* Create a request which merely adds two parameters. *)
> let plus = Caqti_request.find Caqti_type.(tup2 int int) Caqti_type.int "SELECT ?::integer + ?::integer";;
val plus : (int * int, int, [< `Many | `One | `Zero > `One ]) Caqti_request.t = <abstr>

(* Run it. *)
> Db.find plus (7, 13);;
- : (int, [> Caqti_error.call_or_retrieve ]) result = Ok 20