org.datanucleus.store.rdbms.query

Class JPQLQuery

java.lang.Object

org.datanucleus.store.query.Query<T>

org.datanucleus.store.query.AbstractJavaQuery

org.datanucleus.store.query.AbstractJPQLQuery

org.datanucleus.store.rdbms.query.JPQLQuery

All Implemented Interfaces:

Serializable, org.datanucleus.ExecutionContextListener

public class JPQLQuery
extends org.datanucleus.store.query.AbstractJPQLQuery

RDBMS representation of a JPQL query for use by DataNucleus. The query can be specified via method calls, or via a single-string form. This implementation uses the generic query compilation in "org.datanucleus.query". There are the following main ways of running a query here

• Totally in the datastore (no candidate collection specified, and no in-memory eval).
• Totally in-memory (candidate collection specified, and in-memory eval)
• Retrieve candidates from datastore (no candidate collection), and evaluate in-memory

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.datanucleus.store.query.Query

org.datanucleus.store.query.Query.QueryType, org.datanucleus.store.query.Query.SubqueryDefinition

Field Summary

Fields

Modifier and Type	Field and Description
protected RDBMSQueryCompilation	datastoreCompilation The compilation of the query for this datastore.
static String	EXTENSION_FOR_UPDATE_NOWAIT Extension to add NOWAIT when using FOR UPDATE (when supported).
static String	EXTENSION_NAVIGATION_JOIN_TYPE Extension to define the JOIN TYPE to use when navigating single-valued relations.
static String	EXTENSION_NAVIGATION_JOIN_TYPE_FILTER Extension to define the JOIN TYPE to use when navigating single-valued relations, when part of the filter.
static String	EXTENSION_USE_IS_NULL_WHEN_EQUALS_NULL_PARAM Extension for whether to convert "== ?" with null parameter to "IS NULL".

Fields inherited from class org.datanucleus.store.query.AbstractJavaQuery

candidateCollection, singleString

Fields inherited from class org.datanucleus.store.query.Query

candidateClass, candidateClassName, clr, compilation, ec, explicitParameters, explicitVariables, EXTENSION_CHECK_UNUSED_PARAMETERS, EXTENSION_CLOSE_RESULTS_AT_EC_CLOSE, EXTENSION_COMPILATION_CACHED, EXTENSION_EVALUATE_IN_MEMORY, EXTENSION_EXCLUDE_SUBCLASSES, EXTENSION_FLUSH_BEFORE_EXECUTION, EXTENSION_JDOQL_STRICT, EXTENSION_JPQL_STRICT, EXTENSION_LOAD_RESULTS_AT_COMMIT, EXTENSION_MULTITHREAD, EXTENSION_RESULT_CACHE_TYPE, EXTENSION_RESULT_SIZE_METHOD, EXTENSION_RESULTS_CACHED, EXTENSION_SQL_SYNTAX_CHECKS, EXTENSION_USE_FETCH_PLAN, extensions, filter, from, fromInclNo, fromInclParam, grouping, having, ignoreCache, implicitParameters, imports, inputParameters, insertFields, insertSelectQuery, LANGUAGE_JDOQL, LANGUAGE_JPQL, LANGUAGE_SQL, ordering, parameterNames, parsedImports, queryResults, range, result, resultClass, resultClassName, resultDistinct, storeMgr, subclasses, subqueries, tasks, toExclNo, toExclParam, type, unique, unmodifiable, update

Constructor Summary

Constructors

Constructor and Description
JPQLQuery(org.datanucleus.store.StoreManager storeMgr, org.datanucleus.ExecutionContext ec) Constructs a new query instance that uses the given object manager.
JPQLQuery(org.datanucleus.store.StoreManager storeMgr, org.datanucleus.ExecutionContext ec, JPQLQuery q) Constructs a new query instance having the same criteria as the given query.
JPQLQuery(org.datanucleus.store.StoreManager storeMgr, org.datanucleus.ExecutionContext ec, String query) Constructor for a JPQL query where the query is specified using the "Single-String" format.

Method Summary

Modifier and Type	Method and Description
void	addExtension(String key, Object value) Add a vendor-specific extension this query.
protected void	assertSupportsCancel() Method that will throw an UnsupportedOperationException if the query implementation doesn't support cancelling queries.
protected boolean	cancelTaskObject(Object obj)
protected void	compileInternal(Map parameterValues) Method to compile the JPQL query.
protected void	compileQueryDelete(Map parameterValues, org.datanucleus.metadata.AbstractClassMetaData candidateCmd) Method to compile the query for RDBMS for a bulk delete.
protected void	compileQueryInsert(Map parameterValues, org.datanucleus.metadata.AbstractClassMetaData candidateCmd) Method to compile the query for RDBMS for a bulk INSERT.
protected void	compileQueryUpdate(Map parameterValues, org.datanucleus.metadata.AbstractClassMetaData candidateCmd) Method to compile the query for RDBMS for a bulk update.
protected void	discardCompiled() Utility to remove any previous compilation of this Query.
RDBMSQueryCompilation	getDatastoreCompilation()
Object	getNativeQuery()
protected String	getQueryCacheKey() Method to get key for query cache
String	getSQL() Convenience accessor for the SQL to invoke in the datastore for this query.
Set<String>	getSupportedExtensions() Method to return the names of the extensions supported by this query.
protected boolean	isCompiled() Method to return if the query is compiled.
protected Object	performExecute(Map parameters)
boolean	processesRangeInDatastoreQuery()
void	setExtensions(Map extensions) Set multiple extensions, or use null to clear extensions.
void	setImplicitParameter(int position, Object value)
void	setImplicitParameter(String name, Object value)
protected boolean	supportsTimeout() Convenience method for whether this query supports timeouts.

