This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push: new 4e92bd61586 [fix](sql) Wrong result for alter set property (#46028) 4e92bd61586 is described below commit 4e92bd615867617b1ae2b13e906c3a3b7beef8e2 Author: Uniqueyou <wangyix...@selectdb.com> AuthorDate: Fri Dec 27 19:14:44 2024 +0800 [fix](sql) Wrong result for alter set property (#46028) Related PR: https://github.com/selectdb/ccr-syncer/pull/353 --- .../doris/persist/ModifyTablePropertyOperationLog.java | 7 ++++++- .../doris/persist/ModifyDynamicPartitionInfoTest.java | 13 +++++++++++++ 2 files changed, 19 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/persist/ModifyTablePropertyOperationLog.java b/fe/fe-core/src/main/java/org/apache/doris/persist/ModifyTablePropertyOperationLog.java index 50b49074ce1..1d64029bcfd 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/persist/ModifyTablePropertyOperationLog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/persist/ModifyTablePropertyOperationLog.java @@ -55,7 +55,8 @@ public class ModifyTablePropertyOperationLog implements Writable { StringBuilder sb = new StringBuilder(); sb.append("SET ("); for (Map.Entry<String, String> entry : properties.entrySet()) { - sb.append(entry.getKey()).append("=").append(entry.getValue()).append(","); + sb.append("\"").append(entry.getKey()).append("\"").append(" = ").append("\"").append(entry.getValue()) + .append("\" ").append(","); } sb.deleteCharAt(sb.length() - 1); // remove last ',' sb.append(")"); @@ -106,4 +107,8 @@ public class ModifyTablePropertyOperationLog implements Writable { public String toJson() { return GsonUtils.GSON.toJson(this); } + + public String toSql() { + return sql; + } } diff --git a/fe/fe-core/src/test/java/org/apache/doris/persist/ModifyDynamicPartitionInfoTest.java b/fe/fe-core/src/test/java/org/apache/doris/persist/ModifyDynamicPartitionInfoTest.java index bff50dcf768..a54f91dd826 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/persist/ModifyDynamicPartitionInfoTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/persist/ModifyDynamicPartitionInfoTest.java @@ -67,4 +67,17 @@ public class ModifyDynamicPartitionInfoTest { Assert.assertEquals(readModifyDynamicPartitionInfo.getProperties(), properties); in.close(); } + + @Test + public void testToSql() { + HashMap<String, String> properties = new HashMap<>(); + properties.put(DynamicPartitionProperty.ENABLE, "true"); + properties.put(DynamicPartitionProperty.TIME_UNIT, "day"); + properties.put(DynamicPartitionProperty.START, "-3"); + ModifyTablePropertyOperationLog modifyDynamicPartitionInfo = new ModifyTablePropertyOperationLog(100L, 200L, + "test", properties); + Assert.assertTrue(modifyDynamicPartitionInfo.toSql().contains("\"dynamic_partition.enable\" = \"true\"")); + Assert.assertTrue(modifyDynamicPartitionInfo.toSql().contains("\"dynamic_partition.time_unit\" = \"day\"")); + Assert.assertTrue(modifyDynamicPartitionInfo.toSql().contains("\"dynamic_partition.start\" = \"-3\"")); + } } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org