From 92ad5463361bc256797585ee334ba701c754d5bb Mon Sep 17 00:00:00 2001 From: ltt Date: Tue, 18 Apr 2023 13:39:48 +0000 Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86=E6=BD=9C=E5=9C=A8=E7=9A=84?= =?UTF-8?q?=E6=A0=BC=E5=BC=8F=E5=8C=96=E5=AD=97=E7=AC=A6=E4=B8=B2=E6=BC=8F?= =?UTF-8?q?=E6=B4=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: ltt --- .../datashow/service/HandleDataSourceServiceImpl.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/huawei/datashow/service/HandleDataSourceServiceImpl.java b/src/main/java/com/huawei/datashow/service/HandleDataSourceServiceImpl.java index e96116f..ad71da2 100644 --- a/src/main/java/com/huawei/datashow/service/HandleDataSourceServiceImpl.java +++ b/src/main/java/com/huawei/datashow/service/HandleDataSourceServiceImpl.java @@ -30,19 +30,17 @@ public class HandleDataSourceServiceImpl implements HandleDataSourceService { int count = (int) arrayList.get(0).get("count"); int batch = count / 1000; - sql = sql + " limit %d, %d"; - if (batch > 0) { for (int i = 0; i < batch; i++) { - String jsonListMap = openGaussDataBaseServiceImpl.getSourceData(pollName, String.format(sql, i * 1000, 1000)); + String jsonListMap = openGaussDataBaseServiceImpl.getSourceData(pollName, sql + String.format(" limit %d, %d", i * 1000, 1000)); List listMap = JSON.parseObject(jsonListMap, ArrayList.class); CSVUtil.writeCSVFile(dataSourceName, listMap, i != 0); } - String jsonListMap = openGaussDataBaseServiceImpl.getSourceData(pollName, String.format(sql, batch * 1000, count - batch * 1000 + 1)); + String jsonListMap = openGaussDataBaseServiceImpl.getSourceData(pollName, sql + String.format(" limit %d, %d", batch * 1000, count - batch * 1000 + 1)); List listMap = JSON.parseObject(jsonListMap, ArrayList.class); CSVUtil.writeCSVFile(dataSourceName, listMap, true); } else { - String jsonListMap = openGaussDataBaseServiceImpl.getSourceData(pollName, String.format(sql, 0, count)); + String jsonListMap = openGaussDataBaseServiceImpl.getSourceData(pollName, sql + String.format(" limit %d, %d", 0, count)); List listMap = JSON.parseObject(jsonListMap, ArrayList.class); CSVUtil.writeCSVFile(dataSourceName, listMap, false); } -- Gitee