mariadb-pool

mariadb-pool is the connection pooling add-on for the mariadb connector. It provides synchronous and asynchronous connection pools with automatic connection management, health checking, and monitoring.

Installation

Install MariaDB Connector/Python with pool support:

pip install mariadb[pool]

Or install the pool package separately:

pip install mariadb-pool

Features

• Easy Connection Management: Automatic connection pooling via mariadb.ConnectionPool
• URI Support: Create pools with connection URIs for clean configuration
• Dynamic Pool Sizing: Automatically adjusts between min and max connections
• Connection Health Checking: Periodic validation of idle connections
• Thread-Safe: Fully thread-safe for multi-threaded applications
• Pool Statistics: Monitor pool usage and performance
• Context Manager Support: Clean connection handling with with statements

Quick Start

Synchronous Connection Pool

Using create_pool() (Recommended)

The cleanest way to create a connection pool with separated pool and connection parameters:

import mariadb

# Create pool with clean parameter separation
pool = mariadb.create_pool(
    host="localhost",
    port=3306,
    user="root",
    password="password",
    database="mydb",
    min_size=5,
    max_size=10,
    ping_threshold=0.25,  # Only ping connections idle > 250ms
    max_idle_time=600.0,
    reset_connection=True
)

# Get connection from pool
with pool.acquire() as conn:
    with conn.cursor() as cursor:
        cursor.execute("SELECT * FROM users")
        results = cursor.fetchall()

# Close pool when done
pool.close()

Using ConnectionPool Constructor

Alternatively, use the traditional constructor:

import mariadb

# Create pool with connection parameters
pool = mariadb.ConnectionPool(
    pool_name="mypool",
    host="localhost",
    port=3306,
    user="root",
    password="password",
    database="mydb",
    max_size=10,
    pool_reset_connection=True
)

# Use context manager to ensure connection is returned to pool
with pool.get_connection() as conn:
    with conn.cursor() as cursor:
        cursor.execute("SELECT * FROM users")
        results = cursor.fetchall()

pool.close()

Asynchronous Connection Pool

Using create_async_pool() (Recommended)

The cleanest way to create an async pool - automatically pre-filled and ready to use:

import mariadb
import asyncio

async def main():
    # Create async pool with clean parameter separation
    # Pool is automatically opened and pre-filled with connections
    pool = await mariadb.create_async_pool(
        host="localhost",
        port=3306,
        user="root",
        password="password",
        database="mydb",
        min_size=5,
        max_size=20,
        ping_threshold=0.25,  # Only ping connections idle > 250ms
        max_idle_time=600.0,
        reset_connection=True
    )
    
    # Acquire connection from pool
    async with await pool.acquire() as conn:
        async with conn.cursor() as cursor:
            await cursor.execute("SELECT * FROM users")
            results = await cursor.fetchall()
    
    # Close pool if unneeded anymore
    await pool.close()

asyncio.run(main())

Pool Configuration Options

The pool accepts the following configuration parameters:

Pool-Specific Parameters

Performance Tip: The ping_threshold option significantly improves performance by avoiding unnecessary database pings. Connections that have been idle for less than the threshold (default: 250ms) are assumed healthy and returned immediately. Only connections idle longer than the threshold are verified with a ping. Set to 0 to ensure checking connection states.

Note: If you set only min_size or only max_size (without setting the other), both will be set to the same value to create a fixed-size pool.

mariadb.ConnectionPool Parameters

Additional parameters supported by mariadb.ConnectionPool: