Struct RbatisMigrationDriver 

pub struct RbatisMigrationDriver { /* private fields */ }

Rbatis implementation of MigrationStateManager and MigrationExecutor

Implementations

impl RbatisMigrationDriver

pub fn new( db: Arc<RBatis>, migrations_table_name: Option<&str>, ) -> RbatisMigrationDriver

Create a new driver

• db: The Rbatis instance for accessing the database
• migrations_table_name: The optional name of the table the migration state information should be stored in. If None, the DEFAULT_MIGRATIONS_TABLE will be used.

pub fn driver_type(&self) -> Result<RbatisDbDriverType>

The the driver type of the Rbatis instance

This method will get the driver type from Rbatis (which is a string) and convert it into an RbatisDbDriverType. Other(String) will be used for any database drivers not directly known to flyway-rbatis.

Trait Implementations

impl MigrationExecutor for RbatisMigrationDriver

Implementation of the MigrationExecutor

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

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

fn execute_changelog_file<'life0, 'life1, 'async_trait>( &'life0 self, changelog_file: &'life1 ChangelogFile, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

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

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

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

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

impl MigrationStateManager for RbatisMigrationDriver

Implementation of the MigrationStateManager

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

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

Prepare the DB for migration state management

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

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

Get the lowest deployed version

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

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

Get the highest deployed version

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

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

Get a list of all deployed versions

fn begin_version<'life0, 'life1, 'async_trait>( &'life0 self, changelog_file: &'life1 ChangelogFile, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Begin a new version

fn finish_version<'life0, 'life1, 'async_trait>( &'life0 self, changelog_file: &'life1 ChangelogFile, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Finish a new version

fn skip_version<'life0, 'life1, 'async_trait>( &'life0 self, changelog_file: &'life1 ChangelogFile, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Skip version while sql fail