com.j_spaces.jdbc.executor

Interface IQueryExecutor

All Known Implementing Classes:

AbstractQueryExecutor, JoinedQueryExecutor, QueryExecutor

public interface IQueryExecutor

Since:

7.0

Author:

anna

Method Summary

Modifier and Type	Method and Description
IEntryPacket	aggregate(IQueryResultSet<IEntryPacket> entries) Execute SQL function that processes the result entries and calculates one value - sum,average,min,max
int	clear(QueryTemplatePacket template, ISpaceProxy space, Transaction txn, int modifier) 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(AndNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) Execute And expression - execute both children and union the results
void	execute(ExpNode equalNode, ISpaceProxy space, Transaction txn, int readModifier, int max)
void	execute(InnerQueryNode innerQueryNode, ISpaceProxy space, Transaction txn, int readModifier, int max) Execute inner query
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 modifiers, 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
void	filterDistinctEntries(IQueryResultSet<IEntryPacket> entries) Removes duplicate entries from the result set.
IQueryResultSet<IEntryPacket>	groupBy(IQueryResultSet<IEntryPacket> entries, List<SelectColumn> groupColumns) Group the results according to the group by clause
void	orderBy(IQueryResultSet<IEntryPacket> entries, List<OrderColumn> orderColumns) Order the results according to the order by clause
IQueryResultSet<IEntryPacket>	readAll(ISpaceProxy space, Transaction txn)

Method Detail

execute

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

Execute Or expression - execute both children and union the results

Throws:

SQLException

execute

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

Execute And expression - execute both children and union the results

Throws:

SQLException

execute

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

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

Throws:

SQLException

execute

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

execute NOT IN query

Throws:

SQLException

execute

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

Execute inner query

Throws:

SQLException

execute

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

Throws:

SQLException

execute

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

Parameters:

equalNode -

space -

txn -

readModifier -

max -

Throws:

SQLException

clear

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

Execute clear

Returns:

int

Throws:

RemoteException

TransactionException

UnusableEntryException

count

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

Throws:

SQLException

readAll

IQueryResultSet<IEntryPacket> readAll(ISpaceProxy space,
                                      Transaction txn)
                               throws SQLException

Throws:

SQLException

groupBy

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

Group the results according to the group by clause

Returns:

the results according to the group by clause

Throws:

SQLException

orderBy

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

Order the results according to the order by clause

Throws:

SQLException

aggregate

IEntryPacket aggregate(IQueryResultSet<IEntryPacket> entries)
                throws SQLException

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

Returns:

the result entries one value - sum,average,min,max

Throws:

SQLException

filterDistinctEntries

void 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.

convertEntriesToResultArrays

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.