#python #postgresql #flask #sqlalchemy #flask-sqlalchemy
#python #postgresql #flask #sqlalchemy #flask-sqlalchemy
Вопрос:
Я получаю откаты автоматически. Вот мой код:
@socketio.on('update2')
def update_table_infocorp(trigger):
checknotprocess = Infocorp.query.filter(Infocorp.Procesado == False)
for row in checknotprocess:
getidentityuser = Usuarios.query.filter(Usuarios.id_user == row.id_user).first()
getidentityconsulta = Consolidado.query.filter(Consolidado.id_user == row.id_user and
(Consolidado.numdocumento == getidentityuser.numdocumento)).first()
if not getidentityconsulta:
# print("No se encontro la consulta relacionada al usuario.")
test = True
else:
sentinelresult = getsentinel(getidentityuser.tipodocumento, getidentityuser.numdocumento, row.id_consulta,
getidentityconsulta.solicitudes_id)
print(getidentityconsulta.solicitudes_id)
print(getidentityuser.tipodocumento)
if sentinelresult == True:
continue
else:
print("Ocurrio un error")
resultadoquery = Infocorp.query.filter(Infocorp.Procesado == True)
datatransform = InfocorpSchema(many=True)
datatransformresult = datatransform.dump(resultadoquery)
emit('nuevatableinfocorp', datatransformresult, broadcast=True)
И это мои журналы:
Я надеюсь, что вы сможете мне помочь, потому что это влияет на другие системы, которые используют ту же базу данных.
Комментарии:
1. Если вы не
commit
проводите свои сеансы, они будутROLLBACK
, когда они будут закрыты.2. Привет @snakecharmerb в этом случае, куда я должен добавить коммит?