SQL 炼金术 - 事务不起作用

Question

我正在使用SQL Alchemy核心版本1.1，我似乎无法在我的falcon（python）应用程序中让事务工作。我已经正确遵循了文档。

编辑：数据库PostgreSQL -> psycopg2cffi

def __init__(self, *args, **kwargs):
    self.__conn_url__ = settings.get_db_url()
    self.db_engine = create_engine(self.__conn_url__)
    self.db_engine.echo = False
    self.metadata = MetaData(self.db_engine)
    self.connection = self.db_engine.connect()
    self.organization_types_table = Table('organization_types', self.metadata, autoload=True)
    self.organization_type_names_table = Table('organization_type_names', self.metadata, autoload=True)
def post(self, json_data):
    transaction = self.connection.begin()
    print(transaction)
    try:
        results = self.organization_types_table.insert().
            values(date_created=datetime.datetime.now()).
            execute()
        organization_types_id = results.inserted_primary_key
        results = self.organization_type_names_table.insert().
            values(organization_types_id=organization_types_id[0],
                   lang=json_data['lang'],
                   name=json_data['name']).
            execute()
        transaction.commit()
        print("I didn't rollback")
        return results
    except:
        transaction.rollback()
        print("I rollback :D")
        raise

如果我多次运行此代码插入相同的对象。由于索引约束不允许重复，它应该只第一次工作。

根据我的 print（） 语句，我将得到的结果：

1. 事务对象 ->我没有回滚
2. 事务对象 ->我回滚:D
3. 事务对象 ->我回滚:D

如果我查看我的表格，我可以清楚地看到organization_types_table包含 3 条记录，而organization_type_names包含 1 条记录。为什么organization_types_table不根据事务回滚？

Answer 1

你需要做

self.connection.execute(query)

而不是

query.execute()

query.execute()在引擎上执行query，引擎获取新连接，而不是使用打开事务的连接。