ngdb 2.2.2

A high-performance, thread-safe RocksDB wrapper
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
96
97
98
99
100

//! Basic usage example for NGDB
//!
//! Demonstrates core CRUD operations with a simple product database.

use ngdb::{DatabaseConfig, Result, Storable, ngdb};

#[ngdb("products")]
struct Product {
    id: u64,
    name: String,
    price: f64,
    stock: u32,
}

impl Storable for Product {
    type Key = u64;

    fn key(&self) -> Self::Key {
        self.id
    }

    // Optional: validate data before storing
    fn validate(&self) -> Result<()> {
        if self.name.is_empty() {
            return Err(ngdb::Error::InvalidValue(
                "Product name cannot be empty".to_string(),
            ));
        }
        if self.price < 0.0 {
            return Err(ngdb::Error::InvalidValue(
                "Product price cannot be negative".to_string(),
            ));
        }
        Ok(())
    }
}

fn main() -> Result<()> {
    // Open database with a column family for products
    let db = DatabaseConfig::new("./data/products")
        .create_if_missing(true)
        .add_column_family("products")
        .open()?;

    // Create and store products
    let laptop = Product {
        id: 1,
        name: "Laptop".to_string(),
        price: 999.99,
        stock: 15,
    };
    laptop.save(&db)?;

    let mouse = Product {
        id: 2,
        name: "Mouse".to_string(),
        price: 29.99,
        stock: 100,
    };
    mouse.save(&db)?;

    let products = Product::collection(&db)?;

    // Retrieve a single item
    if let Some(product) = products.get(&1)? {
        println!("Found: {} - ${}", product.name, product.price);
    }

    // Multi-get for efficient batch retrieval
    let ids = vec![1, 2];
    let results = products.get_many(&ids)?;
    println!("Retrieved {} products", results.len());

    // Iterate over all items
    println!("All products:");
    products.iter()?.for_each(|p| {
        println!("  {}: ${}", p.name, p.price);
        true
    })?;

    // Update an item
    let updated = Product {
        id: 1,
        name: "Gaming Laptop".to_string(),
        price: 1499.99,
        stock: 10,
    };
    updated.save(&db)?;

    // Delete an item
    products.delete(&2)?;

    // Get statistics
    let count = products.iter()?.count()?;
    println!("Total products: {}", count);

    db.shutdown()?;

    Ok(())
}