add quote to ut

JNSimba · Jan 17, 2024 · 2e415a6 · 2e415a6
1 parent 25e9368
commit 2e415a6
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 8 deletions.
diff --git a/...is-connector/src/test/java/org/apache/doris/flink/sink/schema/SchemaChangeHelperTest.java b/...is-connector/src/test/java/org/apache/doris/flink/sink/schema/SchemaChangeHelperTest.java
@@ -52,15 +52,17 @@ public void testGenerateRenameDDLSql() {
         List<String> ddlSqls =
                 SchemaChangeHelper.generateRenameDDLSql(
                         table, oldColumnName, newColumnName, originFieldSchemaMap);
-        Assert.assertEquals(ddlSqls.get(0), "ALTER TABLE test.test_sink RENAME COLUMN c3 c33");
+        Assert.assertEquals(
+                ddlSqls.get(0), "ALTER TABLE `test`.`test_sink` RENAME COLUMN `c3` `c33`");
     }
 
     @Test
     public void testGenerateDDLSql() {
         SchemaChangeHelper.compareSchema(updateFieldSchemaMap, originFieldSchemaMap);
         List<String> ddlSqls = SchemaChangeHelper.generateDDLSql("test.test_sink");
-        Assert.assertEquals(ddlSqls.get(0), "ALTER TABLE test.test_sink ADD COLUMN c4 BIGINT");
         Assert.assertEquals(
-                ddlSqls.get(1), "ALTER TABLE test.test_sink ADD COLUMN c5 DATETIMEV2(0)");
+                ddlSqls.get(0), "ALTER TABLE `test`.`test_sink` ADD COLUMN `c4` BIGINT");
+        Assert.assertEquals(
+                ddlSqls.get(1), "ALTER TABLE `test`.`test_sink` ADD COLUMN `c5` DATETIMEV2(0)");
     }
 }
diff --git a/...e/doris/flink/sink/writer/serializer/jsondebezium/TestJsonDebeziumSchemaChangeImplV2.java b/...e/doris/flink/sink/writer/serializer/jsondebezium/TestJsonDebeziumSchemaChangeImplV2.java
@@ -64,10 +64,10 @@ public void setUp() {
 
     @Test
     public void testExtractDDLListMultipleColumns() throws IOException {
-        String sql0 = "ALTER TABLE test.t1 ADD COLUMN id INT DEFAULT '10000'";
-        String sql1 = "ALTER TABLE test.t1 ADD COLUMN c199 INT";
-        String sql2 = "ALTER TABLE test.t1 ADD COLUMN c12 INT DEFAULT '100'";
-        String sql3 = "ALTER TABLE test.t1 DROP COLUMN c13";
+        String sql0 = "ALTER TABLE `test`.`t1` ADD COLUMN `id` INT DEFAULT '10000'";
+        String sql1 = "ALTER TABLE `test`.`t1` ADD COLUMN `c199` INT";
+        String sql2 = "ALTER TABLE `test`.`t1` ADD COLUMN `c12` INT DEFAULT '100'";
+        String sql3 = "ALTER TABLE `test`.`t1` DROP COLUMN `c13`";
         List<String> srcSqlList = Arrays.asList(sql0, sql1, sql2, sql3);
 
         Map<String, FieldSchema> originFiledSchemaMap = new LinkedHashMap<>();
@@ -211,7 +211,7 @@ public void testExtractDDLListRename() throws IOException {
         schemaChange.setOriginFieldSchemaMap(originFieldSchemaMap);
 
         List<String> ddlList = schemaChange.extractDDLList(record);
-        Assert.assertEquals("ALTER TABLE test.t1 RENAME COLUMN c3 c333", ddlList.get(0));
+        Assert.assertEquals("ALTER TABLE `test`.`t1` RENAME COLUMN `c3` `c333`", ddlList.get(0));
     }
 
     @Test