From 4af3ab50825590cab90521577f954359d22339a4 Mon Sep 17 00:00:00 2001 From: sheyanjie-qq <249478495@qq.com> Date: Sun, 25 Aug 2024 10:45:34 +0800 Subject: [PATCH] update java code example --- docs/examples/JDBC/SpringJdbcTemplate/pom.xml | 2 +- .../taosdata/example/jdbcTemplate/App.java | 55 +++++++------------ docs/examples/JDBC/mybatisplus-demo/pom.xml | 4 +- .../config/MybatisPlusConfig.java | 14 +++-- .../mapper/TemperatureMapperTest.java | 2 +- .../mapper/WeatherMapperTest.java | 2 +- 6 files changed, 34 insertions(+), 45 deletions(-) diff --git a/docs/examples/JDBC/SpringJdbcTemplate/pom.xml b/docs/examples/JDBC/SpringJdbcTemplate/pom.xml index 99129e180a..6e4941b4f1 100644 --- a/docs/examples/JDBC/SpringJdbcTemplate/pom.xml +++ b/docs/examples/JDBC/SpringJdbcTemplate/pom.xml @@ -47,7 +47,7 @@ com.taosdata.jdbc taos-jdbcdriver - 3.3.1-SNAPSHOT + 3.0.0 diff --git a/docs/examples/JDBC/SpringJdbcTemplate/src/main/java/com/taosdata/example/jdbcTemplate/App.java b/docs/examples/JDBC/SpringJdbcTemplate/src/main/java/com/taosdata/example/jdbcTemplate/App.java index b70c31a8f7..ce26b7504a 100644 --- a/docs/examples/JDBC/SpringJdbcTemplate/src/main/java/com/taosdata/example/jdbcTemplate/App.java +++ b/docs/examples/JDBC/SpringJdbcTemplate/src/main/java/com/taosdata/example/jdbcTemplate/App.java @@ -6,8 +6,6 @@ import com.taosdata.example.jdbcTemplate.dao.WeatherDao; import com.taosdata.example.jdbcTemplate.domain.Weather; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; -import org.springframework.jdbc.core.JdbcTemplate; -import org.springframework.jdbc.datasource.DriverManagerDataSource; import java.sql.Timestamp; import java.util.Date; @@ -20,41 +18,30 @@ public class App { public static void main(String[] args) { -// ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml"); -// -// ExecuteAsStatement executor = ctx.getBean(ExecuteAsStatement.class); -// // drop database -// executor.doExecute("drop database if exists test"); -// // create database -// executor.doExecute("create database if not exists test"); -// //use database -// executor.doExecute("use test"); -// // create table -// executor.doExecute("create table if not exists test.weather (ts timestamp, temperature float, humidity int)"); -// -// WeatherDao weatherDao = ctx.getBean(WeatherDao.class); -// Weather weather = new Weather(new Timestamp(new Date().getTime()), random.nextFloat() * 50.0f, random.nextInt(100)); -// // insert rows -// int affectedRows = weatherDao.add(weather); -// System.out.println("insert success " + affectedRows + " rows."); -// -// // query for list -// int limit = 10, offset = 0; -// List weatherList = weatherDao.queryForList(limit, offset); -// for (Weather w : weatherList) { -// System.out.println(w); -// } - DriverManagerDataSource dataSource = new DriverManagerDataSource(); - dataSource.setDriverClassName("com.taosdata.jdbc.rs.RestfulDriver"); - dataSource.setUrl("jdbc:TAOS-RS://vm98:6041/?batchfetch=true&user=root&password=taosdata"); + ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml"); + ExecuteAsStatement executor = ctx.getBean(ExecuteAsStatement.class); + // drop database + executor.doExecute("drop database if exists test"); + // create database + executor.doExecute("create database if not exists test"); + //use database + executor.doExecute("use test"); + // create table + executor.doExecute("create table if not exists test.weather (ts timestamp, temperature float, humidity int)"); + WeatherDao weatherDao = ctx.getBean(WeatherDao.class); + Weather weather = new Weather(new Timestamp(new Date().getTime()), random.nextFloat() * 50.0f, random.nextInt(100)); + // insert rows + int affectedRows = weatherDao.add(weather); + System.out.println("insert success " + affectedRows + " rows."); - JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); - - jdbcTemplate.query("select * from test.meters limit ?, ?", - (rs, rowNum) -> rs.getString("ts"), 1, 10) - .forEach(System.out::println) ; + // query for list + int limit = 10, offset = 0; + List weatherList = weatherDao.queryForList(limit, offset); + for (Weather w : weatherList) { + System.out.println(w); + } } diff --git a/docs/examples/JDBC/mybatisplus-demo/pom.xml b/docs/examples/JDBC/mybatisplus-demo/pom.xml index 66746d5978..f792946c96 100644 --- a/docs/examples/JDBC/mybatisplus-demo/pom.xml +++ b/docs/examples/JDBC/mybatisplus-demo/pom.xml @@ -31,7 +31,7 @@ com.baomidou mybatis-plus-boot-starter - 3.5.1 + 3.1.2 com.h2database @@ -47,7 +47,7 @@ com.taosdata.jdbc taos-jdbcdriver - 3.3.1-SNAPSHOT + 3.2.4 diff --git a/docs/examples/JDBC/mybatisplus-demo/src/main/java/com/taosdata/example/mybatisplusdemo/config/MybatisPlusConfig.java b/docs/examples/JDBC/mybatisplus-demo/src/main/java/com/taosdata/example/mybatisplusdemo/config/MybatisPlusConfig.java index 321d72814c..a6ac7f7fc2 100644 --- a/docs/examples/JDBC/mybatisplus-demo/src/main/java/com/taosdata/example/mybatisplusdemo/config/MybatisPlusConfig.java +++ b/docs/examples/JDBC/mybatisplus-demo/src/main/java/com/taosdata/example/mybatisplusdemo/config/MybatisPlusConfig.java @@ -1,7 +1,6 @@ package com.taosdata.example.mybatisplusdemo.config; -import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; -import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; +import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -23,10 +22,13 @@ public class MybatisPlusConfig { // } @Bean - public MybatisPlusInterceptor mybatisPlusInterceptor() { - MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); - interceptor.addInnerInterceptor(new PaginationInnerInterceptor()); - return interceptor; + public PaginationInterceptor paginationInterceptor() { +// return new PaginationInterceptor(); + PaginationInterceptor paginationInterceptor = new PaginationInterceptor(); + //TODO: mybatis-plus do not support TDengine, use postgresql Dialect + paginationInterceptor.setDialectType("postgresql"); + + return paginationInterceptor; } } diff --git a/docs/examples/JDBC/mybatisplus-demo/src/test/java/com/taosdata/example/mybatisplusdemo/mapper/TemperatureMapperTest.java b/docs/examples/JDBC/mybatisplus-demo/src/test/java/com/taosdata/example/mybatisplusdemo/mapper/TemperatureMapperTest.java index 763d2b14fc..4d9dbf8d2f 100644 --- a/docs/examples/JDBC/mybatisplus-demo/src/test/java/com/taosdata/example/mybatisplusdemo/mapper/TemperatureMapperTest.java +++ b/docs/examples/JDBC/mybatisplus-demo/src/test/java/com/taosdata/example/mybatisplusdemo/mapper/TemperatureMapperTest.java @@ -107,7 +107,7 @@ public class TemperatureMapperTest { * **/ @Test public void testSelectCount() { - long count = mapper.selectCount(null); + int count = mapper.selectCount(null); Assert.assertEquals(10, count); } diff --git a/docs/examples/JDBC/mybatisplus-demo/src/test/java/com/taosdata/example/mybatisplusdemo/mapper/WeatherMapperTest.java b/docs/examples/JDBC/mybatisplus-demo/src/test/java/com/taosdata/example/mybatisplusdemo/mapper/WeatherMapperTest.java index 3e5de3d6a6..dba8abd1ed 100644 --- a/docs/examples/JDBC/mybatisplus-demo/src/test/java/com/taosdata/example/mybatisplusdemo/mapper/WeatherMapperTest.java +++ b/docs/examples/JDBC/mybatisplus-demo/src/test/java/com/taosdata/example/mybatisplusdemo/mapper/WeatherMapperTest.java @@ -82,7 +82,7 @@ public class WeatherMapperTest { @Test public void testSelectCount() { - long count = mapper.selectCount(null); + int count = mapper.selectCount(null); // Assert.assertEquals(5, count); System.out.println(count); }