From 2c1404e67d6777516ee8dc2f268a205e3329eb93 Mon Sep 17 00:00:00 2001 From: lijinyang Date: Fri, 3 Nov 2023 17:46:14 +0800 Subject: fix:更换新版查询网关url MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mesa/reportservice/service/impl/ClickhouseServiceImpl.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java b/src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java index 0760b41..13eeb38 100644 --- a/src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java +++ b/src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java @@ -51,7 +51,7 @@ public class ClickhouseServiceImpl implements ClickhouseService { CloseableHttpResponse response = null; String query_id = ""; try { - String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/sys/engine/queryIds?resultId=" + resultId + "&query="); + String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/v1/sql/query/query_id?resultId=" + resultId + "&query="); String sql = null; sql = URLEncoder.encode(query, "utf8").replaceAll("\\+", "%20"); url = url + sql; @@ -92,7 +92,7 @@ public class ClickhouseServiceImpl implements ClickhouseService { // 发起请求 HttpResult rs = null; try { - String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/?option=long-term&resultId=" + resultId + "&query="); + String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/sql?option=long-term&resultId=" + resultId + "&query="); query = URLEncoder.encode(query, "utf8").replaceAll("\\+", "%20"); String jobsql = url + query; HttpGet httpGet = new HttpGet(jobsql); @@ -122,7 +122,7 @@ public class ClickhouseServiceImpl implements ClickhouseService { // 发起请求 HttpResult rs = null; try { - String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/sys/engine/processes/" + queryId); + String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/v1/sql/query/" + queryId + "/progress"); HttpGet httpGet = new HttpGet(url); // 加入配置信息 @@ -148,7 +148,7 @@ public class ClickhouseServiceImpl implements ClickhouseService { CloseableHttpResponse response = null; HttpResult rs = null; try { - String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/sys/engine/tasks/" + queryId); + String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/v1/sql/query/" + queryId); // 声明httpPost请求 HttpDelete HttpDelete = new HttpDelete(url); // 加入配置信息 -- cgit v1.2.3