SQLAlchemy immer noch in der Lage, ein Objekt aus der Sitzung nach dem Löschen zu bekommen

Question

Ich habe einen Endpunkt, um ein Objekt aus meiner Datenbank zu löschen. Ich lösche es mit dem folgenden Code:

my_object = Object.query.get(id) 
db.session.delete(my_object) 
db.session.commit() 
return json.dumps({'success': True} 

ich einen API-Test habe den Endpunkt zu testen, wo ich ein Objekt erstellen und dann den Endpunkt verwenden, um es zu löschen. Ich versuche zu behaupten, dass nach der Löschung geschieht es nicht in der Datenbank ist.

my_object = MyObject() 
db.session.add(my_object) 
db.session.commit() 
response = requests.delete('{}/my-object/{}'.format(
    os.environ.get('MY_URL'), 
    my_object.id 
)) 
self.assertTrue(response.json()['success']) // this passes 
self.assertEqual(200, response.status_code) // this passes 
result = db.session.query(MyObject).get(my_object.id) 
print(result.id) // prints the id of the job even though it is deleted from the database 

Ich denke, das bis zu einem gewissen SQLAlchemy Sitzung Caching verwendet ist. Ich habe db.session.flush(), db.session.expire_all() vergeblich versucht. Das Objekt wird tatsächlich aus der Datenbank gelöscht. So würde ich erwarten, dass das Abfrageergebnis None ist.

Ich sehe das in der docs aber habe nicht meinen ganzen Kopf darum gewickelt. when to commit and close a session

Danke für jede Hilfe.

Answer 1

Also in Ihrem Test-Code, fügen Sie das Objekt zu einer Sitzung und Commit es. Es wird in der Datenbank gespeichert und ist die Identitätskarte Ihrer Sitzung.

Dann drücken Sie Ihre App, es hat eine eigene Sitzung. Es löscht das Objekt und Commits, jetzt ist es aus der Datenbank verschwunden. Aber ...

Ihre vorherige Sitzung weiß nichts darüber, und wenn Sie ein .get() verwenden, gibt es zurück, was in seiner Identitätskarte ist: ein Python-Objekt mit einer ID. Es wird nicht erneut geladen, es sei denn, Sie schließen die Sitzung oder erzwingen eine Aktualisierung von der Datenbank (ich kann mich nicht erinnern, wie OTOH dies tut, aber Sie können es irgendwo in der Dokumentation). Wenn Sie eine saubere dritte Sitzung verwendet haben, hätte sie eine neue Identitätskarte und würde keinen Verweis auf das Python-Objekt beibehalten, so dass Sie erhalten, was Sie erwarten, d. kein Ergebnis. Dies ist beabsichtigt, weil die Identity Map es SQLAlchemy ermöglicht, eine Reihe von Änderungen zu einer optimalen SQL-Abfrage zusammenzufassen, die nur beim Commit ausgelöst wird.

Also yeah, Sie sehen den Abruf von der Identity Map, die noch am Leben ist. (Sie können es sogar im interaktiven Interpreter öffnen und herumstochern). Und es macht Sinn, weil Sie sagen, dass Sie zwei Threads mit verschiedenen Webanforderungen haben und dass Sie einen längeren Weg mit einem Objekt machen, wenn eine andere Anfrage das Objekt löscht. Der erste Thread sollte den Python-Code, der mit dem Objekt arbeitet, nicht blockieren, da dies zufällige Ausnahmen auslösen würde, unabhängig davon, wo Sie sich im Code befanden. Es sollte nur denken, dass es seine Sache tun kann, und dann auf commit fehlschlagen, einen Rollback auszulösen.

HTH

Answer 2

db.session.expunge_all()

"Entfernen Sie alle Objektinstanzen aus dieser Session ..."

http://docs.sqlalchemy.org/en/latest/orm/session_api.html#sqlalchemy.orm.session.Session.expunge_all

Oder einfach Trigger nach jeder Anfrage db.session .remove()

Zum Beispiel in Flask mit SQLAlchemy scoped_session:

@app.teardown_appcontext 
def shutdown_session(exception=None): 
    db.session.remove() 

"Die scoped_session.remove() -Methode entfernt wie immer die aktuelle Sitzung, die dem Thread zugeordnet ist, falls vorhanden. Ein Vorteil des threading.local() -Objekts besteht jedoch darin, dass, wenn der Anwendungs-Thread selbst endet, der "Speicher" für diesen Thread ebenfalls "Garbage Collected" ist.Daher ist es in der Tat "sicher", den lokalen Thread des Threads mit einer Anwendung zu verwenden, die Threads erzeugt und abreißt, ohne scoped_session.remove() aufrufen zu müssen. Der Umfang der Transaktionen selbst, dh sie über Session.commit() oder Session.rollback() zu beenden, wird jedoch in der Regel immer noch etwas sein, zu dem zu gegebener Zeit explizit arrangiert werden muss, es sei denn, die Anwendung verknüpft tatsächlich die Lebensdauer eines Threads auf die Lebensdauer einer Transaktion.“

http://docs.sqlalchemy.org/en/latest/orm/contextual.html#thread-local-scope http://docs.sqlalchemy.org/en/latest/orm/contextual.html#using-thread-local-scope-with-web-applications

Answer 3

nach einem fairen Betrag von Lesen und Testen wir eine neue Sitzung zu schaffen fanden die einfachste Lösung zu sein. ich war, um herauszufinden, nicht in der Lage, wie auffrischen der Datensatz aus der Datenbank, obwohl der Datensatz veraltet war

Hier ist ein paar Lesung, die ich tat:

when to commit and close a session

is the session a cache

is the session thread safe

understanding sqlalchemy session

Hier ist, wie ich das Problem gelöst, indem eine neue DB-Verbindung zu schaffen und Sitzung mit Flask-SQLAlchemy:

[my other imports...] 
from flask.ext.sqlalchemy import SQLAlchemy 

[my other code...] 

def test_it_should_delete_my_object(self): 
    my_object = MyObject() 
    db.session.add(my_object) 
    db.session.commit() 
    response = requests.delete('{}/my-object/{}'.format(
     os.environ.get('MY_URL'), 
     my_object.id 
    )) 
    self.assertTrue(response.json()['success']) 
    self.assertEqual(200, response.status_code) 

    new_db = SQLAlchemy(app) // establishing a new connection 
    result = new_db.session.query(MyObject).get(my_object.id) // by using a new 
    self.assertIsNone(result) 

Vielen Dank für die Hilfe. Ich werde mehr darüber recherchieren.