# blood_db.py
import os
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker, declarative_base
from db import Base, engine

def get_connection():
    """
    Returns a new connection to the blood_donation_dev_june_5 database.
    """
    return psycopg2.connect(
        host=os.getenv("BLOOD_DB_HOST", "localhost"),
        port=os.getenv("BLOOD_DB_PORT", "5432"),
        user=os.getenv("BLOOD_DB_USER", "root"),
        password=os.getenv("BLOOD_DB_PASSWORD", "zsVmczGzq9D0NRq1ZseKUrwyucWd0w"),
        dbname=os.getenv("BLOOD_DB_NAME", "blood_donation_dev_june_5"),
        cursor_factory=RealDictCursor,
    )


def init_db():
    """
    Import models and create tables in blood_donation_dev_june_5.
    Import inside function to avoid circular imports.
    """
    Base.metadata.create_all(bind=engine)