Package com.j_spaces.jdbc

Class QueryProcessor

java.lang.Object

com.j_spaces.jdbc.QueryProcessor

All Implemented Interfaces:

IQueryProcessor, Remote

public class QueryProcessor
extends Object
implements IQueryProcessor

The QueryProcessor main class.

Author:

Michael Mitrani - 2Train4, 2004

Field Summary

Fields inherited from interface com.j_spaces.jdbc.IQueryProcessor

QP_LOOKUP_NAME

Constructor Summary

Constructors

Constructor	Description
QueryProcessor(IJSpace clusterProxy, IJSpace spaceProxy, Properties overrideProperties, SecurityInterceptor securityInterceptor)

Method Summary

Modifier and Type	Method	Description
void	clean()
void	close()
void	closeConnection(ConnectionContext context)	Close connection
ResponsePacket	executeQuery(RequestPacket request, ConnectionContext context)	Execute query request and returns the response
static QueryProcessorConfiguration	getDefaultConfig()
QuerySession	getSession(ConnectionContext context)	Retrieve the query session that belongs to the given context
IQueryProcessor	getStub()
void	initStub()
boolean	isAvailable()	Check if QueryProcessor is available
static void	main(String[] args)	Run standalone QP
ConnectionContext	newConnection()	Starts new connection
static void	setDefaultConfig(QueryProcessorConfiguration defaultConfig)
void	setTransaction(Transaction transaction)	Set an explicit transaction to be used by the query processor.

Methods inherited from class java.lang.Object

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

Constructor Details

QueryProcessor

public QueryProcessor(IJSpace clusterProxy,
 IJSpace spaceProxy,
 Properties overrideProperties,
 SecurityInterceptor securityInterceptor)
               throws Exception

Throws:

Exception

Method Details

initStub

public void initStub()
              throws ExportException

Throws:

ExportException

close

public void close()
           throws RemoteException

Throws:

RemoteException

executeQuery

public ResponsePacket executeQuery(RequestPacket request,
 ConnectionContext context)
                            throws RemoteException,
SQLException

Description copied from interface: IQueryProcessor

Execute query request and returns the response

Specified by:

executeQuery in interface IQueryProcessor

Parameters:

request - the request to execute

context - the session of the request

Returns:

response packet

Throws:

RemoteException

SQLException

setTransaction

public void setTransaction(Transaction transaction)
                    throws RemoteException

Description copied from interface: IQueryProcessor

Set an explicit transaction to be used by the query processor.

Specified by:

setTransaction in interface IQueryProcessor

Throws:

RemoteException

isAvailable

public boolean isAvailable()
                    throws RemoteException

Description copied from interface: IQueryProcessor

Check if QueryProcessor is available

Specified by:

isAvailable in interface IQueryProcessor

Throws:

RemoteException

newConnection

public ConnectionContext newConnection()
                                throws RemoteException

Description copied from interface: IQueryProcessor

Starts new connection

Specified by:

newConnection in interface IQueryProcessor

Returns:

connection context

Throws:

RemoteException

getSession

public QuerySession getSession(ConnectionContext context)
                        throws RemoteException

Description copied from interface: IQueryProcessor

Retrieve the query session that belongs to the given context

Specified by:

getSession in interface IQueryProcessor

Returns:

the query session that belongs to the given context

Throws:

RemoteException

closeConnection

public void closeConnection(ConnectionContext context)
                     throws RemoteException

Description copied from interface: IQueryProcessor

Close connection

Specified by:

closeConnection in interface IQueryProcessor

Throws:

RemoteException

getStub

public IQueryProcessor getStub()

setDefaultConfig

public static void setDefaultConfig(QueryProcessorConfiguration defaultConfig)

getDefaultConfig

public static QueryProcessorConfiguration getDefaultConfig()

clean

public void clean()
           throws RemoteException

Throws:

RemoteException

main

public static void main(String[] args)
                 throws Throwable

Run standalone QP

Throws:

Throwable