-
Notifications
You must be signed in to change notification settings - Fork 0
/
value_array_groupby.go
80 lines (76 loc) · 1.57 KB
/
value_array_groupby.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
package runtime
type (
arrayGroupBy struct {
arr []Value
mappers []*arrayMapper
}
arrayGroupByItem struct {
groupFields []Value
record Value
}
arrayGroupByList []arrayGroupByItem
arrayGroupPredict func(Value, Value, *Context) bool
arrayGroupRule []arrayGroupPredict
)
func newGroupBy(arr []Value, mappers []*arrayMapper) *arrayGroupBy {
return &arrayGroupBy{
arr: arr,
mappers: mappers,
}
}
func (arrayGroupBy) isSameGroup(g1, g2 []Value, c *Context) bool {
if len(g1) != len(g2) {
return false
}
for i, v1 := range g1 {
v2 := g2[i]
if !c.ValuesEqual(v1, v2) {
return false
}
}
return true
}
func (gb *arrayGroupBy) Execute(c *Context) [][]Value {
var (
arr = gb.arr
mappers = gb.mappers
)
n := len(arr)
if n == 0 {
return [][]Value{}
}
raw := make([]arrayGroupByItem, n)
for i, v := range arr {
raw[i].record = v
for _, m := range mappers {
raw[i].groupFields = append(raw[i].groupFields, m.Map(v, i, c))
}
}
res := make([][]arrayGroupByItem, 0)
last := raw[0]
res = append(res, []arrayGroupByItem{last})
for i := 1; i < len(raw); i++ {
this := raw[i]
groupExists := false
for i, group := range res {
a := this
b := group[0]
if gb.isSameGroup(a.groupFields, b.groupFields, c) {
res[i] = append(res[i], this)
groupExists = true
break
}
}
if !groupExists {
res = append(res, []arrayGroupByItem{this})
}
}
groups := make([][]Value, len(res))
for i, g := range res {
groups[i] = make([]Value, len(g))
for j, item := range g {
groups[i][j] = item.record
}
}
return groups
}