Skip to content

Commit bf29313

Browse files
committed
Merge branch 'dev' into optimize_docker_image
2 parents 64828fd + bff0703 commit bf29313

File tree

4 files changed

+10
-4
lines changed

4 files changed

+10
-4
lines changed

dinky-admin/src/main/java/org/dinky/interceptor/PostgreSQLPrepareInterceptor.java

+6-1
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,12 @@ public Object intercept(final Invocation invocation) throws Throwable {
4444
BoundSql boundSql = statementHandler.getBoundSql();
4545
Field field = boundSql.getClass().getDeclaredField("sql");
4646
field.setAccessible(true);
47-
field.set(boundSql, boundSql.getSql().replace("`", "\"").toLowerCase());
47+
field.set(
48+
boundSql,
49+
boundSql.getSql()
50+
.replace("`", "\"")
51+
.replace("concat('%', ?, '%')", "concat('%', ?::text, '%')")
52+
.toLowerCase());
4853
return invocation.proceed();
4954
}
5055

dinky-admin/src/main/java/org/dinky/service/impl/TaskServiceImpl.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1101,10 +1101,10 @@ public List<TaskDTO> getUserTasks(Integer userId) {
11011101
private Boolean hasTaskOperatePermission(Integer firstLevelOwner, List<Integer> secondLevelOwners) {
11021102
boolean isFirstLevelOwner = firstLevelOwner != null && firstLevelOwner == StpUtil.getLoginIdAsInt();
11031103
if (TaskOwnerLockStrategyEnum.OWNER.equals(
1104-
SystemConfiguration.getInstances().getTaskOwnerLockStrategy())) {
1104+
SystemConfiguration.getInstances().getTaskOwnerLockStrategy().getValue())) {
11051105
return isFirstLevelOwner;
11061106
} else if (TaskOwnerLockStrategyEnum.OWNER_AND_MAINTAINER.equals(
1107-
SystemConfiguration.getInstances().getTaskOwnerLockStrategy())) {
1107+
SystemConfiguration.getInstances().getTaskOwnerLockStrategy().getValue())) {
11081108
return isFirstLevelOwner
11091109
|| (secondLevelOwners != null && secondLevelOwners.contains(StpUtil.getLoginIdAsInt()));
11101110
}

dinky-core/src/main/java/org/dinky/api/FlinkAPI.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ private String getResult(String route) {
112112
}
113113

114114
private JsonNode post(String route, String body) {
115-
String url = NetConstant.SLASH + route;
115+
String url = address + NetConstant.SLASH + route;
116116
if (!address.startsWith(NetConstant.HTTP) && !address.startsWith(NetConstant.HTTPS)) {
117117
url = NetConstant.HTTP + url;
118118
}

dinky-web/src/pages/DataStudio/CenterTabContent/SqlTask/index.tsx

+1
Original file line numberDiff line numberDiff line change
@@ -237,6 +237,7 @@ export const SqlTask = memo((props: FlinkSqlProps & any) => {
237237
statement: sqlConvertForm?.initSqlStatement ?? ''
238238
});
239239
setOriginStatementValue(sqlConvertForm?.initSqlStatement ?? '');
240+
updateCenterTab({ ...props.tabData, params: newParams });
240241
if (params?.statement && params?.statement !== sqlConvertForm?.initSqlStatement) {
241242
setDiff([
242243
{ key: 'statement', server: sqlConvertForm?.initSqlStatement, cache: params.statement }

0 commit comments

Comments
 (0)