Struct ClickhouseConnection 

pub struct ClickhouseConnection { /* private fields */ }

ClickHouse ADBC Connection implementation.

Sessions in the ClickHouse HTTP Interface

This type does not necessarily represent a persistent TCP connection.

Instead, it makes calls to the ClickHouse HTTP interface. HTTP/1.1 connections are transparently cached in the object.

A random session_id is generated upon construction and subsequently passed to all HTTP interface calls made by this connection and any ClickhouseStatements created from it. Any session-local state (such as settings and temporary tables) is stored in association with this session ID.

The session ID may be overridden or read back using options::SESSION_ID.

Sessions persist for the default session timeout, which is 60 seconds of inactivity. Server-side state is not guaranteed past this timeout.

Tokio Runtime

This connection inherits the Tokio runtime of the parent ClickhouseDriver.

If a runtime was not set when the driver was created, a new current-thread runtime is created for each connection.

See ClickhouseDriver::init() for details.

Trait Implementations

impl Connection for ClickhouseConnection

type StatementType = ClickhouseStatement

fn new_statement(&mut self) -> Result<Self::StatementType>

Allocate and initialize a new statement.

fn cancel(&mut self) -> Result<()>

Cancel the in-progress operation on a connection.

fn get_info( &self, _codes: Option<HashSet<InfoCode>>, ) -> Result<impl RecordBatchReader + Send>

Get metadata about the database/driver.

fn get_objects( &self, _depth: ObjectDepth, _catalog: Option<&str>, _db_schema: Option<&str>, _table_name: Option<&str>, _table_type: Option<Vec<&str>>, _column_name: Option<&str>, ) -> Result<impl RecordBatchReader + Send>

Get a hierarchical view of all catalogs, database schemas, tables, and columns.

fn get_table_schema( &self, _catalog: Option<&str>, db_schema: Option<&str>, table_name: &str, ) -> Result<Schema>

Get the Arrow schema of a table.

fn get_table_types(&self) -> Result<impl RecordBatchReader + Send>

Get a list of table types in the database.

fn get_statistic_names(&self) -> Result<impl RecordBatchReader + Send>

Get the names of statistics specific to this driver.

fn get_statistics( &self, _catalog: Option<&str>, _db_schema: Option<&str>, _table_name: Option<&str>, _approximate: bool, ) -> Result<impl RecordBatchReader + Send>

Get statistics about the data distribution of table(s).

fn commit(&mut self) -> Result<()>

Commit any pending transactions. Only used if autocommit is disabled.

fn rollback(&mut self) -> Result<()>

Roll back any pending transactions. Only used if autocommit is disabled.

fn read_partition( &self, _partition: impl AsRef<[u8]>, ) -> Result<impl RecordBatchReader + Send>

Retrieve a given partition of data.

impl Optionable for ClickhouseConnection

type Option = OptionConnection

fn set_option(&mut self, key: Self::Option, value: OptionValue) -> Result<()>

Set a post-init option.

fn get_option_string(&self, key: Self::Option) -> Result<String>

Get a string option value by key.

fn get_option_bytes(&self, key: Self::Option) -> Result<Vec<u8>>

Get a bytes option value by key.

fn get_option_int(&self, key: Self::Option) -> Result<i64>

Get an integer option value by key.

fn get_option_double(&self, key: Self::Option) -> Result<f64>

Get a float option value by key.