From a3183dff36766776e9d7aac5ab873503e35a2615 Mon Sep 17 00:00:00 2001 From: zyyang Date: Mon, 14 Dec 2020 22:06:12 +0800 Subject: [PATCH] change --- .../example/jdbcTaosdemo/JdbcTaosdemo.java | 1 - .../taosdemo/service/SubTableService.java | 42 ++++++++++++++++++- 2 files changed, 41 insertions(+), 2 deletions(-) diff --git a/tests/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/jdbcTaosdemo/JdbcTaosdemo.java b/tests/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/jdbcTaosdemo/JdbcTaosdemo.java index 259985ec9f..7f127cf6b0 100644 --- a/tests/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/jdbcTaosdemo/JdbcTaosdemo.java +++ b/tests/examples/JDBC/JDBCDemo/src/main/java/com/taosdata/example/jdbcTaosdemo/JdbcTaosdemo.java @@ -286,7 +286,6 @@ public class JdbcTaosdemo { executeQuery(sql); } - private void close() { try { if (connection != null) { 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 ce4f872502..b565b102fd 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 @@ -5,9 +5,15 @@ import com.taosdata.taosdemo.domain.SubTableValue; import com.taosdata.taosdemo.domain.SuperTableMeta; import com.taosdata.taosdemo.mapper.SubTableMapper; import com.taosdata.taosdemo.service.data.SubTableMetaGenerator; +import org.apache.ibatis.session.SqlSessionFactory; +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; @@ -18,6 +24,8 @@ import java.util.concurrent.TimeUnit; @Service public class SubTableService extends AbstractService { + private static Logger logger = Logger.getLogger(SubTableService.class); + @Autowired private SubTableMapper mapper; @@ -99,11 +107,43 @@ public class SubTableService extends AbstractService { return mapper.insertOneTableMultiValuesUsingSuperTable(subTableValue); } + @Autowired + private SqlSessionFactory sqlSessionFactory; + @Autowired + private DataSource dataSource; + // 插入:多表,自动建表, insert into xxx using XXX tags(...) values(),()... xxx using XXX tags(...) values(),()... public int insertAutoCreateTable(List subTableValues) { - return mapper.insertMultiTableMultiValuesUsingSuperTable(subTableValues); + Connection connection = null; + Statement statement = null; + int affectRows = 0; + try { + connection = dataSource.getConnection(); + String sql = sqlSessionFactory.getConfiguration() + .getMappedStatement("com.taosdata.taosdemo.mapper.SubTableMapper.insertMultiTableMultiValuesUsingSuperTable") + .getBoundSql(subTableValues) + .getSql(); + logger.info(">>> SQL : " + sql); +// statement = connection.createStatement(); +// affectRows = statement.executeUpdate(sql); + } catch (SQLException e) { + e.printStackTrace(); + } finally { + try { + if (statement != null) { + statement.close(); + } + if (connection != null) + connection.close(); + } catch (SQLException e) { + e.printStackTrace(); + } + } + return affectRows; } +// return mapper.insertMultiTableMultiValuesUsingSuperTable(subTableValues); + private static void sleep(int sleep) { if (sleep <= 0) return; -- GitLab