diff --git a/db/repository.py b/db/repository.py index 79d9f94..bcfa6b8 100644 --- a/db/repository.py +++ b/db/repository.py @@ -21,7 +21,7 @@ class Repository: def bulk_insert_transactions(self, transactions: List[TransactionRecord]) -> int: """ - Bulk insert transaction records into ach_api_log. + Bulk insert transaction records into ach_api_log_temp git. Args: transactions: List of TransactionRecord objects @@ -42,7 +42,7 @@ class Repository: # Execute batch insert insert_sql = """ - INSERT INTO ach_api_log ( + INSERT INTO ach_api_log_temp ( narration, status, bankcode, jrnl_id, tran_date, cbs_acct, tran_amt, TXNIND ) VALUES ( @@ -55,7 +55,7 @@ class Repository: conn.commit() count = len(transactions) - logger.info(f"Successfully inserted {count} transactions into ach_api_log") + logger.info(f"Successfully inserted {count} transactions into ach_api_log_temp") return count except Exception as e: @@ -174,11 +174,11 @@ class Repository: # Check if ach_api_log table exists try: - cursor.execute("SELECT COUNT(*) FROM ach_api_log WHERE ROWNUM = 1") - logger.info("✓ ach_api_log table exists") + cursor.execute("SELECT COUNT(*) FROM ach_api_log_temp WHERE ROWNUM = 1") + logger.info("✓ ach_api_log_temp table exists") except Exception as e: - logger.error(f"✗ ach_api_log table not found: {e}") - raise SystemExit("FATAL: ach_api_log table must be created manually before running this application") + logger.error(f"✗ ach_api_log_temp table not found: {e}") + raise SystemExit("FATAL: ach_api_log_temp table must be created manually before running this application") # Check if ach_processed_files table exists try: