src/app/executor.py

"""Executor -- chay SQL (da qua sql_validator) tren SQLite, tra ve pandas DataFrame."""

import sqlite3

import pandas as pd


def run_query(db_path: str, sql: str) -> pd.DataFrame:
    conn = sqlite3.connect(db_path)
    try:
        return pd.read_sql_query(sql, conn)
    finally:
        conn.close()