[TD-2301]<hotfix>: change
This commit is contained in:
parent
c633e91bf4
commit
19a410f94b
|
@ -56,7 +56,7 @@
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.taosdata.jdbc</groupId>
|
<groupId>com.taosdata.jdbc</groupId>
|
||||||
<artifactId>taos-jdbcdriver</artifactId>
|
<artifactId>taos-jdbcdriver</artifactId>
|
||||||
<version>2.0.8</version>
|
<version>2.0.12</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>log4j</groupId>
|
<groupId>log4j</groupId>
|
||||||
|
|
|
@ -41,7 +41,7 @@ public class InsertTableTask implements Runnable {
|
||||||
long ts = start.toEpochMilli() + (j * timeGap);
|
long ts = start.toEpochMilli() + (j * timeGap);
|
||||||
// insert data into echo table
|
// insert data into echo table
|
||||||
for (int i = startTbIndex; i < startTbIndex + tableNumber; i++) {
|
for (int i = startTbIndex; i < startTbIndex + tableNumber; i++) {
|
||||||
String sql = SqlSpeller.insertOneRowSQL(config.getDbName(), config.getTbPrefix(), i + 1, ts);
|
String sql = SqlSpeller.insertBatchSizeRowsSQL(config.getDbName(), config.getTbPrefix(), i + 1, ts, config.getNumberOfRecordsPerRequest());
|
||||||
logger.info(Thread.currentThread().getName() + ">>> " + sql);
|
logger.info(Thread.currentThread().getName() + ">>> " + sql);
|
||||||
Statement statement = connection.createStatement();
|
Statement statement = connection.createStatement();
|
||||||
statement.execute(sql);
|
statement.execute(sql);
|
||||||
|
|
Loading…
Reference in New Issue