xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

change

This commit is contained in:
zyyang 2020-12-14 21:41:50 +08:00
parent 995284cc0d
commit a4fe566cf6
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/TaosDemoCommandLineRunner.java
View File

@ -116,6 +116,8 @@ public class TaosDemoCommandLineRunner implements CommandLineRunner {
if (numOfTables < numOfTablesPerSQL) if (numOfTables < numOfTablesPerSQL)
numOfTablesPerSQL = numOfTables; numOfTablesPerSQL = numOfTables;
long timeCost = 0;
// row // row
for (int rowCnt = 0; rowCnt < numOfRowsPerTable; ) { for (int rowCnt = 0; rowCnt < numOfRowsPerTable; ) {
int rowSize = numOfValuesPerSQL; int rowSize = numOfValuesPerSQL;
@ -150,6 +152,7 @@ public class TaosDemoCommandLineRunner implements CommandLineRunner {
subTableService.insertAutoCreateTable(data, config.numOfThreadsForInsert, config.frequency); subTableService.insertAutoCreateTable(data, config.numOfThreadsForInsert, config.frequency);
long b = System.currentTimeMillis(); long b = System.currentTimeMillis();
logger.info(">>> time cost: " + (b - a) + " ms"); logger.info(">>> time cost: " + (b - a) + " ms");
timeCost += (b - a);
} else { } else {
subTableService.insert(data, config.numOfThreadsForInsert, config.frequency); subTableService.insert(data, config.numOfThreadsForInsert, config.frequency);
} }
@ -175,7 +178,7 @@ public class TaosDemoCommandLineRunner implements CommandLineRunner {
// subTableService.insert(subTableMetaList, config.numOfTables, config.tablePrefix, config.numOfThreadsForInsert, config.frequency); // subTableService.insert(subTableMetaList, config.numOfTables, config.tablePrefix, config.numOfThreadsForInsert, config.frequency);
// } // }
long end = System.currentTimeMillis(); long end = System.currentTimeMillis();
logger.info(">>> insert time cost : " + (end - start) + " ms."); logger.info(">>> total : " + (end - start) + " ms, insert : " + (timeCost) + " ms.");
} }
private void prepareMetaData(JdbcTaosdemoConfig config) { private void prepareMetaData(JdbcTaosdemoConfig config) {