一、pom文件

前言一、pom文件二、yamlDataSourceConfigServiceMapper.xml测试总结

Mybatis-plus管理多数据源数据库为mysql和TDengine。

一、pom文件

dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.28/version

!--

scoperuntime/scope--/dependency!--connection

pool--dependencygroupIdcom.alibaba/groupIdartifactIddruid-spring-boot-starter/artifactIdversion1.2.8/version/dependencydependencygroupIdcom.taosdata.jdbc/groupIdartifactIdtaos-jdbcdriver/artifactIdversion3.2.7/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-boot-starter/artifactIdversion3.5.7/version/dependencydependencygroupIdcom.baomidou/groupIdartifactIddynamic-datasource-spring-boot-starter/artifactIdversion3.5.1/version/dependency二、yaml

spring:datasource:

jdbc:mysql://127.0.0.1:3306/wh_vehicles?useUnicodetruecharacterEncodingUTF-8useSSLfalseautoReconnecttruefailOverReadOnlyfalseserverTimezoneAsia/Shanghai

username:

严格按照路由规则从主库读取数据如果主库不可用则从从库读取数据。

datasource:master:driver-class-name:

jdbc:mysql://127.0.0.1:3306/wh_vehicles?useUnicodetruecharacterEncodingUTF-8useSSLfalseautoReconnecttruefailOverReadOnlyfalseserverTimezoneAsia/Shanghaiusername:

rootpassword:

com.taosdata.jdbc.rs.RestfulDriverurl:

jdbc:TAOS-RS://localhost:6041?timezoneUTC-8charsetutf-8useSSLfalseuserrootpassword123#

using

com.alibaba.druid.pool.DruidDataSourcedruid:initial-size:

5min-idle:

60000time-between-eviction-runs-millis:

60000min-evictable-idle-time-millis:

SELECT

truemax-pool-prepared-statement-per-connection-size:

mybatis

classpath:mapper/*.xmltype-aliases-package:

org.zqh.jt808.server.modelDataSourceConfig

package

org.zqh.jt808.server.config;import

org.apache.ibatis.session.SqlSessionFactory;

import

org.mybatis.spring.SqlSessionFactoryBean;

import

org.mybatis.spring.SqlSessionTemplate;

import

org.springframework.beans.factory.annotation.Qualifier;

import

org.springframework.boot.context.properties.ConfigurationProperties;

import

org.springframework.boot.jdbc.DataSourceBuilder;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;

import

org.springframework.context.annotation.Primary;

import

org.springframework.core.io.support.PathMatchingResourcePatternResolver;import

javax.sql.DataSource;Configuration

public

masterDataSource)ConfigurationProperties(prefix

spring.dynamic.datasource.master)public

DataSource

DataSourceBuilder.create().build();}//

从数据源

slaveDataSource)ConfigurationProperties(prefix

spring.dynamic.datasource.slave)public

DataSource

DataSourceBuilder.create().build();}//

SqlSessionFactoryPrimaryBean(name

SqlSessionFactory

masterSqlSessionFactory(Qualifier(masterDataSource)

DataSource

SqlSessionFactoryBean();sqlSessionFactoryBean.setDataSource(dataSource);//

MyBatis

classpath*:/mapper/*.xml;PathMatchingResourcePatternResolver

resolver

PathMatchingResourcePatternResolver();sqlSessionFactoryBean.setMapperLocations(resolver.getResources(locationPattern));return

sqlSessionFactoryBean.getObject();}//

SqlSessionFactory

slaveSqlSessionFactory(Qualifier(slaveDataSource)

DataSource

SqlSessionFactoryBean();sqlSessionFactoryBean.setDataSource(dataSource);//

MyBatis

classpath*:/mapper/*.xml;PathMatchingResourcePatternResolver

resolver

PathMatchingResourcePatternResolver();sqlSessionFactoryBean.setMapperLocations(resolver.getResources(locationPattern));return

sqlSessionFactoryBean.getObject();}

Service

org.zqh.jt808.server.service;import

import

com.baomidou.dynamic.datasource.annotation.DS;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.stereotype.Service;

import

org.zqh.jt808.server.mapper.TDMapper;

import

org.zqh.jt808.server.model.LocationInfo;import

java.util.ArrayList;

{tdMapper.saveLocation(locationInfo);}/***

查询实时位置-全部*

tdMapper.queryLocationAll();}/***

查询历史轨迹*

tdMapper.queryLocationHistory(deviceId,startTime,endTime);}/***

查询实时位置-指定设备列表*

tdMapper.queryLocations(deviceIds);}else

{return

tdMapper.queryLocation(deviceId);}

Mapper.xml

3.0//ENhttp://mybatis.org/dtd/mybatis-3-mapper.dtd

mapper

namespaceorg.zqh.jt808.server.mapper.TDMapperinsert

idsaveLocationINSERT

wh_special_equipment.device_locations

(tbname,

resultTypeorg.zqh.jt808.server.model.LocationInfo![CDATA[select

from

wh_special_equipment.device_locations

where

resultTypeorg.zqh.jt808.server.model.LocationInfoselect

last_row(deviceId),*

wh_special_equipment.device_locationswhere

deviceId

resultTypeorg.zqh.jt808.server.model.LocationInfoselect

from

wh_special_equipment.device_locationsgroup

tbname;/selectselect

resultTypecn.hutool.json.JSONObjectselect

last_row(deviceId),deviceId,ts,longitude,latitude,height,speed,directionfrom

wh_special_equipment.device_locationswhere

deviceId

org.zqh.jt808.server.test;import

import

org.springframework.boot.test.context.SpringBootTest;

import

org.zqh.jt808.server.service.ApiService;

import

org.zqh.jt808.server.service.TDService;import

import

{System.out.println(apiService.queryTD());}Testpublic

void

{log.debug({},apiService.queryMySql());}/***

查询所有坐标*/Testpublic

{log.debug({},tdService.queryLocationAll());}/***

void

ArrayList();list.add(00000000000040904004);log.debug({},tdService.queryLocations(list));}/***

void

{log.info({},tdService.queryLocation(00000000000040904004));}/***

查询历史轨迹*/Testpublic

ArrayList();list.add(00000000000040904004);MapString,

ListString

HashMap();map.put(deviceIds,list);String

deviceId

System.currentTimeMillis();long

endTime

System.currentTimeMillis();log.debug({},tdService.queryLocationHistory(deviceId,startTime,endTime));}

}总结