com.j_spaces.core.client.sql

Class QueryManager

java.lang.Object

com.j_spaces.core.client.sql.QueryManager

All Implemented Interfaces:

IQueryManager

public class QueryManager
extends Object
implements IQueryManager

Manages SQLQuery execution on the proxy side

Since:

6.5

Author:

anna

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QueryManager.QueryThreadPoolExecutor

Constructor Summary

Constructors

Constructor and Description
QueryManager(IDirectSpaceProxy proxy)

Method Summary

Modifier and Type	Method and Description
void	clean()
int	countClear(CountClearProxyActionInfo actionInfo)
static QueryManager.QueryThreadPoolExecutor	getQueryExecutionPool()
ITemplatePacket	getSQLTemplate(SQLQueryTemplatePacket template, Transaction txn)
IEntryPacket	readTake(ReadTakeProxyActionInfo actionInfo)
IEntryPacket[]	readTakeMultiple(ReadTakeMultipleProxyActionInfo actionInfo)

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryManager

public QueryManager(IDirectSpaceProxy proxy)

Method Detail

getQueryExecutionPool

public static QueryManager.QueryThreadPoolExecutor getQueryExecutionPool()

getSQLTemplate

public ITemplatePacket getSQLTemplate(SQLQueryTemplatePacket template,
                                      Transaction txn)

Specified by:

getSQLTemplate in interface IQueryManager

countClear

public int countClear(CountClearProxyActionInfo actionInfo)

Specified by:

countClear in interface IQueryManager

readTake

public IEntryPacket readTake(ReadTakeProxyActionInfo actionInfo)
                      throws RemoteException,
                             UnusableEntryException

Specified by:

readTake in interface IQueryManager

Throws:

RemoteException

UnusableEntryException

readTakeMultiple

public IEntryPacket[] readTakeMultiple(ReadTakeMultipleProxyActionInfo actionInfo)

Specified by:

readTakeMultiple in interface IQueryManager

clean

public void clean()

Specified by:

clean in interface IQueryManager