Trait databend_driver::Connection

pub trait Connection: DynClone + Send + Sync {
    // Required methods
    fn info<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = ConnectionInfo> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn exec<'life0, 'life1, 'async_trait>(
        &'life0 self,
        sql: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<i64, Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn query_row<'life0, 'life1, 'async_trait>(
        &'life0 self,
        sql: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<Option<Row>, Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn query_iter<'life0, 'life1, 'async_trait>(
        &'life0 self,
        sql: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<RowIterator, Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn query_iter_ext<'life0, 'life1, 'async_trait>(
        &'life0 self,
        sql: &'life1 str
    ) -> Pin<Box<dyn Future<Output = Result<(Schema, RowProgressIterator), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn stream_load<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>(
        &'life0 self,
        sql: &'life1 str,
        data: Box<dyn AsyncRead + Send + Sync + Unpin + 'static>,
        size: u64,
        file_format_options: Option<BTreeMap<&'life2 str, &'life3 str>>,
        copy_options: Option<BTreeMap<&'life4 str, &'life5 str>>
    ) -> Pin<Box<dyn Future<Output = Result<QueryProgress, Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait,
             'life4: 'async_trait,
             'life5: 'async_trait;

    // Provided method
    fn version<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
}

Required Methods

fn info<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = ConnectionInfo> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn exec<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<i64, Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn query_row<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<Option<Row>, Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn query_iter<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<RowIterator, Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn query_iter_ext<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<(Schema, RowProgressIterator), Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn stream_load<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, sql: &'life1 str, data: Box<dyn AsyncRead + Send + Sync + Unpin + 'static>, size: u64, file_format_options: Option<BTreeMap<&'life2 str, &'life3 str>>, copy_options: Option<BTreeMap<&'life4 str, &'life5 str>> ) -> Pin<Box<dyn Future<Output = Result<QueryProgress, Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

Provided Methods

fn version<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Trait Implementations

impl<'clone> Clone for Box<dyn Connection + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone> Clone for Box<dyn Connection + Send + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone> Clone for Box<dyn Connection + Send + Sync + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone> Clone for Box<dyn Connection + Sync + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

Implementors