diff --git a/headless/api/src/main/java/com/tencent/supersonic/headless/api/pojo/request/SqlExecuteReq.java b/headless/api/src/main/java/com/tencent/supersonic/headless/api/pojo/request/SqlExecuteReq.java index c4cbf5b54..3553ba1df 100644 --- a/headless/api/src/main/java/com/tencent/supersonic/headless/api/pojo/request/SqlExecuteReq.java +++ b/headless/api/src/main/java/com/tencent/supersonic/headless/api/pojo/request/SqlExecuteReq.java @@ -23,9 +23,11 @@ public class SqlExecuteReq { private Integer limit = 1000; public String getSql() { - if (StringUtils.isNotBlank(sql) && sql.endsWith(";")) { - sql = sql.substring(0, sql.length() - 1); + if(StringUtils.isNotBlank(sql)){ + sql=sql.replaceAll("^[\\n]+|[\\n]+$", ""); + sql=StringUtils.removeEnd(sql,";"); } + return String.format(LIMIT_WRAPPER, sql, limit); } }