0

我正在使用 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根据事务回滚？

4

1 回答 1

1

你需要做

self.connection.execute(query)

代替

query.execute()

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

于 2016-03-15T20:03:43.963 回答