com.orientechnologies.orient.core.sql.query

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

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

All Implemented Interfaces:

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

public class OLiveQuery<T>
extends OSQLSynchQuery<T>

SQL live query.

The statement syntax is the same as a normal SQL SELECT statement, but with LIVE as prefix:

LIVE SELECT FROM Foo WHERE name = 'bar'

Executing this query, the caller will subscribe to receive changes happening in the database, that match this query condition. The query returns a query token in the result set. To unsubscribe, the user has to execute another live query with the following syntax:

LIVE UNSUBSCRIBE <token>

The callback passed as second parameter will be invoked every time a record is created/updated/deleted and it matches the query conditions.

Author:

Luigi Dell'Aquila

See Also:

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
OLiveQuery()
OLiveQuery(String iText, OLiveResultListener iResultListener)

Method Summary

Modifier and Type	Method and Description
<RET> RET	execute(Object... iArgs)

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

end, getNextPageRID, getResult, isAsynchronous, isIdempotent, iterator, queryFromStream, queryToStream, reset, resetPagination, result, run

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

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

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

Constructor Detail

OLiveQuery

public OLiveQuery()

OLiveQuery

public OLiveQuery(String iText,
                  OLiveResultListener iResultListener)

Method Detail

execute

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

Specified by:

execute in interface OCommandRequest

Overrides:

execute in class OQueryAbstract<T>