#orm #sqlx #mapping #built #model #sorm #object-relational

macro sorm-macros

Simple ORM (Object-Relational Mapping) built on SQLx

3 releases

0.1.2 Sep 19, 2024
0.1.1 Jul 5, 2024
0.1.0 Jun 24, 2024

#1303 in Procedural macros

Download history 145/week @ 2024-06-21 6/week @ 2024-06-28 126/week @ 2024-07-05 3/week @ 2024-07-12 23/week @ 2024-07-26 2/week @ 2024-08-02 80/week @ 2024-09-13 80/week @ 2024-09-20 62/week @ 2024-09-27 13/week @ 2024-10-04

235 downloads per month
Used in sorm

MIT license

39KB
1K SLoC

sorm

Simple ORM (Object-Relational Mapping) built on SQLx.

Examples

use std::error::Error;
use std::time::{SystemTime, UNIX_EPOCH};

use serde_json::json;
use sorm::model::Model;
use sorm::{clause, sorm};
use sqlx::{Executor, SqlitePool};

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let db = SqlitePool::connect("sqlite://:memory:").await?;
    db.execute(
        r#"
CREATE TABLE users (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    name TEXT NOT NULL,
    enable INTEGER NOT NULL,
    updated_at INTEGER NOT NULL,
    created_at INTEGER NOT NULL
)
"#,
    )
        .await?;

    // Create
    let mut user = User::new();
    user.set_name("foo".to_string());
    user.create(&db).await?;
    println!("{}", json!(user)); // => {"created_at":1719131281,"enable":1,"id":1,"name":"foo","updated_at":1719131281}

    // Update
    user.set_enable(0);
    user.update(&db).await?;
    println!("{}", json!(user)); // => {"created_at":1719131281,"enable":0,"id":1,"name":"foo","updated_at":1719131281}

    // Find by primary key
    let user = User::find(&db, &1).await?;
    println!("{}", json!(user)); // => {"created_at":1719131281,"enable":0,"id":1,"name":"foo","updated_at":1719131281}

    // Use query builder
    let name = "foo";
    let user = User::query()
        .select(&[User::ID, User::NAME])
        .r#where(clause!("name={&name}"))
        .find(&db)
        .await?;
    println!("{}", json!(user)); // => {"id":1,"name":"foo"}

    // Delete
    user.delete(&db).await?;
    User::destroy(&db, &1).await?;

    Ok(())
}

#[sorm(table = "users", serialize)]
struct User {
    #[sorm(primary_key(increment))]
    id: i64,

    name: String,

    #[sorm(default = "1")]
    enable: i8,

    #[sorm(update_time)]
    updated_at: i64,

    #[sorm(create_time)]
    created_at: i64,
}

fn current_timestamp() -> i64 {
    SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .unwrap()
        .as_secs() as i64
}

Install

  • sqlite

    cargo add sorm --features sqlite

  • postgres

    cargo add sorm --features postgres

  • mysql

    cargo add sorm --features mysql

Dependencies

~260–710KB
~17K SLoC