Added support for array selects

query_executors/memory_executor/memory_executor.go

@@ -84,6 +84,14 @@ func evaluateFilters(expr ExpressionType, row RowType) bool {
 }
 
 func getFieldValue(field parsers.SelectItem, row RowType) interface{} {
+	if field.Type == parsers.SelectItemTypeArray {
+		arrayValue := make([]interface{}, 0)
+		for _, selectItem := range field.SelectItems {
+			arrayValue = append(arrayValue, getFieldValue(selectItem, row))
+		}
+		return arrayValue
+	}
+
 	value := row
 	for _, pathSegment := range field.Path[1:] {
 		if nestedValue, ok := value.(map[string]interface{}); ok {

query_executors/memory_executor/memory_executor_test.go

@@ -62,6 +62,30 @@ func Test_Execute(t *testing.T) {
 		)
 	})
 
+	t.Run("Should execute SELECT array", func(t *testing.T) {
+		testQueryExecute(
+			t,
+			parsers.SelectStmt{
+				SelectItems: []parsers.SelectItem{
+					{
+						Alias: "arr",
+						Type:  parsers.SelectItemTypeArray,
+						SelectItems: []parsers.SelectItem{
+							{Path: []string{"c", "id"}},
+							{Path: []string{"c", "pk"}},
+						},
+					},
+				},
+				Table: parsers.Table{Value: "c"},
+			},
+			mockData,
+			[]memoryexecutor.RowType{
+				map[string]interface{}{"arr": []interface{}{"12345", 123}},
+				map[string]interface{}{"arr": []interface{}{"67890", 456}},
+			},
+		)
+	})
+
 	t.Run("Should execute SELECT with single WHERE condition", func(t *testing.T) {
 		testQueryExecute(
 			t,