[BugFix]: es catalog can not parse columns

Signed-off-by: redscarf <hongweijin1993@gmail.com> Signed-off-by: Jin-H <hongweijin1993@gmail.com>
StarRocks · Aug 23, 2024 · 631b9bb · 631b9bb
1 parent d08bed2
commit 631b9bb
Showing 1 changed file with 70 additions and 0 deletions.
diff --git a/fe/fe-core/src/test/java/com/starrocks/connector/elasticsearch/EsUtilTest.java b/fe/fe-core/src/test/java/com/starrocks/connector/elasticsearch/EsUtilTest.java
@@ -144,4 +144,74 @@ public void testEs7MappingProperties() {
         assertNotNull(jsonObject);
         assertTrue(jsonObject.has("properties"));
     }
+
+    @Test
+    public void testEs681MappingProperties() {
+        String mapping = "{\n" +
+                "  \"_doc\" : {\n" +
+                "    \"dynamic_templates\" : [ {\n" +
+                "      \"integers\" : {\n" +
+                "        \"mapping\" : {\n" +
+                "          \"type\" : \"integer\"\n" +
+                "        },\n" +
+                "        \"match_mapping_type\" : \"long\"\n" +
+                "      }\n" +
+                "    }, {\n" +
+                "      \"strings\" : {\n" +
+                "        \"mapping\" : {\n" +
+                "          \"fields\" : {\n" +
+                "            \"raw\" : {\n" +
+                "              \"ignore_above\" : 256,\n" +
+                "              \"type\" : \"keyword\"\n" +
+                "            }\n" +
+                "          },\n" +
+                "          \"type\" : \"text\"\n" +
+                "        },\n" +
+                "        \"match_mapping_type\" : \"string\"\n" +
+                "      }\n" +
+                "    }, {\n" +
+                "      \"dataFormat\" : {\n" +
+                "        \"mapping\" : {\n" +
+                "          \"type\" : \"date\"\n" +
+                "        },\n" +
+                "        \"match\" : \"*Date\"\n" +
+                "      }\n" +
+                "    }, {\n" +
+                "      \"timeFormat\" : {\n" +
+                "        \"mapping\" : {\n" +
+                "          \"type\" : \"date\"\n" +
+                "        },\n" +
+                "        \"match\" : \"*Time\"\n" +
+                "      }\n" +
+                "    }, {\n" +
+                "      \"noAnalyzed\" : {\n" +
+                "        \"mapping\" : {\n" +
+                "          \"type\" : \"keyword\"\n" +
+                "        },\n" +
+                "        \"match_mapping_type\" : \"string\"\n" +
+                "      }\n" +
+                "    } ],\n" +
+                "    \"properties\" : {\n" +
+                "      \"my_string\" : {\n" +
+                "        \"type\" : \"text\",\n" +
+                "        \"fields\" : {\n" +
+                "          \"raw\" : {\n" +
+                "            \"ignore_above\" : 256,\n" +
+                "            \"type\" : \"keyword\"\n" +
+                "          }\n" +
+                "        }\n" +
+                "      },\n" +
+                "      \"my_integer\" : {\n" +
+                "        \"type\" : \"integer\"\n" +
+                "      }\n" +
+                "    }\n" +
+                "  }\n" +
+                "}";
+        JSONObject json = new JSONObject(mapping);
+
+        JSONObject jsonObject = EsUtil.parsePropertiesRoot(json);
+
+        assertNotNull(jsonObject);
+        assertTrue(jsonObject.has("properties"));
+    }
 }