From 0b5930a511f4e1a9acda55345ea94d19a2d27ffd Mon Sep 17 00:00:00 2001 From: Lance Edgar Date: Sat, 11 Feb 2023 22:06:43 -0600 Subject: [PATCH] Refactor `Query.get()` => `Session.get()` per SQLAlchemy 1.4 --- rattail_corepos/batch/coremember.py | 6 +++--- rattail_corepos/datasync/corepos.py | 26 +++++++++++++------------- 2 files changed, 16 insertions(+), 16 deletions(-) diff --git a/rattail_corepos/batch/coremember.py b/rattail_corepos/batch/coremember.py index 7ee9605..56beedd 100644 --- a/rattail_corepos/batch/coremember.py +++ b/rattail_corepos/batch/coremember.py @@ -2,7 +2,7 @@ ################################################################################ # # Rattail -- Retail Software Framework -# Copyright © 2010-2021 Lance Edgar +# Copyright © 2010-2023 Lance Edgar # # This file is part of Rattail. # @@ -187,7 +187,7 @@ class CoreMemberBatchHandler(BatchHandler): row.status_text = "row has no card number" return - core_member = self.core_session.query(corepos.MemberInfo).get(row.card_number) + core_member = self.core_session.get(corepos.MemberInfo, row.card_number) if not core_member: row.status_code = row.STATUS_MEMBER_NOT_FOUND row.status_text = "matching record not found in CORE" @@ -250,7 +250,7 @@ class CoreMemberBatchHandler(BatchHandler): fields = batch.get_param('fields') def update(row, i): - core_member = core_session.query(corepos.MemberInfo).get(row.card_number) + core_member = core_session.get(corepos.MemberInfo, row.card_number) if not core_member: log.warning("CORE member not found for row %s with card number: %s", row.uuid, row.card_number) diff --git a/rattail_corepos/datasync/corepos.py b/rattail_corepos/datasync/corepos.py index 94fbdd4..78a0f1e 100644 --- a/rattail_corepos/datasync/corepos.py +++ b/rattail_corepos/datasync/corepos.py @@ -2,7 +2,7 @@ ################################################################################ # # Rattail -- Retail Software Framework -# Copyright © 2010-2021 Lance Edgar +# Copyright © 2010-2023 Lance Edgar # # This file is part of Rattail. # @@ -241,37 +241,37 @@ class FromRattailToCore(DataSyncImportConsumer): def get_customers(self, session, change): if change.payload_type == 'Customer': - customer = session.query(model.Customer).get(change.payload_key) + customer = session.get(model.Customer, change.payload_key) if customer: return [customer] if change.payload_type == 'CustomerPerson': - cp = session.query(model.CustomerPerson).get(change.payload_key) + cp = session.get(model.CustomerPerson, change.payload_key) if cp: return [cp.customer] if change.payload_type == 'Person': - person = session.query(model.Person).get(change.payload_key) + person = session.get(model.Person, change.payload_key) if person: return person.customers if change.payload_type == 'CustomerMailingAddress': - address = session.query(model.CustomerMailingAddress).get(change.payload_key) + address = session.get(model.CustomerMailingAddress, change.payload_key) if address: return [address.customer] if change.payload_type == 'PersonPhoneNumber': - phone = session.query(model.PersonPhoneNumber).get(change.payload_key) + phone = session.get(model.PersonPhoneNumber, change.payload_key) if phone: return phone.person.customers if change.payload_type == 'PersonEmailAddress': - email = session.query(model.PersonEmailAddress).get(change.payload_key) + email = session.get(model.PersonEmailAddress, change.payload_key) if email: return email.person.customers if change.payload_type == 'Member': - member = session.query(model.Member).get(change.payload_key) + member = session.get(model.Member, change.payload_key) if member: return [member.customer] @@ -280,24 +280,24 @@ class FromRattailToCore(DataSyncImportConsumer): def get_vendor(self, session, change): if change.payload_type == 'Vendor': - return session.query(model.Vendor).get(change.payload_key) + return session.get(model.Vendor, change.payload_key) if change.payload_type == 'VendorPhoneNumber': - phone = session.query(model.VendorPhoneNumber).get(change.payload_key) + phone = session.get(model.VendorPhoneNumber, change.payload_key) if phone: return phone.vendor if change.payload_type == 'VendorEmailAddress': - email = session.query(model.VendorEmailAddress).get(change.payload_key) + email = session.get(model.VendorEmailAddress, change.payload_key) if email: return email.vendor def get_product(self, session, change): if change.payload_type == 'Product': - return session.query(model.Product).get(change.payload_key) + return session.get(model.Product, change.payload_key) if change.payload_type == 'ProductPrice': - price = session.query(model.ProductPrice).get(change.payload_key) + price = session.get(model.ProductPrice, change.payload_key) if price: return price.product