Skip to content

Commit d945ab6

Browse files
committed
fix: fix Elasticsearch error
1 parent 98d685f commit d945ab6

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

backend/apps/db/db_sql.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,8 @@ def get_table_sql(ds: CoreDatasource, conf: DatasourceConf, db_version: str = ''
140140
WHERE
141141
TABLE_SCHEMA = %s
142142
""", conf.database
143+
elif ds.type == "es":
144+
return "", None
143145

144146

145147
def get_field_sql(ds: CoreDatasource, conf: DatasourceConf, table_name: str = None):
@@ -273,3 +275,5 @@ def get_field_sql(ds: CoreDatasource, conf: DatasourceConf, table_name: str = No
273275
"""
274276
sql2 = " AND TABLE_NAME = %s" if table_name is not None and table_name != "" else ""
275277
return sql1 + sql2, conf.database, table_name
278+
elif ds.type == "es":
279+
return "", None, None

0 commit comments

Comments
 (0)