Struct Db 

pub struct Db { /* private fields */ }

Implementations

impl Db

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

pub async fn memory() -> Result<Self, Error>

Examples found in repository

examples/admin_demo.rs (line 39)

async fn main() -> std::io::Result<()> {
    let db = Db::memory().await.expect("db connect");
    db.execute(
        "CREATE TABLE users (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            name TEXT NOT NULL,
            is_admin INTEGER NOT NULL
        )",
    )
    .await
    .expect("create schema");

    User { id: 0, name: "Alice".into(), is_admin: false }
        .create(&db)
        .await
        .expect("seed alice");
    User { id: 0, name: "Bob".into(), is_admin: true }
        .create(&db)
        .await
        .expect("seed bob");

    let router = with_defaults(Router::new()).wrap(authenticate);
    let router = admin::register::<User>(router, &db);

    let addr: SocketAddr = ([127, 0, 0, 1], 3000).into();
    eprintln!("admin demo: hit /admin/users with `Authorization: Bearer dev-admin` header");
    Server::bind(addr).serve_router(router).await
}

examples/orm_demo.rs (line 34)

async fn main() -> Result<(), Error> {
    let db = Db::memory().await?;
    db.execute(
        "CREATE TABLE users (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            name TEXT NOT NULL,
            is_admin INTEGER NOT NULL
        )",
    )
    .await?;

    let alice_id = User { id: 0, name: "Alice".into(), is_admin: false }
        .create(&db)
        .await?;
    let bob_id = User { id: 0, name: "Bob".into(), is_admin: true }
        .create(&db)
        .await?;
    println!("created ids: alice={alice_id} bob={bob_id}");

    let alice = User::find(&db, alice_id).await?.expect("alice");
    println!("find alice: {alice:?}");

    let all = User::all(&db).await?;
    println!("all: {all:?}");

    let renamed = User { id: alice_id, name: "Alicia".into(), is_admin: false };
    renamed.update(&db).await?;
    let after_update = User::find(&db, alice_id).await?.unwrap();
    println!("after update: {after_update:?}");

    User::delete(&db, bob_id).await?;
    println!("remaining after delete bob: {:?}", User::all(&db).await?);

    Ok(())
}

pub async fn execute(&self, sql: &str) -> Result<(), Error>

Examples found in repository

examples/admin_demo.rs (lines 40-46)

async fn main() -> std::io::Result<()> {
    let db = Db::memory().await.expect("db connect");
    db.execute(
        "CREATE TABLE users (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            name TEXT NOT NULL,
            is_admin INTEGER NOT NULL
        )",
    )
    .await
    .expect("create schema");

    User { id: 0, name: "Alice".into(), is_admin: false }
        .create(&db)
        .await
        .expect("seed alice");
    User { id: 0, name: "Bob".into(), is_admin: true }
        .create(&db)
        .await
        .expect("seed bob");

    let router = with_defaults(Router::new()).wrap(authenticate);
    let router = admin::register::<User>(router, &db);

    let addr: SocketAddr = ([127, 0, 0, 1], 3000).into();
    eprintln!("admin demo: hit /admin/users with `Authorization: Bearer dev-admin` header");
    Server::bind(addr).serve_router(router).await
}

examples/orm_demo.rs (lines 35-41)

async fn main() -> Result<(), Error> {
    let db = Db::memory().await?;
    db.execute(
        "CREATE TABLE users (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            name TEXT NOT NULL,
            is_admin INTEGER NOT NULL
        )",
    )
    .await?;

    let alice_id = User { id: 0, name: "Alice".into(), is_admin: false }
        .create(&db)
        .await?;
    let bob_id = User { id: 0, name: "Bob".into(), is_admin: true }
        .create(&db)
        .await?;
    println!("created ids: alice={alice_id} bob={bob_id}");

    let alice = User::find(&db, alice_id).await?.expect("alice");
    println!("find alice: {alice:?}");

    let all = User::all(&db).await?;
    println!("all: {all:?}");

    let renamed = User { id: alice_id, name: "Alicia".into(), is_admin: false };
    renamed.update(&db).await?;
    let after_update = User::find(&db, alice_id).await?.unwrap();
    println!("after update: {after_update:?}");

    User::delete(&db, bob_id).await?;
    println!("remaining after delete bob: {:?}", User::all(&db).await?);

    Ok(())
}

Trait Implementations

impl Clone for Db

fn clone(&self) -> Db

Returns a duplicate of the value.

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

Performs copy-assignment from source.