多数据源切换自动判定,再添加时无需写逻辑

build.gradle

@@ -3,7 +3,7 @@ version '1.0-SNAPSHOT'
 
 buildscript {
     ext {
-        kotlin_version = '1.2.20'
+        kotlin_version = '1.2.21'
 
         commons_io_version = '2.5'
         commons_logging_version = '1.1.3'

zen-admin/build.gradle

@@ -2,6 +2,6 @@ apply plugin: 'war'
 
 dependencies {
     compile project(":zen-ui")
-//    compile project(":zen-orm")
+    compile project(":zen-orm")
     compile project(":zen-api")
 }

zen-admin/src/main/kotlin/com/gxzc/zen/A.java

@@ -1,95 +0,0 @@
-package com.gxzc.zen;
-
-import com.gxzc.zen.orm.DynamicDataSource;
-import com.gxzc.zen.orm.DynamicMultipleDataSource;
-import kotlin.TypeCastException;
-import kotlin.jvm.internal.Intrinsics;
-import org.apache.commons.lang3.StringUtils;
-import org.aspectj.lang.JoinPoint;
-import org.aspectj.lang.Signature;
-import org.aspectj.lang.annotation.Aspect;
-import org.aspectj.lang.annotation.Before;
-import org.aspectj.lang.reflect.MethodSignature;
-import org.jetbrains.annotations.NotNull;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.core.annotation.Order;
-import org.springframework.stereotype.Component;
-
-import java.lang.reflect.Field;
-import java.lang.reflect.Method;
-import java.util.Objects;
-
-@Aspect
-@Order(-1)
-@Component
-public class A {
-
-    private static final Logger logger = LoggerFactory.getLogger(A.class);
-
-//    @Before("execution(* com.gxzc.zen.api.sys..*Service.*(..))")
-//    public void sysService(@NotNull JoinPoint joinPoint) {
-//        setDataSource(joinPoint, "sysDataSource");
-//    }
-
-    @Before("execution(* com.baomidou.mybatisplus..*Service.*(..)) || execution(* com.baomidou.mybatisplus..*Mapper.*(..)) || execution(* com.gxzc.zen.api..*Service.*(..))")
-    public void dataSourceSys2(@NotNull JoinPoint joinPoint) {
-        Object o = joinPoint.getTarget();
-
-        String packageName = null;
-        try {
-            Field h = o.getClass().getSuperclass().getDeclaredField("h");
-            h.setAccessible(true);
-            Object mapperProxy = h.get(o);
-
-            Field mapperInterface = mapperProxy.getClass().getDeclaredField("mapperInterface");
-            mapperInterface.setAccessible(true);
-
-            Class<?> clazz = (Class<?>) mapperInterface.get(mapperProxy);
-
-            packageName = clazz.getPackage().getName();
-        } catch (Exception e) {
-            logger.debug("get packageName of MapperProxy error, ignore this info if nothing happened!");
-        } finally {
-            if (StringUtils.isBlank(packageName)) {
-                logger.debug("get packageName of target...");
-                packageName = joinPoint.getTarget().getClass().getPackage().getName();
-            }
-        }
-
-        matchDataSource(joinPoint, packageName);
-    }
-
-//    @Before("execution(* com.gxzc.zen.api.rec..*Service.*(..))")
-//    public void recService(@NotNull JoinPoint joinPoint) {
-//        setDataSource(joinPoint, "recDataSource");
-//    }
-
-    private void matchDataSource(JoinPoint joinPoint, String packageName) {
-        if (packageName.contains("com.gxzc.zen.api.sys")) {
-            setDataSource(joinPoint, "sysDataSource");
-        } else if (packageName.contains("com.gxzc.zen.api.rec")) {
-            setDataSource(joinPoint, "recDataSource");
-        }
-    }
-
-    private void setDataSource(JoinPoint joinPoint, String defaultKey) {
-        DynamicDataSource dynamicDataSource = this.currentMethod(joinPoint).getAnnotation(DynamicDataSource.class);
-        if (Objects.isNull(dynamicDataSource)) {
-            DynamicMultipleDataSource.Companion.setDataSource(defaultKey);
-        } else {
-            DynamicMultipleDataSource.Companion.setDataSource(dynamicDataSource.value());
-        }
-    }
-
-    private Method currentMethod(JoinPoint joinPoint) {
-        Signature var10000 = joinPoint.getSignature();
-        if (var10000 == null) {
-            throw new TypeCastException("null cannot be cast to non-null type org.aspectj.lang.reflect.MethodSignature");
-        } else {
-            Method var2 = ((MethodSignature) var10000).getMethod();
-            Intrinsics.checkExpressionValueIsNotNull(var2, "(joinPoint.signature as MethodSignature).method");
-            return var2;
-        }
-    }
-}

zen-admin/src/main/kotlin/com/gxzc/zen/controller/ExampleController.kt

@@ -1,11 +1,12 @@
 package com.gxzc.zen.controller
 
-import com.gxzc.zen.api.rec.model.SysDic
-import com.gxzc.zen.api.rec.service.ISysDicService
+import com.gxzc.zen.api.bus.model.SysDic
+import com.gxzc.zen.api.bus.service.ISysDicService
 import com.gxzc.zen.api.sys.mapper.SysDeptMapper
 import com.gxzc.zen.api.sys.model.SysDept
 import com.gxzc.zen.api.sys.service.ISysDeptService
-import com.gxzc.zen.api.usage.model.SysParam
+import com.gxzc.zen.orm.annotation.DynamicDataSource
+import com.gxzc.zen.orm.contants.DSKey
 import org.slf4j.LoggerFactory
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.stereotype.Controller
@@ -16,7 +17,7 @@ import org.springframework.web.bind.annotation.RequestMapping
 @RequestMapping("example")
 class ExampleController {
     companion object {
-        val logger = LoggerFactory.getLogger(ExampleController::class.java)
+        private val logger = LoggerFactory.getLogger(ExampleController::class.java)
     }
 
     @Autowired
@@ -47,6 +48,7 @@ class ExampleController {
     }
 
     @RequestMapping("/test2")
+    @DynamicDataSource(DSKey.DSKEY_SYS)
     fun test2() {
         val sysDic = SysDic().also {
             it.key = "hehe"
@@ -56,18 +58,7 @@ class ExampleController {
 //        for (i in 1..1000) {
 //            sysDicService.insert(sysDic)
 //        }
-        sysDicService.insert(sysDic)
-//        logger.info("count: {}", sysDicService.custom())
-    }
-
-    @RequestMapping("/test3")
-    fun test3() {
-        val sysParam = SysParam().also {
-            it.key = "a"
-            it.value = "b"
-            it.sort = Integer(1)
-        }
-
-//        sysParamService.insert(sysParam)
+        // sysDicService.insert(sysDic)
+        logger.info("count: {}", sysDicService.custom())
     }
 }

zen-api/build.gradle

@@ -1,6 +1,5 @@
 dependencies {
     compile project(":zen-umps")
-    compile project(":zen-orm")
 }
 
 jar{

zen-api/src/main/kotlin/com/gxzc/zen/api/rec/mapper/SysDicMapper.kt → zen-api/src/main/kotlin/com/gxzc/zen/api/bus/mapper/SysDicMapper.kt

@@ -1,6 +1,6 @@
-package com.gxzc.zen.api.rec.mapper;
+package com.gxzc.zen.api.bus.mapper;
 
-import com.gxzc.zen.api.rec.model.SysDic;
+import com.gxzc.zen.api.bus.model.SysDic;
 import com.gxzc.zen.common.base.BaseMapper;
 import org.springframework.stereotype.Repository
 

zen-api/src/main/kotlin/com/gxzc/zen/api/rec/model/SysDic.kt → zen-api/src/main/kotlin/com/gxzc/zen/api/bus/model/SysDic.kt

@@ -1,4 +1,4 @@
-package com.gxzc.zen.api.rec.model;
+package com.gxzc.zen.api.bus.model;
 
 import com.gxzc.zen.common.base.BaseModel;
 

zen-api/src/main/kotlin/com/gxzc/zen/api/rec/service/ISysDicService.kt → zen-api/src/main/kotlin/com/gxzc/zen/api/bus/service/ISysDicService.kt

@@ -1,6 +1,6 @@
-package com.gxzc.zen.api.rec.service;
+package com.gxzc.zen.api.bus.service;
 
-import com.gxzc.zen.api.rec.model.SysDic;
+import com.gxzc.zen.api.bus.model.SysDic;
 import com.gxzc.zen.common.base.BaseService;
 
 /**

zen-api/src/main/kotlin/com/gxzc/zen/api/rec/service/impl/SysDicServiceImpl.kt → zen-api/src/main/kotlin/com/gxzc/zen/api/bus/service/impl/SysDicServiceImpl.kt

@@ -1,8 +1,8 @@
-package com.gxzc.zen.api.rec.service.impl;
+package com.gxzc.zen.api.bus.service.impl;
 
-import com.gxzc.zen.api.rec.model.SysDic;
-import com.gxzc.zen.api.rec.mapper.SysDicMapper;
-import com.gxzc.zen.api.rec.service.ISysDicService;
+import com.gxzc.zen.api.bus.model.SysDic;
+import com.gxzc.zen.api.bus.mapper.SysDicMapper;
+import com.gxzc.zen.api.bus.service.ISysDicService;
 import com.baomidou.mybatisplus.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 

zen-api/src/main/kotlin/com/gxzc/zen/api/usage/mapper/SysParamMapper.kt

@@ -1,16 +0,0 @@
-package com.gxzc.zen.api.usage.mapper;
-
-import com.gxzc.zen.api.usage.model.SysParam;
-import com.gxzc.zen.common.base.BaseMapper;
-import org.springframework.stereotype.Repository
-
-/**
- * <p>
- * 系统参数表 Mapper 接口
- * </p>
- *
- * @author NorthLan123
- * @since 2018-01-27
- */
-@Repository
-interface SysParamMapper : BaseMapper<SysParam>

zen-api/src/main/kotlin/com/gxzc/zen/api/usage/model/SysParam.kt

@@ -1,36 +0,0 @@
-package com.gxzc.zen.api.usage.model;
-
-import com.gxzc.zen.common.base.BaseModel;
-
-/**
- * <p>
- * 系统参数表
- * </p>
- *
- * @author NorthLan123
- * @since 2018-01-27
- */
-class SysParam : BaseModel() {
-
-    /**
-     * 参数key
-     */
-    var key: String? = null
-    /**
-     * 参数值
-     */
-    var value: String? = null
-    /**
-     * 排序号
-     */
-    var sort: Integer? = null
-
-
-    override fun toString(): String {
-        return "SysParam{" +
-        ", key=" + key +
-        ", value=" + value +
-        ", sort=" + sort +
-        "}"
-    }
-}

zen-api/src/main/kotlin/com/gxzc/zen/api/usage/service/ISysParamService.kt

@@ -1,14 +0,0 @@
-package com.gxzc.zen.api.usage.service;
-
-import com.gxzc.zen.api.usage.model.SysParam;
-import com.gxzc.zen.common.base.BaseService;
-
-/**
- * <p>
- * 系统参数表 服务类
- * </p>
- *
- * @author NorthLan123
- * @since 2018-01-27
- */
-interface ISysParamService : BaseService<SysParam>

zen-api/src/main/kotlin/com/gxzc/zen/api/usage/service/impl/SysParamServiceImpl.kt

@@ -1,19 +0,0 @@
-package com.gxzc.zen.api.usage.service.impl;
-
-import com.baomidou.mybatisplus.service.impl.ServiceImpl
-import com.gxzc.zen.api.usage.mapper.SysParamMapper
-import com.gxzc.zen.api.usage.model.SysParam
-import com.gxzc.zen.api.usage.service.ISysParamService
-
-/**
- * <p>
- * 系统参数表 服务实现类
- * </p>
- *
- * @author NorthLan123
- * @since 2018-01-27
- */
-//@Service
-open class SysParamServiceImpl : ServiceImpl<SysParamMapper, SysParam>(), ISysParamService {
-
-}

zen-api/src/main/resources/mapping/rec/SysDicMapper.xml → zen-api/src/main/resources/mapping/bus/SysDicMapper.xml

@@ -1,9 +1,9 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gxzc.zen.api.rec.mapper.SysDicMapper">
+<mapper namespace="com.gxzc.zen.api.bus.mapper.SysDicMapper">
 
     <!-- 通用查询映射结果 -->
-    <resultMap id="BaseResultMap" type="com.gxzc.zen.api.rec.model.SysDic">
+    <resultMap id="BaseResultMap" type="com.gxzc.zen.api.bus.model.SysDic">
         <result column="id" property="id"/>
         <result column="enable" property="enable"/>
         <result column="remark" property="remark"/>

zen-api/src/main/resources/mapping/usage/SysParamMapper.xml

@@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gxzc.zen.api.usage.mapper.SysParamMapper">
-
-    <!-- 通用查询映射结果 -->
-    <resultMap id="BaseResultMap" type="com.gxzc.zen.api.usage.model.SysParam">
-    <result column="id" property="id" />
-    <result column="enable" property="enable" />
-    <result column="remark" property="remark" />
-    <result column="create_time" property="createTime" />
-    <result column="create_by" property="createBy" />
-    <result column="update_time" property="updateTime" />
-    <result column="update_by" property="updateBy" />
-        <result column="key" property="key" />
-        <result column="value" property="value" />
-        <result column="sort" property="sort" />
-    </resultMap>
-
-</mapper>

zen-orm/build.gradle

@@ -1,4 +1,4 @@
 dependencies {
     compile project(":zen-common")
-//    compile project(":zen-api")
+    compile project(":zen-api")
 }

zen-orm/src/main/java/a/A.java

@@ -1,55 +0,0 @@
-package a;
-
-import com.gxzc.zen.orm.DynamicDataSource;
-import com.gxzc.zen.orm.DynamicMultipleDataSource;
-import kotlin.TypeCastException;
-import kotlin.jvm.internal.Intrinsics;
-import org.aspectj.lang.JoinPoint;
-import org.aspectj.lang.Signature;
-import org.aspectj.lang.annotation.Aspect;
-import org.aspectj.lang.annotation.Before;
-import org.aspectj.lang.reflect.MethodSignature;
-import org.jetbrains.annotations.NotNull;
-import org.springframework.core.annotation.Order;
-import org.springframework.stereotype.Component;
-
-import java.lang.reflect.Method;
-import java.util.Objects;
-
-@Aspect
-@Order(-1)
-@Component
-public class A {
-
-    @Before("execution(* com.gxzc.zen.api.sys.*.*Service.*(..))")
-    public void dataSourceSys(@NotNull JoinPoint joinPoint) {
-        Intrinsics.checkParameterIsNotNull(joinPoint, "joinPoint");
-        this.setDataSource(joinPoint, "sysDataSource");
-    }
-
-    @Before("execution(* com.gxzc.zen.api.rec.*.*Service.*(..))")
-    public void dataSourceRec(@NotNull JoinPoint joinPoint) {
-        Intrinsics.checkParameterIsNotNull(joinPoint, "joinPoint");
-        this.setDataSource(joinPoint, "recDataSource");
-    }
-
-    private void setDataSource(JoinPoint joinPoint, String defaultKey) {
-        DynamicDataSource dynamicDataSource = this.currentMethod(joinPoint).getAnnotation(DynamicDataSource.class);
-        if (Objects.isNull(dynamicDataSource)) {
-            DynamicMultipleDataSource.Companion.setDataSource(defaultKey);
-        } else {
-            DynamicMultipleDataSource.Companion.setDataSource(dynamicDataSource.value());
-        }
-    }
-
-    private Method currentMethod(JoinPoint joinPoint) {
-        Signature var10000 = joinPoint.getSignature();
-        if (var10000 == null) {
-            throw new TypeCastException("null cannot be cast to non-null type org.aspectj.lang.reflect.MethodSignature");
-        } else {
-            Method var2 = ((MethodSignature) var10000).getMethod();
-            Intrinsics.checkExpressionValueIsNotNull(var2, "(joinPoint.signature as MethodSignature).method");
-            return var2;
-        }
-    }
-}

zen-orm/src/main/kotlin/com/gxzc/zen/Generator.kt

@@ -79,7 +79,7 @@ fun main(args: Array<String>) {
     // 包配置
     val pc = PackageConfig()
     with(pc) {
-        parent = "com.gxzc.zen.api.rec"
+        parent = "com.gxzc.zen.api.bus"
 //        moduleName = "zen-orm"
         entity = "model"
     }

zen-orm/src/main/kotlin/com/gxzc/zen/orm/DataSourceSwitchAspect.kt

@@ -1,44 +0,0 @@
-package com.gxzc.zen.orm
-
-import org.aspectj.lang.JoinPoint
-import org.aspectj.lang.annotation.Aspect
-import org.aspectj.lang.annotation.Before
-import org.aspectj.lang.reflect.MethodSignature
-import org.springframework.core.annotation.Order
-import java.lang.reflect.Method
-import java.util.*
-
-/**
- *
- * @author NorthLan at 2018/1/29
- */
-@Aspect
-@Order(-1)
-class DataSourceSwitchAspect {
-
-    @Before("execution(* com.gxzc.zen.api.sys.*.*Service.*(..))")
-    fun dataSourceSys(joinPoint: JoinPoint) {
-        setDataSource(joinPoint, MultipleDataSourceConfig.DS_KEY_SYS)
-    }
-
-    @Before("execution(* com.gxzc.zen.api.rec.*.*Service.*(..))")
-    fun dataSourceRec(joinPoint: JoinPoint) {
-        setDataSource(joinPoint, MultipleDataSourceConfig.DS_KEY_REC)
-    }
-
-    /**
-     * 设置数据源key
-     */
-    private fun setDataSource(joinPoint: JoinPoint, defaultKey: String) {
-        val dynamicDataSource = currentMethod(joinPoint).getAnnotation(DynamicDataSource::class.java)
-        if (Objects.isNull(dynamicDataSource)) {
-            DynamicMultipleDataSource.setDataSource(defaultKey)
-            return
-        }
-        DynamicMultipleDataSource.setDataSource(dynamicDataSource.value)
-    }
-
-    private fun currentMethod(joinPoint: JoinPoint): Method {
-        return (joinPoint.signature as MethodSignature).method
-    }
-}

zen-orm/src/main/kotlin/com/gxzc/zen/orm/DataSourceSwitchMethodInterceptor.kt

@@ -1,35 +0,0 @@
-//package com.gxzc.zen.orm
-//
-//import org.aopalliance.intercept.MethodInterceptor
-//import org.aopalliance.intercept.MethodInvocation
-//import java.lang.reflect.Method
-//import java.util.*
-//
-///**
-// *
-// * @author NorthLan at 2018/1/29
-// */
-//
-//class DataSourceSwitchMethodInterceptor : MethodInterceptor {
-//    override fun invoke(invocation: MethodInvocation): Any {
-//        val packageName = invocation.`this`.javaClass.`package`.name
-//        if ("api.sys" in packageName) {
-//            setDataSourceKey(invocation.method, MultipleDataSourceConfig.DS_KEY_SYS)
-//        } else if ("api.rec" in packageName) {
-//            setDataSourceKey(invocation.method, MultipleDataSourceConfig.DS_KEY_REC)
-//        }
-//        return invocation.proceed()
-//    }
-//
-//    /**
-//     * 设置数据源key
-//     */
-//    private fun setDataSourceKey(method: Method, defaultKey: String) {
-//        val dynamicDataSource = method.getAnnotation(DynamicDataSource::class.java)
-//        if (Objects.isNull(dynamicDataSource)) {
-//            DynamicMultipleDataSource.setDataSource(defaultKey)
-//            return
-//        }
-//        DynamicMultipleDataSource.setDataSource(dynamicDataSource.value)
-//    }
-//}

zen-orm/src/main/kotlin/com/gxzc/zen/orm/DruidConfig.kt

@@ -1,121 +0,0 @@
-//package com.gxzc.zen.orm
-//
-///**
-// *
-// * @author NorthLan at 2018/1/27
-// */
-//import com.alibaba.druid.pool.DruidDataSource
-//import com.alibaba.druid.support.http.StatViewServlet
-//import com.alibaba.druid.support.http.WebStatFilter
-//import org.mybatis.spring.annotation.MapperScan
-//import org.slf4j.LoggerFactory
-//import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
-//import org.springframework.boot.context.properties.ConfigurationProperties
-//import org.springframework.boot.web.servlet.FilterRegistrationBean
-//import org.springframework.boot.web.servlet.ServletRegistrationBean
-//import org.springframework.context.annotation.Bean
-//import org.springframework.context.annotation.Configuration
-//import java.sql.SQLException
-//import javax.sql.DataSource
-//
-//
-//@Configuration
-//@ConfigurationProperties(prefix = "druid.datasource.sys")
-//@MapperScan(basePackages = ["com.gxzc.zen.api.sys.mapper"])
-//class SysDruidConfig : DruidConfig()
-//
-//
-////@Configuration
-////@ConfigurationProperties(prefix = "druid.datasource.rec")
-////@MapperScan(basePackages = ["com.gxzc.zen.api.rec.mapper"])
-////class RecDruidConfig : DruidConfig()
-///**
-// * druid数据源bean注册
-// */
-//open class DruidConfig {
-//    var url: String? = null
-//    var username: String? = null
-//    var password: String? = null
-//    var filters: String? = null
-//
-//    var driverClassName: String? = "com.mysql.jdbc.Driver"
-//    var initialSize: Int = 5
-//    var minIdle: Int = 5
-//    var maxActive: Int = 20
-//    var maxWait: Long = 60000
-//
-//    var timeBetweenEvictionRunsMillis: Long = 60000
-//    var minEvictableIdleTimeMillis: Long = 30000
-//    var validationQuery: String? = null
-//    var testWhileIdle: Boolean = true
-//    var testOnBorrow: Boolean = false
-//    var testOnReturn: Boolean = false
-//
-//    private val logger = LoggerFactory.getLogger(javaClass)
-//
-//    private var datasource: DruidDataSource? = null
-//
-//    @Bean
-//    open fun druidDataSource(): DataSource? {
-//        datasource = DruidDataSource().also {
-//            it.url = url
-//            it.username = username
-//            it.password = password
-//            it.driverClassName = driverClassName
-//            it.initialSize = initialSize
-//            it.minIdle = minIdle
-//            it.maxActive = maxActive
-//            it.maxWait = maxWait
-//            it.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis
-//            it.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis
-//            it.validationQuery = validationQuery
-//            it.isTestWhileIdle = testWhileIdle
-//            it.isTestOnBorrow = testOnBorrow
-//            it.isTestOnReturn = testOnReturn
-//        }
-//        try {
-//            datasource?.setFilters(filters)
-//        } catch (e: SQLException) {
-//            logger.error("druid configuration initialization filter", e)
-//        }
-//
-//        return datasource
-//    }
-//
-//    fun getDatasource(): DruidDataSource? {
-//        return datasource
-//    }
-//}
-//
-///**
-// * 配置druid显示界面
-// */
-//@Configuration
-//@ConfigurationProperties(prefix = "druid.view")
-//@ConditionalOnProperty(prefix = "druid.view", name = ["enable"], havingValue = "true", matchIfMissing = true)
-//open class DruidViewConfig {
-//    var username: String? = null
-//    var password: String? = null
-//    var slowSql: String? = null
-//
-//    @Bean
-//    open fun druidServlet(): ServletRegistrationBean {
-//        return ServletRegistrationBean().also {
-//            it.setServlet(StatViewServlet())
-//            it.addUrlMappings("/druid/*")
-//            it.addInitParameter("loginUsername", username)
-//            it.addInitParameter("loginPassword", password)
-//            it.addInitParameter("logSlowSql", slowSql)
-//        }
-//    }
-//
-//    @Bean
-//    open fun filterRegistrationBean(): FilterRegistrationBean {
-//        return FilterRegistrationBean().also {
-//            it.filter = WebStatFilter()
-//            it.addUrlPatterns("/*")
-//            it.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*")
-//            it.addInitParameter("profileEnable", "true")
-//        }
-//    }
-//}

zen-orm/src/main/kotlin/com/gxzc/zen/orm/DynamicMultipleDataSource.kt

@@ -1,5 +1,6 @@
 package com.gxzc.zen.orm
 
+import com.gxzc.zen.orm.contants.DSKey
 import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource
 
 /**
@@ -8,7 +9,7 @@ import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource
  */
 class DynamicMultipleDataSource : AbstractRoutingDataSource() {
     init {
-        DATA_SOURCE_KEY.set(MultipleDataSourceConfig.DS_KEY_SYS)
+        DATA_SOURCE_KEY.set(DSKey.DSKEY_SYS)
     }
 
     companion object {

zen-orm/src/main/kotlin/com/gxzc/zen/orm/RecDataSourceConfig.kt

@@ -1,64 +0,0 @@
-//package com.gxzc.zen.orm
-//
-//import com.alibaba.druid.pool.DruidDataSource
-//import com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean
-//import com.baomidou.mybatisplus.spring.boot.starter.MybatisPlusProperties
-//import com.baomidou.mybatisplus.spring.boot.starter.SpringBootVFS
-//import org.apache.ibatis.session.SqlSessionFactory
-//import org.mybatis.spring.annotation.MapperScan
-//import org.slf4j.Logger
-//import org.slf4j.LoggerFactory
-//import org.springframework.beans.factory.annotation.Autowired
-//import org.springframework.beans.factory.annotation.Qualifier
-//import org.springframework.boot.context.properties.ConfigurationProperties
-//import org.springframework.boot.context.properties.EnableConfigurationProperties
-//import org.springframework.context.annotation.Bean
-//import org.springframework.context.annotation.Configuration
-//import org.springframework.core.io.support.PathMatchingResourcePatternResolver
-//import org.springframework.jdbc.datasource.DataSourceTransactionManager
-//import javax.sql.DataSource
-//
-///**
-// * Rec 数据源配置<br>
-// * 扫描路径为 com.gxzc.zen.*.rec
-// * @author NorthLan at 2018/1/26
-// */
-//@Configuration
-//@EnableConfigurationProperties(MybatisPlusProperties::class)
-//@MapperScan(basePackages = ["com.gxzc.zen.api.rec.mapper"], sqlSessionFactoryRef = RecDataSourceConfig.SQL_SESSION_FACTORY_NAME)
-//class RecDataSourceConfig {
-//    companion object {
-//        const val DATASOURCE_NAME: String = "recDataSource"
-//        const val TRANSACTION_MANAGER_NAME: String = "recTransactionManager"
-//        const val SQL_SESSION_FACTORY_NAME: String = "recSqlSessionFactory"
-//        val logger: Logger = LoggerFactory.getLogger(RecDataSourceConfig::class.java)
-//    }
-//
-//    @Autowired
-//    private lateinit var properties: MybatisPlusProperties
-//
-//    private val mapperLocation: String = "classpath:/mapping/rec/*.xml"
-//
-////    @Bean(DATASOURCE_NAME)
-////    @ConfigurationProperties(prefix = "datasource.rec")
-////    fun dataSource(): DataSource {
-////        return DruidDataSource()
-////    }
-//
-//    @Bean(TRANSACTION_MANAGER_NAME)
-//    fun transactionManager(@Qualifier(DATASOURCE_NAME) dataSource: DataSource): DataSourceTransactionManager {
-//        return DataSourceTransactionManager(dataSource)
-//    }
-//
-//    @Bean(SQL_SESSION_FACTORY_NAME)
-//    fun sqlSessionFactory(@Qualifier(DATASOURCE_NAME) dataSource: DataSource): SqlSessionFactory {
-//        return MybatisSqlSessionFactoryBean().let {
-//            it.setDataSource(dataSource)
-//            it.vfs = SpringBootVFS::class.java
-//            it.setConfiguration(properties.configuration)
-//            it.setGlobalConfig(properties.globalConfig?.convertGlobalConfiguration())
-//            it.setMapperLocations(PathMatchingResourcePatternResolver().getResources(mapperLocation))
-//            it.`object`
-//        }
-//    }
-//}

zen-orm/src/main/kotlin/com/gxzc/zen/orm/SysDataSourceConfig.kt

@@ -1,68 +0,0 @@
-//package com.gxzc.zen.orm
-//
-//import com.alibaba.druid.pool.DruidDataSource
-//import com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean
-//import com.baomidou.mybatisplus.spring.boot.starter.MybatisPlusProperties
-//import com.baomidou.mybatisplus.spring.boot.starter.SpringBootVFS
-//import org.apache.ibatis.session.SqlSessionFactory
-//import org.mybatis.spring.annotation.MapperScan
-//import org.slf4j.Logger
-//import org.slf4j.LoggerFactory
-//import org.springframework.beans.factory.annotation.Autowired
-//import org.springframework.beans.factory.annotation.Qualifier
-//import org.springframework.boot.context.properties.ConfigurationProperties
-//import org.springframework.boot.context.properties.EnableConfigurationProperties
-//import org.springframework.context.annotation.Bean
-//import org.springframework.context.annotation.Configuration
-//import org.springframework.context.annotation.Primary
-//import org.springframework.core.io.support.PathMatchingResourcePatternResolver
-//import org.springframework.jdbc.datasource.DataSourceTransactionManager
-//import javax.sql.DataSource
-//
-///**
-// * Sys 数据源配置<br>
-// * 扫描路径为 com.gxzc.zen.*.sys
-// * @author NorthLan at 2018/1/26
-// */
-//@Configuration
-//@EnableConfigurationProperties(MybatisPlusProperties::class)
-//@MapperScan(basePackages = ["com.gxzc.zen.api.sys.mapper"], sqlSessionFactoryRef = SysDataSourceConfig.SQL_SESSION_FACTORY_NAME)
-//class SysDataSourceConfig {
-//    companion object {
-//        const val DATASOURCE_NAME: String = "sysDataSource"
-//        const val TRANSACTION_MANAGER_NAME: String = "sysTransactionManager"
-//        const val SQL_SESSION_FACTORY_NAME: String = "sysSqlSessionFactory"
-//        val logger: Logger = LoggerFactory.getLogger(SysDataSourceConfig::class.java)
-//    }
-//
-//    @Autowired
-//    private lateinit var properties: MybatisPlusProperties
-//
-//    private val mapperLocation: String = "classpath:/mapping/sys/*.xml"
-//
-////    @Bean(DATASOURCE_NAME)
-////    @ConfigurationProperties(prefix = "datasource.sys")
-////    @Primary
-////    fun dataSource(): DataSource {
-////        return DruidDataSource()
-////    }
-//
-//    @Bean(TRANSACTION_MANAGER_NAME)
-//    @Primary
-//    fun transactionManager(@Qualifier(DATASOURCE_NAME) dataSource: DataSource): DataSourceTransactionManager {
-//        return DataSourceTransactionManager(dataSource)
-//    }
-//
-//    @Bean(SQL_SESSION_FACTORY_NAME)
-//    @Primary
-//    fun sqlSessionFactory(@Qualifier(DATASOURCE_NAME) dataSource: DataSource): SqlSessionFactory {
-//        return MybatisSqlSessionFactoryBean().let {
-//            it.setDataSource(dataSource)
-//            it.vfs = SpringBootVFS::class.java
-//            it.setConfiguration(properties.configuration)
-//            it.setGlobalConfig(properties.globalConfig?.convertGlobalConfiguration())
-//            it.setMapperLocations(PathMatchingResourcePatternResolver().getResources(mapperLocation))
-//            it.`object`
-//        }
-//    }
-//}

zen-orm/src/main/kotlin/com/gxzc/zen/orm/UsageDataSourceConfig.kt

@@ -1,69 +0,0 @@
-//package com.gxzc.zen.orm
-//
-//import com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean
-//import com.baomidou.mybatisplus.spring.boot.starter.MybatisPlusProperties
-//import com.baomidou.mybatisplus.spring.boot.starter.SpringBootVFS
-//import org.apache.ibatis.session.SqlSessionFactory
-//import org.mybatis.spring.SqlSessionTemplate
-//import org.mybatis.spring.annotation.MapperScan
-//import org.slf4j.Logger
-//import org.slf4j.LoggerFactory
-//import org.springframework.beans.factory.annotation.Autowired
-//import org.springframework.beans.factory.annotation.Qualifier
-//import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder
-//import org.springframework.boot.context.properties.ConfigurationProperties
-//import org.springframework.context.annotation.Bean
-//import org.springframework.context.annotation.Configuration
-//import org.springframework.core.io.support.PathMatchingResourcePatternResolver
-//import org.springframework.jdbc.datasource.DataSourceTransactionManager
-//import javax.sql.DataSource
-//
-///**
-// * Usage 数据源配置<br>
-// * 扫描路径为 com.gxzc.zen.*.usage
-// * @author NorthLan at 2018/1/26
-// */
-//@Configuration
-//@MapperScan(basePackages = ["com.gxzc.zen.api.usage.mapper"], sqlSessionTemplateRef = UsageDataSourceConfig.SQL_SESSION_TEMPLATE_NAME)
-//class UsageDataSourceConfig {
-//    companion object {
-//        const val DATASOURCE_NAME: String = "usageDataSource"
-//        const val TRANSACTION_MANAGER_NAME: String = "usageTransactionManager"
-//        const val SQL_SESSION_FACTORY_NAME: String = "usageSqlSessionFactory"
-//        const val SQL_SESSION_TEMPLATE_NAME: String = "usageSqlSessionTemplate"
-//        val logger: Logger = LoggerFactory.getLogger(UsageDataSourceConfig::class.java)
-//    }
-//
-//    @Autowired
-//    private lateinit var properties: MybatisPlusProperties
-//
-//    private val mapperLocation: String = "classpath:/mapping/usage/*.xml"
-//
-//    @Bean(DATASOURCE_NAME)
-//    @ConfigurationProperties(prefix = "druid.datasource.usage")
-//    fun dataSource(): DataSource {
-//        return DataSourceBuilder.create().build()
-//    }
-//
-//    @Bean(TRANSACTION_MANAGER_NAME)
-//    fun transactionManager(@Qualifier(DATASOURCE_NAME) dataSource: DataSource): DataSourceTransactionManager {
-//        return DataSourceTransactionManager(dataSource)
-//    }
-//
-//    @Bean(SQL_SESSION_FACTORY_NAME)
-//    fun sqlSessionFactory(@Qualifier(DATASOURCE_NAME) dataSource: DataSource): SqlSessionFactory {
-//        return MybatisSqlSessionFactoryBean().let {
-//            it.setDataSource(dataSource)
-//            it.vfs = SpringBootVFS::class.java
-//            it.setConfiguration(properties.configuration)
-//            it.setGlobalConfig(properties.globalConfig.convertGlobalConfiguration())
-//            it.setMapperLocations(PathMatchingResourcePatternResolver().getResources(mapperLocation))
-//            it.`object`
-//        }
-//    }
-//
-//    @Bean(SQL_SESSION_TEMPLATE_NAME)
-//    fun sqlSessionTemplate(@Qualifier(SQL_SESSION_FACTORY_NAME) sqlSessionFactory: SqlSessionFactory): SqlSessionTemplate {
-//        return SqlSessionTemplate(sqlSessionFactory)
-//    }
-//}

zen-orm/src/main/kotlin/com/gxzc/zen/orm/DynamicDataSource.kt → zen-orm/src/main/kotlin/com/gxzc/zen/orm/annotation/DynamicDataSource.kt

@@ -1,4 +1,4 @@
-package com.gxzc.zen.orm
+package com.gxzc.zen.orm.annotation
 
 import org.springframework.core.annotation.AliasFor
 

zen-orm/src/main/kotlin/com/gxzc/zen/orm/aspect/DataSourceSwitchAspect.kt

@@ -0,0 +1,86 @@
+package com.gxzc.zen.orm.aspect
+
+import com.gxzc.zen.orm.annotation.DynamicDataSource
+import com.gxzc.zen.orm.DynamicMultipleDataSource
+import com.gxzc.zen.orm.contants.DSKey
+import org.aspectj.lang.JoinPoint
+import org.aspectj.lang.annotation.Aspect
+import org.aspectj.lang.annotation.Before
+import org.aspectj.lang.annotation.Pointcut
+import org.aspectj.lang.reflect.MethodSignature
+import org.slf4j.LoggerFactory
+import org.springframework.core.annotation.Order
+import org.springframework.stereotype.Component
+import java.lang.reflect.Method
+
+/**
+ *
+ * @author NorthLan at 2018/1/29
+ */
+@Suppress("unused")
+@Aspect
+@Order(-1) // 保证先于事务执行
+@Component
+class DataSourceSwitchAspect {
+    companion object {
+        private val logger = LoggerFactory.getLogger(DataSourceSwitchAspect::class.java)
+    }
+
+    var isControllerDataSourceAnnotation = false
+
+    @Pointcut("execution(* com.gxzc.zen.api..*Service.*(..))")
+    fun zenServicePointCut() {
+    }
+
+    @Pointcut("execution(* com.baomidou.mybatisplus..*Service.*(..))")
+    fun mpServicePointCut() {
+    }
+
+    @Pointcut("execution(* com.baomidou.mybatisplus..*Mapper.*(..))")
+    fun mpMapperPointCut() {
+
+    }
+
+    // @Pointcut("execution(* Controller.*(..))")
+
+    @Before("zenServicePointCut() || mpServicePointCut() || mpMapperPointCut()")
+    fun dynamicDataSource(joinPoint: JoinPoint) {
+        if (isControllerDataSourceAnnotation) {
+            return
+        }
+        val target = joinPoint.target
+
+        val packageName: String = try {
+            val h = target::class.java.superclass.getDeclaredField("h")
+            h.isAccessible = true
+            val mapperProxy = h.get(target)
+
+            val mapperInterface = mapperProxy.javaClass.getDeclaredField("mapperInterface")
+            mapperInterface.isAccessible = true
+
+            val clazz = mapperInterface.get(mapperProxy) as Class<*>
+
+            clazz.`package`.name
+        } catch (e: Exception) {
+            logger.debug("get packageName of MapperProxy error, ignore if nothing happened!")
+            logger.debug("set packageName of target...")
+            target::class.java.`package`.name
+        }
+
+        matchDataSource((joinPoint.signature as MethodSignature).method, packageName)
+    }
+
+    private fun matchDataSource(method: Method, packageName: String) {
+        DSKey.values()
+                .filter { it.pkgName in packageName }
+                .forEach { setDataSource(method, it.dsKey) }
+    }
+
+    /**
+     * 设置数据源key
+     */
+    private fun setDataSource(method: Method, defaultKey: String) {
+        val dynamicDataSource: DynamicDataSource? = method.getAnnotation(DynamicDataSource::class.java)
+        DynamicMultipleDataSource.setDataSource(dynamicDataSource?.value ?: defaultKey)
+    }
+}

zen-orm/src/main/kotlin/com/gxzc/zen/orm/MultipleDataSourceConfig.kt → zen-orm/src/main/kotlin/com/gxzc/zen/orm/config/MultipleDataSourceConfig.kt

@@ -1,10 +1,11 @@
-package com.gxzc.zen.orm
+package com.gxzc.zen.orm.config
 
 import com.alibaba.druid.pool.DruidDataSource
 import com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean
 import com.baomidou.mybatisplus.spring.boot.starter.MybatisPlusProperties
 import com.baomidou.mybatisplus.spring.boot.starter.SpringBootVFS
-import org.mybatis.spring.annotation.MapperScan
+import com.gxzc.zen.orm.DynamicMultipleDataSource
+import com.gxzc.zen.orm.contants.DSKey
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.beans.factory.annotation.Qualifier
 import org.springframework.boot.context.properties.ConfigurationProperties
@@ -12,7 +13,6 @@ import org.springframework.boot.context.properties.EnableConfigurationProperties
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 import org.springframework.context.annotation.Primary
-import org.springframework.core.io.support.PathMatchingResourcePatternResolver
 import org.springframework.jdbc.datasource.DataSourceTransactionManager
 import javax.sql.DataSource
 
@@ -22,37 +22,28 @@ import javax.sql.DataSource
  */
 @Configuration
 @EnableConfigurationProperties(MybatisPlusProperties::class)
-@MapperScan("com.gxzc.zen.api.*.mapper")
 class MultipleDataSourceConfig {
-    companion object {
-        const val DS_KEY_SYS = "sysDataSource"
-        const val DS_KEY_REC = "recDataSource"
-    }
-
     @Autowired
     private lateinit var properties: MybatisPlusProperties
 
-    private val mapperLocation: String = "classpath:/mapping/*/*.xml"
-
-
-    @Bean(DS_KEY_SYS)
+    @Bean(DSKey.DSKEY_SYS)
     @ConfigurationProperties(prefix = "datasource.sys")
     @Primary
     fun dataSourceSys(): DataSource {
         return DruidDataSource()
     }
 
-    @Bean(DS_KEY_REC)
-    @ConfigurationProperties(prefix = "datasource.rec")
+    @Bean(DSKey.DSKEY_BUSINESS)
+    @ConfigurationProperties(prefix = "datasource.bus")
     fun dataSourceRec(): DataSource {
         return DruidDataSource()
     }
 
     @Bean
-    fun multipleDataSource(@Qualifier(DS_KEY_SYS) dataSourceSys: DataSource,
-                           @Qualifier(DS_KEY_REC) dataSourceRec: DataSource): DynamicMultipleDataSource {
+    fun multipleDataSource(@Qualifier(DSKey.DSKEY_SYS) dataSourceSys: DataSource,
+                           @Qualifier(DSKey.DSKEY_BUSINESS) dataSourceRec: DataSource): DynamicMultipleDataSource {
         return DynamicMultipleDataSource().also {
-            it.setTargetDataSources(mapOf(Pair(DS_KEY_SYS, dataSourceSys), Pair(DS_KEY_REC, dataSourceRec)))
+            it.setTargetDataSources(mapOf(Pair(DSKey.DSKEY_SYS, dataSourceSys), Pair(DSKey.DSKEY_BUSINESS, dataSourceRec)))
             it.setDefaultTargetDataSource(dataSourceSys)
         }
     }
@@ -70,7 +61,7 @@ class MultipleDataSourceConfig {
             it.vfs = SpringBootVFS::class.java
             it.setConfiguration(properties.configuration)
             it.setGlobalConfig(properties.globalConfig?.convertGlobalConfiguration())
-            it.setMapperLocations(PathMatchingResourcePatternResolver().getResources(mapperLocation))
+            it.setMapperLocations(properties.resolveMapperLocations())
         }
     }
 

zen-orm/src/main/kotlin/com/gxzc/zen/orm/config/MybatisPlusConfig.kt

@@ -0,0 +1,34 @@
+package com.gxzc.zen.orm.config
+
+import com.baomidou.mybatisplus.plugins.PaginationInterceptor
+import com.baomidou.mybatisplus.plugins.PerformanceInterceptor
+import org.mybatis.spring.annotation.MapperScan
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Profile
+
+/**
+ *
+ * @author NorthLan at 2018/1/30
+ */
+@Configuration
+@MapperScan("com.gxzc.zen.api.*.mapper")
+class MybatisPlusConfig {
+
+    /**
+     * 性能分析插件
+     */
+    @Bean
+    @Profile("dev") // 开发环境开启
+    fun performanceInterceptor(): PerformanceInterceptor {
+        return PerformanceInterceptor().also { it.isFormat = true }
+    }
+
+    /**
+     * 分页插件
+     */
+    @Bean
+    fun paginationInterceptor(): PaginationInterceptor {
+        return PaginationInterceptor()
+    }
+}

zen-orm/src/main/kotlin/com/gxzc/zen/orm/contants/DSKey.kt

@@ -0,0 +1,15 @@
+package com.gxzc.zen.orm.contants
+
+/**
+ *
+ * @author NorthLan at 2018/1/30
+ */
+enum class DSKey(val dsKey: String, val pkgName: String) {
+    DS_SYS("sysDataSource", "com.gxzc.zen.api.sys"),
+    DS_BUSINESS("busDataSource", "com.gxzc.zen.api.bus");
+
+    companion object {
+        const val DSKEY_SYS = "sysDataSource"
+        const val DSKEY_BUSINESS = "busDataSource"
+    }
+}

zen-orm/src/main/resources/application-orm.yml

@@ -4,19 +4,21 @@
 
 ###################  mybatis-plus配置  ###################
 mybatis-plus:
-#  mapper-locations: classpath*:mapping/**/*.xml
-#  type-aliases-package: com.gxzc.zen.api.rec.mapper,com.gxzc.zen.api.sys.mapper #,com.gxzc.zen.api.useage.mapper
+  mapper-locations: classpath*:mapping/**/*.xml
+#  type-aliases-package: com.gxzc.zen.api.bus.mapper,com.gxzc.zen.api.sys.mapper #,com.gxzc.zen.api.useage.mapper
   global-config:
     id-type: 0  #0:数据库ID自增   1:用户输入id  2:全局唯一id(IdWorker)  3:全局唯一ID(uuid)
     db-column-underline: true
     refresh-mapper: true
     logic-delete-value: 0
     logic-not-delete-value: 1
+    sql-injector: com.baomidou.mybatisplus.mapper.LogicSqlInjector
   configuration:
     map-underscore-to-camel-case: true
     cache-enabled: true #配置的缓存的全局开关
     lazyLoadingEnabled: true #延时加载的开关
-    multipleResultSetsEnabled: true #开启的话，延时加载一个属性时会加载该对象全部属性，否则按需加载属性
+    multipleResultSetsEnabled: true #延时加载一个属性时会加载该对象全部属性，否则按需加载属性
+    interceptors: com.baomidou.mybatisplus.plugins.OptimisticLockerInterceptor
     #log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #打印sql语句,调试用
 
 
@@ -51,8 +53,8 @@ datasource:
     maxActive: 20
     timeBetweenEvictionRunsMillis: 60000
     minEvictableIdleTimeMillis: 30000
-  rec:
-    mapper-location: classpath:mapping/rec/*.xml
+  bus:
+    mapper-location: classpath:mapping/bus/*.xml
     name: archives_rec
     url: jdbc:mysql://127.0.0.1:3306/archives_rec?useUnicode=true&characterEncoding=utf-8&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
     username: root
@@ -71,26 +73,6 @@ datasource:
     maxActive: 20
     timeBetweenEvictionRunsMillis: 60000
     minEvictableIdleTimeMillis: 30000
-  usage:
-    mapper-location: classpath:mapping/usage/*.xml
-    name: archives_usage
-    url: jdbc:mysql://127.0.0.1:3306/archives_usage?useUnicode=true&characterEncoding=utf-8&useSSL=false&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
-    username: root
-    password: root
-    testWhileIdle: true
-    testOnBorrow: false
-    testOnReturn: false
-    validationQuery: SELECT 1
-    asyncInit: false # 异步初始化
-    filters: log4j,wall,mergeStat
-    keepAlive: false
-    driver-class-name: com.mysql.jdbc.Driver
-    initialize: false #指定初始化数据源，是否用data.sql来初始化，默认: true
-    initialSize: 5
-    minIdle: 5
-    maxActive: 20
-    timeBetweenEvictionRunsMillis: 60000
-    minEvictableIdleTimeMillis: 30000
 
 ##sharding-jdbc
 #sharding:

zen-orm/src/test/kotlin/com/gxzc/zen/generator/TestPathFinder.kt

@@ -1,5 +1,6 @@
 package com.gxzc.zen.generator
 
+import com.gxzc.zen.orm.contants.DSKey
 import org.junit.Test
 import java.io.File
 
@@ -9,7 +10,7 @@ import java.io.File
  * @date 2018/1/26
  * @url https://noahlan.com
  */
-class TestPathFinder{
+class TestPathFinder {
     @Test
     fun pathFinder() {
         val moduleName = "zen-orm"
@@ -17,4 +18,11 @@ class TestPathFinder{
         val path = file.absolutePath
         System.out.println(path)
     }
+
+    @Test
+    fun enumTest() {
+        DSKey.values()
+                .filter { it.pkgName in "com.gxzc.zen.api.bus.mapper" }
+                .forEach { println(it) }
+    }
 }