Struct sea_orm::MockDatabaseConnection

pub struct MockDatabaseConnection { /* private fields */ }

Defines a connection for the MockDatabase

Implementations

impl MockDatabaseConnection

pub fn new<M>(m: M) -> Selfwhere
    M: MockDatabaseTrait + 'static,

Create a connection to the MockDatabase

Examples found in repository

src/database/mock.rs (line 70)

    pub fn into_connection(self) -> DatabaseConnection {
        DatabaseConnection::MockDatabaseConnection(Arc::new(MockDatabaseConnection::new(self)))
    }

pub fn get_database_backend(&self) -> DbBackend

Get the DatabaseBackend being used by the MockDatabase

Examples found in repository

src/database/transaction.rs (line 86)

    pub(crate) async fn new_mock(
        inner: Arc<crate::MockDatabaseConnection>,
        metric_callback: Option<crate::metric::Callback>,
    ) -> Result<DatabaseTransaction, DbErr> {
        let backend = inner.get_database_backend();
        Self::begin(
            Arc::new(Mutex::new(InnerConnection::Mock(inner))),
            backend,
            metric_callback,
            None,
            None,
        )
        .await
    }

src/database/db_connection.rs (line 102)

    fn get_database_backend(&self) -> DbBackend {
        match self {
            #[cfg(feature = "sqlx-mysql")]
            DatabaseConnection::SqlxMySqlPoolConnection(_) => DbBackend::MySql,
            #[cfg(feature = "sqlx-postgres")]
            DatabaseConnection::SqlxPostgresPoolConnection(_) => DbBackend::Postgres,
            #[cfg(feature = "sqlx-sqlite")]
            DatabaseConnection::SqlxSqlitePoolConnection(_) => DbBackend::Sqlite,
            #[cfg(feature = "mock")]
            DatabaseConnection::MockDatabaseConnection(conn) => conn.get_database_backend(),
            DatabaseConnection::Disconnected => panic!("Disconnected"),
        }
    }

pub fn execute(&self, statement: Statement) -> Result<ExecResult, DbErr>

Execute the SQL statement in the MockDatabase

pub fn query_one(
    &self,
    statement: Statement
) -> Result<Option<QueryResult>, DbErr>

Return one QueryResult if the query was successful

pub fn query_all(&self, statement: Statement) -> Result<Vec<QueryResult>, DbErr>

Return all QueryResults if the query was successful

pub fn fetch(
    &self,
    statement: &Statement
) -> Pin<Box<dyn Stream<Item = Result<QueryResult, DbErr>> + Send>>

Return QueryResults from a multi-query operation

pub fn begin(&self)

Create a statement block of SQL statements that execute together.

pub fn commit(&self)

Commit a transaction atomically to the database

pub fn rollback(&self)

Roll back a faulty transaction

Trait Implementations

impl Debug for MockDatabaseConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.