parsql_sqlite/

lib.rs

//! # parsql-sqlite
//! 
//! SQLite integration for parsql.
//! This crate provides synchronous APIs for working with SQLite databases.
//! 
//! ## Features
//! 
//! - Synchronous SQLite operations
//! - Automatic SQL query generation
//! - Secure parameter management
//! - Generic CRUD operations
//! - Transaction support
//! - Extension methods for the Connection object
//! 
//! ## Usage
//! 
//! ```rust,no_run
//! use rusqlite::{Connection, Result};
//! use parsql::sqlite::{get, insert};
//! 
//! #[derive(Insertable, SqlParams)]
//! #[table("users")]
//! pub struct InsertUser {
//!     pub name: String,
//!     pub email: String,
//! }
//! 
//! #[derive(Queryable, SqlParams, FromRow)]
//! #[table("users")]
//! #[where_clause("id = ?")]
//! pub struct GetUser {
//!     pub id: i32,
//!     pub name: String,
//!     pub email: String,
//! }
//! 
//! fn main() -> Result<()> {
//!     let conn = Connection::open("test.db")?;
//!     
//!     // Insert a new user
//!     let insert_user = InsertUser {
//!         name: "John".to_string(),
//!         email: "john@example.com".to_string(),
//!     };
//!     
//!     let id = insert(&conn, insert_user)?;
//!     
//!     // Get the user back
//!     let get_user = GetUser::new(id as i32);
//!     let user = get(&conn, &get_user)?;
//!     
//!     println!("User: {:?}", user);
//!     Ok(())
//! }
//! ```
//!
//! ## Using Extension Methods
//!
//! You can also use the extension methods directly on the Connection object:
//!
//! ```rust,no_run
//! use rusqlite::{Connection, Result};
//! use parsql::sqlite::CrudOps;  // Import the trait
//! use parsql::sqlite::macros::{Insertable, SqlParams, Queryable, FromRow};
//!
//! #[derive(Insertable, SqlParams)]
//! #[table("users")]
//! pub struct InsertUser {
//!     pub name: String,
//!     pub email: String,
//! }
//!
//! #[derive(Queryable, FromRow, SqlParams)]
//! #[table("users")]
//! #[where_clause("id = ?")]
//! pub struct GetUser {
//!     pub id: i32,
//!     pub name: String,
//!     pub email: String,
//! }
//!
//! fn main() -> Result<()> {
//!     let conn = Connection::open("test.db")?;
//!     
//!     // Insert a new user using extension method
//!     let insert_user = InsertUser {
//!         name: "John".to_string(),
//!         email: "john@example.com".to_string(),
//!     };
//!     
//!     let rows_affected = conn.insert(insert_user)?;
//!     
//!     // Get the user back using extension method
//!     let get_user = GetUser {
//!         id: 1,
//!         name: String::new(),
//!         email: String::new(),
//!     };
//!     let user = conn.get(&get_user)?;
//!     
//!     println!("User: {:?}", user);
//!     Ok(())
//! }
//! ```
//!
//! ## Using Transactions
//! 
//! You can perform database operations within a transaction to ensure atomicity:
//! 
//! ```rust,no_run
//! use rusqlite::{Connection, Result};
//! use parsql::sqlite::transactional;
//! use parsql::macros::{Insertable, SqlParams, Updateable, UpdateParams};
//! 
//! #[derive(Insertable, SqlParams)]
//! #[table("users")]
//! struct InsertUser {
//!     name: String,
//!     email: String,
//! }
//! 
//! #[derive(Updateable, UpdateParams)]
//! #[table("users")]
//! #[update("email")]
//! #[where_clause("id = ?")]
//! struct UpdateUser {
//!     id: i64,
//!     email: String,
//! }
//! 
//! fn main() -> Result<()> {
//!     let conn = Connection::open("test.db")?;
//!     
//!     // Begin a transaction
//!     let tx = transactional::begin(&conn)?;
//!     
//!     // Insert a user within the transaction
//!     let insert_user = InsertUser {
//!         name: "John".to_string(),
//!         email: "john@example.com".to_string(),
//!     };
//!     let (tx, _) = transactional::tx_insert(tx, insert_user)?;
//!     
//!     // Update the user within the same transaction
//!     let update_user = UpdateUser {
//!         id: 1,
//!         email: "john.updated@example.com".to_string(),
//!     };
//!     let (tx, _) = transactional::tx_update(tx, update_user)?;
//!     
//!     // Commit the transaction - both operations succeed or fail together
//!     tx.commit()?;
//!     
//!     Ok(())
//! }
//! ```

pub mod crud_ops;
pub mod transactional_ops;

// Re-export sqlite types that might be needed
pub use rusqlite::{Connection, Error, Row};
pub use rusqlite::types::ToSql;

// Re-export crud operations
pub use crud_ops::{
    insert, 
    select, 
    select_all, 
    update, 
    delete, 
    get, 
    get_all,
    CrudOps,
};

// Re-export transaction operations
pub use transactional_ops as transactional;

pub use parsql_macros as macros;

/// Trait for generating SQL queries.
/// This trait is implemented by the derive macro `Queryable`, `Insertable`, `Updateable`, and `Deletable`.
pub trait SqlQuery {
    /// Returns the SQL query string.
    fn query() -> String;
}

/// Trait for providing SQL parameters.
/// This trait is implemented by the derive macro `SqlParams`.
pub trait SqlParams {
    /// Returns a vector of references to SQL parameters.
    fn params(&self) -> Vec<&(dyn ToSql + Sync)>;
}

/// Trait for providing UPDATE parameters.
/// This trait is implemented by the derive macro `UpdateParams`.
pub trait UpdateParams {
    /// Returns a vector of references to SQL parameters for UPDATE operations.
    fn params(&self) -> Vec<&(dyn ToSql + Sync)>;
}

/// Trait for converting database rows to Rust structs.
/// This trait is implemented by the derive macro `FromRow`.
pub trait FromRow {
    /// Converts a database row to a Rust struct.
    /// 
    /// # Arguments
    /// * `row` - A reference to a database row
    /// 
    /// # Returns
    /// * `Result<Self, Error>` - The converted struct or an error
    fn from_row(row: &Row) -> Result<Self, Error>
    where
        Self: Sized;
}