org.nuxeo.elasticsearch.query

Class NxQueryBuilder

java.lang.Object

org.nuxeo.elasticsearch.query.NxQueryBuilder

public class NxQueryBuilder
extends Object

Elasticsearch query buidler for the Nuxeo ES api.

Since:

5.9.5

Constructor Summary

Constructors

Constructor and Description
NxQueryBuilder(CoreSession coreSession)

Method Summary

Methods

Modifier and Type	Method and Description
NxQueryBuilder	addAggregate(AggregateEsBase<? extends Bucket> aggregate)
NxQueryBuilder	addAggregates(List<AggregateEsBase<? extends Bucket>> aggregates)
NxQueryBuilder	addSearchRepository(String repositoryName) Add a specific repository to search.
NxQueryBuilder	addSort(SortInfo sortInfo)
NxQueryBuilder	addSort(SortInfo[] sortInfos)
NxQueryBuilder	esQuery(org.elasticsearch.index.query.QueryBuilder queryBuilder) Build the query using the Elasticsearch QueryBuilder API.
NxQueryBuilder	fetchFromDatabase() Fetch the documents using VCS (database) engine.
NxQueryBuilder	fetchFromElasticsearch() Fetch the documents from the Elasticsearch _source field.
static String	getAggregateFilterId(Aggregate agg)
List<AggregateEsBase<? extends Bucket>>	getAggregates()
List<org.elasticsearch.search.aggregations.bucket.filter.FilterAggregationBuilder>	getEsAggregates()
Fetcher	getFetcher(org.elasticsearch.action.search.SearchResponse response, Map<String,String> repoNames)
int	getLimit()
String	getNxql()
int	getOffset()
List<String>	getSearchRepositories() Return the list of repositories to search, or an empty list to search on all available repositories;
String[]	getSelectFields()
Map<String,Type>	getSelectFieldsAndTypes()
CoreSession	getSession()
org.elasticsearch.search.sort.SortBuilder[]	getSortBuilders()
List<SortInfo>	getSortInfos()
boolean	isFetchFromElasticsearch()
NxQueryBuilder	limit(int limit) No more than that many documents will be returned.
org.elasticsearch.index.query.QueryBuilder	makeQuery() Get the Elasticsearch queryBuilder.
NxQueryBuilder	nxql(String nxql) Build the query from a NXQL string.
NxQueryBuilder	offset(int offset) Says to skip that many documents before beginning to return documents.
boolean	returnsDocuments()
NxQueryBuilder	searchOnAllRepositories() Search on all available repositories.
void	updateRequest(org.elasticsearch.action.search.SearchRequestBuilder request)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NxQueryBuilder

public NxQueryBuilder(CoreSession coreSession)

Method Detail

getAggregateFilterId

public static String getAggregateFilterId(Aggregate agg)

limit

public NxQueryBuilder limit(int limit)

No more than that many documents will be returned. Default to {DEFAULT_LIMIT}, Use -1 to return all documents.

offset

public NxQueryBuilder offset(int offset)

Says to skip that many documents before beginning to return documents. If both offset and limit appear, then offset documents are skipped before starting to count the limit documents that are returned.

addSort

public NxQueryBuilder addSort(SortInfo sortInfo)

addSort

public NxQueryBuilder addSort(SortInfo[] sortInfos)

nxql

public NxQueryBuilder nxql(String nxql)

Build the query from a NXQL string. You should either use nxql, either esQuery, not both.

esQuery

public NxQueryBuilder esQuery(org.elasticsearch.index.query.QueryBuilder queryBuilder)

Build the query using the Elasticsearch QueryBuilder API. You should either use nxql, either esQuery, not both.

fetchFromElasticsearch

public NxQueryBuilder fetchFromElasticsearch()

Fetch the documents from the Elasticsearch _source field.

fetchFromDatabase

public NxQueryBuilder fetchFromDatabase()

Fetch the documents using VCS (database) engine. This is done by default

addAggregate

public NxQueryBuilder addAggregate(AggregateEsBase<? extends Bucket> aggregate)

addAggregates

public NxQueryBuilder addAggregates(List<AggregateEsBase<? extends Bucket>> aggregates)

getLimit

public int getLimit()

getOffset

public int getOffset()

getSortInfos

public List<SortInfo> getSortInfos()

getNxql

public String getNxql()

isFetchFromElasticsearch

public boolean isFetchFromElasticsearch()

getSession

public CoreSession getSession()

makeQuery

public org.elasticsearch.index.query.QueryBuilder makeQuery()

Get the Elasticsearch queryBuilder. Note that it returns only the query part without order, limits nor aggregates, use the udpateRequest to get the full request.

getSortBuilders

public org.elasticsearch.search.sort.SortBuilder[] getSortBuilders()

getAggregates

public List<AggregateEsBase<? extends Bucket>> getAggregates()

getEsAggregates

public List<org.elasticsearch.search.aggregations.bucket.filter.FilterAggregationBuilder> getEsAggregates()

updateRequest

public void updateRequest(org.elasticsearch.action.search.SearchRequestBuilder request)

addSearchRepository

public NxQueryBuilder addSearchRepository(String repositoryName)

Add a specific repository to search. Default search is done on the session repository only.

Since:

6.0

searchOnAllRepositories

public NxQueryBuilder searchOnAllRepositories()

Search on all available repositories.

Since:

6.0

getSearchRepositories

public List<String> getSearchRepositories()

Return the list of repositories to search, or an empty list to search on all available repositories;

Since:

6.0

getFetcher

public Fetcher getFetcher(org.elasticsearch.action.search.SearchResponse response,
                 Map<String,String> repoNames)

Since:

6.0

getSelectFields

public String[] getSelectFields()

Since:

7.2

getSelectFieldsAndTypes

public Map<String,Type> getSelectFieldsAndTypes()

Since:

7.2

returnsDocuments

public boolean returnsDocuments()

Since:

7.2