[dependencies]
sled = "0.34"

use sled::{Db, IVec};

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 打開或創(chuàng)建一個(gè)新的Sled數(shù)據(jù)庫
    let db: Db = sled::open("my_db")?;
    
    Ok(())
}

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

    // 查詢數(shù)據(jù)
    if let Some(IVec::from(value)) = db.get("key1")? {
        println!("Found value: {}", String::from_utf8(value.to_vec())?);
    }

    // 刪除數(shù)據(jù)
    db.remove("key1")?;

    Ok(())
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let db = sled::open("my_db")?;
    
    // 使用事務(wù)執(zhí)行多個(gè)操作
    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>> {
    // 打開或創(chuàng)建名為"my_db"的Sled數(shù)據(jù)庫
    let db: Db = sled::open("my_db")?;

    // 訂閱數(shù)據(jù)庫中的所有前綴（即訂閱所有變更事件）
    let mut events = db.watch_prefix("");
    
    // 在新線程中監(jiān)聽數(shù)據(jù)庫變更事件
    std::thread::spawn(move || {
        // 遍歷事件流
        for event in events {
            // 匹配不同類型的事件
            match event {
                // 插入事件
                Event::Insert { key, value } => {
                    // 當(dāng)一個(gè)新的鍵值對被插入時(shí)，打印出鍵和值
                    println!("Inserted: {:?}, {:?}", key, value);
                },
                // 刪除事件
                Event::Remove { key } => {
                    // 當(dāng)一個(gè)鍵值對被刪除時(shí)，打印出鍵
                    println!("Removed: {:?}", key);
                }
            }
        }
    });

    // 進(jìn)行一些數(shù)據(jù)庫操作以觸發(fā)上面訂閱的事件...

    // 插入一個(gè)鍵值對，觸發(fā)插入事件
    db.insert("key4", "value4")?;
    // 刪除剛剛插入的鍵值對，觸發(fā)刪除事件
    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")?;

    // 批量插入數(shù)據(jù)
    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")?;

    // 顯式調(diào)用flush確保數(shù)據(jù)持久化到磁盤
    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>> {
    // 打開或創(chuàng)建一個(gè)新的Sled數(shù)據(jù)庫
    let db: Db = sled::open("my_db")?;
    // 打開一個(gè)特定的Tree
    let tree = db.open_tree("my_tree")?;

    // 插入一些數(shù)據(jù)
    tree.insert("user1:John", "Doe")?;
    tree.insert("user2:Jane", "Doe")?;
    tree.insert("user3:Jake", "Smith")?;
    tree.insert("user4:Judy", "Brown")?;

    // 執(zhí)行范圍查詢：查詢以"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)?);
    }

    // 執(zhí)行前綴查詢：查詢所有以"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(())
}