Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for pathExpr (0.06 sec)

  1. internal/s3select/sql/utils.go

    	var pathExpr []*JSONPathElement
    	if hasTableAlias {
    		pathExpr = e.PathExpr
    	} else {
    		pathExpr = make([]*JSONPathElement, len(e.PathExpr)+1)
    		pathExpr[0] = &JSONPathElement{Key: &ObjectKey{ID: e.BaseKey}}
    		copy(pathExpr[1:], e.PathExpr)
    	}
    	e.strippedTableAlias = tableAlias
    	e.strippedPathExpr = pathExpr
    	return e.strippedPathExpr
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Nov 10 16:12:50 UTC 2021
    - 3.6K bytes
    - Viewed (0)
  2. internal/s3select/sql/statement.go

    	if !strings.EqualFold(from.Table.BaseKey.String(), baseTableName) {
    		return errBadTableName(errors.New("table name must be `s3object`"))
    	}
    
    	if len(from.Table.PathExpr) > 0 {
    		if !from.Table.PathExpr[0].ArrayWildcard {
    			return errBadTableName(errors.New("keypath table name is invalid - please check the service documentation"))
    		}
    	}
    	return nil
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9K bytes
    - Viewed (0)
  3. internal/s3select/sql/analysis.go

    	}
    	return result
    }
    
    func (e *In) analyze(s *Select) (result qProp) {
    	switch {
    	case e.JPathExpr != nil:
    		// Check if the path expression is valid
    		if len(e.JPathExpr.PathExpr) > 0 {
    			if e.JPathExpr.BaseKey.String() != s.From.As && !strings.EqualFold(e.JPathExpr.BaseKey.String(), baseTableName) {
    				result = qProp{err: errInvalidKeypath}
    				return result
    			}
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  4. internal/s3select/sql/jsonpath_test.go

    			recs, err := getJSONStructs(b)
    			if err != nil || len(recs) != 3 {
    				t.Fatalf("%v or length was not 3", err)
    			}
    
    			for j, rec := range recs {
    				// fmt.Println(rec)
    				r, _, err := jsonpathEval(jp.PathExpr, rec)
    				if err != nil {
    					t.Errorf("Error: %d %d %v", i, j, err)
    				}
    				if !reflect.DeepEqual(r, tc.res[j]) {
    					fmt.Printf("%#v (%v) != %v (%v)\n", r, reflect.TypeOf(r), tc.res[j], reflect.TypeOf(tc.res[j]))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  5. internal/s3select/sql/jsonpath.go

    // If the value should be considered flat (from wildcards) any array returned should be considered individual values.
    func jsonpathEval(p []*JSONPathElement, v any) (r any, flat bool, err error) {
    	// fmt.Printf("JPATHexpr: %v jsonobj: %v\n\n", p, v)
    	if len(p) == 0 || v == nil {
    		return v, false, nil
    	}
    
    	switch {
    	case p[0].Key != nil:
    		key := p[0].Key.keyString()
    
    		switch kvs := v.(type) {
    		case jstream.KVS:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.4K bytes
    - Viewed (0)
Back to top