Package org.datanucleus.store.query
Class AbstractQueryResult<E>
java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractList<E>
org.datanucleus.store.query.AbstractQueryResult<E>
- Type Parameters:
E
- Type of "element" returned by this query result
- All Implemented Interfaces:
Serializable
,Iterable<E>
,Collection<E>
,List<E>
,QueryResult<E>
- Direct Known Subclasses:
CandidateIdsQueryResult
public abstract class AbstractQueryResult<E>
extends AbstractList<E>
implements QueryResult<E>, Serializable
Abstract representation of a QueryResult.
Provides default implementations of the majority of list methods that we aren't likely to
be providing in a concrete query result.
This class is used where your query implementation needs to return a wrapper to a List so that
you can intercept calls and convert a row of the results into object(s), to avoid full instantiation
at creation.
Supports the following query extensions :-
- datanucleus.query.resultSizeMethod The method used to find the size of the result set.
- datanucleus.query.loadResultsAtCommit Whether to load all results when the connection is closing. Has no effect if caching is not used.
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected ApiAdapter
protected boolean
Whether the results are close.protected List
<ManagedConnectionResourceListener> List of listeners to notify when the query results are closed.protected boolean
Whether to load any unread results at commit (when connection is closed).protected Query
The Query object.protected String
Method for getting the size of the results.private static final long
protected int
size of the query results.Fields inherited from class java.util.AbstractList
modCount
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Method to add a result.boolean
Method to add results.boolean
addAll
(int index, Collection c) Method to add results.void
Method to register a listener to be notified when the query result is closing.protected void
Internal method to throw an Exception if the ResultSet is open.void
clear()
Method to clear the results.void
close()
Method to close the results, meaning that they are inaccessible after this point.protected abstract void
Inform the query result that we are closing the results now.protected abstract void
Inform the query result that the connection is being closed so perform any operations now, or rest in peace.boolean
Method to check if the specified object is contained in this result.boolean
Method to check if all of the specified objects are contained here.void
Method to disconnect the results from the ExecutionContext, meaning that thereafter it just behaves like a List.abstract boolean
Equality operator for QueryResults.abstract E
get
(int index) Method to retrieve a particular element from the list.protected int
Method to get the size using the "resultSizeMethod".int
hashCode()
Accessor for the hashcode of this objectint
Method to check the index of a result.boolean
isEmpty()
Returns true if this collection contains no elements.protected boolean
isOpen()
Accessor whether the results are open.iterator()
Accessor for an iterator for the results.int
Method to check the last index of a result.abstract ListIterator
<E> Accessor for a list iterator for the results.remove
(int index) Method to remove a result.Method to set the position of a result.int
size()
Method to return the size of the result.subList
(int fromIndex, int toIndex) Method return a sub list of results.Object[]
toArray()
Method to return the results as an array.<T> T[]
toArray
(T[] a) Method to return the results as an array.Methods inherited from class java.util.AbstractList
listIterator, removeRange
Methods inherited from class java.util.AbstractCollection
addAll, remove, removeAll, retainAll, toString
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
Methods inherited from interface java.util.Collection
parallelStream, removeIf, stream
Methods inherited from interface java.util.List
addAll, remove, removeAll, replaceAll, retainAll, sort, spliterator
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
closed
protected boolean closedWhether the results are close. -
query
The Query object. -
connectionListeners
List of listeners to notify when the query results are closed. -
api
-
size
protected int sizesize of the query results. Is -1 until known. -
resultSizeMethod
Method for getting the size of the results. -
loadResultsAtCommit
protected boolean loadResultsAtCommitWhether to load any unread results at commit (when connection is closed).
-
-
Constructor Details
-
AbstractQueryResult
Constructor of the result from a Query.- Parameters:
query
- The Query
-
-
Method Details
-
disconnect
public void disconnect()Method to disconnect the results from the ExecutionContext, meaning that thereafter it just behaves like a List. All remaining results are read in at this point (unless selected not to be).- Specified by:
disconnect
in interfaceQueryResult<E>
-
closingConnection
protected abstract void closingConnection()Inform the query result that the connection is being closed so perform any operations now, or rest in peace. -
closeResults
protected abstract void closeResults()Inform the query result that we are closing the results now. -
close
public void close()Method to close the results, meaning that they are inaccessible after this point.- Specified by:
close
in interfaceQueryResult<E>
-
addConnectionListener
Method to register a listener to be notified when the query result is closing.- Parameters:
listener
- The listener
-
isOpen
protected boolean isOpen()Accessor whether the results are open.- Returns:
- Whether it is open.
-
assertIsOpen
protected void assertIsOpen()Internal method to throw an Exception if the ResultSet is open. -
equals
Equality operator for QueryResults. Overrides the AbstractList implementation since that uses size() and iterator() and that would cause problems when closed.- Specified by:
equals
in interfaceCollection<E>
- Specified by:
equals
in interfaceList<E>
- Overrides:
equals
in classAbstractList<E>
- Parameters:
o
- The object to compare against- Returns:
- Whether they are equal
-
get
Method to retrieve a particular element from the list. -
hashCode
public int hashCode()Accessor for the hashcode of this object- Specified by:
hashCode
in interfaceCollection<E>
- Specified by:
hashCode
in interfaceList<E>
- Overrides:
hashCode
in classAbstractList<E>
- Returns:
- The hash code
-
iterator
Accessor for an iterator for the results. -
listIterator
Accessor for a list iterator for the results.- Specified by:
listIterator
in interfaceList<E>
- Overrides:
listIterator
in classAbstractList<E>
- Returns:
- a ListIterator with the query results
-
isEmpty
public boolean isEmpty()Returns true if this collection contains no elements.- Specified by:
isEmpty
in interfaceCollection<E>
- Specified by:
isEmpty
in interfaceList<E>
- Overrides:
isEmpty
in classAbstractCollection<E>
- Returns:
- true if this collection contains no elements.
-
size
public int size()Method to return the size of the result. Hands off the calculation of the size to getSizeUsingMethod() which should be overridden if you want to support other methods.- Specified by:
size
in interfaceCollection<E>
- Specified by:
size
in interfaceList<E>
- Specified by:
size
in classAbstractCollection<E>
- Returns:
- The size of the result.
-
subList
Method return a sub list of results. Method create new ArrayList, iterate and call get() in subclass for optimum performance. -
toArray
Method to return the results as an array.- Specified by:
toArray
in interfaceCollection<E>
- Specified by:
toArray
in interfaceList<E>
- Overrides:
toArray
in classAbstractCollection<E>
- Returns:
- The array.
-
toArray
public <T> T[] toArray(T[] a) Method to return the results as an array.- Specified by:
toArray
in interfaceCollection<E>
- Specified by:
toArray
in interfaceList<E>
- Overrides:
toArray
in classAbstractCollection<E>
- Parameters:
a
- The array to copy into.- Returns:
- The array.
-
getSizeUsingMethod
protected int getSizeUsingMethod()Method to get the size using the "resultSizeMethod". This implementation supports "COUNT" method. Override this in subclasses to implement other methods.- Returns:
- The size
- Throws:
ArithmeticException
- if the size overflows the integer return type
-
add
Method to add a result. Unsupported. -
add
Method to add results. Unsupported.- Specified by:
add
in interfaceCollection<E>
- Specified by:
add
in interfaceList<E>
- Overrides:
add
in classAbstractList<E>
- Parameters:
o
- The result to add- Returns:
- true if added successfully
-
addAll
Method to add results. Unsupported. -
clear
public void clear()Method to clear the results.- Specified by:
clear
in interfaceCollection<E>
- Specified by:
clear
in interfaceList<E>
- Overrides:
clear
in classAbstractList<E>
-
contains
Method to check if the specified object is contained in this result.- Specified by:
contains
in interfaceCollection<E>
- Specified by:
contains
in interfaceList<E>
- Overrides:
contains
in classAbstractCollection<E>
- Parameters:
o
- The object- Returns:
- Whether it is contained here.
-
containsAll
Method to check if all of the specified objects are contained here.- Specified by:
containsAll
in interfaceCollection<E>
- Specified by:
containsAll
in interfaceList<E>
- Overrides:
containsAll
in classAbstractCollection<E>
- Parameters:
c
- The collection of objects- Returns:
- Whether they are all contained here.
-
indexOf
Method to check the index of a result. Not supported. -
lastIndexOf
Method to check the last index of a result. Not supported.- Specified by:
lastIndexOf
in interfaceList<E>
- Overrides:
lastIndexOf
in classAbstractList<E>
- Parameters:
o
- The result- Returns:
- The last index
-
remove
Method to remove a result. Not supported. -
set
Method to set the position of a result. Not supported.
-