Package org.infinispan.client.hotrod.impl.query

Class RemoteQuery<T>

java.lang.Object

org.infinispan.query.dsl.impl.BaseQuery<T>

org.infinispan.client.hotrod.impl.query.RemoteQuery<T>

All Implemented Interfaces:

Iterable<T>, PaginationContext<Query<T>>, ParameterContext<Query<T>>, Query<T>

public final class RemoteQuery<T>
extends BaseQuery<T>

Since:

6.0

Author:

anistor@redhat.com

Field Summary

Fields inherited from class org.infinispan.query.dsl.impl.BaseQuery

hitCountAccuracy, local, maxResults, namedParameters, projection, queryFactory, queryString, startOffset, timeout

Method Summary

Modifier and Type	Method	Description
QueryResult<T>	execute()	Executes the query (a SELECT statement).
int	executeStatement()	Executes a data modifying statement (typically a DELETE) that does not return results; instead it returns an affected entries count.
RemoteCache<?,?>	getCache()
int	getResultSize()	Gets the total number of results matching the query, ignoring pagination (startOffset, maxResults).
SerializationContext	getSerializationContext()	Get the protobuf SerializationContext or null if we are not using protobuf.
CloseableIterator<T>	iterator()	Returns a CloseableIterator over the results.
List<T>	list()	Returns the results of a search as a list.
void	resetQuery()	Reset internal state after pagination or query parameters are modified.
String	toString()

Methods inherited from class org.infinispan.query.dsl.impl.BaseQuery

entryIterator, getMaxResults, getParameters, getProjection, getQueryString, getStartOffset, hasProjections, hitCountAccuracy, hitCountAccuracy, isLocal, local, maxResults, setParameter, setParameters, startOffset, timeout, validateNamedParameters

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Detail

resetQuery

public void resetQuery()

Description copied from class: BaseQuery

Reset internal state after pagination or query parameters are modified. This is needed to ensure the next execution of the query uses the new values.

Specified by:

resetQuery in class BaseQuery<T>

list

public List<T> list()

Description copied from interface: Query

Returns the results of a search as a list.

Returns:

list of objects that were found from the search.

execute

public QueryResult<T> execute()

Description copied from interface: Query

Executes the query (a SELECT statement). Subsequent invocations cause the query to be re-executed.

Executing a DELETE is also allowed. No results will be returned in this case but the number of affected entries will be returned as the hit count in the QueryResult.

Returns:

QueryResult with the results.

executeStatement

public int executeStatement()

Description copied from interface: Query

Executes a data modifying statement (typically a DELETE) that does not return results; instead it returns an affected entries count. This method cannot be used to execute a SELECT.

NOTE: Paging params (firstResult/maxResults) are NOT allowed.

Specified by:

executeStatement in interface Query<T>

Overrides:

executeStatement in class BaseQuery<T>

Returns:

the number of affected (deleted) entries

iterator

public CloseableIterator<T> iterator()

Description copied from interface: Query

Returns a CloseableIterator over the results. Please close the iterator when you are done with processing the results.

Returns:

the results of the query as an iterator.

getResultSize

public int getResultSize()

Description copied from interface: Query

Gets the total number of results matching the query, ignoring pagination (startOffset, maxResults).

Returns:

total number of results.

getSerializationContext

public SerializationContext getSerializationContext()

Get the protobuf SerializationContext or null if we are not using protobuf.

getCache

public RemoteCache<?,?> getCache()

toString

public String toString()

Overrides:

toString in class Object