com.orientechnologies.orient.core.sql.query

Class OSQLAsynchQuery<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>

Type Parameters:

T -

All Implemented Interfaces:

OCommandRequest, OCommandRequestAsynch, OCommandRequestInternal, OCommandRequestText, ODistributedCommand, OQuery<T>

Direct Known Subclasses:

OSQLSynchQuery

public class OSQLAsynchQuery<T>
extends OSQLQuery<T>
implements OCommandRequestAsynch

SQL asynchronous query. When executed the caller does not wait for the execution, rather the listener will be called for each item found in the query. OSQLAsynchQuery has been built on top of this. NOTE: if you're working with remote databases don't execute any remote call inside the callback function because the network channel is locked until the query command has finished.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

See Also:

OSQLSynchQuery

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
OSQLAsynchQuery() Empty constructor for unmarshalling.
OSQLAsynchQuery(String iText)
OSQLAsynchQuery(String iText, int iLimit, OCommandResultListener iResultListener)
OSQLAsynchQuery(String iText, int iLimit, String iFetchPlan, Map<Object,Object> iArgs, OCommandResultListener iResultListener)
OSQLAsynchQuery(String iText, OCommandResultListener iResultListener)

Method Summary

Modifier and Type	Method and Description
boolean	isAsynchronous()
boolean	isIdempotent() Sets default non idempotent to avoid custom query deadlocks database.
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, queryFromStream, queryToStream, runFirst, serializeQueryParameters, setText, toStream, toString

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

execute, getFetchPlan, reset, 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 com.orientechnologies.orient.core.command.OCommandRequestAsynch

getResultListener, setResultListener

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

getParameters, getProgressListener, getResultListener, isCacheableResult, isRecordResultSet, reset, 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

OSQLAsynchQuery

public OSQLAsynchQuery()

Empty constructor for unmarshalling.

OSQLAsynchQuery

public OSQLAsynchQuery(String iText)

OSQLAsynchQuery

public OSQLAsynchQuery(String iText,
                       OCommandResultListener iResultListener)

OSQLAsynchQuery

public OSQLAsynchQuery(String iText,
                       int iLimit,
                       String iFetchPlan,
                       Map<Object,Object> iArgs,
                       OCommandResultListener iResultListener)

OSQLAsynchQuery

public OSQLAsynchQuery(String iText,
                       int iLimit,
                       OCommandResultListener iResultListener)

Method Detail

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 OSQLQuery<T>

Returns:

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

isIdempotent

public boolean isIdempotent()

Sets default non idempotent to avoid custom query deadlocks database.

Specified by:

isIdempotent in interface OCommandRequest

Overrides:

isIdempotent in class OQueryAbstract<T>

isAsynchronous

public boolean isAsynchronous()

Specified by:

isAsynchronous in interface OCommandRequestAsynch