tests for query and schemas with subtypes

connector/fields_test.go

@@ -26,6 +26,9 @@ var tests = []test{
 	{
 		name: "books",
 	},
+	{
+		name: "books_2",
+	},
 }
 
 func TestSchema(t *testing.T) {

connector/query_test.go

@@ -85,11 +85,15 @@ var tests = []test{
 		group: "payments",
 		name:  "simple_terms_clause",
 	},
+	{
+		group: "customers",
+		name:  "sort_by_subtype",
+	},
 }
 
 func TestPrepareElasticsearchQuery(t *testing.T) {
 	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
+		t.Run(tt.group + "." + tt.name, func(t *testing.T) {
 			ctx := context.Background()
 			ctx = context.WithValue(ctx, "postProcessor", &types.PostProcessor{})
 			initTest(t, &tt)

testdata/unit_tests/fields_tests/books_2/configuration.json

@@ -0,0 +1,38 @@
+{
+  "indices": {
+    "my_book_index": {
+      "mappings": {
+        "properties": {
+          "author": {
+            "type": "keyword"
+          },
+          "description": {
+            "type": "text"
+          },
+          "genre": {
+            "type": "keyword"
+          },
+          "pages": {
+            "type": "integer"
+          },
+          "published_date": {
+            "format": "yyyy-MM-dd",
+            "type": "date"
+          },
+          "rating": {
+            "type": "float"
+          },
+          "title": {
+            "fields": {
+              "keywordSubField": {
+                "type": "keyword"
+              }
+            },
+            "type": "text"
+          }
+        }
+      }
+    }
+  },
+  "queries": {}
+}