scratch – Polars Hist DB

import polars as pl
from sqlalchemy import select, text

from polars_hist_db.core import DataframeOps, TableOps, make_engine

engine = make_engine(
    backend="mariadb",
    hostname="127.0.0.1",
    port=3306,
    username="root",
    password="admin",
)

with engine.begin() as connection:
    res = connection.execute(text("select * from information_schema.users"))
    rows = res.fetchall()

pl.from_records(rows)

with engine.begin() as connection:
    tbl = TableOps("information_schema", "users", connection).get_table_metadata()
    query = select(tbl).limit(5)
    df = DataframeOps(connection).from_selectable(
        query, {"PASSWORD_EXPIRATION_TIME": pl.String}
    )

print(df)