Function N1QLQueryWithStats

db/query.go:373–400

N1QlQueryWithStats is a wrapper for gocbBucket.Query that performs additional diagnostic processing (expvars, slow query logging)

(ctx context.Context, dataStore base.DataStore, queryName string, statement string, params map[string]interface{}, consistency base.ConsistencyMode, adhoc bool, dbStats *base.DbStats, slowQueryWarningThreshold time.Duration)

// N1QlQueryWithStats is a wrapper for gocbBucket.Query that performs additional diagnostic processing (expvars, slow query logging)
func N1QLQueryWithStats(ctx context.Context, dataStore base.DataStore, queryName string, statement string, params map[string]interface{}, consistency base.ConsistencyMode, adhoc bool, dbStats *base.DbStats, slowQueryWarningThreshold time.Duration) (results sgbucket.QueryResultIterator, err error) {

	startTime := time.Now()
	if threshold := slowQueryWarningThreshold; threshold > 0 {
		defer base.SlowQueryLog(ctx, startTime, threshold, "N1QL Query(%q)", queryName)
	}

	n1QLStore, ok := base.AsN1QLStore(dataStore)
	if !ok {
		return nil, errors.New("Cannot perform N1QL query on non-Couchbase bucket.")
	}

	results, err = n1QLStore.Query(ctx, statement, params, consistency, adhoc)

	if len(queryName) > 0 {
		queryStat := dbStats.Query(queryName)
		if queryStat == nil {
			// This panic is more recognizable than the one that will otherwise occur below
			panic(fmt.Sprintf("DbStats has no entry for query %q", queryName))
		}
		if err != nil {
			queryStat.QueryErrorCount.Add(1)
		}
		queryStat.QueryCount.Add(1)
		queryStat.QueryTime.Add(time.Since(startTime).Nanoseconds())
	}
	return results, err
}

// ViewQueryWithStats is a wrapper for gocbBucket.Query that performs additional diagnostic processing (expvars, slow query logging)
func (context *DatabaseContext) ViewQueryWithStats(ctx context.Context, dataStore base.DataStore, ddoc string, viewName string, params map[string]interface{}) (results sgbucket.QueryResultIterator, err error) {