sij/sijapi
1
1
Fork 0
Code Issues 3 Pull requests Projects Releases Packages Wiki Activity Actions

Auto-update: Tue Jul 30 16:48:36 PDT 2024

Browse source
This commit is contained in:
sanj 2024-07-30 16:48:36 -07:00
parent b2a71a3dc5
commit c4ebb75953
1 changed files with 2 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
sijapi/classes.py
View file

@ -501,8 +501,6 @@ class APIConfig(BaseModel):
err(f"Traceback: {traceback.format_exc()}") err(f"Traceback: {traceback.format_exc()}")
return False return False
async def ensure_sync_trigger(self, conn, table_name): async def ensure_sync_trigger(self, conn, table_name):
await conn.execute(f""" await conn.execute(f"""
CREATE OR REPLACE FUNCTION update_version_and_server_id() CREATE OR REPLACE FUNCTION update_version_and_server_id()
@ -521,7 +519,6 @@ class APIConfig(BaseModel):
FOR EACH ROW EXECUTE FUNCTION update_version_and_server_id(); FOR EACH ROW EXECUTE FUNCTION update_version_and_server_id();
""") """)
async def get_most_recent_source(self): async def get_most_recent_source(self):
most_recent_source = None most_recent_source = None
max_version = -1 max_version = -1
@ -688,7 +685,7 @@ class APIConfig(BaseModel):
try: try:
columns = list(changes[0].keys()) columns = list(changes[0].keys())
placeholders = [f'${i+1}' for i in range(len(columns))] placeholders = [f'${i}' for i in range(1, len(columns) + 1)]
if has_primary_key: if has_primary_key:
insert_query = f""" insert_query = f"""
@ -719,7 +716,7 @@ class APIConfig(BaseModel):
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] values = [change[col] for col in columns]
debug(f"Executing query for {table_name} with values: {values}") debug(f"Executing query for {table_name} with values: {values}")
result = await conn.execute(insert_query, *values) # Pass values as separate arguments result = await conn.execute(insert_query, *values)
affected_rows += int(result.split()[-1]) affected_rows += int(result.split()[-1])
return affected_rows return affected_rows
@ -731,7 +728,6 @@ class APIConfig(BaseModel):
async def sync_spatial_ref_sys(self, source_conn, dest_conn): async def sync_spatial_ref_sys(self, source_conn, dest_conn):
try: try:
# Get all entries from the source # Get all entries from the source