fix: check sql only contain read operation

2026-11-08 01:06:59 +08:00 · 2026-02-02 10:07:39 +08:00
parent e2af93e781
commit e8508681a3
1 changed files with 2 additions and 0 deletions
@@ -582,6 +582,8 @@ def check_sql_read(sql: str, ds: CoreDatasource | AssistantOutDsSchema):
        dialect = None
        if ds.type == "mysql" or ds.type == "doris" or ds.type == "starrocks":
            dialect = 'mysql'
+        elif ds.type == "sqlServer":
+            dialect = 'tsql'

        statements = sqlglot.parse(sql, dialect=dialect)