Package org.apache.openjpa.kernel
Class DelegatingQuery
- java.lang.Object
-
- org.apache.openjpa.kernel.DelegatingQuery
-
- All Implemented Interfaces:
java.io.Serializable,Query,QueryContext,QueryFlushModes,QueryOperations
public class DelegatingQuery extends java.lang.Object implements Query
Delegating query that can also perform exception translation for use in facades.- Since:
- 0.4.0
- Author:
- Abe White
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from interface org.apache.openjpa.kernel.QueryFlushModes
FLUSH_FALSE, FLUSH_TRUE, FLUSH_WITH_CONNECTION
-
Fields inherited from interface org.apache.openjpa.kernel.QueryOperations
OP_DELETE, OP_SELECT, OP_UPDATE
-
-
Constructor Summary
Constructors Constructor Description DelegatingQuery(Query query)Constructor; supply delegate.DelegatingQuery(Query query, RuntimeExceptionTranslator trans)Constructor; supply delegate and exception translator.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddAggregateListener(AggregateListener listener)Register an aggregate listener for the query.voidaddFilterListener(FilterListener listener)Register a filter listener for the query.voidassertNotReadOnly()Assert that the query is not read-only.voidassertNotSerialized()Check that the query has not been serialized, which causes it to lose its association with its Broker.voidassertOpen()Assert that the query's broker is still open.java.lang.ClassclassForName(java.lang.String name, java.lang.String[] imports)Helper method to instantiate the class with the given name, taking into account the query's candidate package, automatic imports, and the given imports (if any).voidcloseAll()Close all open query results.voidcloseResources()Close query results that are consuming resources.voidcompile()Compile the query.voiddeclareParameters(java.lang.String params)Declared parameters, for query languages that use them.longdeleteAll()Deletes all of the instances that are satisfied by the query.longdeleteAll(java.lang.Object[] parameters)Deletes all of the instances that are satisfied by the query.longdeleteAll(java.util.Map parameterMap)Deletes all of the instances that are satisfied by the query.java.lang.NumberdeleteInMemory(StoreQuery q, StoreQuery.Executor ex, java.lang.Object[] params)Helper method to delete the objects found by executing a query on the given executor.booleanequals(java.lang.Object other)java.lang.Objectexecute()Execute.java.lang.Objectexecute(java.lang.Object[] params)Execute with parameter array.java.lang.Objectexecute(java.util.Map params)Execute with parameter map.ClassMetaData[]getAccessPathMetaDatas()Return the classes that affect this query.AggregateListenergetAggregateListener(java.lang.String tag)Return the filter listener for the given tag, or null.java.util.CollectiongetAggregateListeners()The set of aggregate listeners.java.lang.StringgetAlias()If this query is not a projection but places candidate results into a result class under an alias, return that alias.BrokergetBroker()The broker that generated this query.java.util.CollectiongetCandidateCollection()Return the candidate collection, ornullif an extent was specified instead of a collection.ExtentgetCandidateExtent()Return the candidate extent, ornullif a collection was specified instead of an extent.java.lang.ClassgetCandidateType()Return the class of the objects that this query will return, ornullif this information is not available / not relevant.java.lang.ObjectgetCompilation()Return the query's compilation state.java.lang.String[]getDataStoreActions(java.util.Map params)Returns a description of the commands that will be sent to the datastore in order to execute this query.QuerygetDelegate()Return the direct delegate.longgetEndRange()Return the 0-based exclusive end index for the returned results, orLong.MAX_VALUEfor no limit.FetchConfigurationgetFetchConfiguration()Return the fetch configuration for this query.FilterListenergetFilterListener(java.lang.String tag)Return the filter listener for the given tag, or null.java.util.CollectiongetFilterListeners()The set of filter listeners.booleangetIgnoreChanges()Whether to ignore changes in the current transaction.QuerygetInnermostDelegate()Return the native delegate.java.lang.StringgetLanguage()The query language.intgetOperation()Returns the operation that this query will be expected to perform.OrderedMap<java.lang.Object,java.lang.Class<?>>getOrderedParameterTypes()Return a map of parameter name to type for this query.java.lang.StringgetParameterDeclaration()The parameter declaration.LinkedMapgetParameterTypes()Return a map of parameter name to type for this query.java.lang.String[]getProjectionAliases()If this query is a projection, return the projection aliases.java.lang.Class[]getProjectionTypes()If this query is a projection, return the projection types.QuerygetQuery()Return the query for this context.java.lang.StringgetQueryString()The query string.java.lang.StringgetResultMappingName()Name of a mapping from the result data to its object representation.java.lang.ClassgetResultMappingScope()Scope of a mapping from the result data to its object representation.java.lang.ClassgetResultType()Returns the result class that has been set throughQueryContext.setResultType(java.lang.Class<?>), or null if none.longgetStartRange()Return the 0-based start index for the returned results.StoreContextgetStoreContext()The persistence context for the query.java.util.MapgetUpdates()If this query is a bulk update, return a map of theFieldMetaDatas toConstants.booleanhasGrouping()Return true if the query uses grouping.inthashCode()booleanhasSubclasses()Whether query results will include subclasses of the candidate class.booleanisAggregate()Return true if the query is an aggregate.booleanisDistinct()Affirms if this query results are distinct instance(s).booleanisReadOnly()Whether the query has been marked read-only.booleanisUnique()The unique flag.voidlock()Synchronize on the query's internal lock.voidremoveAggregateListener(AggregateListener listener)Remove an aggregate listener from the query.voidremoveFilterListener(FilterListener listener)Remove a filter listener from the query.voidsetCandidateCollection(java.util.Collection coll)Set a collection of candidates.voidsetCandidateExtent(Extent extent)Set the candidate extent.voidsetCandidateType(java.lang.Class cls, boolean subs)Set the candidate type.voidsetIgnoreChanges(boolean ignore)Whether to ignore changes in the current transaction.booleansetQuery(java.lang.Object query)The query string or template.voidsetRange(long start, long end)Set the range of results to return.voidsetReadOnly(boolean readOnly)Whether the query has been marked read-only.voidsetResultMapping(java.lang.Class scope, java.lang.String name)Name and scope of a mapping from the result data to its object representation.voidsetResultType(java.lang.Class cls)Specify the type of object in which the result of evaluating this query.voidsetUnique(boolean unique)Specify that the query will return only 1 result, rather than a collection.protected java.lang.RuntimeExceptiontranslate(java.lang.RuntimeException re)Translate the OpenJPA exception.voidunlock()Unlock the query's internal lock.longupdateAll()Performs an update of the instances that are satisfied by the query.longupdateAll(java.lang.Object[] parameters)Performs an update of the instances that are satisfied by the query.longupdateAll(java.util.Map parameterMap)Performs an update of the instances that are satisfied by the query.java.lang.NumberupdateInMemory(StoreQuery q, StoreQuery.Executor ex, java.lang.Object[] params)Helper method to update the objects found by executing a query on the given executor.
-
-
-
Constructor Detail
-
DelegatingQuery
public DelegatingQuery(Query query)
Constructor; supply delegate.
-
DelegatingQuery
public DelegatingQuery(Query query, RuntimeExceptionTranslator trans)
Constructor; supply delegate and exception translator.
-
-
Method Detail
-
getDelegate
public Query getDelegate()
Return the direct delegate.
-
getInnermostDelegate
public Query getInnermostDelegate()
Return the native delegate.
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
equals
public boolean equals(java.lang.Object other)
- Overrides:
equalsin classjava.lang.Object
-
translate
protected java.lang.RuntimeException translate(java.lang.RuntimeException re)
Translate the OpenJPA exception.
-
getBroker
public Broker getBroker()
Description copied from interface:QueryThe broker that generated this query.
-
getQuery
public Query getQuery()
Description copied from interface:QueryContextReturn the query for this context. Note that the query will be unavailable in remote contexts, and this method may throw an exception to that effect.- Specified by:
getQueryin interfaceQueryContext
-
getStoreContext
public StoreContext getStoreContext()
Description copied from interface:QueryContextThe persistence context for the query.- Specified by:
getStoreContextin interfaceQueryContext
-
getOperation
public int getOperation()
Description copied from interface:QueryContextReturns the operation that this query will be expected to perform.- Specified by:
getOperationin interfaceQueryContext- See Also:
QueryOperations
-
getLanguage
public java.lang.String getLanguage()
Description copied from interface:QueryContextThe query language.- Specified by:
getLanguagein interfaceQueryContext
-
getFetchConfiguration
public FetchConfiguration getFetchConfiguration()
Description copied from interface:QueryContextReturn the fetch configuration for this query.- Specified by:
getFetchConfigurationin interfaceQueryContext
-
getQueryString
public java.lang.String getQueryString()
Description copied from interface:QueryContextThe query string.- Specified by:
getQueryStringin interfaceQueryContext
-
getIgnoreChanges
public boolean getIgnoreChanges()
Description copied from interface:QueryContextWhether to ignore changes in the current transaction.- Specified by:
getIgnoreChangesin interfaceQueryContext
-
getCompilation
public java.lang.Object getCompilation()
Description copied from interface:QueryContextReturn the query's compilation state.- Specified by:
getCompilationin interfaceQueryContext
-
getAlias
public java.lang.String getAlias()
Description copied from interface:QueryContextIf this query is not a projection but places candidate results into a result class under an alias, return that alias.- Specified by:
getAliasin interfaceQueryContext
-
getProjectionAliases
public java.lang.String[] getProjectionAliases()
Description copied from interface:QueryContextIf this query is a projection, return the projection aliases.- Specified by:
getProjectionAliasesin interfaceQueryContext
-
getProjectionTypes
public java.lang.Class[] getProjectionTypes()
Description copied from interface:QueryContextIf this query is a projection, return the projection types.- Specified by:
getProjectionTypesin interfaceQueryContext
-
isAggregate
public boolean isAggregate()
Description copied from interface:QueryContextReturn true if the query is an aggregate.- Specified by:
isAggregatein interfaceQueryContext
-
hasGrouping
public boolean hasGrouping()
Description copied from interface:QueryContextReturn true if the query uses grouping.- Specified by:
hasGroupingin interfaceQueryContext
-
getAccessPathMetaDatas
public ClassMetaData[] getAccessPathMetaDatas()
Description copied from interface:QueryContextReturn the classes that affect this query.- Specified by:
getAccessPathMetaDatasin interfaceQueryContext
-
getFilterListener
public FilterListener getFilterListener(java.lang.String tag)
Description copied from interface:QueryContextReturn the filter listener for the given tag, or null.- Specified by:
getFilterListenerin interfaceQueryContext
-
getAggregateListener
public AggregateListener getAggregateListener(java.lang.String tag)
Description copied from interface:QueryContextReturn the filter listener for the given tag, or null.- Specified by:
getAggregateListenerin interfaceQueryContext
-
getFilterListeners
public java.util.Collection getFilterListeners()
Description copied from interface:QueryContextThe set of filter listeners.- Specified by:
getFilterListenersin interfaceQueryContext
-
getAggregateListeners
public java.util.Collection getAggregateListeners()
Description copied from interface:QueryContextThe set of aggregate listeners.- Specified by:
getAggregateListenersin interfaceQueryContext
-
getCandidateCollection
public java.util.Collection getCandidateCollection()
Description copied from interface:QueryContextReturn the candidate collection, ornullif an extent was specified instead of a collection.- Specified by:
getCandidateCollectionin interfaceQueryContext
-
getCandidateType
public java.lang.Class getCandidateType()
Description copied from interface:QueryContextReturn the class of the objects that this query will return, ornullif this information is not available / not relevant.- Specified by:
getCandidateTypein interfaceQueryContext
-
hasSubclasses
public boolean hasSubclasses()
Description copied from interface:QueryContextWhether query results will include subclasses of the candidate class.- Specified by:
hasSubclassesin interfaceQueryContext
-
setCandidateType
public void setCandidateType(java.lang.Class cls, boolean subs)Description copied from interface:QueryContextSet the candidate type.- Specified by:
setCandidateTypein interfaceQueryContext
-
isReadOnly
public boolean isReadOnly()
Description copied from interface:QueryContextWhether the query has been marked read-only.- Specified by:
isReadOnlyin interfaceQueryContext
-
setReadOnly
public void setReadOnly(boolean readOnly)
Description copied from interface:QueryContextWhether the query has been marked read-only.- Specified by:
setReadOnlyin interfaceQueryContext
-
getResultMappingScope
public java.lang.Class getResultMappingScope()
Description copied from interface:QueryContextScope of a mapping from the result data to its object representation.- Specified by:
getResultMappingScopein interfaceQueryContext
-
getResultMappingName
public java.lang.String getResultMappingName()
Description copied from interface:QueryContextName of a mapping from the result data to its object representation.- Specified by:
getResultMappingNamein interfaceQueryContext
-
setResultMapping
public void setResultMapping(java.lang.Class scope, java.lang.String name)Description copied from interface:QueryContextName and scope of a mapping from the result data to its object representation.- Specified by:
setResultMappingin interfaceQueryContext
-
isUnique
public boolean isUnique()
Description copied from interface:QueryContextThe unique flag.- Specified by:
isUniquein interfaceQueryContext
-
setUnique
public void setUnique(boolean unique)
Description copied from interface:QueryContextSpecify that the query will return only 1 result, rather than a collection. The execute method will return null if the query result size is 0.- Specified by:
setUniquein interfaceQueryContext
-
isDistinct
public boolean isDistinct()
Description copied from interface:QueryContextAffirms if this query results are distinct instance(s).- Specified by:
isDistinctin interfaceQueryContext
-
getResultType
public java.lang.Class getResultType()
Description copied from interface:QueryContextReturns the result class that has been set throughQueryContext.setResultType(java.lang.Class<?>), or null if none.- Specified by:
getResultTypein interfaceQueryContext
-
setResultType
public void setResultType(java.lang.Class cls)
Description copied from interface:QueryContextSpecify the type of object in which the result of evaluating this query.- Specified by:
setResultTypein interfaceQueryContext
-
getStartRange
public long getStartRange()
Description copied from interface:QueryContextReturn the 0-based start index for the returned results.- Specified by:
getStartRangein interfaceQueryContext
-
getEndRange
public long getEndRange()
Description copied from interface:QueryContextReturn the 0-based exclusive end index for the returned results, orLong.MAX_VALUEfor no limit.- Specified by:
getEndRangein interfaceQueryContext
-
setRange
public void setRange(long start, long end)Description copied from interface:QueryContextSet the range of results to return.- Specified by:
setRangein interfaceQueryContext- Parameters:
start- 0-based inclusive start indexend- 0-based exclusive end index, orLong.MAX_VALUEfor no limit
-
getParameterDeclaration
public java.lang.String getParameterDeclaration()
Description copied from interface:QueryContextThe parameter declaration.- Specified by:
getParameterDeclarationin interfaceQueryContext
-
getOrderedParameterTypes
public OrderedMap<java.lang.Object,java.lang.Class<?>> getOrderedParameterTypes()
Description copied from interface:QueryContextReturn a map of parameter name to type for this query. The returned map will iterate in the order that the parameters were declared or, if they're implicit, used.- Specified by:
getOrderedParameterTypesin interfaceQueryContext
-
getParameterTypes
public LinkedMap getParameterTypes()
Description copied from interface:QueryContextReturn a map of parameter name to type for this query. The returned map will iterate in the order that the parameters were declared or, if they're implicit, used.- Specified by:
getParameterTypesin interfaceQueryContext
-
getUpdates
public java.util.Map getUpdates()
Description copied from interface:QueryContextIf this query is a bulk update, return a map of theFieldMetaDatas toConstants.- Specified by:
getUpdatesin interfaceQueryContext
-
declareParameters
public void declareParameters(java.lang.String params)
Description copied from interface:QueryContextDeclared parameters, for query languages that use them.- Specified by:
declareParametersin interfaceQueryContext
-
deleteInMemory
public java.lang.Number deleteInMemory(StoreQuery q, StoreQuery.Executor ex, java.lang.Object[] params)
Description copied from interface:QueryContextHelper method to delete the objects found by executing a query on the given executor.- Specified by:
deleteInMemoryin interfaceQueryContext
-
updateInMemory
public java.lang.Number updateInMemory(StoreQuery q, StoreQuery.Executor ex, java.lang.Object[] params)
Description copied from interface:QueryContextHelper method to update the objects found by executing a query on the given executor.- Specified by:
updateInMemoryin interfaceQueryContext
-
classForName
public java.lang.Class classForName(java.lang.String name, java.lang.String[] imports)Description copied from interface:QueryContextHelper method to instantiate the class with the given name, taking into account the query's candidate package, automatic imports, and the given imports (if any). Returns null if the type cannot be found.- Specified by:
classForNamein interfaceQueryContext
-
lock
public void lock()
Description copied from interface:QueryContextSynchronize on the query's internal lock.- Specified by:
lockin interfaceQueryContext
-
unlock
public void unlock()
Description copied from interface:QueryContextUnlock the query's internal lock.- Specified by:
unlockin interfaceQueryContext
-
addFilterListener
public void addFilterListener(FilterListener listener)
Description copied from interface:QueryRegister a filter listener for the query.- Specified by:
addFilterListenerin interfaceQuery
-
removeFilterListener
public void removeFilterListener(FilterListener listener)
Description copied from interface:QueryRemove a filter listener from the query.- Specified by:
removeFilterListenerin interfaceQuery
-
addAggregateListener
public void addAggregateListener(AggregateListener listener)
Description copied from interface:QueryRegister an aggregate listener for the query.- Specified by:
addAggregateListenerin interfaceQuery
-
removeAggregateListener
public void removeAggregateListener(AggregateListener listener)
Description copied from interface:QueryRemove an aggregate listener from the query.- Specified by:
removeAggregateListenerin interfaceQuery
-
getCandidateExtent
public Extent getCandidateExtent()
Description copied from interface:QueryReturn the candidate extent, ornullif a collection was specified instead of an extent.- Specified by:
getCandidateExtentin interfaceQuery
-
setCandidateExtent
public void setCandidateExtent(Extent extent)
Description copied from interface:QuerySet the candidate extent.- Specified by:
setCandidateExtentin interfaceQuery
-
setCandidateCollection
public void setCandidateCollection(java.util.Collection coll)
Description copied from interface:QuerySet a collection of candidates.- Specified by:
setCandidateCollectionin interfaceQuery
-
compile
public void compile()
Description copied from interface:QueryCompile the query.
-
execute
public java.lang.Object execute()
Description copied from interface:QueryExecute.
-
execute
public java.lang.Object execute(java.util.Map params)
Description copied from interface:QueryExecute with parameter map.
-
execute
public java.lang.Object execute(java.lang.Object[] params)
Description copied from interface:QueryExecute with parameter array.
-
deleteAll
public long deleteAll()
Description copied from interface:QueryDeletes all of the instances that are satisfied by the query.
-
deleteAll
public long deleteAll(java.lang.Object[] parameters)
Description copied from interface:QueryDeletes all of the instances that are satisfied by the query.
-
deleteAll
public long deleteAll(java.util.Map parameterMap)
Description copied from interface:QueryDeletes all of the instances that are satisfied by the query.
-
updateAll
public long updateAll()
Description copied from interface:QueryPerforms an update of the instances that are satisfied by the query.
-
updateAll
public long updateAll(java.lang.Object[] parameters)
Description copied from interface:QueryPerforms an update of the instances that are satisfied by the query.
-
updateAll
public long updateAll(java.util.Map parameterMap)
Description copied from interface:QueryPerforms an update of the instances that are satisfied by the query.
-
closeAll
public void closeAll()
Description copied from interface:QueryClose all open query results.
-
closeResources
public void closeResources()
Description copied from interface:QueryClose query results that are consuming resources. Allow results that are not consuming resources to remain open so that they continue to function normally.- Specified by:
closeResourcesin interfaceQuery
-
getDataStoreActions
public java.lang.String[] getDataStoreActions(java.util.Map params)
Description copied from interface:QueryReturns a description of the commands that will be sent to the datastore in order to execute this query. This will typically be in the native query language of the database (e.g., SQL).- Specified by:
getDataStoreActionsin interfaceQuery- Parameters:
params- the named parameter map for the query invocation
-
setQuery
public boolean setQuery(java.lang.Object query)
Description copied from interface:QueryThe query string or template.
-
setIgnoreChanges
public void setIgnoreChanges(boolean ignore)
Description copied from interface:QueryWhether to ignore changes in the current transaction.- Specified by:
setIgnoreChangesin interfaceQuery
-
assertOpen
public void assertOpen()
Description copied from interface:QueryAssert that the query's broker is still open.- Specified by:
assertOpenin interfaceQuery
-
assertNotReadOnly
public void assertNotReadOnly()
Description copied from interface:QueryAssert that the query is not read-only.- Specified by:
assertNotReadOnlyin interfaceQuery
-
assertNotSerialized
public void assertNotSerialized()
Description copied from interface:QueryCheck that the query has not been serialized, which causes it to lose its association with its Broker.- Specified by:
assertNotSerializedin interfaceQuery
-
-