Added support for 'SELECT *'

parsers/nosql/nosql.peg

@@ -112,7 +112,13 @@ TopClause <- Top ws count:Integer {
     return count, nil
 }
 
-Selection <- SelectValueSpec / ColumnList
+Selection <- SelectValueSpec / ColumnList /SelectAsterisk
+
+SelectAsterisk <- "*" {
+    selectItem, _ := makeSelectItem("c", make([]interface{}, 0), parsers.SelectItemTypeField)
+	selectItem.IsTopLevel = true
+    return makeColumnList(selectItem, make([]interface{}, 0))
+}
 
 ColumnList <- column:SelectItem other_columns:(ws "," ws coll:SelectItem {return coll, nil })* {
     return makeColumnList(column, other_columns)

parsers/nosql/nosql_test.go

@@ -79,6 +79,19 @@ func Test_Parse(t *testing.T) {
 		)
 	})
 
+	t.Run("Should parse SELECT *", func(t *testing.T) {
+		testQueryParse(
+			t,
+			`SELECT * FROM c`,
+			parsers.SelectStmt{
+				SelectItems: []parsers.SelectItem{
+					{Path: []string{"c"}, IsTopLevel: true},
+				},
+				Table: parsers.Table{Value: "c"},
+			},
+		)
+	})
+
 	t.Run("Should parse SELECT array", func(t *testing.T) {
 		testQueryParse(
 			t,

query_executors/memory_executor/memory_executor.go

@@ -112,11 +112,13 @@ func getFieldValue(field parsers.SelectItem, row RowType) interface{} {
 	}
 
 	value := row
-	for _, pathSegment := range field.Path[1:] {
-		if nestedValue, ok := value.(map[string]interface{}); ok {
-			value = nestedValue[pathSegment]
-		} else {
-			return nil
+	if len(field.Path) > 1 {
+		for _, pathSegment := range field.Path[1:] {
+			if nestedValue, ok := value.(map[string]interface{}); ok {
+				value = nestedValue[pathSegment]
+			} else {
+				return nil
+			}
 		}
 	}
 	return value

query_executors/memory_executor/memory_executor_test.go

@@ -86,6 +86,20 @@ func Test_Execute(t *testing.T) {
 		)
 	})
 
+	t.Run("Should execute SELECT *", func(t *testing.T) {
+		testQueryExecute(
+			t,
+			parsers.SelectStmt{
+				SelectItems: []parsers.SelectItem{
+					{Path: []string{"c"}, IsTopLevel: true},
+				},
+				Table: parsers.Table{Value: "c"},
+			},
+			mockData,
+			mockData,
+		)
+	})
+
 	t.Run("Should execute SELECT array", func(t *testing.T) {
 		testQueryExecute(
 			t,