Struct Client

pub struct Client {
    pub(crate) tx: UnboundedSender<Request>,
}

Higher level wrapper around a tiberius::Client that models transaction management like other database clients.

Fields

tx: UnboundedSender<Request>

Implementations

impl Client

pub async fn connect(config: Config) -> Result<Self, SqlServerError>

Connect to the specified SQL Server instance, returning a Client that can be used to query it and a Connection that must be polled to send and receive results.

TODO(sql_server2): Maybe return a ClientBuilder here that implements IntoFuture and does the default good thing of moving the Connection into a tokio task? And a .raw() option that will instead return both the Client and Connection for manual polling.

pub async fn connect_raw( config: Config, tcp: TcpStream, resources: Option<Box<dyn Any + Send + Sync>>, ) -> Result<(Self, Connection), SqlServerError>

pub async fn execute<'a>( &mut self, query: impl Into<Cow<'a, str>>, params: &[&dyn ToSql], ) -> Result<SmallVec<[u64; 1]>, SqlServerError>

Executes SQL statements in SQL Server, returning the number of rows effected.

Passthrough method for tiberius::Client::execute.

Note: The returned Future does not need to be awaited for the query to be sent.

pub async fn query<'a>( &mut self, query: impl Into<Cow<'a, str>>, params: &[&dyn ToSql], ) -> Result<SmallVec<[Row; 1]>, SqlServerError>

Executes SQL statements in SQL Server, returning the resulting rows.

Passthrough method for tiberius::Client::query.

Note: The returned Future does not need to be awaited for the query to be sent.

pub fn query_streaming<'c, 'q, Q>( &'c mut self, query: Q, params: &[&dyn ToSql], ) -> impl Stream<Item = Result<Row, SqlServerError>> + Send + use<'c, Q>

where Q: Into<Cow<'q, str>>,

Executes SQL statements in SQL Server, returning a Stream of resulting rows.

Passthrough method for tiberius::Client::query.

pub async fn simple_query<'a>( &mut self, query: impl Into<Cow<'a, str>>, ) -> Result<SmallVec<[Row; 1]>, SqlServerError>

Executes multiple queries, delimited with ; and return multiple result sets; one for each query.

Passthrough method for tiberius::Client::simple_query.

Note: The returned Future does not need to be awaited for the query to be sent.

pub async fn transaction(&mut self) -> Result<Transaction<'_>, SqlServerError>

Starts a transaction which is automatically rolled back on drop.

To commit or rollback the transaction, see Transaction::commit and Transaction::rollback respectively.

pub async fn set_transaction_isolation( &mut self, level: TransactionIsolationLevel, ) -> Result<(), SqlServerError>

Sets the transaction isolation level for the current session.

pub async fn get_transaction_isolation( &mut self, ) -> Result<TransactionIsolationLevel, SqlServerError>

Returns the current transaction isolation level for the current session.

pub fn cdc<I>(&mut self, capture_instances: I) -> CdcStream<'_>

where I: IntoIterator, I::Item: Into<Arc<str>>,

Return a CdcStream that can be used to track changes for the specified capture_instances.

Trait Implementations

impl Debug for Client

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

Formats the value using the given formatter.