add AddressModel, AddressDAO class

This commit is contained in:
2024-12-06 19:00:19 +01:00
parent 5865b33c1d
commit f4bd9c296a
8 changed files with 909 additions and 846 deletions

34
lib/DB/AddressDAO.py Normal file
View File

@@ -0,0 +1,34 @@
from .DbManager import DbManager
import mariadb
import json
class AddressDAO:
def __init__(self):
self.__con = DbManager().getConnection()
self.__cur = self.__con.cursor()
def __importPlz(self):
with open("import json filepath here", "r") as plz:
postcodes = json.load(plz)
try:
for i in postcodes:
test =i["plz_name"].split(",")
for town in test:
if "u.a" in town:
town = town[:-4]
town = town.strip()
if town:
print(f"PROCESSING {i['name']} {town}")
self.__cur.callproc("addZipCodes", (i["name"], town,))
except mariadb.OperationalError as e:
print(f"Database Error: {e}")
finally:
self.__con.commit()
print("FINISHED")#
def getAddressData(self, all = True, zipcode = None):
self.__cur.callproc("getAddress", (all, zipcode,))
self.__data = self.__cur.fetchall()
return self.__data