com.highqsoft.avalon

Class QueryEvaluator

java.lang.Object

org.omg.PortableServer.Servant

org.asam.ods.QueryEvaluatorPOA

com.highqsoft.avalon.QueryEvaluator

All Implemented Interfaces:

java.io.Serializable, QueryEvaluator, QueryEvaluatorOperations, org.omg.CORBA.Object, org.omg.CORBA.portable.IDLEntity, org.omg.CORBA.portable.InvokeHandler

public class QueryEvaluator
extends QueryEvaluatorPOA
implements QueryEvaluator

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
QueryEvaluator()
QueryEvaluator(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)
Query	createQuery(java.lang.String queryStr, NameValue[] params) Create a query object to execute it in asynchronous mode.
protected void	finalize()
static org.omg.CORBA.Object	getInstance(long cObjPtr, AoSession aosObj)
InstanceElementIterator	getInstances(java.lang.String queryStr, NameValue[] params) Evaluate a query in synchronous mode.
NameValueSeqUnit[]	getTable(java.lang.String queryStr, NameValue[] params) Evaluate a query in synchronous mode.
NameValueUnitSequenceIterator	getTableRows(java.lang.String queryStr, NameValue[] params) Evaluate a query in synchronous mode.

Methods inherited from class org.asam.ods.QueryEvaluatorPOA

_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

QueryEvaluator

public QueryEvaluator()

QueryEvaluator

public QueryEvaluator(long cObjPtr)

Method Detail

getInstance

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

getInstances

public InstanceElementIterator getInstances(java.lang.String queryStr,
                                   NameValue[] params)
                                     throws AoException

Evaluate a query in synchronous mode.

Specified by:

getInstances in interface QueryEvaluatorOperations

Parameters:

queryStr - The query string.

params - Sequence of parameter names and values. The following parameters should be passed: Name: "MaxDuration"; Type: T_LONG Comment: Can be used to restrict the processing time. The time is given in milliseconds, Default value: 0 (no restriction)

Returns:

The result of the query as an instance element iterator.

Throws:

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

getTableRows

public NameValueUnitSequenceIterator getTableRows(java.lang.String queryStr,
                                         NameValue[] params)
                                           throws AoException

Evaluate a query in synchronous mode.

Specified by:

getTableRows in interface QueryEvaluatorOperations

Parameters:

queryStr - The query string.

params - Sequence of parameter names and values. The following parameters should be passed: Name: "MaxDuration"; Type: T_LONG Comment: Can be used to restrict the processing time. The time is given in milliseconds, Default value: 0 (no restriction)

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_QUERY_TYPE_INVALID AO_QUERY_INVALID AO_QUERY_PROCESSING_ERROR AO_QUERY_TIMEOUT_EXCEEDED AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE

getTable

public NameValueSeqUnit[] getTable(java.lang.String queryStr,
                          NameValue[] params)
                            throws AoException

Evaluate a query in synchronous mode.

Specified by:

getTable in interface QueryEvaluatorOperations

Parameters:

queryStr - The query string.

params - Sequence of parameter names and values. The following parameters should be passed: Name: "MaxDuration"; Type: T_LONG Comment: Can be used to restrict the processing time. The time is given in milliseconds, Default value: 0 (no restriction)

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_QUERY_TYPE_INVALID AO_QUERY_INVALID AO_QUERY_PROCESSING_ERROR AO_QUERY_TIMEOUT_EXCEEDED AO_BAD_PARAMETER AO_CONNECTION_LOST AO_IMPLEMENTATION_PROBLEM AO_NOT_IMPLEMENTED AO_NO_MEMORY AO_SESSION_NOT_ACTIVE

createQuery

public Query createQuery(java.lang.String queryStr,
                NameValue[] params)
                  throws AoException

Create a query object to execute it in asynchronous mode.

Specified by:

createQuery in interface QueryEvaluatorOperations

Parameters:

queryStr - The query string

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. Default value: INSTELEM_ITERATOR_AS_RESULT Name: "MaxDuration"; Type: T_LONG Comment: Can be used to restrict the processing time. The time is given in milliseconds, Default value: 0 (no restriction)

Returns:

The query object.

Throws:

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

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