org.teiid.resource.adapter.infinispan.base

Class InfinispanConnectionImpl

java.lang.Object

org.teiid.resource.spi.BasicConnection

org.teiid.resource.adapter.infinispan.base.InfinispanConnectionImpl

All Implemented Interfaces:

javax.resource.cci.Connection, ObjectConnection

public class InfinispanConnectionImpl
extends BasicConnection
implements ObjectConnection

Represents a connection to an Infinispan cache container. The cacheName that is specified will dictate the cache to be accessed in the container.

Constructor Summary

Constructors

Constructor and Description
InfinispanConnectionImpl(AbstractInfinispanManagedConnectionFactory config)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the connection, if a connection requires closing.
CacheContainerWrapper	getCacheContainer()
Map<String,Class<?>>	getCacheNameClassTypeMapping() Returns a map of all defined caches, and their respective root object class type, that are accessible using this connection.
String	getPkField(String cacheName) Returns the name of the primary key to the cache
Class<?>	getType(String cacheName) Return the root class type stored in the specified cache
boolean	isAlive() Will return true if the CacheContainer has been started.

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

cleanUp, createInteraction, getLocalTransaction, getMetaData, getResultSetInfo, getXAResource

Methods inherited from class java.lang.Object

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

Constructor Detail

InfinispanConnectionImpl

public InfinispanConnectionImpl(AbstractInfinispanManagedConnectionFactory config)

Method Detail

getCacheContainer

public CacheContainerWrapper getCacheContainer()
                                        throws TranslatorException

Specified by:

getCacheContainer in interface ObjectConnection

Throws:

TranslatorException

close

public void close()

Close the connection, if a connection requires closing. (non-Javadoc)

Specified by:

close in interface javax.resource.cci.Connection

isAlive

public boolean isAlive()

Will return true if the CacheContainer has been started.

Overrides:

isAlive in class BasicConnection

Returns:

boolean true if CacheContainer has been started

getType

public Class<?> getType(String cacheName)
                 throws TranslatorException

Description copied from interface: ObjectConnection

Return the root class type stored in the specified cache

Specified by:

getType in interface ObjectConnection

Throws:

TranslatorException

getPkField

public String getPkField(String cacheName)

Description copied from interface: ObjectConnection

Returns the name of the primary key to the cache

Specified by:

getPkField in interface ObjectConnection

Returns:

String key name

getCacheNameClassTypeMapping

public Map<String,Class<?>> getCacheNameClassTypeMapping()

Description copied from interface: ObjectConnection

Returns a map of all defined caches, and their respective root object class type, that are accessible using this connection.

Specified by:

getCacheNameClassTypeMapping in interface ObjectConnection

Returns:

Map --> CacheName, ClassType