SQLAlchemy - wybierz przykład aktualizacji

Question

Poszukuję pełnego przykładu użycia polecenia select for update w SQLAlchemy, ale nie znalazłem jednego googlowania. Muszę zablokować jeden wiersz i aktualizować kolumnę, poniższy kod nie działa (bloki na zawsze):

s = table.select(table.c.user=="test",for_update=True) 
# Do update or not depending on the row 
u = table.update().where(table.c.user=="test")   
u.execute(email="foo") 

Czy muszę popełnić? Jak mogę to zrobić? O ile wiem, trzeba: rozpocząć transakcję wybrać ... dla aktualizacji aktualizacji popełnienia

Answer 1

Tak, trzeba zrobić, aby popełnić, które można wykonać na Engine lub utwórz Transaction jawnie. Również modyfikatory są określone w metodzie values(...), a nie execute:

>>> conn.execute(users.update(). 
...    where(table.c.user=="test"). 
...    values(email="foo") 
...    ) 
>>> my_engine.commit() 

Answer 2

Późne odpowiedź, ale może ktoś znajdzie to użyteczne.

Po pierwsze, nie musisz zatwierdzać (przynajmniej nie pośrednich zapytań, o których zakładam, że pytasz). Twoje drugie zapytanie zawiesza się na czas nieokreślony, ponieważ skutecznie tworzysz dwa równoczesne połączenia z bazą danych. Pierwszym jest uzyskanie blokady wybranych rekordów, a następnie próba modyfikacji zablokowanych rekordów. Więc nie może działać poprawnie. (Przy okazji, w podanym przykładzie nie wywołujesz w ogóle pierwszego zapytania, więc zakładam, że w twoich prawdziwych testach zrobiłeś coś takiego, jak gdzieś). Tak aby realizacja punkt pracy powinien wyglądać bardziej jak:

s = conn.execute(table.select(table.c.user=="test", for_update=True)) 
u = conn.execute(table.update().where(table.c.user=="test), {"email": "foo"}) 
conn.commit() 

oczywiście w takim prostym przypadku nie ma powodu, aby robić żadnych blokowanie ale myślę, że jest to tylko przykład i planujecie dodać jakieś dodatkowe logiki między tymi dwa połączenia.

Answer 3

Jeśli używasz ORM, spróbuj with_for_update funkcję:

 
foo = session.query(Foo).filter(Foo.id==1234).with_for_update().one() 
# this row is now locked 

foo.name = 'bar' 
session.add(foo) 

session.commit() 
# this row is now unlocked