Struct QueryContextBuilder

pub struct QueryContextBuilder {
    current_catalog: Option<String>,
    snapshot_seqs: Option<Arc<RwLock<HashMap<u64, u64>>>>,
    mutable_session_data: Option<Arc<RwLock<MutableInner>>>,
    mutable_query_context_data: Option<Arc<RwLock<QueryContextMutableFields>>>,
    sql_dialect: Option<Arc<dyn Dialect + Send + Sync>>,
    extensions: Option<HashMap<String, String>>,
    configuration_parameter: Option<Arc<ConfigurationVariables>>,
    channel: Option<Channel>,
}

Builder for QueryContext.

Fields

current_catalog: Option<String>

snapshot_seqs: Option<Arc<RwLock<HashMap<u64, u64>>>>

mapping of RegionId to SequenceNumber, for snapshot read, meaning that the read should only container data that was committed before(and include) the given sequence number this field will only be filled if extensions contains a pair of “snapshot_read” and “true”

mutable_session_data: Option<Arc<RwLock<MutableInner>>>

mutable_query_context_data: Option<Arc<RwLock<QueryContextMutableFields>>>

sql_dialect: Option<Arc<dyn Dialect + Send + Sync>>

extensions: Option<HashMap<String, String>>

configuration_parameter: Option<Arc<ConfigurationVariables>>

channel: Option<Channel>

Implementations

impl QueryContextBuilder

pub fn current_catalog(self, value: String) -> Self

pub fn snapshot_seqs(self, value: Arc<RwLock<HashMap<u64, u64>>>) -> Self

mapping of RegionId to SequenceNumber, for snapshot read, meaning that the read should only container data that was committed before(and include) the given sequence number this field will only be filled if extensions contains a pair of “snapshot_read” and “true”

pub fn mutable_session_data(self, value: Arc<RwLock<MutableInner>>) -> Self

pub fn mutable_query_context_data( self, value: Arc<RwLock<QueryContextMutableFields>>, ) -> Self

pub fn sql_dialect(self, value: Arc<dyn Dialect + Send + Sync>) -> Self

pub fn extensions(self, value: HashMap<String, String>) -> Self

pub fn configuration_parameter(self, value: Arc<ConfigurationVariables>) -> Self

pub fn channel(self, value: Channel) -> Self

fn create_empty() -> Self

Create an empty builder, with all fields set to None or PhantomData.

impl QueryContextBuilder

pub fn current_schema(self, schema: String) -> Self

pub fn timezone(self, timezone: Timezone) -> Self

impl QueryContextBuilder

pub fn build(self) -> QueryContext

pub fn set_extension(self, key: String, value: String) -> Self

Trait Implementations

impl Default for QueryContextBuilder

fn default() -> Self

Returns the “default value” for a type.