Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 191 for Idx (0.01 seconds)

  1. internal/s3select/sql/jsonpath.go

    			return jsonpathEval(p[1:], val)
    		default:
    			return nil, false, errKeyLookup
    		}
    
    	case p[0].Index != nil:
    		idx := *p[0].Index
    
    		arr, ok := v.([]any)
    		if !ok {
    			return nil, false, errIndexLookup
    		}
    
    		if idx >= len(arr) {
    			return nil, false, nil
    		}
    		return jsonpathEval(p[1:], arr[idx])
    
    	case p[0].ObjectWildcard:
    		switch kvs := v.(type) {
    		case jstream.KVS:
    			if len(p[1:]) > 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  2. internal/s3select/sql/utils.go

    	jpath := operand.Left.Left.Primary.JPathExpr
    	n := len(jpath.PathExpr)
    	if n > 0 && jpath.PathExpr[n-1].Key == nil {
    		return "", false
    	}
    	ps := jpath.String()
    	if idx := strings.LastIndex(ps, "."); idx >= 0 {
    		// Get last part of path string.
    		ps = ps[idx+1:]
    	}
    	return ps, true
    }
    
    // HasKeypath returns if the from clause has a key path -
    // e.g. S3object[*].id
    func (from *TableExpression) HasKeypath() bool {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Nov 10 16:12:50 GMT 2021
    - 3.6K bytes
    - Click Count (0)
  3. cmd/streaming-v4-unsigned.go

    		if line == "" {
    			continue
    		}
    		// Find first separator.
    		idx := strings.IndexByte(line, trailerKVSeparator[0])
    		if idx <= 0 || idx >= len(line) {
    			if cr.debug {
    				fmt.Printf("Could not find separator, got %q\n", line)
    			}
    			return errMalformedEncoding
    		}
    		key := strings.ToLower(line[:idx])
    		value := line[idx+1:]
    		if _, ok := wantTrailers[key]; !ok {
    			if cr.debug {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 03 14:55:52 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  4. docs/resiliency/resiliency-initial-script.sh

    ./mc mb "${ALIAS_NAME}"/"${BUCKET}"
    rm -rf "${SRC_DIR}" "${INLINED_DIR}" "${DEST_DIR}" && mkdir -p "${SRC_DIR}" "${INLINED_DIR}" "${DEST_DIR}"
    for idx in {1..10}; do
    	# generate random nr of blocks
    	COUNT=$((RANDOM % 100 + 100))
    	# generate random content
    	dd if=/dev/urandom bs=50K count="${COUNT}" of="${SRC_DIR}"/file"$idx"
    done
    
    # create small object that will be inlined into xl.meta
    dd if=/dev/urandom bs=50K count=1 of="${INLINED_DIR}"/inlined
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Dec 21 04:24:45 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  5. clause/expression_test.go

    		Result: "create table `users` (`id` int, `name` text)",
    	}}
    
    	for idx, result := range results {
    		t.Run(fmt.Sprintf("case #%v", idx), func(t *testing.T) {
    			user, _ := schema.Parse(&tests.User{}, &sync.Map{}, db.NamingStrategy)
    			stmt := &gorm.Statement{DB: db, Table: user.Table, Schema: user, Clauses: map[string]clause.Clause{}}
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Nov 04 07:04:52 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  6. clause/update_test.go

    		},
    		{
    			[]clause.Interface{clause.Update{Table: clause.Table{Name: "products"}, Modifier: "LOW_PRIORITY"}},
    			"UPDATE LOW_PRIORITY `products`", nil,
    		},
    	}
    
    	for idx, result := range results {
    		t.Run(fmt.Sprintf("case #%v", idx), func(t *testing.T) {
    			checkBuildClauses(t, result.Clauses, result.Result, result.Vars)
    		})
    	}
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Jun 02 01:18:01 GMT 2020
    - 722 bytes
    - Click Count (0)
  7. callbacks/preload.go

    		for i := 0; i < joinResults.Len(); i++ {
    			joinIndexValue := joinResults.Index(i)
    			for idx, field := range joinForeignFields {
    				fieldValues[idx], _ = field.ValueOf(tx.Statement.Context, joinIndexValue)
    			}
    
    			for idx, field := range joinRelForeignFields {
    				joinFieldValues[idx], _ = field.ValueOf(tx.Statement.Context, joinIndexValue)
    			}
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  8. clause/from.go

    }
    
    // Name from clause name
    func (from From) Name() string {
    	return "FROM"
    }
    
    // Build build from clause
    func (from From) Build(builder Builder) {
    	if len(from.Tables) > 0 {
    		for idx, table := range from.Tables {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    
    			builder.WriteQuoted(table)
    		}
    	} else {
    		builder.WriteQuoted(currentTable)
    	}
    
    	for _, join := range from.Joins {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed Jul 15 02:25:10 GMT 2020
    - 630 bytes
    - Click Count (0)
  9. clause/on_conflict.go

    		builder.WriteString("ON CONSTRAINT ")
    		builder.WriteString(onConflict.OnConstraint)
    		builder.WriteByte(' ')
    	} else {
    		if len(onConflict.Columns) > 0 {
    			builder.WriteByte('(')
    			for idx, column := range onConflict.Columns {
    				if idx > 0 {
    					builder.WriteByte(',')
    				}
    				builder.WriteQuoted(column)
    			}
    			builder.WriteString(`) `)
    		}
    
    		if len(onConflict.TargetWhere.Exprs) > 0 {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Oct 07 05:46:20 GMT 2022
    - 1.3K bytes
    - Click Count (0)
  10. clause/values_test.go

    				},
    			},
    			"INSERT INTO `users` (`name`,`age`) VALUES (?,?),(?,?)",
    			[]interface{}{"jinzhu", 18, "josh", 1},
    		},
    	}
    
    	for idx, result := range results {
    		t.Run(fmt.Sprintf("case #%v", idx), func(t *testing.T) {
    			checkBuildClauses(t, result.Clauses, result.Result, result.Vars)
    		})
    	}
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Jan 06 07:02:53 GMT 2022
    - 691 bytes
    - Click Count (0)
Back to Top