qail-pg 0.26.5

Fastest async PostgreSQL driver - AST to wire protocol, optional io_uring on Linux
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

use bytes::BytesMut;
use qail_core::ast::Qail;
use qail_core::ast::builders::ExprExt;
use qail_core::ast::builders::{col, subquery};

fn main() {
    let last_message = subquery(
        Qail::get("app_chat_messages")
            .column("content")
            .eq("session_id", col("app_chat_sessions.id"))
            .order_desc("created_at")
            .limit(1),
    )
    .with_alias("last_message");

    let unread_count = subquery(
        Qail::get("app_chat_messages")
            .column("count(*)")
            .eq("session_id", col("app_chat_sessions.id"))
            .eq("sender_type", "user")
            .ne("status", "read"),
    )
    .with_alias("unread_count");

    let cmd = Qail::get("app_chat_sessions")
        .columns(["app_chat_sessions.id", "app_chat_sessions.status"])
        .select_expr(last_message)
        .select_expr(unread_count)
        .left_join_as("users", "u", "u.id", "app_chat_sessions.user_id")
        .ne("app_chat_sessions.status", "closed")
        .order_desc("app_chat_sessions.updated_at")
        .limit(20)
        .offset(0);

    // AST encoder (parameterized)
    let mut sql_buf = BytesMut::new();
    let mut params: Vec<Option<Vec<u8>>> = Vec::new();
    let _ = qail_pg::protocol::AstEncoder::encode_select_sql(&cmd, &mut sql_buf, &mut params);

    println!("SQL: {}", std::str::from_utf8(&sql_buf).unwrap_or("ERR"));
    println!("\nParams ({})", params.len());
    for (i, p) in params.iter().enumerate() {
        match p {
            Some(v) => println!(
                "  ${}: {}",
                i + 1,
                std::str::from_utf8(v).unwrap_or("binary")
            ),
            None => println!("  ${}: NULL", i + 1),
        }
    }
}