Enum DatabasePool 

pub enum DatabasePool {
    Postgres(PgPool),
    MySQL(MySqlPool),
}

Database connection pool abstraction.

This enum wraps either a PostgreSQL or MySQL connection pool, providing a unified interface for database operations.

Database URL Format

• PostgreSQL: postgres:// or postgresql://
• MySQL: mysql://

Examples

use cargo_hammerwork::utils::database::DatabasePool;

// The database type is automatically detected from the URL
let pool = DatabasePool::connect(
    "postgresql://user:pass@localhost:5432/hammerwork",
    10  // max connections
).await?;

Variants

Postgres(PgPool)

MySQL(MySqlPool)

Implementations

impl DatabasePool

pub async fn connect(database_url: &str, pool_size: u32) -> Result<Self>

Connect to a database with the specified connection pool size.

The database type is automatically detected from the URL scheme:

• postgres:// or postgresql:// → PostgreSQL
• mysql:// → MySQL

Arguments

• database_url - Database connection URL
• pool_size - Maximum number of connections in the pool

Examples

use cargo_hammerwork::utils::database::DatabasePool;

// PostgreSQL with 10 connections
let pg_pool = DatabasePool::connect(
    "postgresql://user:pass@localhost/mydb",
    10
).await?;

// MySQL with 5 connections
let mysql_pool = DatabasePool::connect(
    "mysql://root:pass@localhost/mydb",
    5
).await?;

pub fn create_job_queue(self) -> JobQueueWrapper

Create a job queue from this database pool.

This consumes the pool and returns a wrapped JobQueue that automatically handles database-specific implementations.

Examples

use cargo_hammerwork::utils::database::DatabasePool;

let pool = DatabasePool::connect("postgresql://localhost/hammerwork", 5).await?;
let job_queue = pool.create_job_queue();
// Use job_queue for enqueuing, processing, etc.

pub async fn migrate(&self, drop_tables: bool) -> Result<()>

Run database migrations.

This method runs all pending migrations on the connected database. Optionally drops existing tables before running migrations.

Arguments

• drop_tables - If true, drops all Hammerwork tables before running migrations

Examples

use cargo_hammerwork::utils::database::DatabasePool;

let pool = DatabasePool::connect("postgresql://localhost/hammerwork", 5).await?;

// Run migrations on existing database
pool.migrate(false).await?;

// Drop tables and run fresh migrations
pool.migrate(true).await?;