Struct aerospike::Statement

pub struct Statement {
    pub namespace: String,
    pub set_name: String,
    pub index_name: Option<String>,
    pub bins: Bins,
    pub filters: Option<Vec<Filter>>,
    pub aggregation: Option<Aggregation>,
    pub predexp: Vec<Arc<Box<dyn PredExp>>>,
}

Query statement parameters.

Fields

namespace: String

Namespace

set_name: String

Set name

index_name: Option<String>

Optional index name

bins: Bins

Optional list of bin names to return in query.

filters: Option<Vec<Filter>>

Optional list of query filters. Currently, only one filter is allowed by the server on a secondary index lookup.

aggregation: Option<Aggregation>

Optional Lua aggregation function parameters.

predexp: Vec<Arc<Box<dyn PredExp>>>

Predicate Filter

Implementations

impl Statement

pub fn new(namespace: &str, set_name: &str, bins: Bins) -> Self

Create a new query statement with the given namespace, set name and optional list of bin names.

Examples

Create a new statement to query the namespace "foo" and set "bar" and return the "name" and "age" bins for each matching record.

let stmt = Statement::new("foo", "bar", Bins::from(["name", "age"]));

pub fn add_filter(&mut self, filter: Filter)

Add a query filter to the statement. Currently, only one filter is allowed by the server on a secondary index lookup.

Example

This example uses a numeric index on bin baz in namespace foo within set bar to find all records using a filter with the range 0 to 100 inclusive:

let mut stmt = Statement::new("foo", "bar", Bins::from(["name", "age"]));
stmt.add_filter(as_range!("baz", 0, 100));

pub fn add_predicate<S: PredExp + 'static>(&mut self, predicate: S)

Add a Predicate filter to the statement.

Example

This Example uses a simple predexp Filter to find all records in namespace foo and set bar where the age Bin is equal to 32.

let mut stmt = Statement::new("foo", "bar", Bins::from(["name", "age"]));
stmt.add_predicate(as_predexp_integer_bin!("age".to_string()));
stmt.add_predicate(as_predexp_integer_value!(32));
stmt.add_predicate(as_predexp_integer_equal!());

pub fn set_aggregate_function(
    &mut self,
    package_name: &str,
    function_name: &str,
    function_args: Option<&[Value]>
)

Set Lua aggregation function parameters.