com.orientechnologies.orient.core.sql.query
Class OSQLSynchQuery<T>
T - public class OSQLSynchQuery<T> extends OSQLAsynchQuery<T> implements OCommandResultListener, Iterable<T>
OSQLAsynchQuerycacheableResult, context, fetchPlan, limit, onAsyncReplicationError, onAsyncReplicationOk, parameters, progressListener, resultListener, timeoutMs, timeoutStrategy, useCache| Constructor and Description |
|---|
OSQLSynchQuery() |
OSQLSynchQuery(String iText) |
OSQLSynchQuery(String iText,
int iLimit) |
| 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,
ORecordSerializer serializer) |
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.
|
deserializeQueryParameters, fromStream, getText, runFirst, serializeQueryParameters, setText, toStream, toStringexecute, getFetchPlan, setFetchPlanaddExcludedNode, 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, setUseCacheclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitforEach, spliteratorgetResultListener, setResultListenergetParameters, getProgressListener, getResultListener, isCacheableResult, isRecordResultSet, setCacheableResult, setProgressListener, setRecordResultSet, setResultListenerexecute, getContext, getFetchPlan, getLimit, getTimeoutStrategy, getTimeoutTime, setContext, setFetchPlan, setLimit, setTimeout, setUseCachepublic OSQLSynchQuery()
public OSQLSynchQuery(String iText)
public OSQLSynchQuery(String iText, int iLimit)
public void reset()
OQueryAbstractreset in interface OCommandRequestInternalreset in interface OQuery<T>reset in class OQueryAbstract<T>public boolean result(Object iRecord)
OCommandResultListenerresult in interface OCommandResultListeneriRecord - Current recordpublic void end()
OCommandResultListenerend in interface OCommandResultListenerpublic List<T> run(Object... iArgs)
OSQLQuerypublic boolean isIdempotent()
OSQLAsynchQueryisIdempotent in interface OCommandRequestisIdempotent in class OSQLAsynchQuery<T>public Object getResult()
getResult in interface OCommandResultListenerpublic ORID getNextPageRID()
public void resetPagination()
public boolean isAsynchronous()
isAsynchronous in interface OCommandRequestAsynchisAsynchronous in class OSQLAsynchQuery<T>protected OMemoryStream queryToStream()
queryToStream in class OSQLQuery<T>protected void queryFromStream(OMemoryStream buffer, ORecordSerializer serializer)
queryFromStream in class OSQLQuery<T>Copyright © 2009–2020 OrientDB. All rights reserved.