Method QueryAllDocs

db/query.go:705–739

AllDocs returns all non-deleted documents in the bucket between startKey and endKey

(ctx context.Context, startKey string, endKey string)

// AllDocs returns all non-deleted documents in the bucket between startKey and endKey
func (c *DatabaseCollection) QueryAllDocs(ctx context.Context, startKey string, endKey string) (sgbucket.QueryResultIterator, error) {

	// View Query
	if c.useViews() {
		opts := Body{"stale": false, "reduce": false}
		if startKey != "" {
			opts[QueryParamStartKey] = startKey
		}
		if endKey != "" {
			opts[QueryParamEndKey] = endKey
		}
		return c.dbCtx.ViewQueryWithStats(ctx, c.dataStore, DesignDocSyncHousekeeping(), ViewAllDocs, opts)
	}

	// N1QL Query
	allDocsQueryStatement := replaceSyncTokensQuery(QueryAllDocs.statement, c.UseXattrs())
	allDocsQueryStatement = replaceIndexTokensQuery(allDocsQueryStatement, sgIndexes[IndexAllDocs], c.UseXattrs(), c.numIndexPartitions())

	params := make(map[string]interface{}, 0)
	if startKey != "" {
		allDocsQueryStatement = fmt.Sprintf("%s AND META(%s).id >= $startkey",
			allDocsQueryStatement, base.KeyspaceQueryAlias)
		params[QueryParamStartKey] = startKey
	}
	if endKey != "" {
		allDocsQueryStatement = fmt.Sprintf("%s AND META(%s).id <= $endkey",
			allDocsQueryStatement, base.KeyspaceQueryAlias)
		params[QueryParamEndKey] = endKey
	}

	allDocsQueryStatement = fmt.Sprintf("%s ORDER BY META(%s).id",
		allDocsQueryStatement, base.KeyspaceQueryAlias)

	return N1QLQueryWithStats(ctx, c.dataStore, QueryTypeAllDocs, allDocsQueryStatement, params, base.RequestPlus, QueryAllDocs.adhoc, c.dbStats(), c.slowQueryWarningThreshold())
}

func (c *DatabaseCollection) QueryTombstones(ctx context.Context, olderThan time.Time, limit int) (sgbucket.QueryResultIterator, error) {