Package org.hibernate.reactive.id.impl

Class TableReactiveIdentifierGenerator

java.lang.Object

org.hibernate.reactive.id.impl.BlockingIdentifierGenerator

org.hibernate.reactive.id.impl.TableReactiveIdentifierGenerator

All Implemented Interfaces:

Serializable, org.hibernate.boot.model.relational.ExportableProducer, org.hibernate.generator.BeforeExecutionGenerator, org.hibernate.generator.Generator, org.hibernate.id.Configurable, org.hibernate.id.IdentifierGenerator, ReactiveIdentifierGenerator<Long>

Direct Known Subclasses:

EmulatedSequenceReactiveIdentifierGenerator

public class TableReactiveIdentifierGenerator
extends BlockingIdentifierGenerator
implements org.hibernate.id.IdentifierGenerator

Support for JPA's TableGenerator. Persistence is managed via a table which may hold multiple rows distinguished by a "segment" column value.

This implementation supports block allocation, but does not guarantee that generated identifiers are sequential.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected String	renderedTableName
protected String	segmentColumnName
protected String	valueColumnName

Fields inherited from interface org.hibernate.id.IdentifierGenerator

CONTRIBUTOR_NAME, ENTITY_NAME, GENERATOR_NAME, JPA_ENTITY_NAME

Constructor Summary

Constructors

Constructor	Description
TableReactiveIdentifierGenerator(org.hibernate.id.enhanced.TableGenerator generator, org.hibernate.metamodel.spi.RuntimeModelCreationContext runtimeModelCreationContext)
TableReactiveIdentifierGenerator(org.hibernate.id.enhanced.TableStructure structure, org.hibernate.metamodel.spi.RuntimeModelCreationContext runtimeModelCreationContext)

Method Summary

Modifier and Type	Method	Description
protected String	buildInsertQuery(org.hibernate.dialect.Dialect dialect)
protected String	buildSelectQuery(org.hibernate.dialect.Dialect dialect)
protected String	buildUpdateQuery(org.hibernate.dialect.Dialect dialect)
void	configure(org.hibernate.type.Type type, Properties params, org.hibernate.service.ServiceRegistry serviceRegistry)
protected String	determineDefaultSegmentValue(Properties params)
protected int	determineIncrement(Properties params)
protected int	determineInitialValue(Properties params)
protected String	determineSegmentColumnName(Properties params, org.hibernate.engine.jdbc.env.spi.JdbcEnvironment jdbcEnvironment)
protected String	determineSegmentValue(Properties params)
protected Boolean	determineStoreLastUsedValue(org.hibernate.service.ServiceRegistry serviceRegistry)
protected String	determineTableName(org.hibernate.type.Type type, Properties params, org.hibernate.service.ServiceRegistry serviceRegistry)
protected String	determineValueColumnNameForTable(Properties params, org.hibernate.engine.jdbc.env.spi.JdbcEnvironment jdbcEnvironment)
Object	generate(org.hibernate.engine.spi.SharedSessionContractImplementor session, Object object)
protected int	getBlockSize()	The block size (the number of "lo" values for each "hi" value)
protected Object[]	insertParameters(long insertedValue)
protected CompletionStage<Long>	nextHiValue(ReactiveConnectionSupplier session)	Allocate a new block, by obtaining the next "hi" value from the database
protected Object[]	selectParameters()
protected Object[]	updateParameters(long currentValue, long updatedValue)

Methods inherited from class org.hibernate.reactive.id.impl.BlockingIdentifierGenerator

generate

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hibernate.generator.BeforeExecutionGenerator

generatedOnExecution

Methods inherited from interface org.hibernate.id.Configurable

configure, initialize

Methods inherited from interface org.hibernate.generator.Generator

allowAssignedIdentifiers, allowMutation, generatedBeforeExecution, generatedOnExecution, generatesOnForceIncrement, generatesOnInsert, generatesOnUpdate, generatesSometimes

Methods inherited from interface org.hibernate.id.IdentifierGenerator

generate, getEventTypes, registerExportables

Methods inherited from interface org.hibernate.reactive.id.ReactiveIdentifierGenerator

generate

Field Details

renderedTableName

protected String renderedTableName

segmentColumnName

protected String segmentColumnName

valueColumnName

protected String valueColumnName

Constructor Details

TableReactiveIdentifierGenerator

public TableReactiveIdentifierGenerator(org.hibernate.id.enhanced.TableGenerator generator,
 org.hibernate.metamodel.spi.RuntimeModelCreationContext runtimeModelCreationContext)

TableReactiveIdentifierGenerator

public TableReactiveIdentifierGenerator(org.hibernate.id.enhanced.TableStructure structure,
 org.hibernate.metamodel.spi.RuntimeModelCreationContext runtimeModelCreationContext)

Method Details

configure

public void configure(org.hibernate.type.Type type,
 Properties params,
 org.hibernate.service.ServiceRegistry serviceRegistry)

Specified by:

configure in interface org.hibernate.id.Configurable

Specified by:

configure in interface org.hibernate.id.IdentifierGenerator

getBlockSize

protected int getBlockSize()

Description copied from class: BlockingIdentifierGenerator

The block size (the number of "lo" values for each "hi" value)

Specified by:

getBlockSize in class BlockingIdentifierGenerator

nextHiValue

protected CompletionStage<Long> nextHiValue(ReactiveConnectionSupplier session)

Description copied from class: BlockingIdentifierGenerator

Allocate a new block, by obtaining the next "hi" value from the database

Specified by:

nextHiValue in class BlockingIdentifierGenerator

generate

public Object generate(org.hibernate.engine.spi.SharedSessionContractImplementor session,
 Object object)
                throws org.hibernate.HibernateException

Specified by:

generate in interface org.hibernate.id.IdentifierGenerator

Throws:

org.hibernate.HibernateException

determineStoreLastUsedValue

protected Boolean determineStoreLastUsedValue(org.hibernate.service.ServiceRegistry serviceRegistry)

determineTableName

protected String determineTableName(org.hibernate.type.Type type,
 Properties params,
 org.hibernate.service.ServiceRegistry serviceRegistry)

determineSegmentColumnName

protected String determineSegmentColumnName(Properties params,
 org.hibernate.engine.jdbc.env.spi.JdbcEnvironment jdbcEnvironment)

determineValueColumnNameForTable

protected String determineValueColumnNameForTable(Properties params,
 org.hibernate.engine.jdbc.env.spi.JdbcEnvironment jdbcEnvironment)

determineSegmentValue

protected String determineSegmentValue(Properties params)

determineDefaultSegmentValue

protected String determineDefaultSegmentValue(Properties params)

determineInitialValue

protected int determineInitialValue(Properties params)

determineIncrement

protected int determineIncrement(Properties params)

updateParameters

protected Object[] updateParameters(long currentValue,
 long updatedValue)

insertParameters

protected Object[] insertParameters(long insertedValue)

selectParameters

protected Object[] selectParameters()

buildSelectQuery

protected String buildSelectQuery(org.hibernate.dialect.Dialect dialect)

buildUpdateQuery

protected String buildUpdateQuery(org.hibernate.dialect.Dialect dialect)

buildInsertQuery

protected String buildInsertQuery(org.hibernate.dialect.Dialect dialect)