com.mulesoft.mule.runtime.module.cluster.internal.persistence

Class JdbcMapStore<T extends Serializable>

java.lang.Object

com.mulesoft.mule.runtime.module.cluster.internal.persistence.JdbcMapStore<T>

All Implemented Interfaces:

com.hazelcast.core.MapLoader<Serializable,T>, com.hazelcast.core.MapLoaderLifecycleSupport, com.hazelcast.core.MapStore<Serializable,T>

public class JdbcMapStore<T extends Serializable>
extends Object
implements com.hazelcast.core.MapStore<Serializable,T>, com.hazelcast.core.MapLoaderLifecycleSupport

Jdbc implementation of MapStore and MapLoader. It overrides all map operations for storing/retrieving/deleting objects to/from a database.

Field Summary

Fields

Modifier and Type	Field and Description
protected DataSource	datasource

Constructor Summary

Constructors

Constructor and Description
JdbcMapStore(DataSource datasource, String tableName, DatabaseStoreQueryBuilderStrategy databaseStoreQueryBuilderStrategy, org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol)

Method Summary

Modifier and Type	Method and Description
void	delete(Serializable key)
void	deleteAll(Collection<Serializable> collection)
void	destroy()
void	init(com.hazelcast.core.HazelcastInstance hazelcastInstance, Properties properties, String mapName)
T	load(Serializable key)
Map<Serializable,T>	loadAll(Collection<Serializable> keys)
List<Serializable>	loadAllKeys()
void	store(Serializable key, T value)
void	storeAll(Map<Serializable,T> map)

Methods inherited from class java.lang.Object

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

Field Detail

datasource

protected final DataSource datasource

Constructor Detail

JdbcMapStore

public JdbcMapStore(DataSource datasource,
                    String tableName,
                    DatabaseStoreQueryBuilderStrategy databaseStoreQueryBuilderStrategy,
                    org.mule.runtime.api.serialization.SerializationProtocol serializationProtocol)
             throws SQLException

Throws:

SQLException

Method Detail

load

public T load(Serializable key)

Specified by:

load in interface com.hazelcast.core.MapLoader<Serializable,T extends Serializable>

loadAll

public Map<Serializable,T> loadAll(Collection<Serializable> keys)

Specified by:

loadAll in interface com.hazelcast.core.MapLoader<Serializable,T extends Serializable>

See Also:

MapLoader.loadAll(java.util.Collection)

loadAllKeys

public List<Serializable> loadAllKeys()

Specified by:

loadAllKeys in interface com.hazelcast.core.MapLoader<Serializable,T extends Serializable>

See Also:

MapLoader.loadAllKeys()

store

public void store(Serializable key,
                  T value)

Specified by:

store in interface com.hazelcast.core.MapStore<Serializable,T extends Serializable>

See Also:

MapStore.store(java.lang.Object, java.lang.Object)

storeAll

public void storeAll(Map<Serializable,T> map)

Specified by:

storeAll in interface com.hazelcast.core.MapStore<Serializable,T extends Serializable>

See Also:

MapStore.storeAll(java.util.Map)

delete

public void delete(Serializable key)

Specified by:

delete in interface com.hazelcast.core.MapStore<Serializable,T extends Serializable>

See Also:

MapStore.delete(java.lang.Object)

deleteAll

public void deleteAll(Collection<Serializable> collection)

Specified by:

deleteAll in interface com.hazelcast.core.MapStore<Serializable,T extends Serializable>

See Also:

MapStore.deleteAll(java.util.Collection)

init

public void init(com.hazelcast.core.HazelcastInstance hazelcastInstance,
                 Properties properties,
                 String mapName)

Specified by:

init in interface com.hazelcast.core.MapLoaderLifecycleSupport

destroy

public void destroy()

Specified by:

destroy in interface com.hazelcast.core.MapLoaderLifecycleSupport