Database.RethinkDB.Network

Documentation

data RethinkDBHandle

A connection to the database server

Constructors

RethinkDBHandle

Fields

rdbHandle :: Handle

rdbWriteLock :: MVar (Maybe SomeException)

rdbToken :: IORef Token

The next token to use

rdbDatabase :: Database

The default database

rdbWait :: IORef (Map Token (Chan Response, Term, IO ()))

rdbThread :: ThreadId

Instances

Show RethinkDBHandle

connect :: HostName -> Integer -> Maybe String -> IO RethinkDBHandle

Create a new connection to the database server

Example: connect using the default port with no passphrase

>>> h <- connect "localhost" 28015 Nothing

close :: RethinkDBHandle -> IO ()

Close an open connection

use :: Database -> RethinkDBHandle -> RethinkDBHandle

Set the default database

The new handle is an alias for the old one. Calling close on either one will close both.

runQLQuery :: RethinkDBHandle -> WireQuery -> Term -> IO (MVar Response)

data Cursor a

Constructors

Cursor

Fields

cursorMBox :: MVar Response

cursorBuffer :: MVar (Either RethinkDBError ([Datum], Bool))

cursorMap :: Datum -> IO a

Instances

Functor Cursor

FromDatum a => Result (Cursor a)

makeCursor :: MVar Response -> IO (Cursor Datum)

next :: Cursor a -> IO (Maybe a)

Get the next value from a cursor

nextBatch :: Cursor a -> IO [a]

Get the next batch from a cursor

collect :: Cursor a -> IO [a]

A lazy stream of all the elements in the cursor

collect' :: Cursor a -> IO [a]

A strict version of collect

nextResponse :: Response -> IO ()

data Response

The response to a query

Constructors

ResponseError RethinkDBError

ResponseSingle Datum

ResponseBatch (Maybe More) [Datum]

Instances

Show Response

Result Response

data ErrorCode

Constructors

ErrorBrokenClient

ErrorBadQuery

ErrorRuntime

ErrorUnexpectedResponse

Instances

Show ErrorCode

data RethinkDBError

Constructors

RethinkDBError

Fields

errorCode :: ErrorCode

errorTerm :: Term

errorMessage :: String

errorBacktrace :: Backtrace

Instances

Show RethinkDBError

Typeable RethinkDBError

Exception RethinkDBError

data RethinkDBConnectionError

Constructors

RethinkDBConnectionError String

Instances

Show RethinkDBConnectionError

Typeable RethinkDBConnectionError

Exception RethinkDBConnectionError

data More

noReplyWait :: RethinkDBHandle -> IO ()

Wait for NoReply queries to complete on the server

>>> () <- runOpts h [NoReply] $ table "users" # get "bob" # update (\row -> merge row ["occupation" := "teacher"])
>>> noReplyWait h

each :: Cursor a -> (a -> IO b) -> IO ()