Struct YdbConnection

pub struct YdbConnection {
    pub retry: bool,
    /* private fields */
}

Available on crate feature sqlx only.

Fields

retry: bool

Implementations

impl YdbConnection

pub fn executor(&mut self) -> Result<YdbExecutor<'_>, 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<YdbSchemeExecutor<'_>, 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>>

where F: for<'c> FnOnce(&'c mut Transaction<'_, Self::Database>) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'c>> + 'a + for<'c> Send + for<'c> 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>>

where Self: Sized,

Establish a new database connection.

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

where Self: Sized,

Establish a new database connection with the provided options.

impl Migrate for YdbConnection

Available on crate feature migrate only.

fn ensure_migrations_table(&mut self) -> BoxFuture<'_, Result<(), MigrateError>>

fn dirty_version(&mut self) -> BoxFuture<'_, Result<Option<i64>, MigrateError>>

fn list_applied_migrations( &mut self, ) -> BoxFuture<'_, Result<Vec<AppliedMigration>, MigrateError>>

fn lock(&mut self) -> BoxFuture<'_, Result<(), MigrateError>>

fn unlock(&mut self) -> BoxFuture<'_, Result<(), MigrateError>>

fn apply<'e: 'm, 'm>( &'e mut self, migration: &'m Migration, ) -> BoxFuture<'m, Result<Duration, MigrateError>>

fn revert<'e: 'm, 'm>( &'e mut self, _migration: &'m Migration, ) -> BoxFuture<'m, Result<Duration, MigrateError>>