Struct influxdb::WriteQuery

pub struct WriteQuery { /* private fields */ }

Internal Representation of a Write query that has not yet been built

Implementations

impl WriteQuery

pub fn new<S>(timestamp: Timestamp, measurement: S) -> Self where
    S: Into<String>, 

Creates a new WriteQuery

pub fn add_field<S, F>(self, field: S, value: F) -> Self where
    S: Into<String>,
    F: WriteType, 

Adds a field to the WriteQuery

Examples

use influxdb::{Query, Timestamp};
use influxdb::InfluxDbWriteable;

Timestamp::Now.into_query("measurement").add_field("field1", 5).build();

pub fn add_tag<S, I>(self, tag: S, value: I) -> Self where
    S: Into<String>,
    I: WriteType, 

Adds a tag to the WriteQuery

Please note that a WriteQuery requires at least one field. Composing a query with only tags will result in a failure building the query.

Examples

use influxdb::{Query, Timestamp};
use influxdb::InfluxDbWriteable;

Timestamp::Now
    .into_query("measurement")
    .add_tag("field1", 5); // calling `.build()` now would result in a `Err(Error::InvalidQueryError)`

pub fn get_precision(&self) -> String

Trait Implementations

impl<'a> From<&'a WriteQuery> for QueryTypes<'a>

fn from(query: &'a WriteQuery) -> Self

Performs the conversion.

impl Query for WriteQuery

fn build(&self) -> Result<ValidQuery, Error>

Builds valid InfluxSQL which can be run against the Database. In case no fields have been specified, it will return an error, as that is invalid InfluxSQL syntax.

fn get_type(&self) -> QueryType