Cambios Verificacion de tablas antes de la creacion

dags/components/Databases/Oracle.py

@@ -113,7 +113,7 @@ class Oracle:
     def check_procedure(self, procedure_name, connection) -> bool:
         exists = False
         try:
-            check_query = f"SHOW CREATE PROCEDURE {procedure_name}"
+            check_query = f"SELECT text FROM all_source WHERE name = '{procedure_name}'"
             result = connection.execute(check_query)
             exists = bool(result.fetchone())
         except Exception as e:
@@ -124,7 +124,7 @@ class Oracle:
     def check_table(self, table_name, connection) -> bool:
         exists = False
         try:
-            check_query = f"SHOW CREATE TABLE {table_name}"
+            check_query = f"DESCRIBE {table_name}"
             result = connection.execute(check_query)
             exists = bool(result.fetchone())
         except Exception as e:

dags/components/Databases/Postgres.py

@@ -107,7 +107,7 @@ class Postgres:
     def check_procedure(self, procedure_name, connection) -> bool:
         exists = False
         try:
-            check_query = f"SHOW CREATE PROCEDURE {procedure_name}"
+            check_query = f"SELECT pg_get_functiondef('{procedure_name}')"
             result = connection.execute(check_query)
             exists = bool(result.fetchone())
         except Exception as e:
@@ -118,7 +118,7 @@ class Postgres:
     def check_table(self, table_name, connection) -> bool:
         exists = False
         try:
-            check_query = f"SHOW CREATE TABLE {table_name}"
+            check_query = f"SELECT pg_get_tabledef('{table_name}')"
             result = connection.execute(check_query)
             exists = bool(result.fetchone())
         except Exception as e:

dags/components/Extractor.py

@@ -150,6 +150,7 @@ def extract_from_source(command, source_conn, intern_conn, chunksize: int, timez
             else:
                 raise AssertionError(f"Error creando tabla {tablename}")
             if is_procedure:
+                logger.info(f"procedure: {tablename}")
                 command = command[len(tablename+"|"):]
                 temp_connection = source_conn.get_basic_connection()
                 command = source_conn.generate_sql_procedure(command)