Struct DbPool 

pub struct DbPool { /* private fields */ }

Database connection pool wrapper

Implementations

impl DbPool

pub async fn connect(url: &str) -> Result<Self>

Examples found in repository

examples/db_demo.rs (line 12)

async fn main() -> Result<(), Box<dyn Error>> {
    println!("🚀 Starting Database Demo");

    // Use SQLite for this example as it's self-contained
    let url = "sqlite::memory:?cache=shared";
    println!("Connecting to {}", url);

    let db = DbPool::connect(url).await?;
    println!("Connected to {:?}", db.db_type());

    // Create a table
    let setup_sql = "
        CREATE TABLE users (
            id INTEGER PRIMARY KEY,
            name TEXT NOT NULL,
            email TEXT NOT NULL
        );
    ";
    db.execute(setup_sql).await?;
    println!("Created table 'users'");

    // Insert some data
    let insert_sql = "INSERT INTO users (name, email) VALUES ('Alice', 'alice@example.com')";
    let rows = db.execute(insert_sql).await?;
    println!("Inserted {} row(s)", rows);

    let insert_sql2 = "INSERT INTO users (name, email) VALUES ('Bob', 'bob@example.com')";
    let rows2 = db.execute(insert_sql2).await?;
    println!("Inserted {} row(s)", rows2);

    // Query data using the new query method
    let select_sql = "SELECT * FROM users";
    let results = db.query(select_sql).await?;
    println!("Found {} user(s)", results.len());

    for row in results {
        let name: String = row.try_get("name")?;
        let email: String = row.try_get("email")?;
        println!("User: {} ({})", name, email);
    }

    // Query one
    let one_sql = "SELECT * FROM users WHERE name = 'Alice'";
    if let Some(row) = db.query_one(one_sql).await? {
        let name: String = row.try_get("name")?;
        println!("Found specific user: {}", name);
    } else {
        println!("User not found");
    }

    db.ping().await?;
    println!("Ping successful");

    Ok(())
}

pub async fn connect_with_options( url: &str, options: PoolOptions, ) -> Result<Self>

Trait Implementations

impl Clone for DbPool

fn clone(&self) -> DbPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Database for DbPool

fn db_type(&self) -> DatabaseType

Get the database type

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Execute a query

fn query<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<AnyRow>>> + Send + 'async_trait>>

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

Query multiple rows

fn query_one<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<AnyRow>>> + Send + 'async_trait>>

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

Query one row

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

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

Check health

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

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

Begin a transaction

fn execute_query<'q, 'life0, 'async_trait>( &'life0 self, query: Query<'q, Any, AnyArguments<'q>>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Execute a sqlx Query

fn fetch_all<'q, 'life0, 'async_trait>( &'life0 self, query: Query<'q, Any, AnyArguments<'q>>, ) -> Pin<Box<dyn Future<Output = Result<Vec<AnyRow>>> + Send + 'async_trait>>

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

Fetch all from a sqlx Query

fn fetch_one<'q, 'life0, 'async_trait>( &'life0 self, query: Query<'q, Any, AnyArguments<'q>>, ) -> Pin<Box<dyn Future<Output = Result<Option<AnyRow>>> + Send + 'async_trait>>

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

Fetch one from a sqlx Query

impl Debug for DbPool

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

Formats the value using the given formatter.