我有一个存储过程。
通过 MySQL Workbench 调用它,如下工作;
CALL `lobdcapi`.`escalatelobalarm`('A0001');
但不是来自 python 程序。 (意味着它不会抛出任何异常,进程默默地完成执行)如果我在列名中犯了任何错误,那么在 python 中我会得到一个错误。所以它调用了我的存储过程,但没有按预期工作。 (这是一个更新查询。它需要安全更新)
为什么通过python sqlalchemy这次更新没有更新任何记录?
CREATE DEFINER=`lob`@`%` PROCEDURE `escalatelobalarm`(IN client_id varchar(50))
BEGIN
SET SQL_SAFE_UPDATES = 0;
update lobdcapi.alarms
set lobalarmescalated=1
where id in (
SELECT al.id
from (select id,alarmoccurredhistoryid from lobdcapi.alarms where lobalarmpriorityid=1 and lobalarmescalated=0 and clientid=client_id
and alarmstatenumber='02' ) as al
inner join lobdcapi.`alarmhistory` as hi on hi.id=al.alarmoccurredhistoryid
and hi.datetimestamp<= current_timestamp() )
);
SET SQL_SAFE_UPDATES = 1;
END
我称之为;
from sqlalchemy import and_, func,text
db.session.execute(text("CALL escalatelobalarm(:param)"), {'param': clientid})
我怀疑我通过代码传递的参数没有正确绑定?
我还没有从 SQLAlchemy 调用存储过程,但是这似乎可能在事务内,因为您正在使用会话。也许打电话db.session.commit()
最后会有帮助吗?
如果失败,SQLAlchemy 会调用调用存储过程 https://docs.sqlalchemy.org/en/13/core/connections.html#calling-stored-procedures这里。也许尝试一下他们的使用方法callproc
。适应您的用例,例如:
connection = db.session.connection()
try:
cursor = connection.cursor()
cursor.callproc("escalatelobalarm", [clientid])
results = list(cursor.fetchall())
cursor.close()
connection.commit()
finally:
connection.close()
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)