From 305cbd8c51264c2e55f38576b56a2d8036cf2162 Mon Sep 17 00:00:00 2001 From: zyyang Date: Mon, 21 Dec 2020 17:13:11 +0800 Subject: [PATCH] change --- .../taosdemo/TaosDemoApplication.java | 7 +- .../components/JdbcTaosdemoConfig.java | 4 +- .../taosdata/taosdemo/dao/DatabaseMapper.java | 3 - .../taosdemo/dao/DatabaseMapperImpl.java | 9 +- .../taosdemo/dao/SubTableMapperImpl.java | 16 ++- .../taosdemo/dao/SuperTableMapperImpl.java | 15 ++- .../taosdemo/service/DatabaseService.java | 85 ++---------- .../taosdata/taosdemo/service/InsertTask.java | 2 +- .../taosdemo/service/SubTableService.java | 127 ++---------------- .../taosdemo/service/SuperTableService.java | 31 +---- .../taosdemo/service/SubTableServiceTest.java | 7 +- 11 files changed, 68 insertions(+), 238 deletions(-) diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/TaosDemoApplication.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/TaosDemoApplication.java index 9beab83aca..63584dbab4 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/TaosDemoApplication.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/TaosDemoApplication.java @@ -6,6 +6,7 @@ import com.taosdata.taosdemo.domain.SuperTableMeta; import com.taosdata.taosdemo.domain.TagMeta; import com.taosdata.taosdemo.service.DatabaseService; import com.taosdata.taosdemo.service.InsertTask; +import com.taosdata.taosdemo.service.SubTableService; import com.taosdata.taosdemo.service.SuperTableService; import com.taosdata.taosdemo.service.data.SuperTableMetaGenerator; import com.taosdata.taosdemo.components.JdbcTaosdemoConfig; @@ -37,6 +38,7 @@ public class TaosDemoApplication { DataSource dataSource = DataSourceFactory.getInstance(config.host, config.port, config.user, config.password); DatabaseService databaseService = new DatabaseService(dataSource); SuperTableService superTableService = new SuperTableService(dataSource); + SubTableService subTableService = new SubTableService(dataSource); // 创建数据库 long start = System.currentTimeMillis(); @@ -78,7 +80,6 @@ public class TaosDemoApplication { // create super table with specified field size and tag size superTableMeta = SuperTableMetaGenerator.generate(config.database, config.superTable, config.numOfFields, config.prefixOfFields, config.numOfTags, config.prefixOfTags); } - /**********************************************************************************/ // 建表 start = System.currentTimeMillis(); @@ -87,7 +88,7 @@ public class TaosDemoApplication { if (config.autoCreateTable) return; // 批量建子表 -// subTableService.createSubTable(superTableMeta, config.numOfTables, config.prefixOfTable, config.numOfThreadsForCreate); + subTableService.createSubTable(superTableMeta, config.numOfTables, config.prefixOfTable, config.numOfThreadsForCreate); } end = System.currentTimeMillis(); logger.info(">>> create table time cost : " + (end - start) + " ms."); @@ -102,7 +103,7 @@ public class TaosDemoApplication { long gap = (long) Math.ceil((0.0d + tableSize) / threadSize); start = System.currentTimeMillis(); - + // multi threads to insert List taskList = new ArrayList<>(); List threads = IntStream.range(0, threadSize) .mapToObj(i -> { diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/JdbcTaosdemoConfig.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/JdbcTaosdemoConfig.java index 5c852e572d..5803896abb 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/JdbcTaosdemoConfig.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/components/JdbcTaosdemoConfig.java @@ -9,7 +9,7 @@ public final class JdbcTaosdemoConfig { public String user = "root"; //user public String password = "taosdata"; //password // database - public String database = "test"; //database + public String database = "jdbcdb"; //database public int keep = 3650; //keep public int days = 30; //days public int replica = 1; //replica @@ -50,7 +50,7 @@ public final class JdbcTaosdemoConfig { System.out.println("-user The TDengine user name to use when connecting to the server. Default is 'root'"); System.out.println("-password The password to use when connecting to the server.Default is 'taosdata'"); // database - System.out.println("-database Destination database. Default is 'test'"); + System.out.println("-database Destination database. Default is 'jdbcdb'"); System.out.println("-keep database keep parameter. Default is 3650"); System.out.println("-days database days parameter. Default is 30"); System.out.println("-replica database replica parameter. Default 1, min: 1, max: 3"); diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/DatabaseMapper.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/DatabaseMapper.java index eba77c2a7e..56e38d2bfc 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/DatabaseMapper.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/DatabaseMapper.java @@ -1,10 +1,7 @@ package com.taosdata.taosdemo.dao; -import org.springframework.stereotype.Repository; - import java.util.Map; -@Repository public interface DatabaseMapper { // create database if not exists XXX diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/DatabaseMapperImpl.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/DatabaseMapperImpl.java index 99e0a62c31..e0a2f77a83 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/DatabaseMapperImpl.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/DatabaseMapperImpl.java @@ -1,14 +1,19 @@ package com.taosdata.taosdemo.dao; -import com.taosdata.taosdemo.dao.DatabaseMapper; import com.taosdata.taosdemo.utils.SqlSpeller; import org.springframework.jdbc.core.JdbcTemplate; +import javax.sql.DataSource; import java.util.Map; public class DatabaseMapperImpl implements DatabaseMapper { - private JdbcTemplate jdbcTemplate = new JdbcTemplate(); + private final JdbcTemplate jdbcTemplate; + + public DatabaseMapperImpl(DataSource dataSource) { + this.jdbcTemplate = new JdbcTemplate(dataSource); + } + @Override public void createDatabase(String dbname) { diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/SubTableMapperImpl.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/SubTableMapperImpl.java index f4c727f5a6..4720a7a70d 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/SubTableMapperImpl.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/SubTableMapperImpl.java @@ -1,45 +1,55 @@ package com.taosdata.taosdemo.dao; -import com.taosdata.taosdemo.dao.SubTableMapper; import com.taosdata.taosdemo.domain.SubTableMeta; import com.taosdata.taosdemo.domain.SubTableValue; import com.taosdata.taosdemo.utils.SqlSpeller; +import org.apache.log4j.Logger; import org.springframework.jdbc.core.JdbcTemplate; +import javax.sql.DataSource; import java.util.List; public class SubTableMapperImpl implements SubTableMapper { - private JdbcTemplate jdbcTemplate; + private static final Logger logger = Logger.getLogger(SubTableMapperImpl.class); + private final JdbcTemplate jdbcTemplate; + + public SubTableMapperImpl(DataSource dataSource) { + this.jdbcTemplate = new JdbcTemplate(dataSource); + } @Override public void createUsingSuperTable(SubTableMeta subTableMeta) { String sql = SqlSpeller.createTableUsingSuperTable(subTableMeta); + logger.info("SQL >>> " + sql); jdbcTemplate.execute(sql); } @Override public int insertOneTableMultiValues(SubTableValue subTableValue) { String sql = SqlSpeller.insertOneTableMultiValues(subTableValue); + logger.info("SQL >>> " + sql); return jdbcTemplate.update(sql); } - @Override public int insertOneTableMultiValuesUsingSuperTable(SubTableValue subTableValue) { String sql = SqlSpeller.insertOneTableMultiValuesUsingSuperTable(subTableValue); + logger.info("SQL >>> " + sql); return jdbcTemplate.update(sql); } @Override public int insertMultiTableMultiValues(List tables) { String sql = SqlSpeller.insertMultiSubTableMultiValues(tables); + logger.info("SQL >>> " + sql); return jdbcTemplate.update(sql); } @Override public int insertMultiTableMultiValuesUsingSuperTable(List tables) { String sql = SqlSpeller.insertMultiTableMultiValuesUsingSuperTable(tables); + logger.info("SQL >>> " + sql); return jdbcTemplate.update(sql); } } diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/SuperTableMapperImpl.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/SuperTableMapperImpl.java index 9a8390f582..a293de5100 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/SuperTableMapperImpl.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/dao/SuperTableMapperImpl.java @@ -1,22 +1,31 @@ package com.taosdata.taosdemo.dao; -import com.taosdata.taosdemo.dao.SuperTableMapper; import com.taosdata.taosdemo.domain.SuperTableMeta; import com.taosdata.taosdemo.utils.SqlSpeller; +import org.apache.log4j.Logger; import org.springframework.jdbc.core.JdbcTemplate; -public class SuperTableMapperImpl implements SuperTableMapper { +import javax.sql.DataSource; +public class SuperTableMapperImpl implements SuperTableMapper { + private static final Logger logger = Logger.getLogger(SuperTableMapperImpl.class); private JdbcTemplate jdbcTemplate; + public SuperTableMapperImpl(DataSource dataSource) { + this.jdbcTemplate = new JdbcTemplate(dataSource); + } + @Override public void createSuperTable(SuperTableMeta tableMetadata) { String sql = SqlSpeller.createSuperTable(tableMetadata); + logger.info("SQL >>> " + sql); jdbcTemplate.execute(sql); } @Override public void dropSuperTable(String database, String name) { - jdbcTemplate.execute("drop table if exists " + database + "." + name); + String sql = "drop table if exists " + database + "." + name; + logger.info("SQL >>> " + sql); + jdbcTemplate.execute(sql); } } diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/DatabaseService.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/DatabaseService.java index e30a65e900..3c8e962406 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/DatabaseService.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/DatabaseService.java @@ -1,99 +1,42 @@ package com.taosdata.taosdemo.service; import com.taosdata.taosdemo.dao.DatabaseMapper; -import org.apache.log4j.Logger; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; +import com.taosdata.taosdemo.dao.DatabaseMapperImpl; import javax.sql.DataSource; -import java.sql.Connection; -import java.sql.SQLException; -import java.sql.Statement; import java.util.Map; -@Service public class DatabaseService { - @Autowired - private DatabaseMapper databaseMapper; - - private DataSource dataSource; - private static Logger logger = Logger.getLogger(DatabaseService.class); + private final DatabaseMapper databaseMapper; public DatabaseService(DataSource dataSource) { - this.dataSource = dataSource; + this.databaseMapper = new DatabaseMapperImpl(dataSource); } // 建库，指定 name - public int createDatabase(String database) { - try { - Connection connection = dataSource.getConnection(); - Statement statement = connection.createStatement(); - statement.execute("create database " + database); - statement.close(); - connection.close(); - } catch (SQLException e) { - e.printStackTrace(); - } - return 0; -// return databaseMapper.createDatabase(database); + public void createDatabase(String database) { + databaseMapper.createDatabase(database); } // 建库，指定参数 keep,days,replica等 - public int createDatabase(Map map) { + public void createDatabase(Map map) { if (map.isEmpty()) - return 0; - if (map.containsKey("database") && map.size() == 1) + return; + if (map.containsKey("database") && map.size() == 1) { createDatabase(map.get("database")); -// return databaseMapper.createDatabase(map.get("database")); -// return databaseMapper.createDatabaseWithParameters(map); - try { - Connection connection = dataSource.getConnection(); - Statement statement = connection.createStatement(); - String sql = "create database if not exists " + map.get("database") - + " keep " + map.get("keep") - + " days " + map.get("days") - + " replica " + map.get("replica"); - logger.info(">>> " + sql); - statement.execute(sql); - statement.close(); - connection.close(); - } catch (SQLException e) { - e.printStackTrace(); + return; } - return 0; + databaseMapper.createDatabaseWithParameters(map); } // drop database - public int dropDatabase(String dbname) { - try { - Connection connection = dataSource.getConnection(); - Statement statement = connection.createStatement(); - String sql = "drop database if exists " + dbname; - logger.info(">>> " + sql); - statement.execute(sql); - statement.close(); - connection.close(); - } catch (SQLException e) { - e.printStackTrace(); - } - return 0; + public void dropDatabase(String dbname) { + databaseMapper.dropDatabase(dbname); } // use database - public int useDatabase(String dbname) { - try { - Connection connection = dataSource.getConnection(); - Statement statement = connection.createStatement(); - String sql = "use " + dbname; - logger.info(">>> " + sql); - statement.execute(sql); - statement.close(); - connection.close(); - } catch (SQLException e) { - e.printStackTrace(); - } - return 0; -// return databaseMapper.useDatabase(dbname); + public void useDatabase(String dbname) { + databaseMapper.useDatabase(dbname); } } diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/InsertTask.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/InsertTask.java index 6ee8cb1138..b213e311ac 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/InsertTask.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/InsertTask.java @@ -82,7 +82,7 @@ public class InsertTask implements Callable { SubTableValueGenerator.disrupt(data, rate, range); } // insert - SubTableService subTableService = new SubTableService(connection); + SubTableService subTableService = new SubTableService(dataSource); if (autoCreateTable) { subTableService.insertAutoCreateTable(data); } else { diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/SubTableService.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/SubTableService.java index d76e92bffa..64732cd257 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/SubTableService.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/SubTableService.java @@ -1,57 +1,25 @@ package com.taosdata.taosdemo.service; import com.taosdata.taosdemo.dao.SubTableMapper; -import com.taosdata.taosdemo.domain.*; +import com.taosdata.taosdemo.dao.SubTableMapperImpl; +import com.taosdata.taosdemo.domain.SubTableMeta; +import com.taosdata.taosdemo.domain.SubTableValue; +import com.taosdata.taosdemo.domain.SuperTableMeta; import com.taosdata.taosdemo.service.data.SubTableMetaGenerator; import org.apache.log4j.Logger; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; import javax.sql.DataSource; -import java.sql.Connection; -import java.sql.SQLException; -import java.sql.Statement; -import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; -import java.util.concurrent.TimeUnit; -@Service public class SubTableService extends AbstractService { - private static Logger logger = Logger.getLogger(SubTableService.class); - - @Autowired private SubTableMapper mapper; - private Connection connection; - - public SubTableService() { - } - - public SubTableService(Connection connection) { - this.connection = connection; - } - - /** - * 1. 选择database，找到所有supertable - * 2. 选择supertable，可以拿到表结构，包括field和tag - * 3. 指定子表的前缀和个数 - * 4. 指定创建子表的线程数 - */ - //TODO：指定database、supertable、子表前缀、子表个数、线程数 - - // 多线程创建表，指定线程个数 - public int createSubTable(List subTables, int threadSize) { - ExecutorService executor = Executors.newFixedThreadPool(threadSize); - List> futureList = new ArrayList<>(); - for (SubTableMeta subTableMeta : subTables) { - executor.submit(() -> createSubTable(subTableMeta)); - } - executor.shutdown(); - return getAffectRows(futureList); + public SubTableService(DataSource datasource) { + this.mapper = new SubTableMapperImpl(datasource); } public void createSubTable(SuperTableMeta superTableMeta, long numOfTables, String prefixOfTable, int numOfThreadsForCreate) { @@ -66,7 +34,7 @@ public class SubTableService extends AbstractService { public void createSubTable(SuperTableMeta superTableMeta, String tableName) { // 构造数据 SubTableMeta meta = SubTableMetaGenerator.generate(superTableMeta, tableName); - mapper.createUsingSuperTable(meta); + createSubTable(meta); } // 创建一张子表，可以指定database，supertable，tablename，tag值 @@ -74,11 +42,6 @@ public class SubTableService extends AbstractService { mapper.createUsingSuperTable(subTableMeta); } - // 单线程创建多张子表，每张子表分别可以指定自己的database，supertable，tablename，tag值 - public int createSubTable(List subTables) { - return createSubTable(subTables, 1); - } - /*************************************************************************************************************************/ // 插入：多线程，多表 public int insert(List subTableValues, int threadSize, int frequency) { @@ -89,19 +52,6 @@ public class SubTableService extends AbstractService { return getAffectRows(future); } - // 插入：多线程，多表, 自动建表 -// public int insertAutoCreateTable(List subTableValues, int threadSize, int frequency) { -// long a = System.currentTimeMillis(); -// ExecutorService executor = Executors.newFixedThreadPool(threadSize); -// long b = System.currentTimeMillis(); -// Future future = executor.submit(() -> insertAutoCreateTable(subTableValues)); -// executor.shutdown(); -// int affectRows = getAffectRows(future); -// long c = System.currentTimeMillis(); -// logger.info(">>> total : " + (c - a) + " ms, thread: " + (b - a) + " ms, insert : " + (c - b) + " ms."); -// return affectRows; -// } - // 插入：单表，insert into xxx values(),()... public int insert(SubTableValue subTableValue) { return mapper.insertOneTableMultiValues(subTableValue); @@ -117,70 +67,9 @@ public class SubTableService extends AbstractService { return mapper.insertOneTableMultiValuesUsingSuperTable(subTableValue); } - @Autowired - private DataSource dataSource; - // 插入：多表，自动建表, insert into xxx using XXX tags(...) values(),()... xxx using XXX tags(...) values(),()... public int insertAutoCreateTable(List subTableValues) { - - int affectRows = 0; - try { - String sql = sql(subTableValues); - logger.info(">>> SQL : " + sql); - Statement statement = connection.createStatement(); - affectRows = statement.executeUpdate(sql); - statement.close(); - } catch (SQLException e) { - e.printStackTrace(); - } - return affectRows; -// return mapper.insertMultiTableMultiValuesUsingSuperTable(subTableValues); - } - - private String sql(List subTableValues) { - StringBuilder sb = new StringBuilder(); - sb.append("insert into "); - for (int i = 0; i < subTableValues.size(); i++) { - SubTableValue subTableValue = subTableValues.get(i); - sb.append(subTableValue.getDatabase() + "." + subTableValue.getName() + " using " + subTableValue.getDatabase() + "." + subTableValue.getSupertable() + " tags ("); - for (int j = 0; j < subTableValue.getTags().size(); j++) { - TagValue tagValue = subTableValue.getTags().get(j); - if (j == 0) - sb.append("'" + tagValue.getValue() + "'"); - else - sb.append(", '" + tagValue.getValue() + "'"); - } - sb.append(") values"); - for (int j = 0; j < subTableValue.getValues().size(); j++) { - sb.append("("); - RowValue rowValue = subTableValue.getValues().get(j); - for (int k = 0; k < rowValue.getFields().size(); k++) { - FieldValue fieldValue = rowValue.getFields().get(k); - if (k == 0) -// sb.append("" + timestamp.getAndIncrement()); - sb.append("" + fieldValue.getValue() + ""); - else - sb.append(", '" + fieldValue.getValue() + "'"); - } - sb.append(") "); - } - } - - return sb.toString(); - } - - - private static void sleep(int sleep) { - if (sleep <= 0) - return; - try { - TimeUnit.MILLISECONDS.sleep(sleep); - } catch (InterruptedException e) { - e.printStackTrace(); - } + return mapper.insertMultiTableMultiValuesUsingSuperTable(subTableValues); } - /********************************************************************/ - - } diff --git a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/SuperTableService.java b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/SuperTableService.java index d58d37fcd7..b91348e2d0 100644 --- a/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/SuperTableService.java +++ b/tests/examples/JDBC/taosdemo/src/main/java/com/taosdata/taosdemo/service/SuperTableService.java @@ -1,45 +1,22 @@ package com.taosdata.taosdemo.service; import com.taosdata.taosdemo.dao.SuperTableMapper; +import com.taosdata.taosdemo.dao.SuperTableMapperImpl; import com.taosdata.taosdemo.domain.SuperTableMeta; -import com.taosdata.taosdemo.utils.SqlSpeller; -import org.apache.log4j.Logger; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; import javax.sql.DataSource; -import java.sql.Connection; -import java.sql.SQLException; -import java.sql.Statement; -@Service public class SuperTableService { - private static Logger logger = Logger.getLogger(SuperTableService.class); - @Autowired private SuperTableMapper superTableMapper; - private DataSource dataSource; - public SuperTableService(DataSource dataSource) { - this.dataSource = dataSource; + this.superTableMapper = new SuperTableMapperImpl(dataSource); } // 创建超级表，指定每个field的名称和类型，每个tag的名称和类型 - public int create(SuperTableMeta superTableMeta) { - int result = 0; - try { - Connection connection = dataSource.getConnection(); - Statement statement = connection.createStatement(); - String sql = SqlSpeller.createSuperTable(superTableMeta); - logger.info(">>> " + sql); - result = statement.executeUpdate(sql); - statement.close(); - connection.close(); - } catch (SQLException e) { - e.printStackTrace(); - } - return result; + public void create(SuperTableMeta superTableMeta) { + superTableMapper.createSuperTable(superTableMeta); } public void drop(String database, String name) { diff --git a/tests/examples/JDBC/taosdemo/src/test/java/com/taosdata/taosdemo/service/SubTableServiceTest.java b/tests/examples/JDBC/taosdemo/src/test/java/com/taosdata/taosdemo/service/SubTableServiceTest.java index 73aa81ef96..f7e5cd4505 100644 --- a/tests/examples/JDBC/taosdemo/src/test/java/com/taosdata/taosdemo/service/SubTableServiceTest.java +++ b/tests/examples/JDBC/taosdemo/src/test/java/com/taosdata/taosdemo/service/SubTableServiceTest.java @@ -9,6 +9,7 @@ import java.util.ArrayList; import java.util.List; public class SubTableServiceTest { + private SubTableService service; private List subTables; @@ -31,13 +32,11 @@ public class SubTableServiceTest { @Test public void testCreateSubTable() { - int count = service.createSubTable(subTables); - System.out.println("count >>> " + count); + } @Test public void testCreateSubTableList() { - int count = service.createSubTable(subTables, 10); - System.out.println("count >>> " + count); + } } \ No newline at end of file -- GitLab