com.j_spaces.jdbc

Class SelectQuery

java.lang.Object

com.j_spaces.jdbc.AbstractDMLQuery

com.j_spaces.jdbc.SelectQuery

All Implemented Interfaces:

Query, Externalizable, Serializable, Cloneable

public class SelectQuery
extends AbstractDMLQuery
implements Externalizable

This class handles the SELECT query logic.

Author:

Michael Mitrani, 2Train4, 2004

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregationSet	_aggregationSet

Fields inherited from class com.j_spaces.jdbc.AbstractDMLQuery

_buildOnly, _containsQuery, _convertResultToArray, _executor, _operationID, _projectionTemplate, _queryResultType, _tablesData, expTree, isPrepared, preparedValues, queryColumns, rownum, securityInterceptor, tables, valueMap

Constructor Summary

Constructors

Constructor and Description
SelectQuery()

Method Summary

Modifier and Type	Method and Description
void	addAbsentCol()
void	addColumn(SelectColumn column) Add a column to the list of columns.
void	addTableWithAlias(Object table, String alias)
SelectQuery	clone() Return a cloned SelectQuery
ResponsePacket	executeOnSpace(ISpaceProxy space, Transaction txn) Execute the query
BatchResponsePacket	executePreparedValuesBatch(ISpaceProxy space, Transaction transaction, GPreparedStatement.PreparedValuesCollection preparedValuesCollection) Executes a query with batched prepared values.
List<SelectColumn>	getGroupColumn()
List<OrderColumn>	getOrderColumns()
boolean	isAggFunction()
boolean	isCollocatedJoin()
boolean	isSelectQuery() Gets whether this query is a SELECT query.
void	readExternal(ObjectInput in)
void	setAggFunction(boolean flag)
void	setDistinct(boolean isDistinct)
void	setForUpdate(boolean forUpdate) Mark this select as a SELECT FOR UPDATE.
void	setGroupColumn(ArrayList<SelectColumn> groupColumnList) Sets the order column.
void	setJoins(List<Join> joins)
void	setOrderColumns(ArrayList<OrderColumn> ordCol) Sets the order column.
void	validateQuery(ISpaceProxy space) This method pre-validates the query, in terms of selected tables and columns.
void	writeExternal(ObjectOutput out)

Methods inherited from class com.j_spaces.jdbc.AbstractDMLQuery

addColumn, addTableWithAlias, assignParameters, build, buildTemplates, containsSubQueries, executeSubQueries, filterByRownum, getBuilder, getExplainPlan, getExpTree, getIfExists, getMinEntriesToWaitFor, getOperationID, getPreparedValues, getProjectionTemplate, getQueryColumnByAlias, getQueryColumns, getQueryResultType, getReadModifier, getRouting, getRownum, getRownumLimit, getSecurityInterceptor, getSession, getTableByAlias, getTableData, getTableData, getTableName, getTablesData, getTablesNames, getTemplatePacketIfExists, getTimeout, getTypeInfo, isBuildOnly, isContainsQuery, isConvertResultToArray, isDirtyState, isForceUnderTransaction, isJoined, isPrepared, isReturnResult, prepare, setBuildOnly, setContainsQuery, setContainsSubQueries, setConvertResultToArray, setExplainPlan, setExpTree, setIfExists, setMaxResults, setMinEntriesToWaitFor, setOperationID, setPrepared, setPreparedValues, setProjectionTemplate, setQueryResultType, setReadModifier, setReturnResult, setRouting, setRownum, setSecurityInterceptor, setSession, setTableName, setTemplatePreparedValues, setTimeout, validateBuiltTemplates, validateQuery

Methods inherited from class java.lang.Object

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

Field Detail

_aggregationSet

protected AggregationSet _aggregationSet

Constructor Detail

SelectQuery

public SelectQuery()

Method Detail

addTableWithAlias

public void addTableWithAlias(Object table,
                              String alias)

setJoins

public void setJoins(List<Join> joins)

addAbsentCol

public void addAbsentCol()

setAggFunction

public void setAggFunction(boolean flag)

isAggFunction

public boolean isAggFunction()

executeOnSpace

public ResponsePacket executeOnSpace(ISpaceProxy space,
                                     Transaction txn)
                              throws SQLException

Execute the query

Specified by:

executeOnSpace in interface Query

Throws:

SQLException

isCollocatedJoin

public boolean isCollocatedJoin()

clone

public SelectQuery clone()

Return a cloned SelectQuery

Specified by:

clone in class AbstractDMLQuery

addColumn

public void addColumn(SelectColumn column)

Add a column to the list of columns.

Parameters:

column - the column to add

setOrderColumns

public void setOrderColumns(ArrayList<OrderColumn> ordCol)

Sets the order column.

setGroupColumn

public void setGroupColumn(ArrayList<SelectColumn> groupColumnList)

Sets the order column.

getGroupColumn

public List<SelectColumn> getGroupColumn()

setForUpdate

public void setForUpdate(boolean forUpdate)

Mark this select as a SELECT FOR UPDATE.

validateQuery

public void validateQuery(ISpaceProxy space)
                   throws SQLException

This method pre-validates the query, in terms of selected tables and columns.

Specified by:

validateQuery in interface Query

Overrides:

validateQuery in class AbstractDMLQuery

Throws:

SQLException

setDistinct

public void setDistinct(boolean isDistinct)

getOrderColumns

public List<OrderColumn> getOrderColumns()

isSelectQuery

public boolean isSelectQuery()

Description copied from class: AbstractDMLQuery

Gets whether this query is a SELECT query.

Overrides:

isSelectQuery in class AbstractDMLQuery

executePreparedValuesBatch

public BatchResponsePacket executePreparedValuesBatch(ISpaceProxy space,
                                                      Transaction transaction,
                                                      GPreparedStatement.PreparedValuesCollection preparedValuesCollection)
                                               throws SQLException

Description copied from class: AbstractDMLQuery

Executes a query with batched prepared values. This is the default implementation - NOT optimized.

Overrides:

executePreparedValuesBatch in class AbstractDMLQuery

Returns:

BatchResponsePacket

Throws:

SQLException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class AbstractDMLQuery

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class AbstractDMLQuery

Throws:

IOException

ClassNotFoundException