chore: restore lib example after thread safety feature
This commit is contained in:
@@ -32,146 +32,147 @@
|
||||
//! and the necessary `From` and `TryFrom` conversions.
|
||||
//!
|
||||
//! ```rust,no_run
|
||||
//! // use heave::*;
|
||||
//! // use std::convert::{From, TryFrom};
|
||||
//! // use std::result::Result;
|
||||
//! use heave::*;
|
||||
//! use std::convert::{From, TryFrom};
|
||||
//! use std::result::Result;
|
||||
//!
|
||||
//! // // Define a simple struct representing a product.
|
||||
//! // #[derive(Debug, Default, PartialEq, Clone)]
|
||||
//! // struct Product {
|
||||
//! // pub id: String,
|
||||
//! // pub name: String,
|
||||
//! // pub price: u64,
|
||||
//! // pub in_stock: bool,
|
||||
//! // }
|
||||
//! // Define a simple struct representing a product.
|
||||
//! #[derive(Debug, Default, PartialEq, Clone)]
|
||||
//! struct Product {
|
||||
//! pub id: String,
|
||||
//! pub name: String,
|
||||
//! pub price: u64,
|
||||
//! pub in_stock: bool,
|
||||
//! }
|
||||
//!
|
||||
//! // // Implement the EAV trait to define the "class" of this entity.
|
||||
//! // impl EAV for Product {
|
||||
//! // fn class() -> &'static str {
|
||||
//! // "product"
|
||||
//! // }
|
||||
//! // }
|
||||
//! // Implement the EAV trait to define the "class" of this entity.
|
||||
//! impl EAV for Product {
|
||||
//! fn class() -> &'static str {
|
||||
//! "product"
|
||||
//! }
|
||||
//! }
|
||||
//!
|
||||
//! // // Convert our Product into a generic Entity.
|
||||
//! // impl From<Product> for Entity {
|
||||
//! // fn from(p: Product) -> Self {
|
||||
//! // Entity::new::<Product>()
|
||||
//! // .with_id(&p.id)
|
||||
//! // .with_attribute("name", p.name)
|
||||
//! // .with_attribute("price", p.price)
|
||||
//! // .with_attribute("in_stock", p.in_stock)
|
||||
//! // }
|
||||
//! // }
|
||||
//! // Convert our Product into a generic Entity.
|
||||
//! impl From<Product> for Entity {
|
||||
//! fn from(p: Product) -> Self {
|
||||
//! Entity::new::<Product>()
|
||||
//! .with_id(&p.id)
|
||||
//! .with_attribute("name", p.name)
|
||||
//! .with_attribute("price", p.price)
|
||||
//! .with_attribute("in_stock", p.in_stock)
|
||||
//! }
|
||||
//! }
|
||||
//!
|
||||
//! // // Convert a generic Entity back into our Product.
|
||||
//! // impl TryFrom<Entity> for Product {
|
||||
//! // type Error = FailedTo;
|
||||
//! // Convert a generic Entity back into our Product.
|
||||
//! impl TryFrom<Entity> for Product {
|
||||
//! type Error = FailedTo;
|
||||
//!
|
||||
//! // fn try_from(entity: Entity) -> Result<Self, Self::Error> {
|
||||
//! // Ok(Self {
|
||||
//! // id: entity.id.clone(),
|
||||
//! // name: entity.unwrap("name").map_err(|_| FailedTo::ConvertEntity)?,
|
||||
//! // price: entity.unwrap("price").map_err(|_| FailedTo::ConvertEntity)?,
|
||||
//! // in_stock: entity.unwrap("in_stock").map_err(|_| FailedTo::ConvertEntity)?,
|
||||
//! // })
|
||||
//! // }
|
||||
//! // }
|
||||
//! fn try_from(entity: Entity) -> Result<Self, Self::Error> {
|
||||
//! Ok(Self {
|
||||
//! id: entity.id.clone(),
|
||||
//! name: entity.unwrap("name").map_err(|_| FailedTo::ConvertEntity)?,
|
||||
//! price: entity.unwrap("price").map_err(|_| FailedTo::ConvertEntity)?,
|
||||
//! in_stock: entity.unwrap("in_stock").map_err(|_| FailedTo::ConvertEntity)?,
|
||||
//! })
|
||||
//! }
|
||||
//! }
|
||||
//!
|
||||
//! // fn main() -> Result<(), FailedTo> {
|
||||
//! // let db_path = "my_products.db";
|
||||
//! fn main() -> Result<(), FailedTo> {
|
||||
//! let db_path = "my_products.db";
|
||||
//!
|
||||
//! // // Clean up previous runs if file exists
|
||||
//! // if std::path::Path::new(db_path).exists() {
|
||||
//! // std::fs::remove_file(db_path).unwrap();
|
||||
//! // }
|
||||
//! // Clean up previous runs if file exists
|
||||
//! if std::path::Path::new(db_path).exists() {
|
||||
//! std::fs::remove_file(db_path).unwrap();
|
||||
//! }
|
||||
//!
|
||||
//! // // == 1. Initialize and Persist Data ==
|
||||
//! // let mut catalog = Catalog::new(db_path);
|
||||
//! // catalog.init()?;
|
||||
//! // == 1. Initialize and Persist Data ==
|
||||
//! let mut catalog = Catalog::new(db_path);
|
||||
//! catalog.init()?;
|
||||
//!
|
||||
//! // let products_to_add = vec![
|
||||
//! // Product {
|
||||
//! // id: "p1".to_string(),
|
||||
//! // name: "Laptop".to_string(),
|
||||
//! // price: 1200,
|
||||
//! // in_stock: true,
|
||||
//! // },
|
||||
//! // Product {
|
||||
//! // id: "p2".to_string(),
|
||||
//! // name: "Mouse".to_string(),
|
||||
//! // price: 25,
|
||||
//! // in_stock: true,
|
||||
//! // },
|
||||
//! // Product {
|
||||
//! // id: "p3".to_string(),
|
||||
//! // name: "Keyboard".to_string(),
|
||||
//! // price: 75,
|
||||
//! // in_stock: false,
|
||||
//! // },
|
||||
//! // ];
|
||||
//! let products_to_add = vec![
|
||||
//! Product {
|
||||
//! id: "p1".to_string(),
|
||||
//! name: "Laptop".to_string(),
|
||||
//! price: 1200,
|
||||
//! in_stock: true,
|
||||
//! },
|
||||
//! Product {
|
||||
//! id: "p2".to_string(),
|
||||
//! name: "Mouse".to_string(),
|
||||
//! price: 25,
|
||||
//! in_stock: true,
|
||||
//! },
|
||||
//! Product {
|
||||
//! id: "p3".to_string(),
|
||||
//! name: "Keyboard".to_string(),
|
||||
//! price: 75,
|
||||
//! in_stock: false,
|
||||
//! },
|
||||
//! ];
|
||||
//!
|
||||
//! // catalog.insert_many(products_to_add)?;
|
||||
//! // catalog.persist()?;
|
||||
//! // println!("✅ Products saved to the database.");
|
||||
//! catalog.insert_many(products_to_add)?;
|
||||
//! catalog.persist()?;
|
||||
//! println!("✅ Products saved to the database.");
|
||||
//!
|
||||
//! // // == 2. Load and Query Data ==
|
||||
//! // let mut query_catalog = Catalog::new(db_path);
|
||||
//! // == 2. Load and Query Data ==
|
||||
//! let mut query_catalog = Catalog::new(db_path);
|
||||
//!
|
||||
//! // // Load a single product by its ID.
|
||||
//! // query_catalog.load_by_id("p1")?;
|
||||
//! // let laptop: Product = query_catalog.get("p1")?.unwrap();
|
||||
//! // println!("✅ Loaded by ID: {:?}", laptop);
|
||||
//! // assert_eq!(laptop.name, "Laptop");
|
||||
//! // Load a single product by its ID.
|
||||
//! query_catalog.load_by_id("p1")?;
|
||||
//! let laptop: Product = query_catalog.get("p1")?.unwrap();
|
||||
//! println!("✅ Loaded by ID: {:?}", laptop);
|
||||
//! assert_eq!(laptop.name, "Laptop");
|
||||
//!
|
||||
//! // // Load products matching a filter (in stock, price < 100)
|
||||
//! // let filter = Filter::new()
|
||||
//! // .with_bool("in_stock", true)
|
||||
//! // .with_unsigned_int("price", Comparison::Lesser, 100);
|
||||
//! // Load products matching a filter (in stock, price < 100)
|
||||
//! let filter = Filter::new()
|
||||
//! .with_bool("in_stock", true)
|
||||
//! .with_unsigned_int("price", Comparison::Lesser, 100);
|
||||
//!
|
||||
//! // let mut filtered_catalog = Catalog::new(db_path);
|
||||
//! // filtered_catalog.load_by_filter(&filter)?;
|
||||
//! // let cheap_products: Vec<Product> = filtered_catalog.list_by_class().map(|p| p.unwrap()).collect();
|
||||
//! // println!("✅ Found {} cheap, in-stock product(s).", cheap_products.len());
|
||||
//! // assert_eq!(cheap_products.len(), 1);
|
||||
//! // assert_eq!(cheap_products[0].id, "p2");
|
||||
//! let mut filtered_catalog = Catalog::new(db_path);
|
||||
//! filtered_catalog.load_by_filter(&filter)?;
|
||||
//! let cheap_products: Vec<Product> = filtered_catalog.list_by_class()
|
||||
//! .unwrap().into_iter().map(|p| p.unwrap()).collect();
|
||||
//! println!("✅ Found {} cheap, in-stock product(s).", cheap_products.len());
|
||||
//! assert_eq!(cheap_products.len(), 1);
|
||||
//! assert_eq!(cheap_products[0].id, "p2");
|
||||
//!
|
||||
//! // // == 3. Update and Delete Data ==
|
||||
//! // let mut update_catalog = Catalog::new(db_path);
|
||||
//! // update_catalog.load_by_class::<Product>()?;
|
||||
//! // == 3. Update and Delete Data ==
|
||||
//! let mut update_catalog = Catalog::new(db_path);
|
||||
//! update_catalog.load_by_class::<Product>()?;
|
||||
//!
|
||||
//! // // Update the price of the laptop
|
||||
//! // let mut laptop_to_update: Product = update_catalog.get("p1")?.unwrap();
|
||||
//! // laptop_to_update.price = 1150;
|
||||
//! // update_catalog.upsert(laptop_to_update)?;
|
||||
//! // Update the price of the laptop
|
||||
//! let mut laptop_to_update: Product = update_catalog.get("p1")?.unwrap();
|
||||
//! laptop_to_update.price = 1150;
|
||||
//! update_catalog.upsert(laptop_to_update)?;
|
||||
//!
|
||||
//! // // Delete the keyboard
|
||||
//! // update_catalog.delete("p3");
|
||||
//! // Delete the keyboard
|
||||
//! update_catalog.delete("p3");
|
||||
//!
|
||||
//! // // Persist all changes
|
||||
//! // update_catalog.persist()?;
|
||||
//! // println!("✅ Laptop price updated and keyboard deleted.");
|
||||
//! // Persist all changes
|
||||
//! update_catalog.persist()?;
|
||||
//! println!("✅ Laptop price updated and keyboard deleted.");
|
||||
//!
|
||||
//! // // == 4. Verify Final State ==
|
||||
//! // let mut final_catalog = Catalog::new(db_path);
|
||||
//! // final_catalog.load_by_class::<Product>()?;
|
||||
//! // == 4. Verify Final State ==
|
||||
//! let mut final_catalog = Catalog::new(db_path);
|
||||
//! final_catalog.load_by_class::<Product>()?;
|
||||
//!
|
||||
//! // let final_count = final_catalog.list_by_class::<Product>().count();
|
||||
//! // println!("✅ Final product count: {}", final_count);
|
||||
//! // assert_eq!(final_count, 2);
|
||||
//! let final_count = final_catalog.list_by_class::<Product>().into_iter().count();
|
||||
//! println!("✅ Final product count: {}", final_count);
|
||||
//! assert_eq!(final_count, 2);
|
||||
//!
|
||||
//! // let updated_laptop: Product = final_catalog.get("p1")?.unwrap();
|
||||
//! // println!("✅ Verified updated laptop price: {}", updated_laptop.price);
|
||||
//! // assert_eq!(updated_laptop.price, 1150);
|
||||
//! let updated_laptop: Product = final_catalog.get("p1")?.unwrap();
|
||||
//! println!("✅ Verified updated laptop price: {}", updated_laptop.price);
|
||||
//! assert_eq!(updated_laptop.price, 1150);
|
||||
//!
|
||||
//! // let deleted_keyboard: Option<Product> = final_catalog.get("p3")?;
|
||||
//! // println!("✅ Verified keyboard is deleted.");
|
||||
//! // assert!(deleted_keyboard.is_none());
|
||||
//! let deleted_keyboard: Option<Product> = final_catalog.get("p3")?;
|
||||
//! println!("✅ Verified keyboard is deleted.");
|
||||
//! assert!(deleted_keyboard.is_none());
|
||||
//!
|
||||
//! // // Clean up the created database file
|
||||
//! // std::fs::remove_file(db_path).unwrap();
|
||||
//! // Clean up the created database file
|
||||
//! std::fs::remove_file(db_path).unwrap();
|
||||
//!
|
||||
//! // Ok(())
|
||||
//! // }
|
||||
//! Ok(())
|
||||
//! }
|
||||
//! ```
|
||||
use std::*;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user