From aa2b9cc476902fae805be61d10c8868de02cf022 Mon Sep 17 00:00:00 2001 From: safishhh <145760482+safishhh@users.noreply.github.com> Date: Tue, 9 Jun 2026 23:02:54 +0800 Subject: [PATCH 1/3] Fix Registry Center - Documentation cannot paginate / cannot turn pages MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 注册中心-文档 无法翻页 前端传递了无效的排序字段：前端在排序时传递了 "undefined" 作为字段名 ERROR 89291 --- [ XNIO-1 task-1] org.dinky.aop.exception.UnKnownExceptionHandler: ### Error querying database. Cause: java.sql.SQLSyntaxErrorException: Unknown column 'a.undefined' in 'order clause' ### The error may exist in file [/home/fishh/Workspaces/dinky/dinky-dev/dinky-admin/target/classes/mapper/DocumentMapper.xml] ### The error may involve defaultParameterMap ### The error occurred while setting parameters ### SQL: SELECT a.* FROM dinky_flink_document a WHERE 1 = 1 ORDER BY a.undefined ASC LIMIT ? ### Cause: java.sql.SQLSyntaxErrorException: Unknown column 'a.undefined' in 'order clause' ; bad SQL grammar []; nested exception is java.sql.SQLSyntaxErrorException: Unknown column 'a.undefined' in 'order clause' org.springframework.jdbc.BadSqlGrammarException: ### Error querying database. Cause: java.sql.SQLSyntaxErrorException: Unknown column 'a.undefined' in 'order clause' ### The error may exist in file [/home/fishh/Workspaces/dinky/dinky-dev/dinky-admin/target/classes/mapper/DocumentMapper.xml] ### The error may involve defaultParameterMap ### The error occurred while setting parameters ### SQL: SELECT a.* FROM dinky_flink_document a WHERE 1 = 1 ORDER BY a.undefined ASC LIMIT ? ### Cause: java.sql.SQLSyntaxErrorException: Unknown column 'a.undefined' in 'order clause' ; bad SQL grammar []; nested exception is java.sql.SQLSyntaxErrorException: Unknown column 'a.undefined' in 'order clause' at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.doTranslate(SQLErrorCodeSQLExceptionTranslator.java:236) ~[spring-jdbc-5.3.31.jar:5.3.31] at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:73) ~[spring-jdbc-5.3.31.jar:5.3.31] at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:92) ~[mybatis-spring-2.1.2.jar:2.1.2] --- .../src/main/java/org/dinky/mybatis/util/ProTableUtil.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/dinky-admin/src/main/java/org/dinky/mybatis/util/ProTableUtil.java b/dinky-admin/src/main/java/org/dinky/mybatis/util/ProTableUtil.java index 7d1b9faaa6..f244ab4d60 100644 --- a/dinky-admin/src/main/java/org/dinky/mybatis/util/ProTableUtil.java +++ b/dinky-admin/src/main/java/org/dinky/mybatis/util/ProTableUtil.java @@ -74,6 +74,10 @@ private static void buildDelete(QueryWrapper wrapper, boolean camelToUndersco private static void buildSort( String sortField, String sortValue, QueryWrapper wrapper, boolean camelToUnderscore) { if (sortField != null && sortValue != null) { + // 过滤无效的排序字段 + if ("undefined".equalsIgnoreCase(sortField) || "null".equalsIgnoreCase(sortField) || sortField.trim().isEmpty()) { + return; + } if (camelToUnderscore) { sortField = CaseFormat.LOWER_CAMEL.to(CaseFormat.LOWER_UNDERSCORE, sortField); } From 62b376953ca6dab0fdb104a4fbdb497a64c58b0e Mon Sep 17 00:00:00 2001 From: safishhh <145760482+safishhh@users.noreply.github.com> Date: Wed, 10 Jun 2026 17:42:51 +0800 Subject: [PATCH 2/3] Improve decimal type conversion in DorisTypeConvert MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 在所有数据源的 convertToDB 方法中，处理 DECIMAL 类型时只返回了 "decimal" ，没有包含精度和小数位数，导致生成的 Flink DDL 中 decimal(22,4) 变成了 decimal(22,null) --- .../java/org/dinky/metadata/convert/DorisTypeConvert.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/dinky-metadata/dinky-metadata-doris/src/main/java/org/dinky/metadata/convert/DorisTypeConvert.java b/dinky-metadata/dinky-metadata-doris/src/main/java/org/dinky/metadata/convert/DorisTypeConvert.java index 2204b7f26a..7bbc5be9e4 100644 --- a/dinky-metadata/dinky-metadata-doris/src/main/java/org/dinky/metadata/convert/DorisTypeConvert.java +++ b/dinky-metadata/dinky-metadata-doris/src/main/java/org/dinky/metadata/convert/DorisTypeConvert.java @@ -82,7 +82,12 @@ public String convertToDB(ColumnType columnType) { return "varchar"; } switch (columnType.getValue()) { - case DECIMAL: + case DECIMAL: + if (columnType.getLogicalType() instanceof org.dinky.data.types.DecimalType) { + org.dinky.data.types.DecimalType decimalType = + (org.dinky.data.types.DecimalType) columnType.getLogicalType(); + return String.format("decimal(%d,%d)", decimalType.getPrecision(), decimalType.getScale()); + } return "decimal"; case BIGINT: return "bigint"; From 9ea5a22f2f5fc4318f74c99917da1ebc0ab5c9f3 Mon Sep 17 00:00:00 2001 From: safishhh <145760482+safishhh@users.noreply.github.com> Date: Wed, 10 Jun 2026 17:44:41 +0800 Subject: [PATCH 3/3] Enhance decimal type conversion in StarRocksTypeConvert --- .../org/dinky/metadata/convert/StarRocksTypeConvert.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/dinky-metadata/dinky-metadata-starrocks/src/main/java/org/dinky/metadata/convert/StarRocksTypeConvert.java b/dinky-metadata/dinky-metadata-starrocks/src/main/java/org/dinky/metadata/convert/StarRocksTypeConvert.java index efd20ffe41..72815cea66 100644 --- a/dinky-metadata/dinky-metadata-starrocks/src/main/java/org/dinky/metadata/convert/StarRocksTypeConvert.java +++ b/dinky-metadata/dinky-metadata-starrocks/src/main/java/org/dinky/metadata/convert/StarRocksTypeConvert.java @@ -77,6 +77,11 @@ public String convertToDB(ColumnType columnType) { } switch (columnType.getValue()) { case DECIMAL: + if (columnType.getLogicalType() instanceof org.dinky.data.types.DecimalType) { + org.dinky.data.types.DecimalType decimalType = + (org.dinky.data.types.DecimalType) columnType.getLogicalType(); + return String.format("decimal(%d,%d)", decimalType.getPrecision(), decimalType.getScale()); + } return "decimal"; case BIGINT: return "bigint";