fix: Possible errors caused by SQL ending with a semicolon

This commit is contained in:
junjun
2025-08-19 09:56:31 +08:00
parent 17874acb21
commit 883654559f
+3
View File
@@ -300,6 +300,9 @@ def get_fields(ds: CoreDatasource, table_name: str = None):
def exec_sql(ds: CoreDatasource | AssistantOutDsSchema, sql: str, origin_column=False):
while sql.endswith(';'):
sql = sql[:-1]
db = DB.get_db(ds.type)
if db.connect_type == ConnectType.sqlalchemy:
with get_session(ds) as session: