Struct databend_client::APIClient

pub struct APIClient {
    pub host: String,
    pub port: u16,
    pub database: Arc<Mutex<Option<String>>>,
    pub user: String,
    /* private fields */
}

Fields

host: String

port: u16

database: Arc<Mutex<Option<String>>>

user: String

Implementations

impl APIClient

pub fn from_dsn(dsn: &str) -> Result<Self>

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

pub async fn query_page(&self, next_uri: &str) -> Result<QueryResponse>

pub async fn wait_for_query(&self, resp: QueryResponse) -> Result<QueryResponse>

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

pub async fn insert_with_stage( &self, sql: &str, stage_location: &str, file_format_options: BTreeMap<&str, &str>, copy_options: BTreeMap<&str, &str> ) -> Result<QueryResponse>

pub async fn upload_to_stage( &self, stage_location: &str, data: impl AsyncRead + Send + Sync + 'static, size: u64 ) -> Result<()>

Trait Implementations

impl Clone for APIClient

fn clone(&self) -> APIClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for APIClient

fn default() -> Self

Returns the “default value” for a type.