com.orientechnologies.orient.core.sql.query

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

Type Parameters:

T - Record type to return.

All Implemented Interfaces:

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

Direct Known Subclasses:

OSQLAsynchQuery, OSQLNonBlockingQuery

public abstract class OSQLQuery<T>
extends OQueryAbstract<T>
implements OCommandRequestText

SQL query implementation.

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
protected String	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
OSQLQuery()
OSQLQuery(String iText)

Method Summary

Modifier and Type	Method and Description
protected Map<Object,Object>	deserializeQueryParameters(byte[] paramBuffer, ORecordSerializer serializer)
OCommandRequestText	fromStream(byte[] iStream, ORecordSerializer serializer)
String	getText()
protected void	queryFromStream(OMemoryStream buffer, ORecordSerializer serializer)
protected OMemoryStream	queryToStream()
List<T>	run(Object... iArgs) Delegates to the OQueryExecutor the query execution.
T	runFirst(Object... iArgs) Returns only the first record if any.
protected byte[]	serializeQueryParameters(Map<Object,Object> params)
OCommandRequestText	setText(String iText)
byte[]	toStream()
String	toString()

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

execute, getFetchPlan, isIdempotent, 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.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, isIdempotent, setContext, setFetchPlan, setLimit, setTimeout, setUseCache

Field Detail

text

protected String text

Constructor Detail

OSQLQuery

public OSQLQuery()

OSQLQuery

public OSQLQuery(String iText)

Method Detail

run

public List<T> run(Object... iArgs)

Delegates to the OQueryExecutor the query execution.

Specified by:

run in interface OQuery<T>

Returns:

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

runFirst

public T runFirst(Object... iArgs)

Returns only the first record if any.

Specified by:

runFirst in interface OQuery<T>

Returns:

Record if found, otherwise null

getText

public String getText()

Specified by:

getText in interface OCommandRequestText

setText

public OCommandRequestText setText(String iText)

Specified by:

setText in interface OCommandRequestText

toString

public String toString()

Overrides:

toString in class Object

fromStream

public OCommandRequestText fromStream(byte[] iStream,
                                      ORecordSerializer serializer)
                               throws OSerializationException

Specified by:

fromStream in interface OCommandRequestText

Throws:

OSerializationException

toStream

public byte[] toStream()
                throws OSerializationException

Specified by:

toStream in interface OCommandRequestText

Throws:

OSerializationException

queryToStream

protected OMemoryStream queryToStream()

queryFromStream

protected void queryFromStream(OMemoryStream buffer,
                               ORecordSerializer serializer)

deserializeQueryParameters

protected Map<Object,Object> deserializeQueryParameters(byte[] paramBuffer,
                                                        ORecordSerializer serializer)

serializeQueryParameters

protected byte[] serializeQueryParameters(Map<Object,Object> params)