From 7f147e0550cb089912ae63268e325a11f1a75dce Mon Sep 17 00:00:00 2001 From: zyyang Date: Mon, 21 Dec 2020 17:17:40 +0800 Subject: [PATCH] change --- .../taosdemo/dao/DatabaseMapperImpl.java | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) 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 b6d53690e4..69bae160f6 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,12 +1,14 @@ package com.taosdata.taosdemo.dao; import com.taosdata.taosdemo.utils.SqlSpeller; +import org.apache.log4j.Logger; import org.springframework.jdbc.core.JdbcTemplate; import javax.sql.DataSource; import java.util.Map; public class DatabaseMapperImpl implements DatabaseMapper { + private static final Logger logger = Logger.getLogger(DatabaseMapperImpl.class); private final JdbcTemplate jdbcTemplate; @@ -17,21 +19,29 @@ public class DatabaseMapperImpl implements DatabaseMapper { @Override public void createDatabase(String dbname) { - jdbcTemplate.execute("create database if not exists " + dbname); + String sql = "create database if not exists " + dbname; + jdbcTemplate.execute(sql); + logger.info("SQL >>> " + sql); } @Override public void dropDatabase(String dbname) { - jdbcTemplate.update("drop database if exists " + dbname); + String sql = "drop database if exists " + dbname; + jdbcTemplate.update(sql); + logger.info("SQL >>> " + sql); } @Override public void createDatabaseWithParameters(Map map) { - jdbcTemplate.execute(SqlSpeller.createDatabase(map)); + String sql = SqlSpeller.createDatabase(map); + jdbcTemplate.execute(sql); + logger.info("SQL >>> " + sql); } @Override public void useDatabase(String dbname) { - jdbcTemplate.execute("use " + dbname); + String sql = "use " + dbname; + jdbcTemplate.execute(sql); + logger.info("SQL >>> " + sql); } }