public class ScrollableCursorPolicy extends CursorPolicy
ScrollableCursorPolicy policy = new ScrollableCursorPolicy()
policy.setResultSetType(ScrollableCursorPolicy.TYPE_SCROLL_INSENSITIVE);
query.useScrollableCursor(policy);
Modifier and Type | Field and Description |
---|---|
static int |
CONCUR_READ_ONLY
JDBC 2.0 The concurrency mode for a ResultSet object that may NOT be updated.
|
static int |
CONCUR_UPDATABLE
JDBC 2.0 The concurrency mode for a ResultSet object that may be updated.
|
static int |
FETCH_FORWARD
JDBC 2.0 The rows in a result set will be processed in a forward direction; first-to-last.
|
static int |
FETCH_REVERSE
JDBC 2.0 The rows in a result set will be processed in a reverse direction; last-to-first.
|
static int |
FETCH_UNKNOWN
JDBC 2.0 The order in which rows in a result set will be processed is unknown.
|
protected int |
resultSetConcurrency |
protected int |
resultSetType |
static int |
TYPE_FORWARD_ONLY
JDBC 2.0 The type for a ResultSet object whose cursor may move only forward.
|
static int |
TYPE_SCROLL_INSENSITIVE
JDBC 2.0 The type for a ResultSet object that is scrollable but generally not sensitive to changes made by others.
|
static int |
TYPE_SCROLL_SENSITIVE
JDBC 2.0 The type for a ResultSet object that is scrollable and generally sensitive to changes made by others.
|
pageSize, query
Constructor and Description |
---|
ScrollableCursorPolicy()
PUBLIC:
Create a new scrollable cursor policy.
|
ScrollableCursorPolicy(ReadQuery query,
int pageSize)
INTERNAL:
Create a cursor policy with the pagesize.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
execute()
INTERNAL:
Execute the cursored select and build the stream.
|
int |
getResultSetConcurrency()
PUBLIC:
The ResultSetConcurrency specifies if the resultset is updatable.
|
int |
getResultSetType()
PUBLIC:
The ResultSetType specifies if the resultset is sensitive to changes made by others.
|
boolean |
isScrollableCursorPolicy() |
java.lang.Object |
remoteExecute()
INTERNAL:
Execute the cursored select and build the stream.
|
void |
setResultSetConcurrency(int resultSetConcurrency)
PUBLIC:
The ResultSetConcurrency specifies if the resultset is updatable.
|
void |
setResultSetType(int resultSetType)
PUBLIC:
The ResultSetType specifies if the resultset is sensitive to changes made by others.
|
clone, createChangeEvent, getPageSize, getQuery, hasNext, isCursorPolicy, iteratorFor, next, overridesRead, prepare, setPageSize, setQuery, sizeFor, toStringInfo
addAdditionalFieldsToQuery, addAll, addAll, addFieldsForMapKey, addInto, addInto, addInto, addInto, addNestedJoinsQueriesForMapKey, addNextValueFromIteratorInto, buildChangeSetForNewObjectInCollection, buildCloneForKey, buildCollectionEntry, buildContainerFromVector, buildDefaultPolicy, buildKey, buildKeyFromJoinedRow, buildPolicyFor, buildPolicyFor, buildReferencesPKList, buildSelectionQueryForDirectCollectionMapping, cascadeDiscoverAndPersistUnregisteredNewObjects, cascadePerformRemoveIfRequired, cascadeRegisterNewIfRequired, clear, clone, cloneFor, collectObjectForNewCollection, compareCollectionsForChange, compareKeys, concatenateContainers, containerInstance, containerInstance, contains, contains, convertClassNamesToClasses, copyMapDataToRow, createChangeSetForKeys, createWrappedObjectFromExistingWrappedObject, deleteWrappedObject, equals, getAdditionalFieldsForJoin, getAdditionalTablesForJoinQuery, getChangeValuesFrom, getCloneDataFromChangeSet, getConstructor, getContainerClass, getContainerClassName, getDefaultContainerClass, getDescriptorForMapKey, getElementDescriptor, getIdentityFieldsForMapKey, getKeyMappingDataForWriteQuery, getKeySelectionCriteria, getKeyType, hasElementDescriptor, hasOrder, initialize, initializeConstructor, isCollectionPolicy, isCursoredStreamPolicy, isDirectMapPolicy, isEmpty, isListPolicy, isMapKeyObject, isMappedKeyMapPolicy, isMapPolicy, isOrderedListPolicy, isValidContainer, isValidContainerType, iterateOnMapKey, keyFrom, keyFromEntry, keyFromIterator, mergeCascadeParts, mergeChanges, mergeChanges, next, nextEntry, nextEntry, postCalculateChanges, postCalculateChanges, postInitialize, prepareForExecution, processAdditionalWritableMapKeyFields, propagatesEventsToCollection, propogatePostDelete, propogatePostInsert, propogatePostUpdate, propogatePreDelete, propogatePreInsert, propogatePreUpdate, recordAddToCollectionInChangeRecord, recordPrivateOwnedRemovals, recordRemoveFromCollectionInChangeRecord, recordUpdateToCollectionInChangeRecord, removeFrom, removeFrom, removeFrom, requiresDataModificationEvents, setConstructor, setContainerClass, setContainerClassName, setDefaultContainerClass, setElementDescriptor, setKeyName, setKeyName, shouldAddAll, shouldIncludeKeyInDeleteEvent, shouldUpdateForeignKeysPostInsert, toString, unwrapElement, unwrapIteratorResult, updateChangeRecordForSelfMerge, updateJoinedMappingIndexesForMapKey, valueFromPKList, vectorFor
protected int resultSetType
protected int resultSetConcurrency
public static final int FETCH_FORWARD
public static final int FETCH_REVERSE
public static final int FETCH_UNKNOWN
public static final int TYPE_FORWARD_ONLY
public static final int TYPE_SCROLL_INSENSITIVE
public static final int TYPE_SCROLL_SENSITIVE
public static final int CONCUR_READ_ONLY
public static final int CONCUR_UPDATABLE
public ScrollableCursorPolicy()
public ScrollableCursorPolicy(ReadQuery query, int pageSize)
public java.lang.Object execute()
execute
in class CursorPolicy
public int getResultSetConcurrency()
public int getResultSetType()
public boolean isScrollableCursorPolicy()
isScrollableCursorPolicy
in class org.eclipse.persistence.internal.queries.ContainerPolicy
public java.lang.Object remoteExecute()
remoteExecute
in class CursorPolicy
public void setResultSetConcurrency(int resultSetConcurrency)
public void setResultSetType(int resultSetType)