org.teiid.runtime

Class EmbeddedServer

java.lang.Object

org.teiid.runtime.AbstractVDBDeployer

org.teiid.runtime.EmbeddedServer

All Implemented Interfaces:

ConnectorManagerRepository.ExecutionFactoryProvider, EventDistributorFactory

public class EmbeddedServer
extends AbstractVDBDeployer
implements EventDistributorFactory, ConnectorManagerRepository.ExecutionFactoryProvider

A simplified server environment for embedded use. Needs to be started prior to use with a call to start(EmbeddedConfiguration)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	EmbeddedServer.ConnectionFactoryProvider<T>
protected class	EmbeddedServer.ProviderAwareConnectorManagerRepository
static class	EmbeddedServer.SimpleConnectionFactoryProvider<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected BufferServiceImpl	bufferService
protected ConnectorManagerRepository	cmr
protected DQPCore	dqp
protected AbstractEventDistributorFactoryService	eventDistributorFactoryService
protected LogonImpl	logon
protected ObjectReplicator	replicator
protected VDBRepository	repo Custom vdb repository that will immediately throw exceptions for metadata validation errors
protected ClientServiceRegistryImpl	services
protected SessionServiceImpl	sessionService
protected boolean	throwMetadataErrors
protected TransactionServerImpl	transactionService
protected ArrayList<SocketListener>	transports
protected boolean	useCallingThread
protected boolean	waitForLoad

Fields inherited from class org.teiid.runtime.AbstractVDBDeployer

repositories

Constructor Summary

Constructors

Constructor and Description
EmbeddedServer()

Method Summary

Modifier and Type	Method and Description
void	addConnectionFactory(String name, Object connectionFactory) Adds the object as the named connection factory to replace the default JNDI lookup strategy.
void	addConnectionFactoryProvider(String name, EmbeddedServer.ConnectionFactoryProvider<?> connectionFactoryProvider) Adds the EmbeddedServer.ConnectionFactoryProvider with the given connection name to replace the default JNDI lookup strategy.
void	addTranslator(Class<? extends ExecutionFactory> clazz) Adds a definition of the ExecutionFactory using the default name either from the Translator annotation or the class name.
void	addTranslator(String name, ExecutionFactory<?,?> ef) Add a named ExecutionFactory.
void	addTranslator(String name, String type, Map<String,String> properties) Add an override translator
protected boolean	allowOverrideTranslators()
static void	createPreParser(VDBMetaData deployment)
void	deployVDB(InputStream is) Deploy a vdb.xml file.
void	deployVDB(InputStream is, boolean ddl) Deploy a vdb.xml file.
void	deployVDB(String name, ModelMetaData... models) Deploy the given set of models as vdb name.1
protected void	deployVDB(VDBMetaData vdb, VDBResources resources)
void	deployVDBZip(URL url) Deploy a vdb zip file.
Admin	getAdmin()
protected BufferService	getBufferService()
protected EmbeddedConfiguration	getConfiguration()
protected ConcurrentHashMap<String,EmbeddedServer.ConnectionFactoryProvider<?>>	getConnectionFactoryProviders()
TeiidDriver	getDriver()
EventDistributor	getEventDistributor() Get an EventDistributor that will distribute events to all members.
ExecutionFactory<Object,Object>	getExecutionFactory(String name)
protected MaterializationManager	getMaterializationManager()
protected MetadataRepository<?,?>	getMetadataRepository(String repoType)
int	getPort(int transport) Return the bound port for the transport number
protected SessionAwareCache<PreparedPlan>	getPpcCache()
protected SessionAwareCache<CachedResults>	getRsCache()
String	getSchemaDdl(String vdbName, String schemaName) Get the effective ddl text for the given schema
protected TranslatorRepository	getTranslatorRepository()
protected VDBRepository	getVDBRepository()
protected void	loadMetadata(VDBMetaData vdb, ModelMetaData model, ConnectorManagerRepository cmr, MetadataRepository metadataRepository, MetadataStore store, AtomicInteger loadCount, VDBResources vdbResources) TODO: consolidate this logic more into the abstract deployer
void	start(EmbeddedConfiguration config)
void	stop() Stops the server.
void	undeployVDB(String vdbName)
void	undeployVDB(String vdbName, String version)