Methods inherited from class org.datanucleus.store.query.AbstractJPQLQuery

compileGeneric, compileSubqueries, getLanguage, getSingleStringQuery, resolveClassDeclaration, setResult

Methods inherited from class org.datanucleus.store.query.AbstractJavaQuery

dereferenceFilter, evaluateInMemory, performDeletePersistentAll, setCandidates, setCandidates, toString

Methods inherited from class org.datanucleus.store.query.Query

addSubquery, applyImplicitParameterValueToCompilation, applyImplicitParameterValueToSubqueries, assertIsModifiable, assertIsOpen, cancel, cancel, checkForMissingParameters, checkParameterTypesAgainstCompilation, checkUnusedParameters, close, closeAll, compile, declareExplicitParameters, declareExplicitVariables, declareImports, deepFindSymbolForParameterInCompilation, deletePersistentAll, deletePersistentAll, deletePersistentAll, deregisterTask, equals, execute, executeQuery, executeWithArray, executeWithMap, executionContextClosing, getBooleanExtensionProperty, getCandidateClass, getCandidateClassMetaData, getCandidateClassName, getCompilation, getDatastoreReadTimeoutMillis, getDatastoreWriteTimeoutMillis, getExecutionContext, getExplicitParametersDeclaration, getExplicitVariablesDeclaration, getExtension, getExtensions, getFetchPlan, getFilter, getFrom, getGrouping, getHaving, getIgnoreCache, getImplicitParameters, getImportsDeclaration, getInputParameters, getInsertFields, getInsertSelectQuery, getOrdering, getParameterMapForValues, getParsedImports, getQueryManager, getRange, getRangeFromIncl, getRangeFromInclParam, getRangeToExcl, getRangeToExclParam, getResult, getResultClass, getResultClassName, getResultDistinct, getSerializeRead, getStoreManager, getStringExtensionProperty, getSubqueryForVariable, getType, getUpdate, hashCode, hasSubqueryForVariable, isSubclasses, isUnique, isUnmodifiable, prepareDatastore, registerTask, setCacheResults, setCandidateClass, setCandidateClassName, setCompilation, setDatastoreReadTimeoutMillis, setDatastoreWriteTimeoutMillis, setFetchPlan, setFilter, setFrom, setGrouping, setHaving, setIgnoreCache, setInsertFields, setInsertSelectQuery, setOrdering, setRange, setRange, setResultClass, setResultClassName, setResultDistinct, setResultMetaData, setSerializeRead, setSubclasses, setType, setUnique, setUnmodifiable, setUpdate, shouldReturnSingleRow, useCaching, useFetchPlan, useResultsCaching

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

EXTENSION_USE_IS_NULL_WHEN_EQUALS_NULL_PARAM

public static final String EXTENSION_USE_IS_NULL_WHEN_EQUALS_NULL_PARAM

Extension for whether to convert "== ?" with null parameter to "IS NULL". Defaults to false to comply with JPA spec 4.11.

See Also:

Constant Field Values

EXTENSION_FOR_UPDATE_NOWAIT

public static final String EXTENSION_FOR_UPDATE_NOWAIT

Extension to add NOWAIT when using FOR UPDATE (when supported).

See Also:

Constant Field Values

EXTENSION_NAVIGATION_JOIN_TYPE_FILTER

public static final String EXTENSION_NAVIGATION_JOIN_TYPE_FILTER

Extension to define the JOIN TYPE to use when navigating single-valued relations, when part of the filter.

See Also:

Constant Field Values

EXTENSION_NAVIGATION_JOIN_TYPE

public static final String EXTENSION_NAVIGATION_JOIN_TYPE

Extension to define the JOIN TYPE to use when navigating single-valued relations.

See Also:

Constant Field Values

datastoreCompilation

protected transient RDBMSQueryCompilation datastoreCompilation

The compilation of the query for this datastore. Not applicable if totally in-memory.

Constructor Detail

JPQLQuery

public JPQLQuery(org.datanucleus.store.StoreManager storeMgr,
                 org.datanucleus.ExecutionContext ec)

Constructs a new query instance that uses the given object manager.

Parameters:

storeMgr - StoreManager for this query

ec - execution context

JPQLQuery

