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.