From f4a8dd970f5d0134ecbd4e27a21e12994602537d Mon Sep 17 00:00:00 2001 From: Ondrej Kokes Date: Mon, 5 Jan 2026 11:26:33 +0100 Subject: [PATCH 1/2] ignoruj duplicity vic --- main.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/main.py b/main.py index 2db3d0a..02eb63c 100644 --- a/main.py +++ b/main.py @@ -149,6 +149,8 @@ def main( conn = engine.raw_connection() cur = conn.cursor() cur.execute(f"TRUNCATE {full_table_name} CASCADE") # TODO: cascade yolo + # TODO: pg neumi `ON CONFLICT(ico) DO NOTHING` v `COPY`, takze nam nebude fungovat + # historicky load justice for filename in files: logging.info("Nahravam %s", filename) with open(filename, "rt", encoding="utf-8") as f: @@ -170,7 +172,7 @@ def main( f"INSERT INTO {full_table_name} SELECT * FROM " f"read_csv('{filename}', quote='\"', escape='\"')" ) - if table.name == "subjekty": + if table.schema == "justice" and table.name == "subjekty": q += " ON CONFLICT(ico) DO NOTHING" cur.execute(q) @@ -180,6 +182,8 @@ def main( ph = ", ".join(["?"] * len(table.columns)) query = f"INSERT INTO {table.name} VALUES({ph})" + if table.name == "justice_subjekty": + query += " ON CONFLICT(ico) DO NOTHING" bools = [isinstance(j.type, Boolean) for j in table.columns] for filename in files: logging.info("Nahravam %s", filename) From 85bb1f8394a1e2427c0abd1447c4bb2d427abe97 Mon Sep 17 00:00:00 2001 From: Ondrej Kokes Date: Mon, 5 Jan 2026 11:41:10 +0100 Subject: [PATCH 2/2] lint --- main.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/main.py b/main.py index 02eb63c..0ed4c56 100644 --- a/main.py +++ b/main.py @@ -149,8 +149,8 @@ def main( conn = engine.raw_connection() cur = conn.cursor() cur.execute(f"TRUNCATE {full_table_name} CASCADE") # TODO: cascade yolo - # TODO: pg neumi `ON CONFLICT(ico) DO NOTHING` v `COPY`, takze nam nebude fungovat - # historicky load justice + # TODO: pg neumi `ON CONFLICT(ico) DO NOTHING` v `COPY`, + # takze nam nebude fungovat historicky load justice for filename in files: logging.info("Nahravam %s", filename) with open(filename, "rt", encoding="utf-8") as f: