org.teiid.resource.adapter.infinispan

Class InfinispanCacheRAConnection

java.lang.Object

org.teiid.resource.spi.BasicConnection

org.teiid.resource.adapter.infinispan.InfinispanCacheRAConnection

All Implemented Interfaces:

javax.resource.cci.Connection, InfinispanCacheConnection, ObjectConnection

public class InfinispanCacheRAConnection
extends BasicConnection
implements InfinispanCacheConnection

Author:

vanhalbert

Constructor Summary

Constructors

Constructor and Description
InfinispanCacheRAConnection(InfinispanManagedConnectionFactory config)

Method Summary

Modifier and Type	Method and Description
void	add(Object key, Object value) Call to add an object to the cache
void	close()
Object	get(Object key) Call to obtain an object from the cache based on the specified key
Collection<Object>	getAll() Call to obtain all the objects from the cache
Map<Object,Object>	getCache() Call to obtain the cache object
Class<?>	getCacheClassType() Returns root object class type that is defined for the cache.
Class<?>	getCacheKeyClassType() Returns the class type of the key to the cache.
String	getCacheName() Returns the name of the cache
ClassRegistry	getClassRegistry() Return the ClassRegistry that contains which classes and their methods.
protected InfinispanManagedConnectionFactory	getConfig()
Collection<Object>	getFirst(int limit) Call to obtain all the first number of objects based on limit
String	getPkField() Returns the name of the primary key to the cache
org.infinispan.query.dsl.QueryFactory	getQueryFactory() Call to return the QueryFactory that based on the type of Search used.
Object	remove(Object key) Call to remove an object from the cache
void	update(Object key, Object value) Call to update an object in the cache

Methods inherited from class org.teiid.resource.spi.BasicConnection

cleanUp, createInteraction, getLocalTransaction, getMetaData, getResultSetInfo, getXAResource, isAlive

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.teiid.translator.object.ObjectConnection

cleanUp, isAlive

Constructor Detail

InfinispanCacheRAConnection

public InfinispanCacheRAConnection(InfinispanManagedConnectionFactory config)

Method Detail

getConfig

protected InfinispanManagedConnectionFactory getConfig()

getCache

public Map<Object,Object> getCache()

Call to obtain the cache object

Specified by:

getCache in interface ObjectConnection

Returns:

Map object cache

See Also:

ObjectConnection.getCache()

getAll

public Collection<Object> getAll()

Call to obtain all the objects from the cache

Specified by:

getAll in interface ObjectConnection

Returns:

List of all the objects in the cache

See Also:

ObjectConnection.getAll()

getFirst

public Collection<Object> getFirst(int limit)

Call to obtain all the first number of objects based on limit

Specified by:

getFirst in interface ObjectConnection

Parameters:

limit - is the number of objects to return

Returns:

List of the objects to return

See Also:

ObjectConnection.getFirst(int)

getQueryFactory

public org.infinispan.query.dsl.QueryFactory getQueryFactory()
                                                      throws TranslatorException

Call to return the QueryFactory that based on the type of Search used.

Specified by:

getQueryFactory in interface InfinispanCacheConnection

Returns:

QueryFactory

Throws:

TranslatorException

See Also:

org.teiid.translator.infinispanCache.InfinispanCacheConnection#getQueryFactory()

getPkField

public String getPkField()

Returns the name of the primary key to the cache

Specified by:

getPkField in interface ObjectConnection

Returns:

String key name

See Also:

ObjectConnection.getPkField()

getCacheKeyClassType

public Class<?> getCacheKeyClassType()

Returns the class type of the key to the cache. If the primary key class type is different from the cache key type, then the value will be converted to the cache key class type before performing a get/put on the cache.

Specified by:

getCacheKeyClassType in interface ObjectConnection

Returns:

Class

See Also:

ObjectConnection.getCacheKeyClassType()

getCacheName

public String getCacheName()

Returns the name of the cache

Specified by:

getCacheName in interface ObjectConnection

Returns:

String cacheName

See Also:

ObjectConnection.getCacheName()

getCacheClassType

public Class<?> getCacheClassType()

Returns root object class type that is defined for the cache.

Specified by:

getCacheClassType in interface ObjectConnection

Returns:

Cache ClassType

See Also:

ObjectConnection.getCacheClassType()

add

public void add(Object key,
                Object value)
         throws TranslatorException

Call to add an object to the cache

Specified by:

add in interface ObjectConnection

Throws:

TranslatorException

See Also:

ObjectConnection.add(java.lang.Object, java.lang.Object)

remove

public Object remove(Object key)
              throws TranslatorException

Call to remove an object from the cache

Specified by:

remove in interface ObjectConnection

Returns:

Object that was removed

Throws:

TranslatorException

See Also:

ObjectConnection.remove(java.lang.Object)

update

public void update(Object key,
                   Object value)
            throws TranslatorException

Call to update an object in the cache

Specified by:

update in interface ObjectConnection

Throws:

TranslatorException

See Also:

ObjectConnection.update(java.lang.Object, java.lang.Object)

getClassRegistry

public ClassRegistry getClassRegistry()

Return the ClassRegistry that contains which classes and their methods.

Specified by:

getClassRegistry in interface ObjectConnection

Returns:

ClassRegistry

See Also:

ObjectConnection.getClassRegistry()

get

public Object get(Object key)
           throws TranslatorException

Call to obtain an object from the cache based on the specified key

Specified by:

get in interface ObjectConnection

Parameters:

key - to use to get the object from the cache

Returns:

Object

Throws:

TranslatorException

See Also:

ObjectConnection.get(java.lang.Object)

close

public void close()

Specified by:

close in interface javax.resource.cci.Connection

See Also:

Connection.close()