Package com.j_spaces.jdbc.executor

Class AbstractQueryExecutor

java.lang.Object

com.j_spaces.jdbc.executor.AbstractQueryExecutor

All Implemented Interfaces:

IQueryExecutor, Externalizable, Serializable

Direct Known Subclasses:

CollocatedJoinedQueryExecutor, JoinedQueryExecutor, QueryExecutor

public abstract class AbstractQueryExecutor
extends Object
implements IQueryExecutor

Since:

7.0

Author:

anna

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractQueryExecutor.EntriesOrderByComparator	This private class implements the Comparator and is used to sort.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	_logger
protected AbstractDMLQuery	query

Constructor Summary

Constructors

Constructor	Description
AbstractQueryExecutor()
AbstractQueryExecutor(AbstractDMLQuery query)

Method Summary

Modifier and Type	Method	Description
IEntryPacket	aggregate(IQueryResultSet<IEntryPacket> entries)	Execute SQL function that processes the result entries and calculates one value - sum,average,min,max
Number	avg(SelectColumn funcColumn, IQueryResultSet<IEntryPacket> entries)	Calculate the average value of the given column for all entries .
int	clear(QueryTemplatePacket template, ISpaceProxy space, Transaction txn, int modifiers)	Execute clear
ResultEntry	convertEntriesToResultArrays(IQueryResultSet<IEntryPacket> entries)	Converts the list of ExternaEntries to 2 dimensional array that contains the values of the entries.
int	count(QueryTemplatePacket template, ISpaceProxy space, Transaction txn, int readModifier)
void	execute(InnerQueryNode innerQueryNode, ISpaceProxy space, Transaction txn, int readModifier, int max)	Executes an inner query
IQueryResultSet<IEntryPacket>	executeTemplate(QueryTemplatePacket template, ISpaceProxy space, Transaction txn, int readModifier, int max)
IQueryResultSet<IEntryPacket>	extractResults(ExpNode node)
IQueryResultSet<IEntryPacket>	filterDistinctEntries(IQueryResultSet<IEntryPacket> entries)	Removes duplicate entries from the result set.
Comparator<IEntryPacket>	getGroupByComparator(IQueryResultSet<IEntryPacket> queryResult, List<SelectColumn> groupColumns)
protected HashMap<ExpNode,IQueryResultSet<IEntryPacket>>	getIntermediateResults()
Comparator<IEntryPacket>	getOrderByComparator(IQueryResultSet<IEntryPacket> entries, List<OrderColumn> orderColumns)
AbstractDMLQuery	getQuery()
IQueryResultSet<IEntryPacket>	groupBy(IQueryResultSet<IEntryPacket> entries, List<SelectColumn> groupColumns)	Group the results according to the group by clause
Object	minMax(SelectColumn funcColumn, IQueryResultSet<IEntryPacket> entries, boolean isMax)	Finds the minimum/maximum value of given column
void	orderBy(IQueryResultSet<IEntryPacket> entries, List<OrderColumn> orderColumns)	Order the results according to the order by clause
IQueryResultSet	readAll(ISpaceProxy space, Transaction txn)
void	readExternal(ObjectInput in)
void	setResults(ExpNode node, IQueryResultSet<IEntryPacket> results)
Number	sum(SelectColumn funcColumn, IQueryResultSet<IEntryPacket> entries)	Calculate the sum value of the given column for all entries
protected IQueryResultSet<IEntryPacket>	traverseExpressionTree(ExpNode root, ISpaceProxy space, Transaction txn, int readModifier, int max)	Traverse the binary expression tree non-recursively using a custom stack The tree has to be traversed in postorder - the parent is traversed after its children.
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.j_spaces.jdbc.executor.IQueryExecutor

execute, execute, execute, execute, execute, execute

Field Details

_logger

protected static final org.slf4j.Logger _logger

query

protected AbstractDMLQuery query

Constructor Details

AbstractQueryExecutor

public AbstractQueryExecutor()

AbstractQueryExecutor

public AbstractQueryExecutor(AbstractDMLQuery query)

Method Details

clear

public int clear(QueryTemplatePacket template,
 ISpaceProxy space,
 Transaction txn,
 int modifiers)
          throws RemoteException,
TransactionException,
UnusableEntryException

Description copied from interface: IQueryExecutor

Execute clear

Specified by:

clear in interface IQueryExecutor

Returns:

int

Throws:

RemoteException

TransactionException

UnusableEntryException

count

