org.infinispan.loaders.jdbc
public abstract class DataManipulationHelper extends Object
JdbcStringBasedCacheStore
and JdbcBinaryCacheStore
. This class implements GOF's template method pattern.Modifier and Type | Field and Description |
---|---|
protected org.infinispan.marshall.StreamingMarshaller |
marshaller |
Constructor and Description |
---|
DataManipulationHelper(ConnectionFactory connectionFactory,
TableManipulation tableManipulation,
org.infinispan.marshall.StreamingMarshaller marshaller) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
protected abstract boolean |
fromStreamProcess(Object objFromStream,
PreparedStatement ps,
ObjectInput objectInput) |
void |
fromStreamSupport(ObjectInput objectInput) |
protected abstract String |
getLoadAllKeysSql() |
protected boolean |
includeKey(Object key,
Set<Object> keysToExclude) |
protected abstract void |
loadAllKeysProcess(ResultSet rs,
Set<Object> keys,
Set<Object> keysToExclude) |
Set<Object> |
loadAllKeysSupport(Set<Object> keysToExclude) |
protected abstract void |
loadAllProcess(ResultSet rs,
Set<org.infinispan.container.entries.InternalCacheEntry> result) |
protected abstract void |
loadAllProcess(ResultSet rs,
Set<org.infinispan.container.entries.InternalCacheEntry> result,
int maxEntries) |
Set<org.infinispan.container.entries.InternalCacheEntry> |
loadAllSupport(boolean filterExpired) |
Set<org.infinispan.container.entries.InternalCacheEntry> |
loadSome(int maxEntries) |
protected abstract void |
toStreamProcess(ResultSet rs,
InputStream is,
ObjectOutput objectOutput) |
void |
toStreamSupport(ObjectOutput objectOutput,
byte streamDelimiter,
boolean filterExpired) |
public DataManipulationHelper(ConnectionFactory connectionFactory, TableManipulation tableManipulation, org.infinispan.marshall.StreamingMarshaller marshaller)
public void clear() throws org.infinispan.loaders.CacheLoaderException
org.infinispan.loaders.CacheLoaderException
public final void fromStreamSupport(ObjectInput objectInput) throws org.infinispan.loaders.CacheLoaderException
org.infinispan.loaders.CacheLoaderException
public final void toStreamSupport(ObjectOutput objectOutput, byte streamDelimiter, boolean filterExpired) throws org.infinispan.loaders.CacheLoaderException
org.infinispan.loaders.CacheLoaderException
public final Set<org.infinispan.container.entries.InternalCacheEntry> loadAllSupport(boolean filterExpired) throws org.infinispan.loaders.CacheLoaderException
org.infinispan.loaders.CacheLoaderException
public Set<Object> loadAllKeysSupport(Set<Object> keysToExclude) throws org.infinispan.loaders.CacheLoaderException
org.infinispan.loaders.CacheLoaderException
public final Set<org.infinispan.container.entries.InternalCacheEntry> loadSome(int maxEntries) throws org.infinispan.loaders.CacheLoaderException
org.infinispan.loaders.CacheLoaderException
protected abstract String getLoadAllKeysSql()
protected abstract void loadAllProcess(ResultSet rs, Set<org.infinispan.container.entries.InternalCacheEntry> result) throws SQLException, org.infinispan.loaders.CacheLoaderException
SQLException
org.infinispan.loaders.CacheLoaderException
protected abstract void loadAllProcess(ResultSet rs, Set<org.infinispan.container.entries.InternalCacheEntry> result, int maxEntries) throws SQLException, org.infinispan.loaders.CacheLoaderException
SQLException
org.infinispan.loaders.CacheLoaderException
protected abstract void loadAllKeysProcess(ResultSet rs, Set<Object> keys, Set<Object> keysToExclude) throws SQLException, org.infinispan.loaders.CacheLoaderException
SQLException
org.infinispan.loaders.CacheLoaderException
protected abstract void toStreamProcess(ResultSet rs, InputStream is, ObjectOutput objectOutput) throws org.infinispan.loaders.CacheLoaderException, SQLException, IOException
org.infinispan.loaders.CacheLoaderException
SQLException
IOException
protected abstract boolean fromStreamProcess(Object objFromStream, PreparedStatement ps, ObjectInput objectInput) throws SQLException, org.infinispan.loaders.CacheLoaderException, IOException, ClassNotFoundException, InterruptedException
SQLException
org.infinispan.loaders.CacheLoaderException
IOException
ClassNotFoundException
InterruptedException
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.