pub struct Command { /* private fields */ }
Expand description
The query that will be sent to RethinkDB
Implementations§
Source§impl<'a> Command
impl<'a> Command
pub fn changes<T>(self, arg: T) -> Selfwhere
T: Arg,
Sourcepub fn table_create<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn table_create<T>(self, arg: T) -> Selfwhere
T: Arg,
Create a table
A RethinkDB table is a collection of JSON documents.
§Example
Create a table named “dc_universe” with the default settings.
r.db("heroes").table_create("dc_universe").run(conn)
{
"config_changes": [
{
"new_val": {
"db": "test",
"durability": "hard",
"id": "20ea60d4-3b76-4817-8828-98a236df0297",
"name": "dc_universe",
"primary_key": "id",
"shards": [
{
"primary_replica": "rethinkdb_srv1",
"replicas": [
"rethinkdb_srv1",
"rethinkdb_srv2"
]
}
],
"write_acks": "majority"
},
"old_val": None
}
],
"tables_created": 1
}
```
pub fn table_drop<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn table_list(self) -> Self
pub fn table<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn index_create<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn index_drop<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn index_list(self) -> Self
pub fn index_rename<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn index_status<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn index_wait<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn set_write_hook<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn get_write_hook(self) -> Self
pub fn insert<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn update<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn replace<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn delete<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn sync(self) -> Self
pub fn get<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn get_all<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn between<T>(self, arg: T) -> Selfwhere
T: Arg<'a>,
pub fn filter<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn inner_join<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn outer_join<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn eq_join<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn zip(self) -> Self
pub fn map<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn with_fields<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn concat_map<T>(self, arg: T) -> Selfwhere
T: Arg,
Sourcepub fn order_by<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn order_by<T>(self, arg: T) -> Selfwhere
T: Arg,
Orders the result based on the given column.
Argument can either be a string, r.asc("column")
for ascending or r.desc("column")
for descending.
If the given argument is a string, the direction will default to ascending.
§Example
Sort the result in descending order based on the created_at
column.
r.db("database").table("users").order_by(r.desc("created_at")).run(conn)
pub fn skip<T>(self, arg: T) -> Selfwhere
T: Arg,
Sourcepub fn limit<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn limit<T>(self, arg: T) -> Selfwhere
T: Arg,
Limits the result set to the given amount.
Argument can be an isize.
§Example
Get 5 records.
r.db("database").table("users").limit(5).run(conn)
pub fn slice<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn nth<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn offsets_of<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn is_empty(self) -> Self
pub fn union<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn sample<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn group<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn ungroup(self) -> Self
pub fn reduce<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn fold<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn count<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn sum<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn avg<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn min<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn max<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn distinct<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn contains<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn pluck<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn without<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn merge<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn append<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn prepend<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn difference<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn set_insert<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn set_union<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn set_intersection<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn set_difference<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn bracket<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn get_field<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn has_fields<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn insert_at<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn splice_at<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn delete_at<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn change_at<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn keys(self) -> Self
pub fn values(self) -> Self
pub fn match_<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn split<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn upcase(self) -> Self
pub fn downcase(self) -> Self
pub fn and<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn or<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn eq<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn ne<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn gt<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn ge<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn lt<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn le<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn not<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn bit_and<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn bit_or<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn bit_xor<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn bit_not(self) -> Self
pub fn bit_sal<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn bit_sar<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn round(self) -> Self
pub fn ceil(self) -> Self
pub fn floor(self) -> Self
pub fn in_timezone<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn timezone(self) -> Self
pub fn during<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn date(self) -> Self
pub fn time_of_day(self) -> Self
pub fn year(self) -> Self
pub fn month(self) -> Self
pub fn day(self) -> Self
pub fn day_of_week(self) -> Self
pub fn day_of_year(self) -> Self
pub fn hours(self) -> Self
pub fn minutes(self) -> Self
pub fn seconds(self) -> Self
pub fn to_iso8601(self) -> Self
pub fn to_epoch_time(self) -> Self
pub fn binary<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn do_<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn branch<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn for_each<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn default<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn coerce_to<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn type_of(self) -> Self
pub fn info(self) -> Self
pub fn to_json(self) -> Self
pub fn distance<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn fill(self) -> Self
pub fn to_geojson(self) -> Self
pub fn get_intersecting<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn get_nearest<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn includes<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn intersects<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn polygon_sub<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn grant<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn config(self) -> Self
pub fn rebalance(self) -> Self
pub fn reconfigure<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn status(self) -> Self
pub fn wait<T>(self, arg: T) -> Selfwhere
T: Arg,
pub fn run<A, T>(self, arg: A) -> impl Stream<Item = Result<T>>
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Command
impl !RefUnwindSafe for Command
impl Send for Command
impl Sync for Command
impl Unpin for Command
impl !UnwindSafe for Command
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more