Package org.hibernate.reactive.sql.exec.spi

Class ReactiveRowProcessingState

java.lang.Object

org.hibernate.sql.exec.internal.BaseExecutionContext

org.hibernate.reactive.sql.exec.spi.ReactiveRowProcessingState

All Implemented Interfaces:

org.hibernate.sql.exec.spi.ExecutionContext, org.hibernate.sql.results.jdbc.spi.RowProcessingState

public class ReactiveRowProcessingState
extends org.hibernate.sql.exec.internal.BaseExecutionContext
implements org.hibernate.sql.results.jdbc.spi.RowProcessingState

See Also:

• RowProcessingStateStandardImpl

Constructor Summary

Constructors

Constructor	Description
ReactiveRowProcessingState(org.hibernate.sql.results.jdbc.internal.JdbcValuesSourceProcessingStateStandardImpl resultSetProcessingState, org.hibernate.sql.exec.spi.ExecutionContext executionContext, ReactiveRowReader<?> rowReader, ReactiveValuesResultSet jdbcValues)

Method Summary

Modifier and Type	Method	Description
LockMode	determineEffectiveLockMode(String alias)
void	finishRowProcessing(boolean wasAdded)
Object	getEntityId()
<T extends org.hibernate.sql.results.graph.InitializerData> T	getInitializerData(int initializerId)
Object	getJdbcValue(int position)
org.hibernate.sql.results.jdbc.spi.JdbcValuesSourceProcessingState	getJdbcValuesSourceProcessingState()
QueryOptions	getQueryOptions()
org.hibernate.sql.results.spi.RowReader<?>	getRowReader()
boolean	isQueryCacheHit()
boolean	needsResolveState()
CompletionStage<Boolean>	next()
void	registerNonExists(org.hibernate.sql.results.graph.entity.EntityFetch fetch)
void	setInitializerData(int initializerId, org.hibernate.sql.results.graph.InitializerData state)

Methods inherited from class org.hibernate.sql.exec.internal.BaseExecutionContext

getCallback, getLoadQueryInfluencers, getQueryIdentifier, getQueryParameterBindings, getSession, isTransactionActive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.hibernate.sql.exec.spi.ExecutionContext

afterStatement, getCallback, getCollectionKey, getEntityInstance, getEntityUniqueKey, getEntityUniqueKeyAttributePath, getLoadQueryInfluencers, getQueryIdentifier, getQueryParameterBindings, getRootEntityDescriptor, getSession, hasCallbackActions, hasQueryExecutionToBeAddedToStatistics, isScrollResult, isTransactionActive, registerLoadingEntityHolder, upgradeLocks

Methods inherited from interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

getJdbcValue, unwrap

Constructor Details

ReactiveRowProcessingState

public ReactiveRowProcessingState(org.hibernate.sql.results.jdbc.internal.JdbcValuesSourceProcessingStateStandardImpl resultSetProcessingState,
 org.hibernate.sql.exec.spi.ExecutionContext executionContext,
 ReactiveRowReader<?> rowReader,
 ReactiveValuesResultSet jdbcValues)

Method Details

next

public CompletionStage<Boolean> next()

getJdbcValuesSourceProcessingState

public org.hibernate.sql.results.jdbc.spi.JdbcValuesSourceProcessingState getJdbcValuesSourceProcessingState()

Specified by:

getJdbcValuesSourceProcessingState in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

getEntityId

public Object getEntityId()

Specified by:

getEntityId in interface org.hibernate.sql.exec.spi.ExecutionContext

determineEffectiveLockMode

public LockMode determineEffectiveLockMode(String alias)

Specified by:

determineEffectiveLockMode in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

needsResolveState

public boolean needsResolveState()

Specified by:

needsResolveState in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

getInitializerData

public <T extends org.hibernate.sql.results.graph.InitializerData>
T getInitializerData(int initializerId)

Specified by:

getInitializerData in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

setInitializerData

public void setInitializerData(int initializerId,
 org.hibernate.sql.results.graph.InitializerData state)

Specified by:

setInitializerData in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

getRowReader

public org.hibernate.sql.results.spi.RowReader<?> getRowReader()

Specified by:

getRowReader in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

getJdbcValue

public Object getJdbcValue(int position)

Specified by:

getJdbcValue in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

registerNonExists

public void registerNonExists(org.hibernate.sql.results.graph.entity.EntityFetch fetch)

Specified by:

registerNonExists in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

isQueryCacheHit

public boolean isQueryCacheHit()

Specified by:

isQueryCacheHit in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

finishRowProcessing

public void finishRowProcessing(boolean wasAdded)

Specified by:

finishRowProcessing in interface org.hibernate.sql.results.jdbc.spi.RowProcessingState

getQueryOptions

public QueryOptions getQueryOptions()

Specified by:

getQueryOptions in interface org.hibernate.sql.exec.spi.ExecutionContext

Overrides:

getQueryOptions in class org.hibernate.sql.exec.internal.BaseExecutionContext