Methods inherited from class org.teiid.runtime.AbstractVDBDeployer

addMetadataRepository, assignMetadataRepositories, createMetadataFactory, getConnectorManagers, loadMetadata, metadataLoaded

Methods inherited from class java.lang.Object

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

Field Detail

dqp

protected DQPCore dqp

repo

protected VDBRepository repo

Custom vdb repository that will immediately throw exceptions for metadata validation errors

throwMetadataErrors

protected boolean throwMetadataErrors

sessionService

protected SessionServiceImpl sessionService

replicator

protected ObjectReplicator replicator

bufferService

protected BufferServiceImpl bufferService

transactionService

protected TransactionServerImpl transactionService

waitForLoad

protected boolean waitForLoad

services

protected ClientServiceRegistryImpl services

logon

protected LogonImpl logon

cmr

protected ConnectorManagerRepository cmr

eventDistributorFactoryService

protected AbstractEventDistributorFactoryService eventDistributorFactoryService

useCallingThread

protected boolean useCallingThread

transports

protected ArrayList<SocketListener> transports

Constructor Detail

EmbeddedServer

public EmbeddedServer()

Method Detail

addConnectionFactoryProvider

public void addConnectionFactoryProvider(String name,
                                         EmbeddedServer.ConnectionFactoryProvider<?> connectionFactoryProvider)

Adds the EmbeddedServer.ConnectionFactoryProvider with the given connection name to replace the default JNDI lookup strategy.

Parameters:

name -

connectionFactoryProvider -

See Also:

for a basic wrapper

addConnectionFactory

public void addConnectionFactory(String name,
                                 Object connectionFactory)

Adds the object as the named connection factory to replace the default JNDI lookup strategy.

Parameters:

name -

connectionFactory -

start

public void start(EmbeddedConfiguration config)

getBufferService

protected BufferService getBufferService()

getMaterializationManager

protected MaterializationManager getMaterializationManager()

addTranslator

public void addTranslator(Class<? extends ExecutionFactory> clazz)
                   throws TranslatorException

Adds a definition of the ExecutionFactory using the default name either from the Translator annotation or the class name. Only ExecutionFactory classes with a Translator annotation can be referenced by addTranslator(String, String, Map)

Parameters:

ef -

Throws:

TranslatorException

addTranslator

public void addTranslator(String name,
                          String type,
                          Map<String,String> properties)
                   throws TranslatorException

Add an override translator

Parameters:

name -

type - the name of an existing translator to override

properties -

Throws:

TranslatorException

addTranslator

public void addTranslator(String name,
                          ExecutionFactory<?,?> ef)

Add a named ExecutionFactory. NOTE: Only this single instance will be shared for all usage.

Parameters:

name -

ef - the already started ExecutionFactory

See Also:

#addTranslator(String, String, Map)} or {@link #addTranslator(Class)}

deployVDB

public void deployVDB(String name,
                      ModelMetaData... models)
               throws ConnectorManagerRepository.ConnectorManagerException,
                      VirtualDatabaseException,
                      TranslatorException

Deploy the given set of models as vdb name.1

Parameters:

name -

models -

Throws:

ConnectorManagerRepository.ConnectorManagerException

VirtualDatabaseException

TranslatorException

deployVDB

public void deployVDB(InputStream is)
               throws VirtualDatabaseException,
                      ConnectorManagerRepository.ConnectorManagerException,
                      TranslatorException,
                      IOException

Deploy a vdb.xml file. The name and version will be derived from the xml.

Parameters:

is, - which will be closed by this deployment

Throws:

TranslatorException

ConnectorManagerRepository.ConnectorManagerException

VirtualDatabaseException

IOException

deployVDB

public void deployVDB(InputStream is,
                      boolean ddl)
               throws VirtualDatabaseException,
                      ConnectorManagerRepository.ConnectorManagerException,
                      TranslatorException,
                      IOException

