From 5586964c3e63f95c9e460a6a3d85d7dca408e096 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Mon, 18 Oct 2021 14:35:39 +0800
Subject: [PATCH] Merge branch 'dev' of http://blit.7drlb.com:8888/r/moral into dev
---
screen-job/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java | 28 ++++++++++++++++++++++++++++
1 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/screen-job/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java b/screen-job/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java
index 3468cf7..253480b 100644
--- a/screen-job/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java
+++ b/screen-job/src/main/java/com/moral/api/config/mybatis/MybatisPlusConfig.java
@@ -1,11 +1,20 @@
package com.moral.api.config.mybatis;
+import com.baomidou.mybatisplus.annotation.DbType;
+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 org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
+import java.util.HashMap;
+
@Configuration
public class MybatisPlusConfig {
+
+ public static ThreadLocal<String> tableName = new ThreadLocal<>();
/**
* ������������
@@ -16,5 +25,24 @@
return page;
}
+ @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