Merge pull request #296 from Ryuk-me/oracle-username-as-schema

Ryuk-me · web-flow · commit 28922bd3237e · 2025-04-16T17:38:41.000+05:30
fix: oracle schema prefix
diff --git a/dcs_core/integrations/databases/bigquery.py b/dcs_core/integrations/databases/bigquery.py
@@ -135,9 +135,9 @@ def query_get_table_columns(
         schema = schema or self.schema_name
         query = (
             "SELECT column_name, data_type, "
-            "6 AS datetime_precision, "
-            "38 AS numeric_precision, "
-            "9 AS numeric_scale, "
+            "NULL AS datetime_precision, "
+            "NULL AS numeric_precision, "
+            "NULL AS numeric_scale, "
             "NULL AS collation_name, "
             "NULL AS character_maximum_length "
             f"FROM `{self.project_id}.{schema}.INFORMATION_SCHEMA.COLUMNS` "
diff --git a/dcs_core/integrations/databases/oracle.py b/dcs_core/integrations/databases/oracle.py
@@ -57,6 +57,7 @@ def connect(self) -> Any:
                     "service_name": self.data_connection.get("service_name"),
                 },
             )
+            self.schema_name = self.data_connection.get("username")
             self.connection = engine.connect()
             return self.connection
         except Exception as e:

Original file line number	Diff line number	Diff line change
`@@ -57,6 +57,7 @@ def connect(self) -> Any:`
`57`	`57`	`"service_name": self.data_connection.get("service_name"),`
`58`	`58`	`},`
`59`	`59`	`)`
	`60`	`+ self.schema_name = self.data_connection.get("username")`
`60`	`61`	`self.connection = engine.connect()`
`61`	`62`	`return self.connection`
`62`	`63`	`except Exception as e:`