Struct SqlServerConnection 

pub struct SqlServerConnection { /* private fields */ }

SQL Server connection

Implementations

impl SqlServerConnection

pub fn age(&self) -> Duration

Get the age of this connection (time since creation)

pub fn is_expired(&self, max_lifetime: Duration) -> bool

Check if connection is older than the specified max lifetime

pub async fn idle_time(&self) -> Duration

Get time since last use

pub async fn connect(config: &ConnectionConfig) -> Result<Self>

Create a new SQL Server connection from config

pub async fn from_url(url: &str) -> Result<Self>

Create connection from URL

Trait Implementations

impl Connection for SqlServerConnection

fn begin_with_isolation<'life0, 'async_trait>( &'life0 self, isolation: IsolationLevel, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Transaction>>> + Send + 'async_trait>>

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

SQL Server requires SET TRANSACTION ISOLATION LEVEL before BEGIN TRANSACTION for it to take effect for that transaction.

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a query that modifies data, returns affected row count

fn query<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a query that returns rows

fn prepare<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn PreparedStatement>>> + Send + 'async_trait>>

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

Prepare a statement for repeated execution

fn begin<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Transaction>>> + Send + 'async_trait>>

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

Begin a transaction

fn query_stream<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn RowStream>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a query and stream results

fn is_valid<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Check if connection is valid/alive

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Close the connection

fn execute_batch<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, statements: &'life1 [(&'life2 str, &'life3 [Value])], ) -> Pin<Box<dyn Future<Output = Result<Vec<u64>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Execute a batch of statements, returns affected counts per statement

fn query_one<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<Option<Row>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a query and return the first row (convenience method)

impl ConnectionLifecycle for SqlServerConnection

fn created_at(&self) -> Instant

Get the instant when this connection was created

fn idle_time<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Duration> + Send + 'async_trait>>

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

Get duration since this connection was last used

fn touch<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Update the last-used timestamp (called when connection is actively used)

fn age(&self) -> Duration

Get the age of this connection (time since creation)

fn is_expired(&self, max_lifetime: Duration) -> bool

Check if connection has exceeded the given maximum lifetime

fn is_idle_expired<'life0, 'async_trait>( &'life0 self, idle_timeout: Duration, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Check if connection has exceeded idle timeout