Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for SELECT (0.25 sec)

  1. internal/s3select/select_test.go

    mango`,
    		},
    		{
    			name:  "Select column simplest",
    			query: `select qty from S3Object`,
    			wantResult: `1
    3`,
    		},
    		{
    			name:  "Select column with table name prefix",
    			query: `select S3Object.qty from S3Object`,
    			wantResult: `1
    3`,
    		},
    		{
    			name:  "Select column without table alias",
    			query: `select qty from S3Object s`,
    			wantResult: `1
    3`,
    		},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 76.2K bytes
    - Viewed (0)
  2. cmd/iam.go

    		return nil, errServerNotInitialized
    	}
    
    	select {
    	case <-sys.configLoaded:
    		return sys.store.GetBucketUsers(bucket)
    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    // ListUsers - list all users.
    func (sys *IAMSys) ListUsers(ctx context.Context) (map[string]madmin.UserInfo, error) {
    	if !sys.Initialized() {
    		return nil, errServerNotInitialized
    	}
    	select {
    	case <-sys.configLoaded:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  3. cmd/api-errors.go

    		Description:    "Other expressions are not allowed in the SELECT list when '*' is used without dot notation in the SQL expression.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrParseCannotMixSqbAndWildcardInSelectList: {
    		Code:           "ParseCannotMixSqbAndWildcardInSelectList",
    		Description:    "Cannot mix [] and * in the same expression in a SELECT list in SQL expression.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (6)
  4. cmd/erasure-server-pool.go

    				lastUpdate = allMerged.Info.LastUpdate
    			}
    		}
    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case v := <-updateCloser:
    				update()
    				xioutil.SafeClose(v)
    				return
    			case <-updateTicker.C:
    				update()
    			}
    		}
    	}()
    
    	wg.Wait()
    	ch := make(chan struct{})
    	select {
    	case updateCloser <- ch:
    		<-ch
    	case <-ctx.Done():
    		mu.Lock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    			}
    			if ok {
    				continue
    			}
    		} // in all other cases metadata is corrupt, do not read from it.
    
    		onlineMeta[i] = FileInfo{}
    		onlineDisks[i] = nil
    	}
    
    	select {
    	case mrfCheck <- fi.ShallowCopy():
    	case <-ctx.Done():
    		return fi, onlineMeta, onlineDisks, toObjectErr(ctx.Err(), bucket, object)
    	}
    
    	return fi, onlineMeta, onlineDisks, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  6. cmd/xl-storage.go

    			r.Exists = true
    			r.Error = fmt.Sprintf("max size (%d) exceeded: %d", req.MaxSize, len(data))
    			select {
    			case <-ctx.Done():
    				return ctx.Err()
    			case resp <- r:
    				continue
    			}
    		}
    		found++
    		r.Exists = true
    		r.Data = data
    		r.Modtime = mt
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		case resp <- r:
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    	// We have however a dynamic downstream buffer (ch).
    	buf := bytes.NewBuffer(grid.GetByteBuffer())
    	enc := json.NewEncoder(buf)
    	tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}}
    	for {
    		select {
    		case <-ctx.Done():
    			grid.PutByteBuffer(buf.Bytes())
    			return nil
    		case ev := <-ch:
    			buf.Reset()
    			tmpEvt.Records[0] = ev
    			if err := enc.Encode(tmpEvt); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  8. cmd/batch-handlers.go

    			batchLogIf(ctx, err)
    			continue
    		}
    	}
    }
    
    // AddWorker adds a replication worker to the pool
    func (j *BatchJobPool) AddWorker() {
    	if j == nil {
    		return
    	}
    	for {
    		select {
    		case <-j.ctx.Done():
    			return
    		case job, ok := <-j.jobCh:
    			if !ok {
    				return
    			}
    			switch {
    			case job.Replicate != nil:
    				if job.Replicate.RemoteToLocal() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  9. docs/bucket/notifications/README.md

    ```
    mc cp myphoto.jpg myminio/images
    ```
    
    Open PostgreSQL terminal to list the rows in the `bucketevents` table.
    
    ```
    $ psql -h 127.0.0.1 -U postgres -d minio_events
    minio_events=# select * from bucketevents;
    
    key                 |                      value
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
Back to top