From ea66c01f85340a5ed65d5dd74607e5cfcdbec03d Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Wed, 14 Dec 2022 10:01:33 +0800
Subject: [PATCH] 修改sql语句问题3
---
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