fix orm to compatible with sqlalchemy 2

Change-Id: Ia462750553e3f0ab1a33d439508c4a08c3e71778
This commit is contained in:
Hoai-Thu Vuong 2024-05-17 17:45:09 +07:00
parent 13121a1059
commit 841dcc0fb1

View File

@ -38,17 +38,17 @@ class OrmRepo(object):
nmt = nmt_insert.alias('nmt') nmt = nmt_insert.alias('nmt')
a = models.create_alarm_model(metadata).alias('a') a = models.create_alarm_model(metadata).alias('a')
self._orm_query = select([nm.c.id, nm.c.type, nm.c.name, nm.c.address, nm.c.period])\ self._orm_query = select(nm.c.id, nm.c.type, nm.c.name, nm.c.address, nm.c.period)\
.select_from(aa.join(nm, aa.c.action_id == nm.c.id))\ .select_from(aa.join(nm, aa.c.action_id == nm.c.id))\
.where( .where(
and_(aa.c.alarm_definition_id == bindparam('alarm_definition_id'), and_(aa.c.alarm_definition_id == bindparam('alarm_definition_id'),
aa.c.alarm_state == bindparam('alarm_state'))) aa.c.alarm_state == bindparam('alarm_state')))
self._orm_get_alarm_state = select([a.c.state]).where(a.c.id == bindparam('alarm_id')) self._orm_get_alarm_state = select(a.c.state).where(a.c.id == bindparam('alarm_id'))
self._orm_nmt_query = select([nmt.c.name]) self._orm_nmt_query = select(nmt.c.name)
self._orm_get_notification = select([nm.c.name, nm.c.type, nm.c.address, nm.c.period])\ self._orm_get_notification = select(nm.c.name, nm.c.type, nm.c.address, nm.c.period)\
.where(nm.c.id == bindparam('notification_id')) .where(nm.c.id == bindparam('notification_id'))
self._orm_add_notification_type = insert(nmt_insert).values(name=bindparam('b_name')) self._orm_add_notification_type = insert(nmt_insert).values(name=bindparam('b_name'))