Method QueryPrincipals

db/query.go:554–582

Query to retrieve the set of user and role doc ids, using the syncDocs index

(ctx context.Context, startKey string, limit int)

// Query to retrieve the set of user and role doc ids, using the syncDocs index
func (context *DatabaseContext) QueryPrincipals(ctx context.Context, startKey string, limit int) (sgbucket.QueryResultIterator, error) {

	// View Query
	if context.Options.UseViews {
		opts := map[string]interface{}{"stale": false}

		if limit > 0 {
			opts[QueryParamLimit] = limit
		}

		if startKey != "" {
			opts[QueryParamStartKey] = startKey
		}

		return context.ViewQueryWithStats(ctx, context.MetadataStore, DesignDocSyncGateway(), ViewPrincipals, opts)
	}

	queryStatement := replaceIndexTokensQuery(QueryPrincipals.statement, sgIndexes[IndexSyncDocs], context.UseXattrs(), context.numIndexPartitions())

	params := make(map[string]interface{})
	params[QueryParamStartKey] = startKey

	if limit > 0 {
		queryStatement = fmt.Sprintf("%s LIMIT %d", queryStatement, limit)
	}

	// N1QL Query
	return N1QLQueryWithStats(ctx, context.MetadataStore, QueryPrincipals.name, queryStatement, params, base.RequestPlus, QueryPrincipals.adhoc, context.DbStats, context.Options.SlowQueryWarningThreshold)
}

// Query to retrieve user details, using the syncDocs or users index
func (context *DatabaseContext) QueryUsers(ctx context.Context, startKey string, limit int) (sgbucket.QueryResultIterator, error) {