This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new aa8c93cfe28 branch-2.1: [fix](sql) Wrong result for alter set property 
#46028 (#46141)
aa8c93cfe28 is described below

commit aa8c93cfe28a12729dce9e60d3791c9ccfca6df4
Author: Uniqueyou <wangyix...@selectdb.com>
AuthorDate: Tue Dec 31 09:52:43 2024 +0800

    branch-2.1: [fix](sql) Wrong result for alter set property #46028 (#46141)
    
    pick https://github.com/apache/doris/pull/46028
---
 .../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 a782db9f9c0..2f06624c5ec 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
@@ -51,7 +51,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(")");
@@ -82,4 +83,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

Reply via email to