#!/usr/bin/env python3
# encoding: utf-8
import polars as pl
from sqlalchemy import Table, MetaData, func
from sqlalchemy.engine import create_engine
from sqlalchemy.engine.base import Engine
from sqlalchemy.orm import Query, Session
...
frame=pl.DataFrame(data={'data':range(10)})
OUT_TABLE_NAME:str='transaction_test'

with EngineContext(uri=CONNECTION) as engine:
    out_table: Table = Table(OUT_TABLE_NAME, MetaData(bind=engine, schema=SCHEMA_NAME), autoload=True)
    with Session(bind=engine) as session, session.begin():
        for item in frame.to_dicts():
            # Insert values from 0 to 9 sequentially
            print(item['data'])
            if item['data']==5:
                # This to ensure premature termination
                # and making sure the session is rolled back
                raise ValueError 
            statement=out_table.insert(values=[item])
            print(statement)
            session.execute(statement=statement)
            sleep(1)