org.openspaces.persistency.hibernate

Class StatelessHibernateSpaceDataSourceFactoryBean

java.lang.Object

org.openspaces.persistency.hibernate.StatelessHibernateSpaceDataSourceFactoryBean

All Implemented Interfaces:

ClusterInfoAware, org.springframework.beans.factory.FactoryBean<StatelessHibernateSpaceDataSource>, org.springframework.beans.factory.InitializingBean

public class StatelessHibernateSpaceDataSourceFactoryBean
extends Object
implements org.springframework.beans.factory.FactoryBean<StatelessHibernateSpaceDataSource>, org.springframework.beans.factory.InitializingBean, ClusterInfoAware

A factory bean which creates StatelessHibernateSpaceDataSource

Since:

9.5

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
StatelessHibernateSpaceDataSourceFactoryBean()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected StatelessHibernateSpaceDataSourceConfigurer	getConfigurer()
StatelessHibernateSpaceDataSource	getObject()
Class<?>	getObjectType()
boolean	isSingleton()
void	setAugmentInitialLoadEntries(boolean augmentInitialLoadEntries) Feature switch for initial load entries augmentation (creation of partition-specific query for entries).
void	setClusterInfo(ClusterInfo clusterInfo) Sets the cluster information.
void	setFetchSize(int fetchSize) Sets the fetch size that will be used when working with scrollable results.
void	setInitialLoadChunkSize(int initalLoadChunkSize) By default, the initial load process will chunk large tables and will iterate over the table (entity) per chunk (concurrently).
void	setInitialLoadEntries(String... initialLoadEntries) Sets a list of entries that will be used to perform the #initialLoad() operation.
void	setInitialLoadQueryScanningBasePackages(String... initialLoadQueryScanningBasePackages)
void	setInitialLoadThreadPoolSize(int initialLoadThreadPoolSize) The initial load operation uses the ConcurrentMultiDataIterator.
void	setManagedEntries(String... entries) Sets all the entries this Hibernate data source will work with.
void	setPerformOrderById(boolean performOrderById) When performing initial load, this flag indicates if the generated query will order to results by the id.
void	setSessionFactory(org.hibernate.SessionFactory sessionFactory) Injects the Hibernate SessionFactory to be used with this data source.
void	setUseScrollableResultSet(boolean useScrollableResultSet) Controls if scrollable result sets will be used with initial load operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatelessHibernateSpaceDataSourceFactoryBean

public StatelessHibernateSpaceDataSourceFactoryBean()

Method Detail

getConfigurer

protected StatelessHibernateSpaceDataSourceConfigurer getConfigurer()

setSessionFactory

public void setSessionFactory(org.hibernate.SessionFactory sessionFactory)

Injects the Hibernate SessionFactory to be used with this data source.

setManagedEntries

public void setManagedEntries(String... entries)

Sets all the entries this Hibernate data source will work with. By default, will use Hibernate meta data API in order to get the list of all the given entities it handles.

This list is used to filter out entities when performing all data source operations exception for the #initialLoad() operation.

Usually, there is no need to explicitly set this.

setFetchSize

public void setFetchSize(int fetchSize)

Sets the fetch size that will be used when working with scrollable results. Defaults to 100.

See Also:

Criteria.setFetchSize(int)

setPerformOrderById

public void setPerformOrderById(boolean performOrderById)

When performing initial load, this flag indicates if the generated query will order to results by the id. By default set to true as it most times results in better initial load performance.

setInitialLoadEntries

public void setInitialLoadEntries(String... initialLoadEntries)

Sets a list of entries that will be used to perform the #initialLoad() operation. By default, will try and build a sensible list based on Hibernate meta data.

Note, sometimes an explicit list should be provided. For example, if we have a class A and class B, and A has a relationship to B which is not component. If in the space, we only wish to have A, and have B just as a field in A (and not as an Entry), then we need to explicitly set the list just to A. By default, if we won't set it, it will result in two entries existing in the Space, A and B, with A having a field of B as well.

setInitialLoadThreadPoolSize

public void setInitialLoadThreadPoolSize(int initialLoadThreadPoolSize)

The initial load operation uses the ConcurrentMultiDataIterator. This property allows to control the thread pool size of the concurrent multi data iterator. Defaults to 10.

Note, this usually will map one to one to the number of open connections / cursors against the database.

setInitialLoadChunkSize

public void setInitialLoadChunkSize(int initalLoadChunkSize)

By default, the initial load process will chunk large tables and will iterate over the table (entity) per chunk (concurrently). This setting allows to control the chunk size to split the table by. By default, set to 100,000. Batching can be disabled by setting -1.

setUseScrollableResultSet

public void setUseScrollableResultSet(boolean useScrollableResultSet)

Controls if scrollable result sets will be used with initial load operation. Defaults to true.

setInitialLoadQueryScanningBasePackages

public void setInitialLoadQueryScanningBasePackages(String... initialLoadQueryScanningBasePackages)

See Also:

StatelessHibernateSpaceDataSourceConfigurer.initialLoadQueryScanningBasePackages(String[])

setClusterInfo

public void setClusterInfo(ClusterInfo clusterInfo)

Description copied from interface: ClusterInfoAware

Sets the cluster information.

Note, the cluster information is obtained externally from the application context which means that this feature need to be supported by specific containers (and is not supported by plain Spring application context). This means that beans that implement ClusterInfoAware should take into account the fact that the cluster info provided might be null.

Specified by:

setClusterInfo in interface ClusterInfoAware

Parameters:

clusterInfo - The cluster information to be injected

See Also:

StatelessHibernateSpaceDataSourceConfigurer.clusterInfo(org.openspaces.core.cluster.ClusterInfo)

setAugmentInitialLoadEntries

public void setAugmentInitialLoadEntries(boolean augmentInitialLoadEntries)

Feature switch for initial load entries augmentation (creation of partition-specific query for entries). Defaults to true.

getObject

public StatelessHibernateSpaceDataSource getObject()
                                            throws Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<StatelessHibernateSpaceDataSource>

Throws:

Exception

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<StatelessHibernateSpaceDataSource>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<StatelessHibernateSpaceDataSource>

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception