Struct DbConnection 

pub struct DbConnection { /* private fields */ }

Wrapper around SeaORM’s DatabaseConnection

This provides a clonable, thread-safe connection that can be stored in the application container and shared across requests.

Example

let conn = DbConnection::connect(&config).await?;

// Use with SeaORM queries
let users = User::find().all(conn.inner()).await?;

Implementations

impl DbConnection

pub async fn connect(config: &DatabaseConfig) -> Result<Self, FrameworkError>

Create a new database connection from config

This establishes a connection pool using the provided configuration. For SQLite databases, this will automatically create the database file if it doesn’t exist.

pub fn inner(&self) -> &DatabaseConnection

Get a reference to the underlying SeaORM connection

Use this when you need to execute raw SeaORM queries.

Example

let conn = DB::connection()?;
let users = User::find()
    .filter(user::Column::Active.eq(true))
    .all(conn.inner())
    .await?;

pub fn conn(&self) -> &DatabaseConnection

Get a reference to the database connection (short alias for inner())

Use this when passing to SeaORM queries. This provides a cleaner API than using the Deref implementation with &*.

Example

let users = User::find().all(self.db.conn()).await?;

pub fn is_closed(&self) -> bool

Check if the connection is closed

Methods from Deref<Target = DatabaseConnection>

pub async fn ping(&self) -> Result<(), DbErr>

Checks if a connection to the database is still valid.

pub async fn close_by_ref(&self) -> Result<(), DbErr>

Explicitly close the database connection

pub fn get_postgres_connection_pool(&self) -> &Pool<Postgres>

Get sqlx::PgPool

Panics

Panics if DbConn is not a Postgres connection.

pub fn get_sqlite_connection_pool(&self) -> &Pool<Sqlite>

Get sqlx::SqlitePool

Panics

Panics if DbConn is not a SQLite connection.

Trait Implementations

impl AsRef<DatabaseConnection> for DbConnection

fn as_ref(&self) -> &DatabaseConnection

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for DbConnection

fn clone(&self) -> DbConnection

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Deref for DbConnection

type Target = DatabaseConnection

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.