com.highqsoft.avalon

Class Query

java.lang.Object

org.omg.PortableServer.Servant

org.asam.ods.QueryPOA

com.highqsoft.avalon.Query

All Implemented Interfaces:

java.io.Serializable, Query, QueryOperations, org.omg.CORBA.Object, org.omg.CORBA.portable.IDLEntity, org.omg.CORBA.portable.InvokeHandler

public class Query
extends QueryPOA
implements Query

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected AoSession	aosObj
protected long	cObjPtr

Constructor Summary

Constructors

Constructor and Description
Query()
Query(long cObjPtr)

Method Summary

Methods

Modifier and Type	Method and Description
org.omg.CORBA.Request	_create_request(org.omg.CORBA.Context ctx, java.lang.String operation, org.omg.CORBA.NVList arg_list, org.omg.CORBA.NamedValue result)
org.omg.CORBA.Request	_create_request(org.omg.CORBA.Context ctx, java.lang.String operation, org.omg.CORBA.NVList arg_list, org.omg.CORBA.NamedValue result, org.omg.CORBA.ExceptionList exclist, org.omg.CORBA.ContextList ctxlist)
org.omg.CORBA.Object	_duplicate()
org.omg.CORBA.DomainManager[]	_get_domain_managers()
org.omg.CORBA.Policy	_get_policy(int policy_type)
int	_hash(int maximum)
boolean	_is_equivalent(org.omg.CORBA.Object other)
void	_release()
org.omg.CORBA.Request	_request(java.lang.String operation)
org.omg.CORBA.Object	_set_policy_override(org.omg.CORBA.Policy[] policies, org.omg.CORBA.SetOverrideType set_add)
void	executeQuery(NameValue[] params) Execute query in asynchronous mode.
protected void	finalize()
static org.omg.CORBA.Object	getInstance(long cObjPtr, AoSession aosObj)
InstanceElementIterator	getInstances() Get the query result.
QueryEvaluator	getQueryEvaluator() Get the QueryEvaluator object which is responsible for this query.
QueryStatus	getStatus() Return query status.
NameValueSeqUnit[]	getTable() Get the query result.
NameValueUnitSequenceIterator	getTableRows() Get the query result.
void	prepareQuery(NameValue[] params) Do the query pre-processing (optimization, etc.)

Methods inherited from class org.asam.ods.QueryPOA

_all_interfaces, _invoke, _this, _this

Methods inherited from class org.omg.PortableServer.Servant

_default_POA, _get_delegate, _get_interface_def, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.omg.CORBA.Object

_get_interface_def, _is_a, _non_existent

Field Detail

cObjPtr

protected long cObjPtr

aosObj

protected AoSession aosObj

Constructor Detail

Query

public Query()

Query

public Query(long cObjPtr)

Method Detail

getInstance

public static org.omg.CORBA.Object getInstance(long cObjPtr,
                               AoSession aosObj)

getQueryEvaluator

public QueryEvaluator getQueryEvaluator()
                                 throws AoException

Get the QueryEvaluator object which is responsible for this query.

Specified by:

getQueryEvaluator in interface QueryOperations

Returns:

The QueryEvaluator object which is responsible for this query.

Throws:

AoException - with the following possible error codes: AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE AO_TRANSACTION_NOT_ACTIVE

prepareQuery

public void prepareQuery(NameValue[] params)
                  throws AoException

Do the query pre-processing (optimization, etc.) Call can be omited by the client. In this case the functionality is executed on the call of executeQuery.

Specified by:

prepareQuery in interface QueryOperations

Parameters:

params - Sequence of parameter names and values. The following parameters should be passed: Name: "QueryResultType"; Type: ResultType. Comment: Specifies what kind of result is expected by the client, this parameter is required if the parameters isn't given at the method createQuery of the interface QueryEvaluator. Default value: INSTELEM_ITERATOR_AS_RESULT

Throws:

AoException - with the following possible error codes: AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE AO_QUERY_PROCESSING_ERROR AO_QUERY_INVALID_RESULTTYPE

executeQuery

public void executeQuery(NameValue[] params)
                  throws AoException

Execute query in asynchronous mode.

Specified by:

executeQuery in interface QueryOperations

Parameters:

