From 3027093ef9121772d00266c1f04e6941b036a038 Mon Sep 17 00:00:00 2001
From: sanj <67624670+iodrift@users.noreply.github.com>
Date: Tue, 30 Jul 2024 16:45:22 -0700
Subject: [PATCH] Auto-update: Tue Jul 30 16:45:22 PDT 2024
---
sijapi/classes.py | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/sijapi/classes.py b/sijapi/classes.py
index 8eac7c6..dd8b850 100644
--- a/sijapi/classes.py
+++ b/sijapi/classes.py
@@ -503,7 +503,6 @@ class APIConfig(BaseModel):
-
async def ensure_sync_trigger(self, conn, table_name):
await conn.execute(f"""
CREATE OR REPLACE FUNCTION update_version_and_server_id()
@@ -683,7 +682,6 @@ class APIConfig(BaseModel):
return total_changes
-
async def apply_batch_changes(self, conn, table_name, changes, has_primary_key):
if not changes:
return 0
@@ -718,10 +716,10 @@ class APIConfig(BaseModel):
debug(f"Generated insert query for {table_name}: {insert_query}")
affected_rows = 0
- async for change in tqdm(changes, desc=f"Syncing {table_name}", unit="row"):
+ for change in tqdm(changes, desc=f"Syncing {table_name}", unit="row"):
values = [change[col] for col in columns]
debug(f"Executing query for {table_name} with values: {values}")
- result = await conn.execute(insert_query, *values)
+ result = await conn.execute(insert_query, *values) # Pass values as separate arguments
affected_rows += int(result.split()[-1])
return affected_rows
@@ -733,6 +731,7 @@ class APIConfig(BaseModel):
+
async def sync_spatial_ref_sys(self, source_conn, dest_conn):
try:
# Get all entries from the source