com.orientechnologies.orient.core.sql.executor

Class LiveQueryListenerImpl

java.lang.Object

com.orientechnologies.orient.core.sql.executor.LiveQueryListenerImpl

All Implemented Interfaces:

OLiveQueryListenerV2

public class LiveQueryListenerImpl
extends Object
implements OLiveQueryListenerV2

Created by luigidellaquila on 15/06/17.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BEFORE_METADATA_KEY

Constructor Summary

Constructors

Constructor and Description
LiveQueryListenerImpl(OLiveQueryResultListener clientListener, String query, ODatabaseDocument db, Map<Object,Object> iArgs)
LiveQueryListenerImpl(OLiveQueryResultListener clientListener, String query, ODatabaseDocument db, Object[] iArgs)

Method Summary

Modifier and Type	Method and Description
protected void	execInSeparateDatabase(OCallable iCallback)
OSelectStatement	getStatement()
int	getToken()
void	onLiveResultEnd()
void	onLiveResults(List<OLiveQueryHookV2.OLiveQueryOp> iRecords)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

BEFORE_METADATA_KEY

public static final String BEFORE_METADATA_KEY

See Also:

Constant Field Values

Constructor Detail

LiveQueryListenerImpl

public LiveQueryListenerImpl(OLiveQueryResultListener clientListener,
                             String query,
                             ODatabaseDocument db,
                             Object[] iArgs)

LiveQueryListenerImpl

public LiveQueryListenerImpl(OLiveQueryResultListener clientListener,
                             String query,
                             ODatabaseDocument db,
                             Map<Object,Object> iArgs)

Method Detail

getToken

public int getToken()

Specified by:

getToken in interface OLiveQueryListenerV2

onLiveResults

public void onLiveResults(List<OLiveQueryHookV2.OLiveQueryOp> iRecords)

Specified by:

onLiveResults in interface OLiveQueryListenerV2

onLiveResultEnd

public void onLiveResultEnd()

Specified by:

onLiveResultEnd in interface OLiveQueryListenerV2

execInSeparateDatabase

protected void execInSeparateDatabase(OCallable iCallback)

getStatement

public OSelectStatement getStatement()