params - Sequence of parameter names and values.The following parameter should be passed: Name: "QueryResultType"; Type: ResultType. Comment: Specifies what kind of result is expected by the client, this parameter is required if the parameters isn't given at the method prepareQuery or the method createQuery of the interface QueryEvaluator. Default value: INSTELEM_ITERATOR_AS_RESULT Name: "Synchronous"; Type: T_BOOLEAN Comment: In case of "true" guarantees synchronous execution. Default value: "false"

Throws:

AoException - with the following possible error codes: AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE AO_QUERY_PROCESSING_ERROR AO_QUERY_INVALID_RESULTTYPE

getStatus

public QueryStatus getStatus()
                      throws AoException

Return query status. Returns INCOMPLETE if the query is still executing. Returns COMPLETE if the query finished execution or if the query execution stopped because of an error or because the timeout was exceeded.

Specified by:

getStatus in interface QueryOperations

Returns:

The status of the query.

Throws:

AoException - with the following possible error codes: AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE

getInstances

public InstanceElementIterator getInstances()
                                     throws AoException

Get the query result.

Specified by:

getInstances in interface QueryOperations

Returns:

The result of the query as an instance element iterator.

Throws:

AoException - with the following possible error codes: AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE AO_QUERY_PROCESSING_ERROR AO_QUERY_TIMEOUT_EXCEEDED AO_QUERY_INCOMPLETE AO_QUERY_INVALID_RESULTTYPE

getTableRows

public NameValueUnitSequenceIterator getTableRows()
                                           throws AoException

Get the query result.

Specified by:

getTableRows in interface QueryOperations

Returns:

The result of the query as a name value unit sequence iterator. Each name value unit tuple is one cell of the table. The name value unit sequence is one row of the table.

Throws:

AoException - with the following possible error codes: AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE AO_QUERY_PROCESSING_ERROR AO_QUERY_TIMEOUT_EXCEEDED AO_QUERY_INCOMPLETE AO_QUERY_INVALID_RESULTTYPE

getTable

public NameValueSeqUnit[] getTable()
                            throws AoException

Get the query result.

Specified by:

getTable in interface QueryOperations

Returns:

The result of the query as a name value sequence unit sequence. Each name value sequecne unit tuple is one column of the table. The name value sequence unit sequence is the table. The result structure can be very huge.

Throws:

AoException - with the following possible error codes: AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE AO_QUERY_PROCESSING_ERROR AO_QUERY_TIMEOUT_EXCEEDED AO_QUERY_INCOMPLETE AO_QUERY_INVALID_RESULTTYPE

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

_create_request

public org.omg.CORBA.Request _create_request(org.omg.CORBA.Context ctx,
                                    java.lang.String operation,
                                    org.omg.CORBA.NVList arg_list,
                                    org.omg.CORBA.NamedValue result)

Specified by:

_create_request in interface org.omg.CORBA.Object

_create_request

public org.omg.CORBA.Request _create_request(org.omg.CORBA.Context ctx,
                                    java.lang.String operation,
                                    org.omg.CORBA.NVList arg_list,
                                    org.omg.CORBA.NamedValue result,
                                    org.omg.CORBA.ExceptionList exclist,
                                    org.omg.CORBA.ContextList ctxlist)

Specified by:

_create_request in interface org.omg.CORBA.Object

_duplicate

public org.omg.CORBA.Object _duplicate()

Specified by:

_duplicate in interface org.omg.CORBA.Object

_get_domain_managers

public org.omg.CORBA.DomainManager[] _get_domain_managers()

Specified by:

_get_domain_managers in interface org.omg.CORBA.Object

_get_policy

public org.omg.CORBA.Policy _get_policy(int policy_type)

Specified by:

_get_policy in interface org.omg.CORBA.Object

_hash

public int _hash(int maximum)

Specified by:

_hash in interface org.omg.CORBA.Object

_is_equivalent

public boolean _is_equivalent(org.omg.CORBA.Object other)

Specified by:

_is_equivalent in interface org.omg.CORBA.Object

_release

public void _release()

Specified by:

_release in interface org.omg.CORBA.Object

_request

public org.omg.CORBA.Request _request(java.lang.String operation)

Specified by:

_request in interface org.omg.CORBA.Object

_set_policy_override

public org.omg.CORBA.Object _set_policy_override(org.omg.CORBA.Policy[] policies,
                                        org.omg.CORBA.SetOverrideType set_add)

Specified by:

_set_policy_override in interface org.omg.CORBA.Object