Struct Client 

pub struct Client { /* private fields */ }

Main ClickType client

Implementations

impl Client

pub fn builder() -> ClientBuilder

Create a new client builder

pub async fn execute(&self, sql: &str) -> Result<()>

Execute a DDL statement (CREATE TABLE, DROP TABLE, etc.)

pub async fn query<T>(&self, sql: &str) -> Result<Vec<T>>

where T: DeserializeOwned + Row,

Execute a query and return typed results

The type T must implement serde::Deserialize and clickhouse::Row

pub async fn query_check(&self, sql: &str) -> Result<u64>

Execute a query and count rows (for verification)

pub async fn insert<T>(&self, table_name: &str, rows: &[T]) -> Result<()>

where T: Serialize + Row,

Insert rows using ClickHouse HTTP insert

The type T must implement serde::Serialize and clickhouse::Row

pub async fn insert_binary(&self, table_name: &str, data: &[u8]) -> Result<()>

Insert raw RowBinary data directly to ClickHouse

This is the low-level method for high-performance batching. The data must be pre-serialized in RowBinary format.

pub async fn validate_schema<T>(&self, table_name: &str) -> Result<()>

where T: ClickTable,

Validate that the table schema matches the struct definition

This is critical for RowBinary inserts to prevent silent data corruption. Call this before starting batch inserts to ensure schema compatibility.

pub fn database(&self) -> &str

Get the database name

Trait Implementations

impl ClickTypeTransport for Client

fn insert_binary<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table_name: &'life1 str, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Insert raw RowBinary data.

fn validate_schema<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, table_name: &'life1 str, expected_columns: &'life2 [(&'life3 str, String)], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Validate that the table schema matches the expected columns.

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.