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>, OSerializableStream, Serializable

Direct Known Subclasses:

OSQLAsynchQuery, OSQLNonBlockingQuery

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

SQL query implementation.

Author:

Luca Garulli

See Also:

Serialized Form

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)
OSerializableStream	fromStream(byte[] iStream) Unmarshalls the object.
String	getText()
protected void	queryFromStream(OMemoryStream buffer)
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() Marshalls the object.
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 OSerializableStream fromStream(byte[] iStream)
                               throws OSerializationException

Description copied from interface: OSerializableStream

Unmarshalls the object. Fills the current object with the values contained in the byte array representation restoring a previous state. Usually byte[] comes from the storage or network.

Specified by:

fromStream in interface OSerializableStream

Parameters:

iStream - byte array representation of the object

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

Throws:

OSerializationException - if the unmarshalling does not succeed

toStream

public byte[] toStream()
                throws OSerializationException

Description copied from interface: OSerializableStream

Marshalls the object. Transforms the current object in byte[] form to being stored or transferred over the network.

Specified by:

toStream in interface OSerializableStream

Returns:

The byte array representation of the object

Throws:

OSerializationException - if the marshalling does not succeed

See Also:

OSerializableStream.fromStream(byte[])

queryToStream

protected OMemoryStream queryToStream()

queryFromStream

protected void queryFromStream(OMemoryStream buffer)

deserializeQueryParameters

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

serializeQueryParameters

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