Struct rinfluxdb_influxql::QueryBuilder

pub struct QueryBuilder { /* fields omitted */ }

A builder for InfluxQL queries

let query = QueryBuilder::from("indoor_environment")
    .field("temperature")
    .field("humidity")
    .start(Utc.ymd(2021, 3, 7).and_hms(21, 0, 0))
    .build();

assert_eq!(
    query.as_ref(),
    "SELECT temperature, humidity \
    FROM indoor_environment \
    WHERE time > '2021-03-07T21:00:00Z'",
);

Implementations

impl QueryBuilder

pub fn from<T>(measurement: T) -> Self where
    T: Into<String>, 

Create a query selecting from a measurement

This sets the measurement in the FROM clause.

pub fn database<T>(self, database: T) -> Self where
    T: Into<String>, 

Set the database

This sets the database in the FROM clause: database.retention_policy.measurement.

pub fn retention_policy<T>(self, retention_policy: T) -> Self where
    T: Into<String>, 

Set the retention policy

This sets the retention policy in the FROM clause: database.retention_policy.measurement.

pub fn field<T>(self, field: T) -> Self where
    T: Into<String>, 

Add a field to the query

pub fn start<T>(self, start: T) -> Self where
    T: Into<DateTime<Utc>>, 

Restrict query results to a start time

pub fn stop<T>(self, stop: T) -> Self where
    T: Into<DateTime<Utc>>, 

Restrict query results to a stop time

pub fn group_by<T>(self, tag: T) -> Self where
    T: Into<String>, 

Group by a tag

pub fn build(self) -> Query

Create the InfluxQL query