yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-12-30 00:48:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle quoted entity names in masking queries (#22174)

Browse Source 
Co-authored-by: Sriharsha Chintalapani <harshach@users.noreply.github.com>
This commit is contained in:
Mohit Tilala 2025-07-09 03:39:00 +05:30 committed by GitHub
parent 0c4253386b
commit ebfce5ba7b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ingestion/src/metadata/ingestion/lineage/masker.py
View File

@ -13,6 +13,7 @@ Query masking utilities
"""
import traceback
from typing import Optional
from cachetools import LRUCache
from collate_sqllineage.runner import SQLPARSE_DIALECT, LineageRunner
@ -26,6 +27,7 @@ MASK_TOKEN = "?"
# Cache size is 128 to avoid memory issues
masked_query_cache = LRUCache(maxsize=128)
# pylint: disable=protected-access
def get_logger():
# pylint: disable=import-outside-toplevel
@ -52,7 +54,6 @@ def mask_literals_with_sqlparse(query: str, parser: LineageRunner):
Literal.Number.Integer,
Literal.Number.Float,
Literal.String.Single,
Literal.String.Symbol,
):
token.value = MASK_TOKEN
elif token.is_group:
@ -113,7 +114,9 @@ def mask_literals_with_sqlfluff(query: str, parser: LineageRunner) -> str:
def mask_query(
query: str, dialect: str = Dialect.ANSI.value, parser: LineageRunner = None
query: str,
dialect: str = Dialect.ANSI.value,
parser: Optional[LineageRunner] = None,
) -> str:
"""
Mask a query using sqlparse or sqlfluff.

16
ingestion/tests/unit/test_sql_lineage.py
View File

@ -16,6 +16,7 @@ import uuid
from unittest import TestCase
import pytest
from collate_sqllineage.runner import SQLPARSE_DIALECT
from metadata.generated.schema.entity.data.table import Table
from metadata.ingestion.lineage.masker import mask_query
@ -261,7 +262,18 @@ class SqlLineageTest(TestCase):
"""select * from users where id > 2 and name <> 'pere';""",
Dialect.ANSI.value,
),
("""select * from users where id > 2 and name <> 'pere';""", "random"),
(
"""select * from users where id > 2 and name <> 'pere';""",
"random",
),
(
"""CREATE TABLE "db001"."table001" AS SELECT * FROM "db002"."table002" WHERE age > 18 AND name = 'John';""",
SQLPARSE_DIALECT, # test with sqlparse
),
(
"""CREATE TABLE "db001"."table001" AS SELECT * FROM "db002"."table002" WHERE age > 18 AND name = 'John';""",
Dialect.ANSI.value, # test with sqlfluff
),
]
expected_query_list = [
@ -274,6 +286,8 @@ class SqlLineageTest(TestCase):
"""select * from (select * from (SELECT CASE address WHEN ? THEN ? ELSE ? END AS person FROM user));""",
"""select * from users where id > ? and name <> ?;""",
"""select * from users where id > ? and name <> ?;""",
"""CREATE TABLE "db001"."table001" AS SELECT * FROM "db002"."table002" WHERE age > ? AND name = ?;""",
"""CREATE TABLE "db001"."table001" AS SELECT * FROM "db002"."table002" WHERE age > ? AND name = ?;""",
]
for i, query in enumerate(query_list):