Struct ydb_unofficial::sqlx::connection::YdbConnection

pub struct YdbConnection { /* private fields */ }

Available on crate feature sqlx only.

Implementations

impl YdbConnection

pub fn executor( &mut self ) -> Result<YdbTransaction<'_, UpdatableToken>, YdbError>

Retrieve DML executor, that can select/insert/update values in existing tables, but cannot modify their definitions

pub fn scheme_executor( &mut self ) -> Result<TableClientWithSession<'_, UpdatableToken>, YdbError>

Retrieve DDL executor, that makes operations on tables (create, delete, replace tables/indexes/etc). Note that DDL executor cannot fetch results, prepare and describe (never can used in sqlx macro). Parameter binding also unavailable

pub async fn reconnect(&mut self) -> Result<(), Error>

Reconnect to Ydb if received YdbError::NoSession received Sometimes Ydb service can invalidate connection with Session. An if you use single connection, you need to reconnect them

Trait Implementations

impl Connection for YdbConnection

type Database = Ydb

type Options = YdbConnectOptions

fn close(self) -> BoxFuture<'static, Result<(), Error>>

Explicitly close this database connection.

fn ping(&mut self) -> BoxFuture<'_, Result<(), Error>>

Checks if a connection to the database is still valid.

fn begin(&mut self) -> BoxFuture<'_, Result<Transaction<'_, Ydb>, Error>>where Self: Sized,

Begin a new transaction or establish a savepoint within the active transaction.

fn shrink_buffers(&mut self)

Restore any buffers in the connection to their default capacity, if possible.

fn transaction<'a, F, R, E>( &'a mut self, callback: F ) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'a, Global>>where F: for<'c> FnOnce(&'c mut Transaction<'_, Self::Database>) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'c, Global>> + 'a + Send + Sync, Self: Sized, R: Send, E: From<Error> + Send,

Execute the function inside a transaction.

fn connect( url: &str ) -> Pin<Box<dyn Future<Output = Result<Self, Error>> + Send, Global>>where Self: Sized,

Establish a new database connection.

fn connect_with( options: &Self::Options ) -> Pin<Box<dyn Future<Output = Result<Self, Error>> + Send + '_, Global>>where Self: Sized,

Establish a new database connection with the provided options.