Struct Query 

pub struct Query { /* private fields */ }

Query structure for building and executing queries

Implementations

impl Query

pub fn new(query_text: impl Into<String>) -> Self

Create a new query

impl Query

pub fn with_query_id(self, query_id: impl Into<String>) -> Self

Set the query ID

pub fn with_setting( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Set a query setting with value (no flags)

pub fn with_setting_flags( self, key: impl Into<String>, value: impl Into<String>, flags: u64, ) -> Self

Set a query setting with value and flags

pub fn with_important_setting( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Set an important query setting

pub fn with_parameter( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Set a query parameter

pub fn with_tracing_context(self, context: TracingContext) -> Self

Set OpenTelemetry tracing context

pub fn text(&self) -> &str

Get the query text

pub fn tracing_context(&self) -> Option<&TracingContext>

Get the tracing context

pub fn id(&self) -> &str

Get the query ID

pub fn settings(&self) -> &QuerySettings

Get the settings

pub fn parameters(&self) -> &HashMap<String, String>

Get the parameters

pub fn on_progress<F>(self, callback: F) -> Self

where F: Fn(&Progress) + Send + Sync + 'static,

Set progress callback

pub fn on_profile<F>(self, callback: F) -> Self

where F: Fn(&Profile) + Send + Sync + 'static,

Set profile callback

pub fn on_profile_events<F>(self, callback: F) -> Self

where F: Fn(&Block) -> bool + Send + Sync + 'static,

Set profile events callback

pub fn on_server_log<F>(self, callback: F) -> Self

where F: Fn(&Block) -> bool + Send + Sync + 'static,

Set server log callback

pub fn on_exception<F>(self, callback: F) -> Self

where F: Fn(&Exception) + Send + Sync + 'static,

Set exception callback

pub fn on_data<F>(self, callback: F) -> Self

where F: Fn(&Block) + Send + Sync + 'static,

Set data callback

pub fn on_data_cancelable<F>(self, callback: F) -> Self

where F: Fn(&Block) -> bool + Send + Sync + 'static,

Set cancelable data callback (return false to cancel)

Trait Implementations

impl Clone for Query

fn clone(&self) -> Query

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl From<&str> for Query

fn from(s: &str) -> Self

Converts to this type from the input type.

impl From<String> for Query

fn from(s: String) -> Self

Converts to this type from the input type.