forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2023-10-27 e3bac98f092a10c0e897143bece3abbcc59469f2 
 screen-api/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java


@@ -1,22 +1,63 @@


package com.moral.api.config.mybatis;




import com.baomidou.mybatisplus.annotation.DbType;


import com.baomidou.mybatisplus.autoconfigure.ConfigurationCustomizer;


import com.baomidou.mybatisplus.core.MybatisConfiguration;


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.PaginationInterceptor;


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.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;


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.Qualifier;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.context.annotation.Bean;


import org.springframework.context.annotation.Configuration;


import org.springframework.context.annotation.Primary;




import javax.sql.DataSource;


import java.text.SimpleDateFormat;


import java.util.*;








@Configuration


/*@Configuration*/


public class MybatisPlusConfig {




    /**


     * 分页插件


     */






    @Bean


    public PaginationInterceptor paginationInterceptor() {


        PaginationInterceptor page = new PaginationInterceptor();


        return page;


    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);


        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));


        return interceptor;


    }


    @Bean


    public ConfigurationCustomizer configurationCustomizer() {


        return configuration -> configuration.setUseDeprecatedExecutor(false);


    }






    public static ThreadLocal<String> tableName = new ThreadLocal<>();




}