com.j_spaces.jdbc.executor

Class JoinedQueryExecutor

java.lang.Object

com.j_spaces.jdbc.executor.AbstractQueryExecutor

com.j_spaces.jdbc.executor.JoinedQueryExecutor

All Implemented Interfaces:

IQueryExecutor, Externalizable, Serializable

public class JoinedQueryExecutor
extends AbstractQueryExecutor

Executes a join query. Create a cartesian product of all the tables , keep only the products that satisfy the where condition

Since:

7.0

Author:

anna

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.j_spaces.jdbc.executor.AbstractQueryExecutor

AbstractQueryExecutor.EntriesOrderByComparator

Field Summary

Fields inherited from class com.j_spaces.jdbc.executor.AbstractQueryExecutor

_logger, query

Constructor Summary

Constructors

Constructor and Description
JoinedQueryExecutor()
JoinedQueryExecutor(AbstractDMLQuery query)

Method Summary

Modifier and Type	Method and Description
void	execute(AndNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) Execute And expression - execute both children and union the results
void	execute(ExpNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max)
void	execute(InNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) Execute IN expression - can be a list of simple values or an inner select query
IQueryResultSet<IEntryPacket>	execute(ISpaceProxy space, Transaction txn, int readModifier, int max)
void	execute(NotInNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) execute NOT IN query
void	execute(OrNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) Execute Or expression - execute both children and union the results
Comparator<IEntryPacket>	getGroupByComparator(List<SelectColumn> groupColumns)
boolean	getResults(ExpNode node)
protected boolean	matchesExpressionTree(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	readExternal(ObjectInput in)
void	setResults(ExpNode node, boolean result)
void	writeExternal(ObjectOutput out)

Methods inherited from class com.j_spaces.jdbc.executor.AbstractQueryExecutor

aggregate, avg, clear, convertEntriesToResultArrays, count, execute, executeTemplate, extractResults, filterDistinctEntries, getGroupByComparator, getIntermediateResults, getOrderByComparator, getQuery, groupBy, minMax, orderBy, readAll, setResults, sum, traverseExpressionTree

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinedQueryExecutor

public JoinedQueryExecutor()

JoinedQueryExecutor

public JoinedQueryExecutor(AbstractDMLQuery query)

Method Detail

execute

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

Throws:

SQLException

execute

public void execute(ExpNode exp,
                    ISpaceProxy space,
                    Transaction txn,
                    int readModifier,
                    int max)
             throws SQLException

Throws:

SQLException

getResults

public boolean getResults(ExpNode node)

setResults

public void setResults(ExpNode node,
                       boolean result)

execute

public void execute(AndNode exp,
                    ISpaceProxy space,
                    Transaction txn,
                    int readModifier,
                    int max)
             throws SQLException

Description copied from interface: IQueryExecutor

Execute And expression - execute both children and union the results

Throws:

SQLException

execute

public void execute(InNode exp,
                    ISpaceProxy space,
                    Transaction txn,
                    int readModifier,
                    int max)
             throws SQLException

Description copied from interface: IQueryExecutor

Execute IN expression - can be a list of simple values or an inner select query

Throws:

SQLException

execute

public void execute(NotInNode exp,
                    ISpaceProxy space,
                    Transaction txn,
                    int readModifier,
                    int max)
             throws SQLException

Description copied from interface: IQueryExecutor

execute NOT IN query

Throws:

SQLException

execute

public void execute(OrNode exp,
                    ISpaceProxy space,
                    Transaction txn,
                    int readModifier,
                    int max)
             throws SQLException

Description copied from interface: IQueryExecutor

Execute Or expression - execute both children and union the results

Throws:

SQLException

getGroupByComparator

public Comparator<IEntryPacket> getGroupByComparator(List<SelectColumn> groupColumns)

matchesExpressionTree

protected boolean matchesExpressionTree(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

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class AbstractQueryExecutor

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class AbstractQueryExecutor

Throws:

IOException

ClassNotFoundException