com.orientechnologies.orient.core.sql.query

Class OSQLNonBlockingQuery<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.OSQLNonBlockingQuery<T>

All Implemented Interfaces:

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

public class OSQLNonBlockingQuery<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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	OSQLNonBlockingQuery.ONonBlockingQueryFuture

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

Method Summary

Modifier and Type	Method and Description
<RET> RET	execute(Object... iArgs)
<RET> RET	execute2(String iText, Object... iArgs)
T	executeFirst()
boolean	isAsynchronous()
boolean	isIdempotent() Returns true if the command doesn't change the database, otherwise false.

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

deserializeQueryParameters, fromStream, getText, queryFromStream, queryToStream, run, runFirst, serializeQueryParameters, setText, toStream, toString

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

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

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

Constructor Detail

OSQLNonBlockingQuery

public OSQLNonBlockingQuery()

Empty constructor for unmarshalling.

OSQLNonBlockingQuery

public OSQLNonBlockingQuery(String iText,
                            OCommandResultListener iResultListener)

OSQLNonBlockingQuery

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

OSQLNonBlockingQuery

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

Method Detail

execute2

public <RET> RET execute2(String iText,
                          Object... iArgs)

executeFirst

public T executeFirst()

execute

public <RET> RET execute(Object... iArgs)

Specified by:

execute in interface OCommandRequest

Overrides:

execute in class OQueryAbstract<T>

isIdempotent

public boolean isIdempotent()

Description copied from interface: OCommandRequest

Returns true if the command doesn't change the database, otherwise false.

Specified by:

isIdempotent in interface OCommandRequest

Overrides:

isIdempotent in class OQueryAbstract<T>

isAsynchronous

public boolean isAsynchronous()

Specified by:

isAsynchronous in interface OCommandRequestAsynch