default value add

JNSimba · Jan 24, 2024 · d67d9b1 · d67d9b1
1 parent 11e7369
commit d67d9b1
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/...-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java b/...-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java
@@ -111,7 +111,7 @@ public static String buildAddColumnDDL(String tableIdentifier, FieldSchema field
                         DorisSystem.identifier(name),
                         type);
         if (!StringUtils.isNullOrWhitespaceOnly(defaultValue)) {
-            addDDL = addDDL + " DEFAULT " + defaultValue;
+            addDDL = addDDL + " DEFAULT '" + defaultValue + "'";
         }
         if (!StringUtils.isNullOrWhitespaceOnly(comment)) {
             addDDL = addDDL + " COMMENT '" + DorisSystem.quoteComment(comment) + "'";

diff --git a/...k-doris-connector/src/test/java/org/apache/doris/flink/sink/schema/SchemaManagerTest.java b/...k-doris-connector/src/test/java/org/apache/doris/flink/sink/schema/SchemaManagerTest.java
@@ -113,6 +113,12 @@ public void testAddColumn() {
         Assert.assertEquals(
                 "ALTER TABLE `test`.`test_flink` ADD COLUMN `col` int COMMENT 'comment \"\\'sdf\\''",
                 addColumnDDL);
+
+        field = new FieldSchema("col", "int", "10","comment \"'sdf'");
+        addColumnDDL = SchemaChangeHelper.buildAddColumnDDL("test.test_flink", field);
+        Assert.assertEquals(
+                "ALTER TABLE `test`.`test_flink` ADD COLUMN `col` int DEFAULT '10' COMMENT 'comment \"\\'sdf\\''",
+                addColumnDDL);
     }
 
     @Test