public int count(QueryTemplatePacket template,
 ISpaceProxy space,
 Transaction txn,
 int readModifier)
          throws SQLException

Specified by:

count in interface IQueryExecutor

Throws:

SQLException

getQuery

public AbstractDMLQuery getQuery()

extractResults

public IQueryResultSet<IEntryPacket> extractResults(ExpNode node)

setResults

public void setResults(ExpNode node,
 IQueryResultSet<IEntryPacket> results)

traverseExpressionTree

protected IQueryResultSet<IEntryPacket> traverseExpressionTree(ExpNode root,
 ISpaceProxy space,
 Transaction txn,
 int readModifier,
 int max)
                                                        throws SQLException

Traverse the binary expression tree non-recursively using a custom stack The tree has to be traversed in postorder - the parent is traversed after its children.

Throws:

SQLException

readAll

public IQueryResultSet readAll(ISpaceProxy space,
 Transaction txn)
                        throws SQLException

Specified by:

readAll in interface IQueryExecutor

Throws:

SQLException

executeTemplate

public IQueryResultSet<IEntryPacket> executeTemplate(QueryTemplatePacket template,
 ISpaceProxy space,
 Transaction txn,
 int readModifier,
 int max)
                                              throws SQLException

Throws:

SQLException

getIntermediateResults

protected HashMap<ExpNode,IQueryResultSet<IEntryPacket>> getIntermediateResults()

aggregate

public IEntryPacket aggregate(IQueryResultSet<IEntryPacket> entries)
                       throws SQLException

Execute SQL function that processes the result entries and calculates one value - sum,average,min,max

Specified by:

aggregate in interface IQueryExecutor

Returns:

The result of sum,average,min,max

Throws:

SQLException

groupBy

public IQueryResultSet<IEntryPacket> groupBy(IQueryResultSet<IEntryPacket> entries,
 List<SelectColumn> groupColumns)
                                      throws SQLException

Group the results according to the group by clause

Specified by:

groupBy in interface IQueryExecutor

Returns:

IQuery result set

Throws:

SQLException

getGroupByComparator

public Comparator<IEntryPacket> getGroupByComparator(IQueryResultSet<IEntryPacket> queryResult,
 List<SelectColumn> groupColumns)

orderBy

public void orderBy(IQueryResultSet<IEntryPacket> entries,
 List<OrderColumn> orderColumns)
             throws SQLException

Order the results according to the order by clause

Specified by:

orderBy in interface IQueryExecutor

Throws:

SQLException

getOrderByComparator

public Comparator<IEntryPacket> getOrderByComparator(IQueryResultSet<IEntryPacket> entries,
 List<OrderColumn> orderColumns)

minMax

public Object minMax(SelectColumn funcColumn,
 IQueryResultSet<IEntryPacket> entries,
 boolean isMax)

Finds the minimum/maximum value of given column

Returns:

minimum/maximum value of given column

avg

public Number avg(SelectColumn funcColumn,
 IQueryResultSet<IEntryPacket> entries)
           throws SQLException

Calculate the average value of the given column for all entries . Average is calculated using Double precision

Returns:

the sum value of the field

Throws:

SQLException

sum

public Number sum(SelectColumn funcColumn,
 IQueryResultSet<IEntryPacket> entries)
           throws SQLException

Calculate the sum value of the given column for all entries

Returns:

the sum value of the field

Throws:

SQLException

filterDistinctEntries

public IQueryResultSet<IEntryPacket> filterDistinctEntries(IQueryResultSet<IEntryPacket> entries)

Removes duplicate entries from the result set. The rows are inserted into a TreeSet and only the rows that were successfully added, are considered distinct. Note: TreeSet is used and not HashSet to avoid creating hashCode for all fields.

Specified by:

filterDistinctEntries in interface IQueryExecutor

Returns:

new IQueryResultSet with distinct entries

convertEntriesToResultArrays

public ResultEntry convertEntriesToResultArrays(IQueryResultSet<IEntryPacket> entries)

Converts the list of ExternaEntries to 2 dimensional array that contains the values of the entries. Each row matches specific IEntryPacket. The conversion is necessary for entries ordering.

Specified by:

convertEntriesToResultArrays in interface IQueryExecutor

execute

public void execute(InnerQueryNode innerQueryNode,
 ISpaceProxy space,
 Transaction txn,
 int readModifier,
 int max)
             throws SQLException

Executes an inner query

Specified by:

execute in interface IQueryExecutor

Throws:

SQLException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException