darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-02-02 17:31:14 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix first paginate method

Browse Source
This commit is contained in:
Kenneth Kehl
2024-10-18 09:21:04 -07:00
parent 3b651a2716
commit c36a1ba221
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
app/dao/inbound_sms_dao.py
View File

@@ -73,7 +73,7 @@ def dao_count_inbound_sms_for_service(service_id, limit_days):
def _insert_inbound_sms_history(subquery, query_limit=10000): def _insert_inbound_sms_history(subquery, query_limit=10000):
offset = 0 offset = 0
inbound_sms_query = db.session.query( inbound_sms_query = select(
InboundSms.id, InboundSms.id,
InboundSms.created_at, InboundSms.created_at,
InboundSms.service_id, InboundSms.service_id,
@@ -81,8 +81,10 @@ def _insert_inbound_sms_history(subquery, query_limit=10000):
InboundSms.provider_date, InboundSms.provider_date,
InboundSms.provider_reference, InboundSms.provider_reference,
InboundSms.provider, InboundSms.provider,
).filter(InboundSms.id.in_(subquery)) ).where(InboundSms.id.in_(subquery))
inbound_sms_count = inbound_sms_query.count() inbound_sms_count = db.session.execute(
select([db.func.count()]).select_from(inbound_sms_query.subquery()).scalar_one()
)
while offset < inbound_sms_count: while offset < inbound_sms_count:
statement = insert(InboundSmsHistory).from_select( statement = insert(InboundSmsHistory).from_select(
@@ -93,7 +95,8 @@ def _insert_inbound_sms_history(subquery, query_limit=10000):
statement = statement.on_conflict_do_nothing( statement = statement.on_conflict_do_nothing(
constraint="inbound_sms_history_pkey" constraint="inbound_sms_history_pkey"
) )
db.session.connection().execute(statement) db.session.execute(statement)
db.session.commit()
offset += query_limit offset += query_limit