基础添加mybatis-plus-join

base-common/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>base</artifactId>
         <groupId>com.ozs</groupId>
-        <version>3.8.5-SNAPSHOT</version>
+        <version>1.0-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>
@@ -144,6 +144,11 @@
             <artifactId>mybatis-plus-boot-starter</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>icu.mhb</groupId>
+            <artifactId>mybatis-plus-join</artifactId>
+        </dependency>
+
         <!-- swagger3-->
         <dependency>
             <groupId>io.springfox</groupId>

base-framework/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>base</artifactId>
         <groupId>com.ozs</groupId>
-        <version>3.8.5-SNAPSHOT</version>
+        <version>1.0-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

base-framework/src/main/java/com/ozs/framework/config/CipherMybatisPlusConfig.java

@@ -0,0 +1,39 @@
+package com.ozs.framework.config;
+
+import com.baomidou.mybatisplus.annotation.DbType;
+import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
+import com.ozs.framework.config.properties.DruidProperties;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration
+@ComponentScan("com.ozs")
+@MapperScan("com.ozs.*.mapper")
+public class CipherMybatisPlusConfig {
+
+    @Value("${base.sql-type:mysql}")
+    private String type;
+
+
+    @Bean
+    public MybatisPlusInterceptor mybatisPlusInterceptor() {
+        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
+
+        // 自定义拦截器，先添加先执行。
+        if (type.equals(DbType.POSTGRE_SQL.getDb())) {
+            interceptor.addInnerInterceptor(new PostgreSqlMybatisIntercepts());
+        }
+
+        // 自带分页拦截器
+        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.getDbType(type)));
+        return interceptor;
+    }
+
+
+}

base-framework/src/main/java/com/ozs/framework/config/PostgreSqlMybatisIntercepts.java

@@ -0,0 +1,73 @@
+package com.ozs.framework.config;
+
+import com.baomidou.mybatisplus.core.plugins.InterceptorIgnoreHelper;
+import com.baomidou.mybatisplus.core.toolkit.PluginUtils;
+import com.baomidou.mybatisplus.core.toolkit.TableNameParser;
+import com.baomidou.mybatisplus.extension.plugins.inner.InnerInterceptor;
+import org.apache.ibatis.executor.Executor;
+import org.apache.ibatis.executor.statement.StatementHandler;
+import org.apache.ibatis.mapping.BoundSql;
+import org.apache.ibatis.mapping.MappedStatement;
+import org.apache.ibatis.mapping.SqlCommandType;
+import org.apache.ibatis.session.ResultHandler;
+import org.apache.ibatis.session.RowBounds;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+public class PostgreSqlMybatisIntercepts implements InnerInterceptor {
+
+
+    // 重写查询方法修改表名
+    @Override
+    public void beforeQuery(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException {
+        PluginUtils.MPBoundSql mpBs = PluginUtils.mpBoundSql(boundSql);
+        if (!InterceptorIgnoreHelper.willIgnoreDynamicTableName(ms.getId())) {
+            // 非忽略执行
+            mpBs.sql(this.changeTable(mpBs.sql()));
+        }
+    }
+
+    // 重写 插入、删除、修改方法的表名
+    @Override
+    public void beforePrepare(StatementHandler sh, Connection connection, Integer transactionTimeout) {
+        PluginUtils.MPStatementHandler mpSh = PluginUtils.mpStatementHandler(sh);
+        MappedStatement ms = mpSh.mappedStatement();
+        SqlCommandType sct = ms.getSqlCommandType();
+        if (sct == SqlCommandType.INSERT || sct == SqlCommandType.UPDATE || sct == SqlCommandType.DELETE) {
+            if (!InterceptorIgnoreHelper.willIgnoreDynamicTableName(ms.getId())) {
+                // 非忽略执行
+                PluginUtils.MPBoundSql mpBs = mpSh.mPBoundSql();
+                mpBs.sql(this.changeTable(mpBs.sql()));
+            }
+        }
+    }
+
+    protected String changeTable(String sql) {
+        TableNameParser parser = new TableNameParser(sql);
+        List<TableNameParser.SqlToken> names = new ArrayList<>();
+        parser.accept(names::add);
+        StringBuilder builder = new StringBuilder();
+        int last = 0;
+        for (TableNameParser.SqlToken name : names) {
+            String tname = name.toString();
+            int start = name.getStart();
+            if (start != last) {
+                builder.append(sql, last, start);
+                builder.append("\"");
+                builder.append(tname);
+                builder.append("\"");
+            }
+            last = name.getEnd();
+        }
+
+
+        if (last != sql.length()) {
+            builder.append(sql.substring(last));
+        }
+
+        return builder.toString();
+    }
+}

base-generator/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>base</artifactId>
         <groupId>com.ozs</groupId>
-        <version>3.8.5-SNAPSHOT</version>
+        <version>1.0-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

base-quartz/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>base</artifactId>
         <groupId>com.ozs</groupId>
-        <version>3.8.5-SNAPSHOT</version>
+        <version>1.0-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

base-system/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>base</artifactId>
         <groupId>com.ozs</groupId>
-        <version>3.8.5-SNAPSHOT</version>
+        <version>1.0-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

pom.xml

@@ -6,13 +6,13 @@
 
     <groupId>com.ozs</groupId>
     <artifactId>base</artifactId>
-    <version>3.8.5-SNAPSHOT</version>
+    <version>1.0-SNAPSHOT</version>
 
     <name>base</name>
     <description>基础管理系统</description>
 
     <properties>
-        <base.version>3.8.5-SNAPSHOT</base.version>
+        <base.version>1.0-SNAPSHOT</base.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <java.version>1.8</java.version>
@@ -31,6 +31,7 @@
         <velocity.version>2.3</velocity.version>
         <jwt.version>0.9.1</jwt.version>
         <mybatis-plus.version>3.5.1</mybatis-plus.version>
+        <mybatis-plus-join.version>1.1.3</mybatis-plus-join.version>
     </properties>
 
     <!-- 依赖声明 -->
@@ -184,7 +185,12 @@
                 <artifactId>mybatis-plus-boot-starter</artifactId>
                 <version>${mybatis-plus.version}</version>
             </dependency>
-
+            <!-- mybatis-plus-join 关联查询 -->
+            <dependency>
+                <groupId>icu.mhb</groupId>
+                <artifactId>mybatis-plus-join</artifactId>
+                <version>${mybatis-plus-join.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>