public interface IQueryExecutor extends Externalizable
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
|
IQueryResultSet<IEntryPacket> |
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) |
readExternal, writeExternal
void execute(OrNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) throws SQLException
SQLException
void execute(AndNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) throws SQLException
SQLException
void execute(InNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) throws SQLException
SQLException
void execute(NotInNode exp, ISpaceProxy space, Transaction txn, int readModifier, int max) throws SQLException
SQLException
void execute(InnerQueryNode innerQueryNode, ISpaceProxy space, Transaction txn, int readModifier, int max) throws SQLException
SQLException
IQueryResultSet<IEntryPacket> execute(ISpaceProxy space, Transaction txn, int modifiers, int max) throws SQLException
SQLException
void execute(ExpNode equalNode, ISpaceProxy space, Transaction txn, int readModifier, int max) throws SQLException
equalNode
- space
- txn
- readModifier
- max
- SQLException
int clear(QueryTemplatePacket template, ISpaceProxy space, Transaction txn, int modifier) throws RemoteException, TransactionException, UnusableEntryException
RemoteException
TransactionException
UnusableEntryException
int count(QueryTemplatePacket template, ISpaceProxy space, Transaction txn, int readModifier) throws SQLException
SQLException
IQueryResultSet<IEntryPacket> readAll(ISpaceProxy space, Transaction txn) throws SQLException
SQLException
IQueryResultSet<IEntryPacket> groupBy(IQueryResultSet<IEntryPacket> entries, List<SelectColumn> groupColumns) throws SQLException
SQLException
void orderBy(IQueryResultSet<IEntryPacket> entries, List<OrderColumn> orderColumns) throws SQLException
SQLException
IEntryPacket aggregate(IQueryResultSet<IEntryPacket> entries) throws SQLException
SQLException
IQueryResultSet<IEntryPacket> filterDistinctEntries(IQueryResultSet<IEntryPacket> entries)
ResultEntry convertEntriesToResultArrays(IQueryResultSet<IEntryPacket> _entries)
Copyright © GigaSpaces.