Struct MssqlConnection 

pub struct MssqlConnection<S: AsyncRead + AsyncWrite + Unpin + Send = TokioConnectionStream> { /* private fields */ }

Implementations

impl MssqlConnection<TokioConnectionStream>

pub async fn connect(connection_string: &str) -> Result<Self, OrmError>

pub async fn connect_with_config( config: MssqlConnectionConfig, ) -> Result<Self, OrmError>

impl<S: AsyncRead + AsyncWrite + Unpin + Send> MssqlConnection<S>

pub fn new(client: Client<S>, config: MssqlConnectionConfig) -> Self

pub fn config(&self) -> &MssqlConnectionConfig

pub fn client(&self) -> &Client<S>

pub fn client_mut(&mut self) -> &mut Client<S>

pub async fn begin_transaction<'a>( &'a mut self, ) -> Result<MssqlTransaction<'a, S>, OrmError>

pub async fn begin_transaction_scope(&mut self) -> Result<(), OrmError>

pub async fn commit_transaction(&mut self) -> Result<(), OrmError>

pub async fn rollback_transaction(&mut self) -> Result<(), OrmError>

pub async fn health_check(&mut self) -> Result<(), OrmError>

pub fn into_inner(self) -> Client<S>

impl<S> MssqlConnection<S>

where S: AsyncRead + AsyncWrite + Unpin + Send,

pub async fn execute( &mut self, query: CompiledQuery, ) -> Result<ExecuteResult, OrmError>

pub async fn query_raw<'a>( &'a mut self, query: CompiledQuery, ) -> Result<QueryStream<'a>, OrmError>

pub async fn fetch_one<T>( &mut self, query: CompiledQuery, ) -> Result<Option<T>, OrmError>

where T: FromRow + Send,

pub async fn fetch_all<T>( &mut self, query: CompiledQuery, ) -> Result<Vec<T>, OrmError>

where T: FromRow + Send,

pub async fn fetch_one_with<T, F>( &mut self, query: CompiledQuery, map: F, ) -> Result<Option<T>, OrmError>

where F: FnMut(MssqlRow<'_>) -> Result<T, OrmError> + Send,

pub async fn fetch_all_with<T, F>( &mut self, query: CompiledQuery, map: F, ) -> Result<Vec<T>, OrmError>

where F: FnMut(MssqlRow<'_>) -> Result<T, OrmError> + Send,

Trait Implementations

impl<S> Executor for MssqlConnection<S>

where S: AsyncRead + AsyncWrite + Unpin + Send,

fn execute<'life0, 'async_trait>( &'life0 mut self, query: CompiledQuery, ) -> Pin<Box<dyn Future<Output = Result<ExecuteResult, OrmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn fetch_one<'life0, 'async_trait, T>( &'life0 mut self, query: CompiledQuery, ) -> Pin<Box<dyn Future<Output = Result<Option<T>, OrmError>> + Send + 'async_trait>>

where T: FromRow + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn fetch_all<'life0, 'async_trait, T>( &'life0 mut self, query: CompiledQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<T>, OrmError>> + Send + 'async_trait>>

where T: FromRow + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,