Struct PooledClient 

pub struct PooledClient { /* private fields */ }

A client acquired from the pool

Implementations

impl PooledClient

pub fn client(&self) -> &Client

Get a reference to the underlying client

pub fn client_mut(&mut self) -> &mut Client

Get a mutable reference to the underlying client

Methods from Deref<Target = Client>

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 Deref for PooledClient

type Target = Client

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for PooledClient

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl Drop for PooledClient

fn drop(&mut self)

Executes the destructor for this type.