private MySqlExtractNode buildMysqlExtractNode() {
        List<FieldInfo> fields = Arrays.asList(
                new FieldInfo("id", new IntFormatInfo()),
                new FieldInfo("user_name", new StringFormatInfo()),
                new FieldInfo("phone", new StringFormatInfo()));
        Map<String, String> map = new HashMap<>();
        return new MySqlExtractNode("1", "mysql_input", fields,
                null, map, "id",
                Collections.singletonList("t_ds_user"), "localhost", "root", "root",
                "dolphinscheduler", 3308, 10011,
                true, null);
    }
Test mysql cdc for {@link OceanBaseLoadNode}
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java