(where message.PredicateGroups)
| 59 | } |
| 60 | |
| 61 | func extractPredicateValues(where message.PredicateGroups) ([]any, error) { |
| 62 | predicateCount := 0 |
| 63 | for _, predicateGroup := range where { |
| 64 | predicateCount += len(predicateGroup.Predicates) |
| 65 | } |
| 66 | results := make([]any, predicateCount) |
| 67 | counter := 0 |
| 68 | for _, predicateGroup := range where { |
| 69 | for _, predicate := range predicateGroup.Predicates { |
| 70 | col := predicate.Record.Column(0) |
| 71 | primitiveValues, err := typeconv.FromArray(col) |
| 72 | if err != nil { |
| 73 | return nil, err |
| 74 | } |
| 75 | unpacked := unpackArray(primitiveValues) |
| 76 | results[counter] = unpacked[0] |
| 77 | counter++ |
| 78 | } |
| 79 | } |
| 80 | return results, nil |
| 81 | } |
| 82 | |
| 83 | func unpackArray(s any) []any { |
| 84 | v := reflect.ValueOf(s) |
no test coverage detected