uorm 0.9.4

Rust 下的轻量级 ORM 框架，借鉴了 Java MyBatis 的设计理念，强调 SQL 与业务逻辑分离。它结合 Rust 的类型系统与宏机制，支持编写原生 SQL 并自动映射结果，兼容 async/await，兼顾性能与可控性。
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

use uorm::Param;
use uorm::Result;
use uorm::driver_manager::U;
use uorm::sql;
#[cfg(feature = "postgres")]
use pgvector::Vector;
#[cfg(feature = "postgres")]
use uorm::udbc::postgres::pool::PostgresDriver;

#[sql("pg_user")]
struct PgVectorDao;

#[cfg(feature = "postgres")]
#[derive(Param)]
struct VectorInsert {
    doc_id: i64,
    embedding: Vector,
}

#[cfg(feature = "postgres")]
#[derive(Param)]
struct VectorQuery {
    embedding: Vector,
}

#[cfg(feature = "postgres")]
impl PgVectorDao {
    #[sql("create_vector_table")]
    async fn create_vector_table() -> Result<u64> {
        exec!()
    }

    #[sql("clear_vector_table")]
    async fn clear_vector_table() -> Result<u64> {
        exec!()
    }

    #[sql("insert_vector")]
    async fn insert_vector(row: VectorInsert) -> Result<u64> {
        exec!()
    }

    #[sql("select_vector_nearest")]
    async fn select_vector_nearest(query: VectorQuery) -> Result<i64> {
        exec!()
    }
}

#[cfg(feature = "postgres")]
fn build_vector(seed: f32, dim: usize) -> Vector {
    let mut values = Vec::with_capacity(dim);
    for i in 0..dim {
        values.push(seed + (i as f32) * 0.001);
    }
    Vector::from(values)
}

#[cfg(feature = "postgres")]
#[tokio::test]
async fn test_postgres_vector_insert_query() -> Result<()> {
    let url = std::env::var("DATABASE_URL").unwrap_or_default();
    if url.is_empty() {
        return Ok(());
    }

    uorm::mapper_loader::clear();
    U.assets("tests/resources/**/*.xml")?;

    let driver = PostgresDriver::new(url).build()?;
    U.register(driver)?;

    PgVectorDao::create_vector_table().await?;
    PgVectorDao::clear_vector_table().await?;

    let v1 = build_vector(0.01, 1024);
    let v2 = build_vector(10.01, 1024);

    PgVectorDao::insert_vector(VectorInsert {
        doc_id: 1,
        embedding: v1.clone(),
    })
    .await?;
    PgVectorDao::insert_vector(VectorInsert {
        doc_id: 2,
        embedding: v2.clone(),
    })
    .await?;

    let nearest1 = PgVectorDao::select_vector_nearest(VectorQuery { embedding: v1 }).await?;
    let nearest2 = PgVectorDao::select_vector_nearest(VectorQuery { embedding: v2 }).await?;

    assert_eq!(nearest1, 1);
    assert_eq!(nearest2, 2);
    Ok(())
}