Package 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	Description
static final String	BEFORE_METADATA_KEY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

BEFORE_METADATA_KEY

public static final String BEFORE_METADATA_KEY

See Also:

• Constant Field Values

Constructor Details

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 Details

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()