Skip to content

Commit ff767a3

Browse files
fix(hive): remove semicolon from view query, fix docstring and test assertion (#12787)
1 parent c1348cb commit ff767a3

2 files changed

Lines changed: 5 additions & 3 deletions

File tree

ingestion/src/metadata/ingestion/source/database/hive/metastore_dialects/mssql/dialect.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
"""
1212
Hive Metastore MSSQL Dialect Mixin
1313
"""
14+
1415
from sqlalchemy import text
1516
from sqlalchemy.dialects.mssql.pyodbc import MSDialect_pyodbc
1617
from sqlalchemy.engine import reflection
@@ -31,7 +32,7 @@
3132
class HiveMssqlMetaStoreDialect(HiveMetaStoreDialectMixin, MSDialect_pyodbc):
3233
"""
3334
MSSQL metastore dialect class for Hive metastore backed by SQL Server.
34-
Uses square-bracket quoting compatible with MSSQL and supports CTEs.
35+
Uses unquoted identifiers and supports CTEs.
3536
"""
3637

3738
name = "hive"
@@ -115,7 +116,7 @@ def get_view_definition(self, connection, view_name, schema=None, **kw):
115116
tbls.VIEW_ORIGINAL_TEXT AS view_def
116117
FROM TBLS tbls
117118
JOIN DBS dbs ON tbls.DB_ID = dbs.DB_ID
118-
WHERE tbls.VIEW_ORIGINAL_TEXT IS NOT NULL;
119+
WHERE tbls.VIEW_ORIGINAL_TEXT IS NOT NULL
119120
"""
120121
return get_view_definition_wrapper(
121122
self,

ingestion/tests/unit/topology/database/test_hive_metastore_mssql_dialect.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
"""
1212
Test Hive MSSQL Metastore Dialect
1313
"""
14+
1415
from unittest.mock import MagicMock, Mock
1516

1617
from metadata.ingestion.source.database.hive.metastore_dialects.mssql.dialect import (
@@ -87,7 +88,7 @@ def test_get_table_columns_query_structure(self):
8788
assert "PKEY_NAME" in executed_query
8889
assert "PKEY_TYPE" in executed_query
8990
assert "PKEY_COMMENT" in executed_query
90-
assert executed_query.upper().count("SELECT") == 2
91+
assert executed_query.upper().count("SELECT") == 4
9192

9293
def test_get_table_columns_uses_unquoted_identifiers(self):
9394
"""MSSQL dialect uses unquoted identifiers, not double-quoted like Postgres."""

0 commit comments

Comments
 (0)