org.apache.ignite.cache.store.hibernate

Class CacheHibernateBlobStore<K,V>

java.lang.Object

org.apache.ignite.cache.store.CacheStoreAdapter<K,V>

org.apache.ignite.cache.store.hibernate.CacheHibernateBlobStore<K,V>

All Implemented Interfaces:

javax.cache.integration.CacheLoader<K,V>, javax.cache.integration.CacheWriter<K,V>, CacheStore<K,V>

public class CacheHibernateBlobStore<K,V>
extends CacheStoreAdapter<K,V>

CacheStore implementation backed by Hibernate. This implementation stores objects in underlying database in BLOB format.

Configuration

Either setSessionFactory(SessionFactory) or setHibernateConfigurationPath(String) or setHibernateProperties(Properties) should be set.

If session factory is provided it should contain CacheHibernateBlobStoreEntry persistent class (via provided mapping file GridCacheHibernateStoreEntry.hbm.xml or by adding CacheHibernateBlobStoreEntry to annotated classes of session factory.

Path to hibernate configuration may be either an URL or a file path or a classpath resource. This configuration file should include provided mapping GridCacheHibernateStoreEntry.hbm.xml or include annotated class CacheHibernateBlobStoreEntry.

If hibernate properties are provided, mapping GridCacheHibernateStoreEntry.hbm.xml is included automatically.

Use CacheHibernateBlobStoreFactory factory to pass CacheHibernateBlobStore to CacheConfiguration.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DFLT_CONN_POOL_SIZE Default hibernate.connection.pool_size property value (value is 64).
static String	DFLT_CONN_URL Default connection URL (value is jdbc:gg-h2:mem:hibernateCacheStore;DB_CLOSE_DELAY=-1;DEFAULT_LOCK_TIMEOUT=5000).
static String	DFLT_HBM2DDL_AUTO Default hibernate.hbm2ddl.auto property value (value is true).
static String	DFLT_SHOW_SQL Default show SQL property value (value is true).

Constructor Summary

Constructors

Constructor and Description
CacheHibernateBlobStore()

Method Summary

Modifier and Type	Method and Description
void	delete(Object key)
protected <X> X	fromBytes(byte[] bytes) Deserialize object from byte array using marshaller.
V	load(K key)
void	sessionEnd(boolean commit) Default empty implementation for ending transactions.
void	setHibernateConfigurationPath(String hibernateCfgPath) Sets hibernate configuration path.
void	setHibernateProperties(Properties hibernateProps) Sets Hibernate properties.
void	setSessionFactory(org.hibernate.SessionFactory sesFactory) Sets session factory.
protected byte[]	toBytes(Object obj) Serialize object to byte array using marshaller.
String	toString()
void	write(javax.cache.Cache.Entry<? extends K,? extends V> entry)

Methods inherited from class org.apache.ignite.cache.store.CacheStoreAdapter

deleteAll, loadAll, loadCache, writeAll

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_CONN_URL

public static final String DFLT_CONN_URL

Default connection URL (value is jdbc:gg-h2:mem:hibernateCacheStore;DB_CLOSE_DELAY=-1;DEFAULT_LOCK_TIMEOUT=5000).

See Also:

Constant Field Values

DFLT_SHOW_SQL

public static final String DFLT_SHOW_SQL

Default show SQL property value (value is true).

See Also:

Constant Field Values

DFLT_HBM2DDL_AUTO

public static final String DFLT_HBM2DDL_AUTO

Default hibernate.hbm2ddl.auto property value (value is true).

See Also:

Constant Field Values

DFLT_CONN_POOL_SIZE

public static final String DFLT_CONN_POOL_SIZE

Default hibernate.connection.pool_size property value (value is 64).

See Also:

Constant Field Values

Constructor Detail

CacheHibernateBlobStore

public CacheHibernateBlobStore()

Method Detail

load

public V load(K key)

write

public void write(javax.cache.Cache.Entry<? extends K,? extends V> entry)

delete

public void delete(Object key)

sessionEnd

public void sessionEnd(boolean commit)

Default empty implementation for ending transactions. Note that if explicit cache transactions are not used, then transactions do not have to be explicitly ended - for all other cases this method should be overridden with custom commit/rollback logic.

Specified by:

sessionEnd in interface CacheStore<K,V>

Overrides:

sessionEnd in class CacheStoreAdapter<K,V>

Parameters:

commit - True if transaction should commit, false for rollback.

setSessionFactory

public void setSessionFactory(org.hibernate.SessionFactory sesFactory)

Sets session factory.

Parameters:

sesFactory - Session factory.

setHibernateConfigurationPath

public void setHibernateConfigurationPath(String hibernateCfgPath)

Sets hibernate configuration path.

This may be either URL or file path or classpath resource.

Parameters:

hibernateCfgPath - URL or file path or classpath resource pointing to hibernate configuration XML file.

setHibernateProperties

public void setHibernateProperties(Properties hibernateProps)

Sets Hibernate properties.

Parameters:

hibernateProps - Hibernate properties.

toString

public String toString()

Overrides:

toString in class CacheStoreAdapter<K,V>

toBytes

protected byte[] toBytes(Object obj)
                  throws IgniteCheckedException

Serialize object to byte array using marshaller.

Parameters:

obj - Object to convert to byte array.

Returns:

Byte array.

Throws:

IgniteCheckedException - If failed to convert.

fromBytes

protected <X> X fromBytes(byte[] bytes)
                   throws IgniteCheckedException

Deserialize object from byte array using marshaller.

Type Parameters:

X - Result object type.

Parameters:

bytes - Bytes to deserialize.

Returns:

Deserialized object.

Throws:

IgniteCheckedException - If failed.