Struct reql::r

pub struct r;

The top-level ReQL namespace

Example

Set up your top-level namespace.

use reql::r;

Implementations

impl<'a> r

pub async fn connection<A, T>(self, options: A) -> Result<Connection<'a, T>> where
    A: Arg<'a, T>,
    T: TcpStream<'a>,
    &'a T: AsyncRead + AsyncWrite, 

Create a new connection to the database server

Example

Open a connection using the default host and port, specifying the default database.

use async_std::net::TcpStream;
use reql::cmd::connection::Options;
use reql::{r, DEFAULT_ADDR};

let stream = TcpStream::connect(DEFAULT_ADDR).await?;
let conn = r.connection((stream, Options::new().db("marvel"))).await?;

Read more about this command cmd::connection

pub fn db_create<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn db_drop<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn db_list(self) -> Query

pub fn db<T>(self, arg: T) -> Query where
    T: Arg, 

Reference a database

The db command is optional. If it is not present in a query, the query will run against the default database for the connection, specified in the db argument to r::connection.

Examples

Explicitly specify a database for a query.

let mut query = r.db("heroes").table("marvel").run(&conn);

pub fn table_create<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn table<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn map<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn union<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn group<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn reduce<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn count<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn sum<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn avg<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn min<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn max<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn distinct<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn contains<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn literal<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn object<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn random<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn round<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn ceil<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn floor<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn now(self) -> Query

pub fn time<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn epoch_time<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn iso8601<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn do<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn branch<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn range<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn error<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn expr<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn js<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn info<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn json<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn http<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn uuid<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn circle<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn distance<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn geojson<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn intersects<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn line<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn point<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn polygon<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn grant<T>(self, arg: T) -> Query where
    T: Arg, 

pub fn wait<T>(self, arg: T) -> Query where
    T: Arg,