com.orientechnologies.orient.core.sql.query

Class OSQLSynchQuery<T>

java.lang.Object

com.orientechnologies.orient.core.command.OCommandRequestAbstract

com.orientechnologies.orient.core.query.OQueryAbstract<T>

com.orientechnologies.orient.core.sql.query.OSQLQuery<T>

com.orientechnologies.orient.core.sql.query.OSQLAsynchQuery<T>

com.orientechnologies.orient.core.sql.query.OSQLSynchQuery<T>

Type Parameters:

T -

All Implemented Interfaces:

OCommandRequest, OCommandRequestAsynch, OCommandRequestInternal, OCommandRequestText, OCommandResultListener, ODistributedCommand, OQuery<T>, OSerializableStream, Serializable, Iterable<T>

Direct Known Subclasses:

OLiveQuery

public class OSQLSynchQuery<T>
extends OSQLAsynchQuery<T>
implements OCommandResultListener, Iterable<T>

SQL synchronous query. When executed the caller wait for the result.

Author:

Luca Garulli

See Also:

OSQLAsynchQuery, Serialized Form

Field Summary

Fields inherited from class com.orientechnologies.orient.core.sql.query.OSQLQuery

text

Fields inherited from class com.orientechnologies.orient.core.command.OCommandRequestAbstract

cacheableResult, context, fetchPlan, limit, onAsyncReplicationError, onAsyncReplicationOk, parameters, progressListener, resultListener, timeoutMs, timeoutStrategy, useCache

Constructor Summary

Constructors

Constructor and Description
OSQLSynchQuery()
OSQLSynchQuery(String iText)
OSQLSynchQuery(String iText, int iLimit)

Method Summary

Modifier and Type	Method and Description
void	end() Called at the end of processing.
ORID	getNextPageRID()
Object	getResult()
boolean	isAsynchronous()
boolean	isIdempotent() Sets default non idempotent to avoid custom query deadlocks database.
Iterator<T>	iterator()
protected void	queryFromStream(OMemoryStream buffer)
protected OMemoryStream	queryToStream()
void	reset() Resets the query removing the result set.
void	resetPagination()
boolean	result(Object iRecord) This method is called for each result.
List<T>	run(Object... iArgs) Delegates to the OQueryExecutor the query execution.

Methods inherited from class com.orientechnologies.orient.core.sql.query.OSQLQuery

deserializeQueryParameters, fromStream, getText, runFirst, serializeQueryParameters, setText, toStream, toString

Methods inherited from class com.orientechnologies.orient.core.query.OQueryAbstract

execute, getFetchPlan, setFetchPlan

Methods inherited from class com.orientechnologies.orient.core.command.OCommandRequestAbstract

addExcludedNode, convertToParameters, getContext, getLimit, getOnAsyncReplicationError, getOnAsyncReplicationOk, getParameters, getProgressListener, getResultListener, getTimeoutStrategy, getTimeoutTime, isCacheableResult, isRecordResultSet, isUseCache, nodesToExclude, onAsyncReplicationError, onAsyncReplicationOk, removeExcludedNode, setCacheableResult, setContext, setLimit, setParameters, setProgressListener, setRecordResultSet, setResultListener, setTimeout, setUseCache

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

Methods inherited from interface com.orientechnologies.orient.core.command.OCommandRequestAsynch

getResultListener, setResultListener

Methods inherited from interface com.orientechnologies.orient.core.command.OCommandRequestInternal

getParameters, getProgressListener, getResultListener, isCacheableResult, isRecordResultSet, setCacheableResult, setProgressListener, setRecordResultSet, setResultListener

Methods inherited from interface com.orientechnologies.orient.core.command.OCommandRequest

execute, getContext, getFetchPlan, getLimit, getTimeoutStrategy, getTimeoutTime, setContext, setFetchPlan, setLimit, setTimeout, setUseCache

Constructor Detail

OSQLSynchQuery

public OSQLSynchQuery()

OSQLSynchQuery

public OSQLSynchQuery(String iText)

OSQLSynchQuery

public OSQLSynchQuery(String iText,
                      int iLimit)

Method Detail

reset

public void reset()

Description copied from class: OQueryAbstract

Resets the query removing the result set. Call this to reuse the Query object preventing a pagination.

Specified by:

reset in interface OCommandRequestInternal

Specified by:

reset in interface OQuery<T>

Overrides:

reset in class OQueryAbstract<T>

result

public boolean result(Object iRecord)

Description copied from interface: OCommandResultListener

This method is called for each result.

Specified by:

result in interface OCommandResultListener

Parameters:

iRecord - Current record

Returns:

True to continue the query, otherwise false

end

public void end()

Description copied from interface: OCommandResultListener

Called at the end of processing. This is useful to clean-up local attributes.

Specified by:

end in interface OCommandResultListener

run

public List<T> run(Object... iArgs)

Description copied from class: OSQLQuery

Delegates to the OQueryExecutor the query execution.

Specified by:

run in interface OQuery<T>

Overrides:

run in class OSQLAsynchQuery<T>

Returns:

List of records if any record matches the query constraints, otherwise an empty List.

isIdempotent

public boolean isIdempotent()

Description copied from class: OSQLAsynchQuery

Sets default non idempotent to avoid custom query deadlocks database.

Specified by:

isIdempotent in interface OCommandRequest

Overrides:

isIdempotent in class OSQLAsynchQuery<T>

getResult

public Object getResult()

Specified by:

getResult in interface OCommandResultListener

getNextPageRID

public ORID getNextPageRID()

Returns:

RID of the record that will be processed first during pagination mode.

resetPagination

public void resetPagination()

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

isAsynchronous

public boolean isAsynchronous()

Specified by:

isAsynchronous in interface OCommandRequestAsynch

Overrides:

isAsynchronous in class OSQLAsynchQuery<T>

queryToStream

protected OMemoryStream queryToStream()

Overrides:

queryToStream in class OSQLQuery<T>

queryFromStream

protected void queryFromStream(OMemoryStream buffer)

Overrides:

queryFromStream in class OSQLQuery<T>