Class ReactiveDeferredResultSetAccess

java.lang.Object
org.hibernate.sql.results.jdbc.internal.AbstractResultSetAccess
org.hibernate.sql.results.jdbc.internal.DeferredResultSetAccess
org.hibernate.reactive.sql.results.internal.ReactiveDeferredResultSetAccess
All Implemented Interfaces:
ReactiveResultSetAccess, org.hibernate.sql.results.jdbc.internal.ResultSetAccess, org.hibernate.sql.results.jdbc.spi.JdbcValuesMetadata

public class ReactiveDeferredResultSetAccess extends org.hibernate.sql.results.jdbc.internal.DeferredResultSetAccess implements ReactiveResultSetAccess
  • Constructor Details

    • ReactiveDeferredResultSetAccess

      public ReactiveDeferredResultSetAccess(org.hibernate.sql.exec.spi.JdbcOperationQuerySelect jdbcSelect, org.hibernate.sql.exec.spi.JdbcParameterBindings jdbcParameterBindings, org.hibernate.sql.exec.spi.ExecutionContext executionContext, org.hibernate.sql.exec.spi.JdbcSelectExecutor.StatementCreator statementCreator, int resultCountEstimate)
  • Method Details

    • getJdbcServices

      public org.hibernate.engine.jdbc.spi.JdbcServices getJdbcServices()
      Specified by:
      getJdbcServices in interface ReactiveResultSetAccess
    • convertSqlException

      public org.hibernate.JDBCException convertSqlException(SQLException e, String message)
      Specified by:
      convertSqlException in interface ReactiveResultSetAccess
    • registerAfterLoadAction

      protected void registerAfterLoadAction(org.hibernate.sql.exec.spi.ExecutionContext executionContext, org.hibernate.LockOptions lockOptionsToUse)
      Reactive version of DeferredResultSetAccess.registerAfterLoadAction(ExecutionContext, LockOptions) calling ReactiveSession.reactiveLock(String, Object, LockOptions)
      Overrides:
      registerAfterLoadAction in class org.hibernate.sql.results.jdbc.internal.DeferredResultSetAccess
    • getResultSet

      public ResultSet getResultSet()
      Specified by:
      getResultSet in interface ReactiveResultSetAccess
      Specified by:
      getResultSet in interface org.hibernate.sql.results.jdbc.internal.ResultSetAccess
      Overrides:
      getResultSet in class org.hibernate.sql.results.jdbc.internal.DeferredResultSetAccess
    • getReactiveResultSet

      public CompletionStage<ResultSet> getReactiveResultSet()
      Specified by:
      getReactiveResultSet in interface ReactiveResultSetAccess
    • getColumnCount

      public int getColumnCount()
      Specified by:
      getColumnCount in interface org.hibernate.sql.results.jdbc.spi.JdbcValuesMetadata
      Specified by:
      getColumnCount in interface ReactiveResultSetAccess
      Overrides:
      getColumnCount in class org.hibernate.sql.results.jdbc.internal.AbstractResultSetAccess
    • getReactiveColumnCount

      public CompletionStage<Integer> getReactiveColumnCount()
      Specified by:
      getReactiveColumnCount in interface ReactiveResultSetAccess
    • resolveType

      public <J> org.hibernate.type.BasicType<J> resolveType(int position, org.hibernate.type.descriptor.java.JavaType<J> explicitJavaType, org.hibernate.engine.spi.SessionFactoryImplementor sessionFactory)
      Specified by:
      resolveType in interface org.hibernate.sql.results.jdbc.spi.JdbcValuesMetadata
    • resolveType

      public <J> org.hibernate.type.BasicType<J> resolveType(int position, org.hibernate.type.descriptor.java.JavaType<J> explicitJavaType, org.hibernate.type.spi.TypeConfiguration typeConfiguration)
      Specified by:
      resolveType in interface org.hibernate.sql.results.jdbc.spi.JdbcValuesMetadata
      Specified by:
      resolveType in interface ReactiveResultSetAccess
      Overrides:
      resolveType in class org.hibernate.sql.results.jdbc.internal.AbstractResultSetAccess
    • resolveJdbcValueMetadata

      public CompletionStage<org.hibernate.sql.results.jdbc.spi.JdbcValuesMetadata> resolveJdbcValueMetadata()
      Specified by:
      resolveJdbcValueMetadata in interface ReactiveResultSetAccess