com.j_spaces.jdbc

Class QueryHandler

java.lang.Object

com.j_spaces.jdbc.QueryHandler

public class QueryHandler
extends Object

QueryHandler executes the JDBC statements set by the GConnection. For each statement the QueryHandler performs the parsing (or retrieves the statement from QueryCache ) and calls the necessary methods of the GigaSpaces API.

Author:

Michael Mitrani, 2Train4, 2004, anna - refactoring

Constructor Summary

Constructors

Constructor and Description
QueryHandler(IJSpace spaceCluster, IJSpace spaceRegular, QueryProcessorConfiguration config, SecurityInterceptor securityInterceptor)

Method Summary

Modifier and Type	Method and Description
void	close() Close QueryHandler resources
QueryCache	getQueryCache()
ITransactionManagerProvider	getTransactionManagerProvider()
Query	handleStatement(RequestPacket request, ISpaceProxy space) The main method to handle the query.
ResponsePacket	visit(RequestPacket request, QuerySession session)
ResponsePacket	visit(RequestPacketV3 request, QuerySession session)
ResponsePacket	visit(SetAutoCommitRequest request, QuerySession session) Handle set auto commit [on off] request
ResponsePacket	visit(SetTransaction request, QuerySession session) Handle set transaction lease time
ResponsePacket	visit(SetUseSingleSpace request, QuerySession session) Handle set single space [on off] request

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryHandler

public QueryHandler(IJSpace spaceCluster,
                    IJSpace spaceRegular,
                    QueryProcessorConfiguration config,
                    SecurityInterceptor securityInterceptor)

Method Detail

handleStatement

public Query handleStatement(RequestPacket request,
                             ISpaceProxy space)
                      throws SQLException

The main method to handle the query. first it will try to retrieve the query from the cache, if its not there, it will build a parser to parse the statement and then put it in the cache.

Throws:

SQLException

getTransactionManagerProvider

public ITransactionManagerProvider getTransactionManagerProvider()
                                                          throws TransactionException,
                                                                 RemoteException

Throws:

TransactionException

RemoteException

close

public void close()
           throws RemoteException

Close QueryHandler resources

Throws:

RemoteException

getQueryCache

public QueryCache getQueryCache()

visit

public ResponsePacket visit(RequestPacket request,
                            QuerySession session)
                     throws LeaseDeniedException,
                            RemoteException,
                            TransactionException,
                            SQLException

Returns:

response packet

Throws:

LeaseDeniedException

RemoteException

TransactionException

SQLException

visit

public ResponsePacket visit(RequestPacketV3 request,
                            QuerySession session)
                     throws LeaseDeniedException,
                            RemoteException,
                            TransactionException,
                            SQLException

Returns:

response packet for V3

Throws:

LeaseDeniedException

RemoteException

TransactionException

SQLException

visit

public ResponsePacket visit(SetAutoCommitRequest request,
                            QuerySession session)
                     throws LeaseDeniedException,
                            RemoteException,
                            TransactionException

Handle set auto commit [on off] request

Returns:

response packet

Throws:

LeaseDeniedException

RemoteException

TransactionException

visit

public ResponsePacket visit(SetUseSingleSpace request,
                            QuerySession session)

Handle set single space [on off] request

Returns:

response packet

visit

public ResponsePacket visit(SetTransaction request,
                            QuerySession session)

Handle set transaction lease time

Returns:

response packet