Struct ClickHouseResource 

pub struct ClickHouseResource {
    pub database: String,
    /* private fields */
}

ClickHouse resource manager

Fields

database: String

Name of the isolated database

Implementations

impl ClickHouseResource

pub async fn connect_existing(url: &str, database: &str) -> Result<Self>

Connect to an existing ClickHouse database (for inspection, does not drop on cleanup)

pub async fn new(url: &str, database: &str) -> Result<Self>

Create a new ClickHouse resource with an isolated database

pub fn client(&self) -> &Client

Get the ClickHouse client

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

Execute a SQL statement

pub async fn count(&self, query: &str) -> Result<u64>

Execute a count query and return the result

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

where T: Row + for<'a> Deserialize<'a>,

Execute a query and fetch all rows

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

where T: Row + for<'a> Deserialize<'a>,

Execute a query and fetch one row

pub async fn get_column_types( &self, table: &str, ) -> Result<Vec<(String, String)>>

Get the column types for a table

pub fn connection_url(&self) -> String

Get the connection URL for this database

pub async fn list_tables(&self) -> Result<Vec<String>>

List all tables in the database

pub async fn get_sample_data_formatted( &self, table: &str, limit: usize, ) -> Result<String>

Get sample data from a table using HTTP API (for better formatting)

Trait Implementations

impl Drop for ClickHouseResource

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.