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::Nanoseconds(0).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::Nanoseconds(0)
    .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 Clone for WriteQuery

fn clone(&self) -> WriteQuery

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WriteQuery

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

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 build_with_opts(&self, use_v2: bool) -> Result<ValidQuery, Error>

Like [build] but with additional support for unsigned integers in the line protocol. Please note, this crate can only interact with InfluxDB 2.0 in compatibility mode and does not natively support InfluxDB 2.0.

fn get_type(&self) -> QueryType