Rust使用Sled添加高性能嵌入式数据库

[dependencies]
sled = "0.34"

use sled::{Db, IVec};

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 打开或创建一个新的Sled数据库
    let db: Db = sled::open("my_db")?;
    
    Ok(())
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let db = sled::open("my_db")?;
    
    // 插入数据
    db.insert("key1", "value1")?;

    // 查询数据
    if let Some(IVec::from(value)) = db.get("key1")? {
        println!("Found value: {}", String::from_utf8(value.to_vec())?);
    }

    // 删除数据
    db.remove("key1")?;

    Ok(())
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let db = sled::open("my_db")?;
    
    // 使用事务执行多个操作
    db.transaction(|txn| {
        txn.insert("key2", "value2")?;
        txn.insert("key3", "value3")?;
        Ok(())
    })?;

    Ok(())
}

use sled::{Db, Event};

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 打开或创建名为"my_db"的Sled数据库
    let db: Db = sled::open("my_db")?;

    // 订阅数据库中的所有前缀（即订阅所有变更事件）
    let mut events = db.watch_prefix("");
    
    // 在新线程中监听数据库变更事件
    std::thread::spawn(move || {
        // 遍历事件流
        for event in events {
            // 匹配不同类型的事件
            match event {
                // 插入事件
                Event::Insert { key, value } => {
                    // 当一个新的键值对被插入时，打印出键和值
                    println!("Inserted: {:?}, {:?}", key, value);
                },
                // 删除事件
                Event::Remove { key } => {
                    // 当一个键值对被删除时，打印出键
                    println!("Removed: {:?}", key);
                }
            }
        }
    });

    // 进行一些数据库操作以触发上面订阅的事件...

    // 插入一个键值对，触发插入事件
    db.insert("key4", "value4")?;
    // 删除刚刚插入的键值对，触发删除事件
    db.remove("key4")?;

    Ok(())
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let db = sled::open("my_db")?;
    let tree = db.open_tree("my_tree")?;
    
    tree.insert("key1", "value1")?;
    
    if let Some(value) = tree.get("key1")? {
        println!("Found value in tree: {}", String::from_utf8(value.to_vec())?);
    }

    Ok(())
}

use sled::Db;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let db = sled::open("my_db")?;

    // 批量插入数据
    let mut batch = sled::Batch::default();
    for i in 0..1000 {
        let key = format!("key{}", i);
        let value = format!("value{}", i);
        batch.insert(key.as_bytes(), value.as_bytes());
    }
    db.apply_batch(batch)?;

    println!("Batch insert completed.");

    Ok(())
}

use sled::Db;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let db = sled::open("my_db")?;
    db.insert("key", "value")?;

    // 显式调用flush确保数据持久化到磁盘
    db.flush()?;

    println!("Data has been flushed to disk.");

    Ok(())
}

use sled::{Db, IVec};
use std::str;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 打开或创建一个新的Sled数据库
    let db: Db = sled::open("my_db")?;
    // 打开一个特定的Tree
    let tree = db.open_tree("my_tree")?;

    // 插入一些数据
    tree.insert("user1:John", "Doe")?;
    tree.insert("user2:Jane", "Doe")?;
    tree.insert("user3:Jake", "Smith")?;
    tree.insert("user4:Judy", "Brown")?;

    // 执行范围查询：查询以"user2"开头的键
    println!("Range query for keys starting with 'user2':");
    for item in tree.range("user2"..="user2\xff") {
        let (key, value) = item?;
        println!("{}: {}", str::from_utf8(&key)?, str::from_utf8(&value)?);
    }

    // 执行前缀查询：查询所有以"user"前缀的键
    println!("\nPrefix query for keys starting with 'user':");
    for item in tree.scan_prefix("user") {
        let (key, value) = item?;
        println!("{}: {}", str::from_utf8(&key)?, str::from_utf8(&value)?);
    }

    Ok(())
}