@contextmanager
def transacting(db):
    try:
        yield db
    except:
        db.rollback()
        raise
    else:
        db.commit()
    db.close()

with transacting(connect_db()) as db:
    with app.open_resource('schema.sql', mode='r') as f:
        db.cursor().executescript(f.read())