From da4e29e96a1d01fd9fed34e8b1e993081c3fd450 Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Fri, 22 Sep 2023 11:14:48 +0800 Subject: [PATCH] feat:补充提交 --- screen-api/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java | 45 ++++++++++++++++++++++++++++++++++++--------- 1 files changed, 36 insertions(+), 9 deletions(-) diff --git a/screen-api/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java b/screen-api/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java index 4a253f7..e57509c 100644 --- a/screen-api/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java +++ b/screen-api/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java @@ -1,22 +1,49 @@ package com.moral.api.config.mybatis; -import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor; +import com.baomidou.mybatisplus.annotation.DbType; +import com.baomidou.mybatisplus.extension.parsers.DynamicTableNameParser; +import com.baomidou.mybatisplus.extension.parsers.ITableNameHandler; +import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; +import com.baomidou.mybatisplus.extension.plugins.handler.TableNameHandler; +import com.baomidou.mybatisplus.extension.plugins.inner.DynamicTableNameInnerInterceptor; +import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; +import com.moral.api.entity.HistoryFiveMinutely; +import com.moral.api.mapper.HistoryFiveMinutelyMapper; +import com.moral.api.service.HistorySecondUavService; +import com.moral.api.service.impl.HistorySecondUavServiceImpl; +import com.moral.api.service.impl.OrganizationServiceImpl; +import org.apache.ibatis.reflection.MetaObject; +import org.apache.ibatis.session.SqlSessionFactory; +import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import java.text.SimpleDateFormat; +import java.util.*; @Configuration public class MybatisPlusConfig { - /** - * ������������ - */ - @Bean - public PaginationInterceptor paginationInterceptor() { - PaginationInterceptor page = new PaginationInterceptor(); - return page; - } + public static ThreadLocal<String> tableName = new ThreadLocal<>(); + @Bean + public MybatisPlusInterceptor mybatisPlusInterceptor() { + MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); + + //������������ + interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); + + // ������������SQL��������� + DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor(); + HashMap<String, TableNameHandler> map = new HashMap<>(); + map.put("history_hourly", (sql, tableName) -> tableName+this.tableName.get()); + map.put("history_five_minutely", (sql, tableName) -> tableName+this.tableName.get()); + + dynamicTableNameInnerInterceptor.setTableNameHandlerMap(map); + interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor); + + return interceptor; + } } -- Gitblit v1.8.0