Deploy a vdb.xml file. The name and version will be derived from the xml.

Parameters:

is, - which will be closed by this deployment

ddl, - true if the file contents are DDL

Throws:

TranslatorException

ConnectorManagerRepository.ConnectorManagerException

VirtualDatabaseException

IOException

deployVDBZip

public void deployVDBZip(URL url)
                  throws VirtualDatabaseException,
                         ConnectorManagerRepository.ConnectorManagerException,
                         TranslatorException,
                         IOException,
                         URISyntaxException

Deploy a vdb zip file. The name and version will be derived from the xml.

Parameters:

url -

Throws:

TranslatorException

ConnectorManagerRepository.ConnectorManagerException

VirtualDatabaseException

URISyntaxException

IOException

allowOverrideTranslators

protected boolean allowOverrideTranslators()

deployVDB

protected void deployVDB(VDBMetaData vdb,
                         VDBResources resources)
                  throws ConnectorManagerRepository.ConnectorManagerException,
                         VirtualDatabaseException,
                         TranslatorException

Throws:

ConnectorManagerRepository.ConnectorManagerException

VirtualDatabaseException

TranslatorException

getMetadataRepository

protected MetadataRepository<?,?> getMetadataRepository(String repoType)
                                                 throws VirtualDatabaseException

Overrides:

getMetadataRepository in class AbstractVDBDeployer

Throws:

VirtualDatabaseException

loadMetadata

protected void loadMetadata(VDBMetaData vdb,
                            ModelMetaData model,
                            ConnectorManagerRepository cmr,
                            MetadataRepository metadataRepository,
                            MetadataStore store,
                            AtomicInteger loadCount,
                            VDBResources vdbResources)
                     throws TranslatorException

TODO: consolidate this logic more into the abstract deployer

Specified by:

loadMetadata in class AbstractVDBDeployer

Throws:

TranslatorException

undeployVDB

public void undeployVDB(String vdbName)

undeployVDB

public void undeployVDB(String vdbName,
                        String version)

getConfiguration

protected EmbeddedConfiguration getConfiguration()

stop

public void stop()

Stops the server. Once stopped it cannot be restarted.

getDriver

public TeiidDriver getDriver()

getEventDistributor

public EventDistributor getEventDistributor()

Description copied from interface: EventDistributorFactory

Get an EventDistributor that will distribute events to all members.

Specified by:

getEventDistributor in interface EventDistributorFactory

Returns:

getExecutionFactory

public ExecutionFactory<Object,Object> getExecutionFactory(String name)
                                                    throws ConnectorManagerRepository.ConnectorManagerException

Specified by:

getExecutionFactory in interface ConnectorManagerRepository.ExecutionFactoryProvider

Returns:

the named ExecutionFactory or throw a ConnectorManagerRepository.ConnectorManagerException if it does not exist

Throws:

ConnectorManagerRepository.ConnectorManagerException

getVDBRepository

protected VDBRepository getVDBRepository()

Specified by:

getVDBRepository in class AbstractVDBDeployer

getSchemaDdl

public String getSchemaDdl(String vdbName,
                           String schemaName)

Get the effective ddl text for the given schema

Parameters:

vdbName -

schemaName -

Returns:

the ddl or null if the vdb/schema does not exist

getPort

public int getPort(int transport)

Return the bound port for the transport number

Parameters:

transport -

Returns:

getTranslatorRepository

protected TranslatorRepository getTranslatorRepository()

getConnectionFactoryProviders

protected ConcurrentHashMap<String,EmbeddedServer.ConnectionFactoryProvider<?>> getConnectionFactoryProviders()

getRsCache

protected SessionAwareCache<CachedResults> getRsCache()

getPpcCache

protected SessionAwareCache<PreparedPlan> getPpcCache()

getAdmin

public Admin getAdmin()

createPreParser

public static void createPreParser(VDBMetaData deployment)
                            throws TeiidException

Throws:

TeiidException