SQL Alchemy demo

sql_alchemy_demo.py

import sqlalchemy as sa

from sqlalchemy.orm import create_session

engine = sa.create_engine('postgresql://localhost:5432/dedupeapi')

db_session = create_session(bind=engine,
                            autocommit=False,
                            autoflush=False)

get_session_ids = ''' 
    SELECT id, name FROM dedupe_session 
    WHERE deleted = :deleted
'''

sessions = engine.execute(sa.text(get_session_ids), deleted=False)

for session in sessions:
    table_name = 'change_log_{}'.format(session.id)

    table = sa.Table(table_name, 
                     sa.MetaData(), 
                     autoload=True, 
                     autoload_with=engine)

    rows = db_session.query(table)\
                     .filter(table.c.reviewer != 'machine')\
                     .order_by(table.c.date_added.desc())\
                     .all()

    for row in rows:
        print(row)