Struct ClickHouseExecutor 

pub struct ClickHouseExecutor { /* private fields */ }

ClickHouse column-store executor using the ClickHouse HTTP interface.

Implementations

impl ClickHouseExecutor

pub fn new(config: ClickHouseConfig) -> Self

Construct from config.

GAP 20 fix: the HTTP client is built once with configurable connect and query timeouts. Credentials are sent as X-ClickHouse-* headers (not URL query params that appear in access logs).

GAP 39: When UDB_CH_DEPLOY_MODE=cloud, the URL must use https:// and the client is built with .https_only(true) to prevent credential leakage over plaintext HTTP.

pub fn kind(&self) -> BackendKind

pub fn name(&self) -> &str

pub fn from_env() -> Option<Self>

Construct from environment variables. Returns None when UDB_COLUMN_DSN / UDB_COLUMN_HTTP_URL are absent.

pub async fn select_rows(&self, sql: &str) -> Result<Vec<Json>, String>

Execute a SELECT and return rows as a Vec<Json>. Uses JSONCompact output format.

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

Execute a DDL or DML statement (no result rows expected).

pub async fn insert_rows( &self, table: &str, rows: &[Json], ) -> Result<(), String>

Insert a batch of rows into table using JSONEachRow format.

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

Check whether a table exists in the configured database.

Trait Implementations

impl BackendContextEnforcer for ClickHouseExecutor

fn backend_label(&self) -> &str

Backend label (canonical lowercase: "postgres", "mysql", …).

fn enforce(&self, ctx: &AppliedContext) -> ContextEffect

Apply the context and report the effect. Implementations either emit SQL session variables (SQL backends), prepend filter fragments (document backends), or produce a key prefix (KV / object stores).

impl BackendExecutor for ClickHouseExecutor

async fn transaction(&self, _request_json: &str) -> Result<String, Status>

async fn probe(&self) -> Result<BackendProbe, Status>

impl BackendHealth for ClickHouseExecutor

async fn ping(&self) -> Result<(), String>

impl Clone for ClickHouseExecutor

fn clone(&self) -> ClickHouseExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClickHouseExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MutationExecutor for ClickHouseExecutor

async fn mutate(&self, request_json: &str) -> Result<String, Status>

{"sql":"CREATE ..."} → DDL, or {"table":"t","rows":[...]} → insert.

impl ObjectExecutor for ClickHouseExecutor

async fn get_object(&self, _request_json: &str) -> Result<Vec<u8>, Status>

async fn put_object( &self, _request_json: &str, _bytes: Vec<u8>, ) -> Result<String, Status>

async fn get_object_stream( &self, request_json: &str, ) -> Result<ExecutorByteStream, Status>

async fn put_object_stream( &self, request_json: &str, stream: ExecutorByteStream, ) -> Result<String, Status>

Streaming upload (A.6). The default collects the byte stream into one buffer and delegates to ObjectExecutor::put_object, so backends that cannot stream keep working unchanged. Real object stores (S3/MinIO, …) override this to forward bytes to the provider without buffering the whole object in UDB.

async fn delete_object(&self, _request_json: &str) -> Result<(), Status>

Remove an object by {"bucket","object_key"|"key"}. Only real object stores (S3/MinIO, GCS, Azure Blob) override this; other backends report unimplemented so callers never silently no-op a delete.

impl QueryExecutor for ClickHouseExecutor

async fn query(&self, request_json: &str) -> Result<String, Status>

{"sql":"SELECT ..."} or {"table":"t","columns":[...],"filter":{}}.

async fn query_stream( &self, request_json: &str, ) -> Result<ExecutorByteStream, Status>

impl ResourceAdminExecutor for ClickHouseExecutor

async fn ensure_resource( &self, resource_name: &str, spec_json: &str, ) -> Result<(), Status>

async fn drop_resource(&self, resource_name: &str) -> Result<(), Status>

async fn list_resources(&self) -> Result<Vec<String>, Status>

impl SearchExecutor for ClickHouseExecutor

async fn search(&self, _request_json: &str) -> Result<String, Status>