public final class ScrollableQueryResult<E> extends AbstractRDBMSQueryResult<E> implements Serializable
| Modifier and Type | Field and Description |
|---|---|
protected Map<Integer,Object> |
resultIds |
bulkLoadedValueByMemberNumber, closeStatementWithResultSet, rof, rsapi, closed, connectionListeners, loadResultsAtCommit, query, resultSizeMethod, sizemodCount| Constructor and Description |
|---|
ScrollableQueryResult(org.datanucleus.store.query.Query query,
ResultObjectFactory<E> rof,
ResultSet rs,
Collection candidates)
Constructor of the result from a Query.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
cacheQueryResults() |
void |
close()
Method to close the results, making the results unusable thereafter.
|
protected void |
closingConnection()
Inform the query result that the connection is being closed so perform
any operations now, or rest in peace.
|
boolean |
equals(Object o) |
E |
get(int index)
Method to retrieve a particular element from the list.
|
protected E |
getObjectForIndex(int index)
Accessor for the result object at an index.
|
protected int |
getSizeUsingMethod()
Method to get the size using the "resultSizeMethod".
|
int |
hashCode() |
void |
initialise() |
Iterator<E> |
iterator()
Accessor for an iterator for the results.
|
ListIterator<E> |
listIterator()
Accessor for an iterator for the results.
|
protected void |
loadObjects(int start,
int maxNumber)
Convenience method to load up rows starting at the specified position.
|
Object[] |
toArray() |
Object[] |
toArray(Object[] a) |
protected Object |
writeReplace()
Handle serialisation by returning a java.util.ArrayList of all of the results for this query
after disconnecting the query which has the consequence of enforcing the load of all objects.
|
closeResults, disconnect, registerMemberBulkResultSet, setCloseStatementWithResultSetadd, add, addAll, addConnectionListener, assertIsOpen, clear, contains, containsAll, indexOf, isEmpty, isOpen, lastIndexOf, remove, set, size, subListlistIterator, removeRangeaddAll, remove, removeAll, retainAll, toStringclone, finalize, getClass, notify, notifyAll, wait, wait, waitaddAll, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, streamaddAll, remove, removeAll, replaceAll, retainAll, sort, spliteratorpublic ScrollableQueryResult(org.datanucleus.store.query.Query query,
ResultObjectFactory<E> rof,
ResultSet rs,
Collection candidates)
query - The Queryrof - The factory to retrieve results fromrs - The ResultSet from the Query Statementcandidates - the Candidates collection. Pass this argument only when distinct = falsepublic void initialise()
initialise in class AbstractRDBMSQueryResult<E>protected void loadObjects(int start,
int maxNumber)
start - Start rowmaxNumber - Max number to process (-1 means no maximum)protected E getObjectForIndex(int index)
index - The list index positionpublic void close()
close in interface org.datanucleus.store.query.QueryResult<E>close in class AbstractRDBMSQueryResult<E>protected void closingConnection()
closingConnection in class org.datanucleus.store.query.AbstractQueryResult<E>protected void cacheQueryResults()
public ListIterator<E> listIterator()
listIterator in interface List<E>listIterator in class org.datanucleus.store.query.AbstractQueryResult<E>public boolean equals(Object o)
equals in interface Collection<E>equals in interface List<E>equals in class AbstractRDBMSQueryResult<E>public int hashCode()
hashCode in interface Collection<E>hashCode in interface List<E>hashCode in class AbstractRDBMSQueryResult<E>public E get(int index)
protected int getSizeUsingMethod()
getSizeUsingMethod in class org.datanucleus.store.query.AbstractQueryResult<E>public Object[] toArray()
protected Object writeReplace() throws ObjectStreamException
ObjectStreamException - thrown if an error occursCopyright © 2017. All rights reserved.