public JPQLQuery(org.datanucleus.store.StoreManager storeMgr,
                 org.datanucleus.ExecutionContext ec,
                 JPQLQuery q)

Constructs a new query instance having the same criteria as the given query.

Parameters:

storeMgr - StoreManager for this query

ec - execution context

q - The query from which to copy criteria.

JPQLQuery

public JPQLQuery(org.datanucleus.store.StoreManager storeMgr,
                 org.datanucleus.ExecutionContext ec,
                 String query)

Constructor for a JPQL query where the query is specified using the "Single-String" format.

Parameters:

storeMgr - StoreManager for this query

ec - The ExecutionContext

query - The single-string query form

Method Detail

setImplicitParameter

public void setImplicitParameter(int position,
                                 Object value)

Overrides:

setImplicitParameter in class org.datanucleus.store.query.Query

setImplicitParameter

public void setImplicitParameter(String name,
                                 Object value)

Overrides:

setImplicitParameter in class org.datanucleus.store.query.Query

discardCompiled

protected void discardCompiled()

Utility to remove any previous compilation of this Query.

Overrides:

discardCompiled in class org.datanucleus.store.query.AbstractJavaQuery

isCompiled

protected boolean isCompiled()

Method to return if the query is compiled.

Overrides:

isCompiled in class org.datanucleus.store.query.Query

Returns:

Whether it is compiled

getQueryCacheKey

protected String getQueryCacheKey()

Method to get key for query cache

Overrides:

getQueryCacheKey in class org.datanucleus.store.query.AbstractJPQLQuery

Returns:

The cache key

compileInternal

protected void compileInternal(Map parameterValues)

Method to compile the JPQL query. Uses the superclass to compile the generic query populating the "compilation", and then generates the datastore-specific "datastoreCompilation".

Overrides:

compileInternal in class org.datanucleus.store.query.AbstractJPQLQuery

Parameters:

parameterValues - Map of param values keyed by param name (if available at compile time)

getSQL

public String getSQL()

Convenience accessor for the SQL to invoke in the datastore for this query.

Returns:

The SQL.

performExecute

protected Object performExecute(Map parameters)

Specified by:

performExecute in class org.datanucleus.store.query.Query

assertSupportsCancel

protected void assertSupportsCancel()

Method that will throw an UnsupportedOperationException if the query implementation doesn't support cancelling queries.

Overrides:

assertSupportsCancel in class org.datanucleus.store.query.Query

cancelTaskObject

protected boolean cancelTaskObject(Object obj)

Overrides:

cancelTaskObject in class org.datanucleus.store.query.Query

supportsTimeout

protected boolean supportsTimeout()

Convenience method for whether this query supports timeouts.

Overrides:

supportsTimeout in class org.datanucleus.store.query.Query

Returns:

Whether timeouts are supported.

compileQueryInsert

protected void compileQueryInsert(Map parameterValues,
                                  org.datanucleus.metadata.AbstractClassMetaData candidateCmd)

Method to compile the query for RDBMS for a bulk INSERT.

Parameters:

parameterValues - The parameter values (if any)

candidateCmd - Meta-data for the candidate class

compileQueryUpdate

protected void compileQueryUpdate(Map parameterValues,
                                  org.datanucleus.metadata.AbstractClassMetaData candidateCmd)

Method to compile the query for RDBMS for a bulk update.

Parameters:

parameterValues - The parameter values (if any)

candidateCmd - Meta-data for the candidate class

compileQueryDelete

protected void compileQueryDelete(Map parameterValues,
                                  org.datanucleus.metadata.AbstractClassMetaData candidateCmd)

Method to compile the query for RDBMS for a bulk delete.

Parameters:

parameterValues - The parameter values (if any)

candidateCmd - Meta-data for the candidate class

processesRangeInDatastoreQuery

public boolean processesRangeInDatastoreQuery()

Overrides:

processesRangeInDatastoreQuery in class org.datanucleus.store.query.Query

getSupportedExtensions

public Set<String> getSupportedExtensions()

Method to return the names of the extensions supported by this query. To be overridden by subclasses where they support additional extensions.

Overrides:

getSupportedExtensions in class org.datanucleus.store.query.Query

Returns:

The supported extension names

addExtension

public void addExtension(String key,
                         Object value)

Add a vendor-specific extension this query. Intercepts any setting of in-memory evaluation, so we can throw away any datastore compilation.

Overrides:

addExtension in class org.datanucleus.store.query.Query

Parameters:

key - the extension key

value - the extension value

setExtensions

public void setExtensions(Map extensions)

Set multiple extensions, or use null to clear extensions. Intercepts any setting of in-memory evaluation, so we can throw away any datastore compilation.

Overrides:

setExtensions in class org.datanucleus.store.query.Query

Parameters:

extensions - Query extensions

getDatastoreCompilation

public RDBMSQueryCompilation getDatastoreCompilation()

getNativeQuery

public Object getNativeQuery()

Overrides:

getNativeQuery in class org.datanucleus.store.query.Query