org.infinispan.loaders.jdbc.binary
public class JdbcBinaryCacheStore extends org.infinispan.loaders.bucket.BucketBasedCacheStore
BucketBasedCacheStore
implementation that will store all the buckets as rows in database, each row
corresponding to a bucket. This is in contrast to JdbcStringBasedCacheStore
which stores each StoredEntry as a row in the database.
It is generally recommended to use JdbcStringBasedCacheStore
whenever
possible as it performs better. Please read JdbcStringBasedCacheStore
's
javadoc for more details on this.
This class has the benefit of being able to store StoredEntries that do not have String keys, at the cost of coarser
grained access granularity, and inherently performance.
All the DB related configurations are described in JdbcBinaryCacheStoreConfig
.JdbcBinaryCacheStoreConfig
,
JdbcStringBasedCacheStore
Constructor and Description |
---|
JdbcBinaryCacheStore() |
Modifier and Type | Method and Description |
---|---|
protected void |
clearLockSafe() |
void |
doConnectionFactoryInitialization(ConnectionFactory connectionFactory)
Keeps a reference to the connection factory for further use.
|
protected void |
fromStreamLockSafe(ObjectInput objectInput) |
Class<? extends org.infinispan.loaders.CacheLoaderConfig> |
getConfigurationClass() |
ConnectionFactory |
getConnectionFactory() |
protected org.infinispan.marshall.StreamingMarshaller |
getMarshaller() |
TableManipulation |
getTableManipulation() |
void |
init(org.infinispan.loaders.CacheLoaderConfig config,
org.infinispan.Cache<?,?> cache,
org.infinispan.marshall.StreamingMarshaller m) |
protected void |
insertBucket(org.infinispan.loaders.bucket.Bucket bucket) |
Set<Object> |
loadAllKeys(Set<Object> keysToExclude) |
Set<org.infinispan.container.entries.InternalCacheEntry> |
loadAllLockSafe() |
protected org.infinispan.loaders.bucket.Bucket |
loadBucket(Integer keyHashCode) |
protected Set<org.infinispan.container.entries.InternalCacheEntry> |
loadLockSafe(int maxEntries) |
protected void |
loopOverBuckets(org.infinispan.loaders.bucket.BucketBasedCacheStore.BucketHandler handler) |
void |
purgeInternal() |
void |
start() |
void |
stop() |
protected void |
toStreamLockSafe(ObjectOutput objectOutput) |
protected void |
updateBucket(org.infinispan.loaders.bucket.Bucket bucket) |
getLockFromKey, loadAllKeysLockSafe, loadLockSafe, removeLockSafe, storeLockSafe
acquireGlobalLock, clear, downgradeLock, fromStream, getTotalLockCount, immediateLockForWriting, load, load, loadAll, lockForReading, lockForWriting, releaseGlobalLock, remove, store, toStream, unlock, upgradeLock
applyModifications, commit, getCacheStoreConfig, getConcurrencyLevel, prepare, purgeExpired, removeAll, rollback, safeClose, safeClose, supportsMultiThreadedPurge
public void init(org.infinispan.loaders.CacheLoaderConfig config, org.infinispan.Cache<?,?> cache, org.infinispan.marshall.StreamingMarshaller m) throws org.infinispan.loaders.CacheLoaderException
init
in interface org.infinispan.loaders.CacheLoader
init
in class org.infinispan.loaders.LockSupportCacheStore<Integer>
org.infinispan.loaders.CacheLoaderException
public void start() throws org.infinispan.loaders.CacheLoaderException
start
in interface org.infinispan.loaders.CacheLoader
start
in class org.infinispan.loaders.LockSupportCacheStore<Integer>
org.infinispan.loaders.CacheLoaderException
public void stop() throws org.infinispan.loaders.CacheLoaderException
stop
in interface org.infinispan.loaders.CacheLoader
stop
in class org.infinispan.loaders.AbstractCacheStore
org.infinispan.loaders.CacheLoaderException
protected void insertBucket(org.infinispan.loaders.bucket.Bucket bucket) throws org.infinispan.loaders.CacheLoaderException
insertBucket
in class org.infinispan.loaders.bucket.BucketBasedCacheStore
org.infinispan.loaders.CacheLoaderException
protected void updateBucket(org.infinispan.loaders.bucket.Bucket bucket) throws org.infinispan.loaders.CacheLoaderException
updateBucket
in class org.infinispan.loaders.bucket.BucketBasedCacheStore
org.infinispan.loaders.CacheLoaderException
protected org.infinispan.loaders.bucket.Bucket loadBucket(Integer keyHashCode) throws org.infinispan.loaders.CacheLoaderException
loadBucket
in class org.infinispan.loaders.bucket.BucketBasedCacheStore
org.infinispan.loaders.CacheLoaderException
public Set<org.infinispan.container.entries.InternalCacheEntry> loadAllLockSafe() throws org.infinispan.loaders.CacheLoaderException
loadAllLockSafe
in class org.infinispan.loaders.bucket.BucketBasedCacheStore
org.infinispan.loaders.CacheLoaderException
public Set<Object> loadAllKeys(Set<Object> keysToExclude) throws org.infinispan.loaders.CacheLoaderException
loadAllKeys
in interface org.infinispan.loaders.CacheLoader
loadAllKeys
in class org.infinispan.loaders.LockSupportCacheStore<Integer>
org.infinispan.loaders.CacheLoaderException
protected Set<org.infinispan.container.entries.InternalCacheEntry> loadLockSafe(int maxEntries) throws org.infinispan.loaders.CacheLoaderException
loadLockSafe
in class org.infinispan.loaders.bucket.BucketBasedCacheStore
org.infinispan.loaders.CacheLoaderException
protected void loopOverBuckets(org.infinispan.loaders.bucket.BucketBasedCacheStore.BucketHandler handler) throws org.infinispan.loaders.CacheLoaderException
loopOverBuckets
in class org.infinispan.loaders.bucket.BucketBasedCacheStore
org.infinispan.loaders.CacheLoaderException
protected void fromStreamLockSafe(ObjectInput objectInput) throws org.infinispan.loaders.CacheLoaderException
fromStreamLockSafe
in class org.infinispan.loaders.LockSupportCacheStore<Integer>
org.infinispan.loaders.CacheLoaderException
protected void toStreamLockSafe(ObjectOutput objectOutput) throws org.infinispan.loaders.CacheLoaderException
toStreamLockSafe
in class org.infinispan.loaders.LockSupportCacheStore<Integer>
org.infinispan.loaders.CacheLoaderException
protected void clearLockSafe() throws org.infinispan.loaders.CacheLoaderException
clearLockSafe
in class org.infinispan.loaders.LockSupportCacheStore<Integer>
org.infinispan.loaders.CacheLoaderException
public void purgeInternal() throws org.infinispan.loaders.CacheLoaderException
purgeInternal
in class org.infinispan.loaders.AbstractCacheStore
org.infinispan.loaders.CacheLoaderException
public Class<? extends org.infinispan.loaders.CacheLoaderConfig> getConfigurationClass()
public ConnectionFactory getConnectionFactory()
public void doConnectionFactoryInitialization(ConnectionFactory connectionFactory) throws org.infinispan.loaders.CacheLoaderException
TableManipulation
that needs connections. This method should be called when you don't
want the store to manage the connection factory, perhaps because it is using an shared connection factory: see
JdbcMixedCacheStore
for such an example of this.org.infinispan.loaders.CacheLoaderException
public TableManipulation getTableManipulation()
protected org.infinispan.marshall.StreamingMarshaller getMarshaller()
getMarshaller
in class org.infinispan.loaders.AbstractCacheStore
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.