diff options
| author | lijinyang <[email protected]> | 2023-11-03 17:46:14 +0800 |
|---|---|---|
| committer | lijinyang <[email protected]> | 2023-11-03 17:46:14 +0800 |
| commit | 2c1404e67d6777516ee8dc2f268a205e3329eb93 (patch) | |
| tree | 3e743ccbbecffb5ebb0e97870391e36ff5eef8d9 /src/main | |
| parent | 64bae22a57cf2bf92d6c8fae676feafa0a9f2936 (diff) | |
fix:更换新版查询网关url
Diffstat (limited to 'src/main')
| -rw-r--r-- | src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java | 8 |
1 files 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); // 加入配置信息 |