SQLAlchemy - seleccionar para el ejemplo de actualización

Question

Estoy buscando un ejemplo completo del uso de seleccionar para actualizar en SQLAlchemy, pero no he encontrado uno en Google. Necesito bloquear una sola fila y actualizar una columna, el código siguiente no funciona (bloques para siempre):

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") 

¿Necesito una confirmación? ¿Cómo puedo hacer eso? Por lo que yo sé lo que necesita: begin transaction seleccione ... para la actualización actualización cometer

Answer 1

Sí, sí es necesario comprometerse, que se puede ejecutar en el Engine o crear una Transaction explícitamente. También los modificadores se especifican en el método values(...), y no execute:

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

Answer 2

respuesta tardía, pero tal vez alguien lo encontrarán útil.

En primer lugar, no es necesario confirmar (al menos, no entre las consultas, que estoy suponiendo que está preguntando). Su segunda consulta se cuelga indefinidamente, porque está creando efectivamente dos conexiones concurrentes a la base de datos. El primero es obtener el bloqueo en los registros seleccionados, luego el segundo intenta modificar los registros bloqueados. Entonces no puede funcionar correctamente. (Por cierto en el ejemplo dado, no estás llamando a la primera consulta, así que supongo que en tus pruebas reales hiciste algo como s.execute() en algún lugar). Así que para la implementación de punto de trabajo debe verse más como:

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() 

Por supuesto, en tal caso simple que no hay razón para hacer cualquier bloqueo, pero supongo que es ejemplo y se planea añadir algo de lógica adicional entre los dos llamadas.

Answer 3

Si está utilizando el ORM, pruebe la función with_for_update:

 
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