SQLAlchemy の動作確認

テーブルを作って動作確認してみます。

#!/usr/bin/env python3

from os import path
from sqlalchemy import *

def connect(filename):
    exists = path.exists(filename)
    db = create_engine("sqlite:///" + filename)
    if not exists:
        create(db)
    return db

def create(db):
    c = db.connect()
    try:
        tr = c.begin()
        try:
            c.execute("CREATE TABLE ...省略...")
            tr.commit()
        except:
            tr.rollback()
            raise
    finally:
        c.close()

connect("dvds-sqlalchemy.db")