From d0dc66eacc74ce08bfd9bc7f185676354a26b190 Mon Sep 17 00:00:00 2001
From: asif <md.asif5@tcs.com>
Date: Wed, 11 Feb 2026 14:49:06 +0530
Subject: [PATCH] changed some logging levels and replaced ach_api_log_temp
 with ach_api_log table

---
 db/oracle_connector.py | 16 ++--------------
 db/repository.py       | 12 ++++++------
 main.py                |  1 +
 3 files changed, 9 insertions(+), 20 deletions(-)

diff --git a/db/oracle_connector.py b/db/oracle_connector.py
index cccebee..15ab91b 100644
--- a/db/oracle_connector.py
+++ b/db/oracle_connector.py
@@ -21,18 +21,6 @@ class OracleConnector:
         """Initialize connection pool."""
         self.pool = None
         self.config = get_config()
-        self._initialize_client_mode()
-
-    def _initialize_client_mode(self):
-        """
-        Initialize oracledb client mode.
-        oracledb uses Thin mode by default (no Oracle Instant Client needed).
-        """
-        try:
-            # oracledb defaults to Thin mode - no initialization needed
-            logger.info("Using oracledb Thin mode (no Oracle Instant Client required)")
-        except Exception as e:
-            logger.warning(f"Oracle client initialization note: {e}")
 
     def initialize_pool(self):
         """Create connection pool."""
@@ -53,7 +41,7 @@ class OracleConnector:
                 increment=1,
             )
 
-            logger.info(f"Oracle connection pool initialized: min={self.config.db_pool_min}, max={self.config.db_pool_max}")
+            logger.debug(f"Oracle connection pool initialized: min={self.config.db_pool_min}, max={self.config.db_pool_max}")
             return True
         except oracledb.DatabaseError as e:
             logger.error(f"Failed to initialize connection pool: {e}", exc_info=True)
@@ -96,7 +84,7 @@ class OracleConnector:
             result = cursor.fetchone()
             cursor.close()
             conn.close()
-            logger.info("Database connection test successful")
+            logger.debug("Database connection test successful")
             return True
         except Exception as e:
             logger.error(f"Database connection test failed: {e}")
diff --git a/db/repository.py b/db/repository.py
index a04fa5d..fc429f4 100644
--- a/db/repository.py
+++ b/db/repository.py
@@ -83,7 +83,7 @@ class Repository:
 
             # Execute batch insert
             insert_sql = """
-                INSERT INTO ach_api_log_temp (
+                INSERT INTO ach_api_log (
                     narration, status, bankcode, jrnl_id,
                     tran_date, cbs_acct, tran_amt, TXNIND
                 ) VALUES (
@@ -237,13 +237,13 @@ class Repository:
         try:
             cursor = conn.cursor()
 
-            # Check if ach_api_log_temp table exists
+            # Check if ach_api_log table exists
             try:
-                cursor.execute("SELECT COUNT(*) FROM ach_api_log_temp WHERE ROWNUM = 1")
-                logger.info("✓ ach_api_log_temp table exists")
+                cursor.execute("SELECT COUNT(*) FROM ach_api_log WHERE ROWNUM = 1")
+                logger.info("✓ ach_api_log table exists")
             except Exception as e:
-                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")
+                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")
 
             # Check if ach_processed_files table exists
             try:
diff --git a/main.py b/main.py
index b243f09..c282ee3 100644
--- a/main.py
+++ b/main.py
@@ -9,6 +9,7 @@ from logging_config import setup_logging, get_logger
 from scheduler import Scheduler
 
 # Initialize logging
+logging.getLogger("paramiko").setLevel(logging.WARNING)
 logger = setup_logging(log_level=logging.INFO)
 app_logger = get_logger(__name__)