diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/config/MybatisPlusConfig.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/config/MybatisPlusConfig.java index 43dfb9c250e62390272c02632078f13e96cf6e07..21d2349a060bdf2dd8dca037dd7194647266713d 100644 --- a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/config/MybatisPlusConfig.java +++ b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/config/MybatisPlusConfig.java @@ -33,7 +33,7 @@ public class MybatisPlusConfig { * @return pagination interceptor */ @Bean - public PaginationInterceptor paginationInterceptor() { + public static PaginationInterceptor paginationInterceptor() { return new PaginationInterceptor(); } diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/ConnectionFactory.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/ConnectionFactory.java index aa4429d2c60f802fc725151e192f1f847e06b100..f437d8b2d9d04533fbf402d51b82cf986b01c799 100644 --- a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/ConnectionFactory.java +++ b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/ConnectionFactory.java @@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean; import org.apache.commons.configuration.ConfigurationException; import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.dolphinscheduler.common.Constants; +import org.apache.dolphinscheduler.dao.config.MybatisPlusConfig; import org.apache.ibatis.mapping.Environment; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; @@ -122,6 +123,7 @@ public class ConnectionFactory { configuration.setEnvironment(environment); configuration.setLazyLoadingEnabled(true); configuration.addMappers("org.apache.dolphinscheduler.dao.mapper"); + configuration.addInterceptor(MybatisPlusConfig.paginationInterceptor()); MybatisSqlSessionFactoryBean sqlSessionFactoryBean = new MybatisSqlSessionFactoryBean(); sqlSessionFactoryBean.setConfiguration(configuration);