public class JdbcMixedCacheStore extends Object implements AdvancedLoadWriteStore
JdbcBinaryStore and JdbcStringBasedStore. It
aggregates an instance of JdbcBinaryStore and JdbcStringBasedStore, delegating work to one of them
(sometimes both, see below) based on the passed in key. In order to determine which store to use it will rely on the
configured Key2StringMapper )(see configuration).
The advantage it brings is the possibility of efficiently storing string(able) keyed InternalCacheEntrys, and at the same time being able to store any other keys, a la
JdbcBinaryStore.
There will only be a performance cost for the aggregate operations: loadAll, fromStream, toStream and clear. For
these operations there will be two distinct database call, one for each JdbcStore implementation. Most of application
are only using these operations at lifecycles changes (e.g. fromStream and toStream at cluster join time, loadAll at
startup for warm caches), so performance drawback shouldn't be significant (again, most of the cases).
Resource sharing - both aggregated cache loaders have locks and connection pools. The locking is not shared, each
loader keeping its own StripedLock instance. Also the tables (even though
similar as definition) are different in order to avoid key collision. On the other hand, the connection pooling is a
shared resource.JdbcBinaryStore,
JdbcStringBasedStoreAdvancedCacheLoader.CacheLoaderTask<K,V>, AdvancedCacheLoader.KeyFilter<K>, AdvancedCacheLoader.TaskContextAdvancedCacheWriter.PurgeListener<K>| Constructor and Description |
|---|
JdbcMixedCacheStore() |
| Modifier and Type | Method and Description |
|---|---|
void |
clear()
Removes all the data from the storage.
|
boolean |
contains(Object key)
Returns true if the storage contains an entry associated with the given key.
|
boolean |
delete(Object key) |
JdbcBinaryStore |
getBinaryStore() |
JdbcMixedStoreConfiguration |
getConfiguration() |
ConnectionFactory |
getConnectionFactory() |
JdbcStringBasedStore |
getStringStore() |
void |
init(InitializationContext ctx)
Used to initialize a cache loader.
|
MarshalledEntry |
load(Object key)
Fetches an entry from the storage.
|
void |
process(AdvancedCacheLoader.KeyFilter filter,
AdvancedCacheLoader.CacheLoaderTask task,
Executor executor,
boolean fetchValue,
boolean fetchMetadata)
Iterates in parallel over the entries in the storage using the threads from the executor pool.
|
void |
purge(Executor threadPool,
AdvancedCacheWriter.PurgeListener task)
Using the thread in the pool, removed all the expired data from the persistence storage.
|
int |
size()
Returns the number of elements in the store.
|
void |
start() |
void |
stop() |
void |
write(MarshalledEntry ed) |
public void init(InitializationContext ctx)
CacheLoaderPersistenceManager
when setting up cache loaders.init in interface CacheLoaderinit in interface CacheWriterpublic void purge(Executor threadPool, AdvancedCacheWriter.PurgeListener task)
AdvancedCacheWriterpurge in interface AdvancedCacheWriterpublic MarshalledEntry load(Object key)
CacheLoaderload in interface CacheLoaderpublic void process(AdvancedCacheLoader.KeyFilter filter, AdvancedCacheLoader.CacheLoaderTask task, Executor executor, boolean fetchValue, boolean fetchMetadata)
AdvancedCacheLoaderCacheLoaderTask#processEntry(MarshalledEntry, TaskContext) is invoked. Before passing an entry
to the callback task, the entry should be validated against the filter. The method should only return once
the iteration is complete.process in interface AdvancedCacheLoaderfilter - to validate which entries should be feed into the task. Might be null.task - callback to be invoked in parallel for each stored entry that passes the filter checkexecutor - a thread pool to be used for parallel iterationfetchValue - whether or not to fetch the value from the persistent store. E.g. if the iteration is
intended only over the key set, no point fetching the values from the persistent store as
wellfetchMetadata - whether or not to fetch the metadata from the persistent store. E.g. if the iteration is
intended only ove the key set, then no pint fetching the metadata from the persistent store
as wellpublic void write(MarshalledEntry ed)
write in interface CacheWriterpublic boolean delete(Object key)
delete in interface CacheWriterpublic int size()
AdvancedCacheLoadersize in interface AdvancedCacheLoaderpublic boolean contains(Object key)
CacheLoadercontains in interface CacheLoaderpublic void clear()
AdvancedCacheWriterclear in interface AdvancedCacheWriterpublic ConnectionFactory getConnectionFactory()
public JdbcBinaryStore getBinaryStore()
public JdbcStringBasedStore getStringStore()
public JdbcMixedStoreConfiguration getConfiguration()
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.