mirror of
https://github.com/datahub-project/datahub.git
synced 2025-08-31 21:03:03 +00:00
fix(ingest): mssql - lowercase db name in mssql ingestion (#6448)
This commit is contained in:
parent
ba7fc3a685
commit
cf6fb91f8d
@ -122,7 +122,7 @@ class SQLServerSource(SQLAlchemySource):
|
|||||||
super().__init__(config, ctx, "mssql")
|
super().__init__(config, ctx, "mssql")
|
||||||
# Cache the table and column descriptions
|
# Cache the table and column descriptions
|
||||||
self.config: SQLServerConfig = config
|
self.config: SQLServerConfig = config
|
||||||
self.current_database = None
|
self.current_database: Optional[str] = None
|
||||||
self.table_descriptions: Dict[str, str] = {}
|
self.table_descriptions: Dict[str, str] = {}
|
||||||
self.column_descriptions: Dict[str, str] = {}
|
self.column_descriptions: Dict[str, str] = {}
|
||||||
for inspector in self.get_inspectors():
|
for inspector in self.get_inspectors():
|
||||||
@ -262,5 +262,5 @@ class SQLServerSource(SQLAlchemySource):
|
|||||||
return f"{self.config.database_alias}.{regular}"
|
return f"{self.config.database_alias}.{regular}"
|
||||||
return f"{self.config.database}.{regular}"
|
return f"{self.config.database}.{regular}"
|
||||||
if self.current_database:
|
if self.current_database:
|
||||||
return f"{self.current_database}.{regular}"
|
return f"{self.current_database.lower()}.{regular}"
|
||||||
return regular
|
return regular
|
||||||
|
Loading…
x
Reference in New Issue
Block a user