use futures::StreamExt;
use std::io;
#[tokio::main]
async fn main() -> io::Result<()> {
let mut conn = asqlite::Connection::builder()
.create(true) .write(true) .open_memory("db1") .await?;
conn.execute(
"CREATE TABLE fruit (name TEXT, color TEXT)",
(), )
.await?;
let _apple_id = conn
.insert(
"INSERT INTO fruit (name, color) VALUES (?, ?)",
asqlite::params!("apple", "red"),
)
.await?;
let mut rows = conn.query(
"SELECT name FROM fruit WHERE color = ?",
asqlite::params!("red"),
);
while let Some(row) = rows.next().await {
let name: String = row?;
println!("{} is red", name);
}
Ok(())
}