いつSQLAlchemyでflush（）を呼び出す必要がありますか？

Question

私はSQLAlchemyを使い慣れておらず、オリジナルの著者にアクセスできないやや乱雑なコードベースを継承しています。

コードは、DBSession.flush()へのコールでリラックスされています。作者がデータが保存されていることを確認したいときはいつでもそうです。最初は私がこのコードで見たパターンにちょうど従っていましたが、私はドキュメントを読んでいるので、これは不要であると思われます。さらに、「InvalidRequestError：セッションが既にフラッシングしています」というエラーを生成するAJAX呼び出しでは、いくつかのケースに遭遇しました。

どのようなシナリオで、私は合法的にflush（）を呼びたいと思っていましたか？

これは、ピラミッドのアプリで、SQLAlchemyのはで設定されている：pyramid_tmはあなたのためのすべてのコミットを処理するプロジェクトに積極的であることを

一緒に DBSession上

DBSession = scoped_session(sessionmaker(extension=ZopeTransactionExtension(), expire_on_commit=False)) 
Base = declarative_base() 

Answer 1

ZopeTransactionExtension。

• 新しいオブジェクトを作成して元のキーに戻したい場合は、次のようにします。

  DBSession.add(obj) 
  DBSession.flush() 
  log.info('look, my new object got primary key %d', obj.id) 
  

• あなたはそれがトランザクション全体を無効にすることなく、失敗した場合、セーブポイントとロールバックでいくつかのSQLを実行しようとします。 ORMを含む他のすべての場合には

  sp = transaction.savepoint() 
  try: 
      foo = Foo() 
      foo.id = 5 
      DBSession.add(foo) 
      DBSession.flush() 
  except IntegrityError: 
      log.error('something already has id 5!!') 
      sp.rollback() 
  

、トランザクションは、例外時に、あなたのために中止され、またはpyramid_tmによって自動的に成功するとコミットされます。未処理のSQLを実行する場合はtransaction.commit()を実行するか、セッションをダーティーとしてzope.sqlalchemy.mark_changed(DBSession)でマークする必要があります。そうしないと、セッションが変更されたことをZTEが認識できなくなります。

また、expire_on_commitはデフォルトでTrueのままにしておきます