GiteaTest2015/streamsql
1
0
Fork 0
mirror of https://gitee.com/rulego/streamsql.git synced 2025-07-06 07:58:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat:字段访问支持访问数组

Browse Source
This commit is contained in:
rulego-team
2025-06-16 12:45:12 +08:00
parent a05f4ace98
commit 43a9f46f24
14 changed files with 2689 additions and 766 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
aggregator/group_aggregator.go
View File

@ -7,8 +7,8 @@ import (
"sync"
"github.com/rulego/streamsql/functions"
"github.com/rulego/streamsql/utils"
"github.com/rulego/streamsql/utils/cast"
"github.com/rulego/streamsql/utils/fieldpath"
)
type Aggregator interface {
@ -161,8 +161,8 @@ func (ga *GroupAggregator) Add(data interface{}) error {
var found bool
// 检查是否是嵌套字段
if utils.IsNestedField(field) {
fieldVal, found = utils.GetNestedField(data, field)
if fieldpath.IsNestedField(field) {
fieldVal, found = fieldpath.GetNestedField(data, field)
} else {
// 原有的字段访问逻辑
var f reflect.Value
@ -240,8 +240,8 @@ func (ga *GroupAggregator) Add(data interface{}) error {
var fieldVal interface{}
var found bool
if utils.IsNestedField(inputField) {
fieldVal, found = utils.GetNestedField(data, inputField)
if fieldpath.IsNestedField(inputField) {
fieldVal, found = fieldpath.GetNestedField(data, inputField)
} else {
// 原有的字段访问逻辑
var f reflect.Value