diff --git a/headless/server/src/main/java/com/tencent/supersonic/headless/server/service/impl/DatabaseServiceImpl.java b/headless/server/src/main/java/com/tencent/supersonic/headless/server/service/impl/DatabaseServiceImpl.java index 1a0192ccc..9579c5d3d 100644 --- a/headless/server/src/main/java/com/tencent/supersonic/headless/server/service/impl/DatabaseServiceImpl.java +++ b/headless/server/src/main/java/com/tencent/supersonic/headless/server/service/impl/DatabaseServiceImpl.java @@ -186,6 +186,9 @@ public class DatabaseServiceImpl extends ServiceImpl getColumns(Long id, String sql) throws SQLException { + if (sql.endsWith(";")) { + sql = sql.substring(0, sql.length() - 1); + } String wrapSql = String.format("select * from (%s) a limit 1", sql); DatabaseResp databaseResp = getDatabase(id); SemanticQueryResp semanticQueryResp = executeSql(wrapSql, databaseResp);