From d304641011700c585f434d07589eb931ba5eb532 Mon Sep 17 00:00:00 2001 From: zyyang Date: Mon, 14 Dec 2020 21:16:50 +0800 Subject: [PATCH] change --- .../components/TaosDemoCommandLineRunner.java | 26 +++++++++---------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/TaosDemoCommandLineRunner.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/TaosDemoCommandLineRunner.java index 5825a5ddef..f65a9342db 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/TaosDemoCommandLineRunner.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/TaosDemoCommandLineRunner.java @@ -132,24 +132,24 @@ public class TaosDemoCommandLineRunner implements CommandLineRunner { /***********************************************/ long startTime = config.startTime + rowCnt * config.timeGap; - for (int i = 0; i < tableSize; i++) { - System.out.print(config.prefixOfTable + (tableCnt + i + 1) + ", tableSize: " + tableSize + ", rowSize: " + rowSize); - System.out.println(", startTime: " + TimeStampUtil.longToDatetime(startTime) + ",timeGap: " + config.timeGap); - } +// for (int i = 0; i < tableSize; i++) { +// System.out.print(config.prefixOfTable + (tableCnt + i + 1) + ", tableSize: " + tableSize + ", rowSize: " + rowSize); +// System.out.println(", startTime: " + TimeStampUtil.longToDatetime(startTime) + ",timeGap: " + config.timeGap); +// } // 生成数据 -// List data = SubTableValueGenerator.generate(superTableMeta, config.prefixOfTable, tableCnt, tableSize, rowSize, startTime, config.timeGap); + List data = SubTableValueGenerator.generate(superTableMeta, config.prefixOfTable, tableCnt, tableSize, rowSize, startTime, config.timeGap); // List data = SubTableValueGenerator.generate(subTableMetaList, tableCnt, tableSize, rowSize, startTime, config.timeGap); // 乱序 -// if (config.order != 0) { -// SubTableValueGenerator.disrupt(data, config.rate, config.range); -// } + if (config.order != 0) { + SubTableValueGenerator.disrupt(data, config.rate, config.range); + } // insert -// if (config.autoCreateTable) { -// subTableService.insertAutoCreateTable(data, config.numOfThreadsForInsert, config.frequency); -// } else { -// subTableService.insert(data, config.numOfThreadsForInsert, config.frequency); -// } + if (config.autoCreateTable) { + subTableService.insertAutoCreateTable(data, config.numOfThreadsForInsert, config.frequency); + } else { + subTableService.insert(data, config.numOfThreadsForInsert, config.frequency); + } /***********************************************/ tableCnt += tableSize; } -- GitLab