Skip to content

Commit

Permalink
[Improve] mybatis-plus query improvements (#4167)
Browse files Browse the repository at this point in the history
* [Improve] mybatis-plus query impovements

* [Improve] mybatis-plus query improvement

* [Improve] mybatis-plus query improvements

* [Improve] add mybatis-plus PaginationInterceptor

* [Improve] add mybatis-plus PaginationInterceptor.java

* [Improve] trigger ci

* [Bug] spark application mapping state bug fixed.

* [Bug] yarnQueue check exists bug fixed.

* [Improve] check project-name exists improvement

* [Improve] project e2e bug fixed.
  • Loading branch information
wolfboys authored Jan 18, 2025
1 parent 7019777 commit f512b6b
Show file tree
Hide file tree
Showing 55 changed files with 659 additions and 545 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ insert into `t_flink_effective` values (100000, 100000, 2, 100000, now());
-- ----------------------------
-- Records of t_flink_project
-- ----------------------------
insert into `t_flink_project` values (100000, 100000, 'streampark-quickstart', 'https://github.com/apache/incubator-streampark-quickstart', 'release-2.0.0', null, null, null, null, null, null, 1, 1, null, 'streampark-quickstart', -1, now(), now());
insert into `t_flink_project` values (100000, 100000, 'streampark-quickstart', 'https://github.com/apache/streampark-quickstart', 'release-2.0.0', null, null, null, null, null, null, 1, 1, null, 'streampark-quickstart', -1, now(), now());

-- ----------------------------
-- Records of t_flink_sql
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ insert into "public"."t_flink_effective" values (100000, 100000, 2, 100000, now(
-- ----------------------------
-- Records of t_flink_project
-- ----------------------------
insert into "public"."t_flink_project" values (100000, 100000, 'streampark-quickstart', 'https://github.com/apache/incubator-streampark-quickstart', 'release-2.0.0', null, null, null, null, null, null, 1, 1, null, 'streampark-quickstart', -1, now(), now());
insert into "public"."t_flink_project" values (100000, 100000, 'streampark-quickstart', 'https://github.com/apache/streampark-quickstart', 'release-2.0.0', null, null, null, null, null, null, 1, 1, null, 'streampark-quickstart', -1, now(), now());

-- ----------------------------
-- Records of t_flink_sql
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@

package org.apache.streampark.console.base.config;

import org.apache.streampark.console.base.mybatis.interceptor.PaginationInterceptor;
import org.apache.streampark.console.base.mybatis.interceptor.PostgreSQLPrepareInterceptor;
import org.apache.streampark.console.base.mybatis.interceptor.PostgreSQLQueryInterceptor;

Expand All @@ -30,7 +31,6 @@
import com.baomidou.mybatisplus.core.config.GlobalConfig;
import com.baomidou.mybatisplus.core.toolkit.GlobalConfigUtils;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
Expand All @@ -46,7 +46,7 @@ public class MybatisConfig {
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor() {
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
interceptor.addInnerInterceptor(new PaginationInnerInterceptor());
interceptor.addInnerInterceptor(new PaginationInterceptor());
return interceptor;
}

Expand Down
Loading

0 comments on commit f512b6b

Please sign in to comment.