use ryzz::*; #[table("posts")] struct Post { #[ryzz(pk)] id: i64, title: Option<String>, body: String } #[table] struct Comment { #[ryzz(pk)] id: i64, body: String, #[ryzz(fk = "posts(id)")] post_id: i64, }

let db = Database::new("db.sqlite3").await?; let posts = Post::table(&db).await?; let comments = Comment::table(&db).await?; let post = Post { id: 1, title: None, body: "".into() }; // insert into posts (id, body) values (?, ?) returning * let mut post: Post = db .insert(posts) .values(post)? .returning() .await?; post.body = "post".into(); // update posts set body = ?, id = ? where id = ? returning * let post: Post = db .update(posts) .set(post)? .where_(and(eq(posts.id, 1), eq(posts.title, Value::Null))) .returning() .await?; // delete from posts where id = ? returning * let post: Post = db .delete_from(posts) .where_(eq(posts.id, 1)) .returning() .await?;

// select ... from Comment let rows: Vec<Comment> = db .select(()) .from(comments) .all() .await?; // select ... from Comment let rows: Vec<Comment> = db .select((comments.id, comments.body)) .from(comments) .all() .await?;

#[row] struct CommentWithPost { comment: Comment, post: Post } // select ... from Comment inner join posts on posts.id = Comment.post_id let rows = db .select(()) .from(comments) .inner_join(posts, eq(posts.id, comments.post_id)) .all::<CommentWithPost>() .await?;

let query = db .select(()) .from(comments); let prepped = query.prep::<Comment>(); let rows: Vec<Comment> = prepped.all().await?;

let ix = index("posts_id_body_ix") .unique() .on(posts, (posts.id, posts.body)); // create unique index if not exists posts_id_body_ix on posts (id, body); db.create(&ix).await?; // drop index if exists posts_id_body_ix; db.drop(&ix).await?;