com.metamatrix.dqp.embedded.admin
Class DQPConfigAdminImpl

java.lang.Object
  extended by com.metamatrix.dqp.embedded.admin.DQPConfigAdminImpl
All Implemented Interfaces:
ConfigurationAdmin

public class DQPConfigAdminImpl
extends java.lang.Object
implements ConfigurationAdmin

DQP implementation of the Config Admin API

Since:
4.3

Constructor Summary
DQPConfigAdminImpl(EmbeddedConnectionFactoryImpl manager)
           
 
Method Summary
protected  AdminException accumulateProcessingException(AdminException parent, java.lang.Exception e)
           
protected  AdminException accumulateSystemException(AdminException parent, java.lang.Exception e)
           
 void addConnectorArchive(byte[] contents, AdminOptions options)
          Add Connector Type and all the required extension modules required by the this connector type into the system from the given file byte stream which is encoded inthe Connector Archive format.
 ConnectorBinding addConnectorBinding(java.lang.String deployName, char[] xmlFile, AdminOptions options)
          Import a ConnectorBinding into the Configuration.
 ConnectorBinding addConnectorBinding(java.lang.String deployName, java.lang.String type, java.util.Properties properties, AdminOptions options)
          Deploy a ConnectorBinding to Configuration
 void addConnectorType(java.lang.String deployName, char[] cdkFile)
          Add Connector Type, will import Connector Type from a file
 void addExtensionModule(java.lang.String type, java.lang.String sourceName, byte[] source, java.lang.String description)
          Adds an ExtensionModule to the end of the list of modules.
 void addUDF(byte[] modelFileContents, java.lang.String classpath)
          Add User Defined Function model to the system.
 VDB addVDB(java.lang.String deployName, byte[] vdbFile, AdminOptions options)
          Import a VDB file.
 void assignBindingsToModel(java.lang.String[] deployedConnectorBindingName, java.lang.String vdbName, java.lang.String vdbVersion, java.lang.String modelName)
           
 void assignBindingToModel(java.lang.String deployedConnectorBindingName, java.lang.String vdbName, java.lang.String vdbVersion, java.lang.String modelName)
          Assign a ConnectorBinding to a VDB's Model
protected  void changeVDBStatus(java.lang.String name, java.lang.String version, int status)
           
protected  java.util.Collection convertPropertyDefinitions(ComponentType ctype, java.util.Properties properties)
          Convert a ComponentType and a set of properties into a Collection of com.metamatrix.admin.api.objects.PropertyDefinition objects
protected  java.util.Collection convertPropertyDefinitions(java.util.Properties properties)
          Convert a set of properties into a Collection of com.metamatrix.admin.api.objects.PropertyDefinition objects
protected  java.lang.Object convertToAdminObjects(java.lang.Object src)
           
protected  java.lang.Object convertToAdminObjects(java.lang.Object src, java.lang.Object parent)
           
 void deleteConnectorBinding(java.lang.String identifier)
          Delete the ConnectorBinding from the Configuration
 void deleteConnectorType(java.lang.String deployName)
          Delete Connector Type from Next Configuration
 void deleteExtensionModule(java.lang.String sourceName)
          Deletes an ExtensionModule from the list of modules.
 void deleteUDF()
          Delete the User Defined Function model.
 void deleteVDB(java.lang.String vdbName, java.lang.String vdbVersion)
          Delete the VDB with the given name and version
 char[] exportConfiguration()
          Export Configuration to character Array in XML format
 byte[] exportConnectorArchive(java.lang.String identifier)
          Export Connector Archive, which is bundled connector type with its xml properties file and all the extension modules required by the this connector type
 char[] exportConnectorBinding(java.lang.String identifier)
          Export a ConnectorBinding to character Array in XML format
 char[] exportConnectorType(java.lang.String identifier)
          Export Connector Type to character array
 byte[] exportExtensionModule(java.lang.String sourceName)
          Export an ExtensionModule to byte array
 byte[] exportVDB(java.lang.String name, java.lang.String version)
          Export VDB to byte array
 void extensionModuleModified(java.lang.String name)
          Indicates that an extension module has changed
 LogConfiguration getLogConfiguration()
          Get the LogConfiguration
 EmbeddedConnectionFactoryImpl getManager()
           
protected  java.lang.String prettyPrintBindingNames(java.util.List bindings)
           
 void setConnectorBindingProperty(java.lang.String deployedName, java.lang.String propertyName, java.lang.String propertyValue)
          Set/update the property for the Connector Binding identified by the given deployed name.
 void setLogConfiguration(LogConfiguration config)
          Set the LogConfiguration in the MetaMatrix Server
 void setLogListener(EmbeddedLogger listener)
          Set the log listener to install into MM Query.
 void setProcessProperty(java.lang.String processIdentifier, java.lang.String propertyName, java.lang.String propertyValue)
          Set a process level property.
protected  SessionToken validateSession()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DQPConfigAdminImpl

public DQPConfigAdminImpl(EmbeddedConnectionFactoryImpl manager)
Method Detail

setConnectorBindingProperty

public void setConnectorBindingProperty(java.lang.String deployedName,
                                        java.lang.String propertyName,
                                        java.lang.String propertyValue)
                                 throws AdminException
Description copied from interface: ConfigurationAdmin
Set/update the property for the Connector Binding identified by the given deployed name.

Specified by:
setConnectorBindingProperty in interface ConfigurationAdmin
Throws:
AdminException
Since:
4.3
See Also:
org.teiid.adminapi.ConfigurationAdmin#setProperty(java.lang.String, java.lang.String, java.lang.String, java.lang.String)

addConnectorType

public void addConnectorType(java.lang.String deployName,
                             char[] cdkFile)
                      throws AdminException
Description copied from interface: ConfigurationAdmin
Add Connector Type, will import Connector Type from a file

Specified by:
addConnectorType in interface ConfigurationAdmin
Parameters:
deployName - of the Connector Type to add
cdkFile - contents of File from Client
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.addConnectorType(java.lang.String, char[])

deleteConnectorType

public void deleteConnectorType(java.lang.String deployName)
                         throws AdminException
Description copied from interface: ConfigurationAdmin
Delete Connector Type from Next Configuration

Specified by:
deleteConnectorType in interface ConfigurationAdmin
Parameters:
deployName - String name of the Connector Type to delete
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.deleteConnectorType(java.lang.String)

addConnectorBinding

public ConnectorBinding addConnectorBinding(java.lang.String deployName,
                                            java.lang.String type,
                                            java.util.Properties properties,
                                            AdminOptions options)
                                     throws AdminException
Description copied from interface: ConfigurationAdmin
Deploy a ConnectorBinding to Configuration

Specified by:
addConnectorBinding in interface ConfigurationAdmin
Parameters:
deployName - is the Connector Binding name that will be added to Configuration
type - Name of the Connector Type
properties - Name & Value pair need to deploy the Connector Binding
options - The perferred options when executing this method. There are choices about what to do when a connector binding with the given identifier already exists in the system. See the interface AdminOptions.OnConflict for details.

Another option is to ignore a binding connection password decrypt error, when adding a connector binding whose password was encrypted with a different keystore, so that the new password property can be set after the connector binding has been added.

Returns:
the ConnectorBinding representing the current property values and runtime state. Note that if this is a system with multiple Processes, this method may actually create multiple deployed Connector Bindings (one for each process). This method will return one of them, arbitrarily.
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.addConnectorBinding(java.lang.String, java.lang.String, java.util.Properties, AdminOptions)

addConnectorBinding

public ConnectorBinding addConnectorBinding(java.lang.String deployName,
                                            char[] xmlFile,
                                            AdminOptions options)
                                     throws AdminException
Description copied from interface: ConfigurationAdmin
Import a ConnectorBinding into the Configuration.

Specified by:
addConnectorBinding in interface ConfigurationAdmin
Parameters:
deployName - is the Connector Binding name that will be added to Configuration
xmlFile - contents of XML file that will be sent to the server.
options - The perferred options when executing this method. There are choices about what to do when a connector binding with the given identifier already exists in the system. See the interface AdminOptions.OnConflict for details.

Another option is to ignore a binding connection password decrypt error, when adding a connector binding whose password was encrypted with a different keystore, so that the new password property can be set after the connector binding has been added.

Returns:
the ConnectorBinding representing the current property values and runtime state. Note that if this is a system with multiple Processes, this method may actually create multiple deployed Connector Bindings (one for each process). This method will return one of them, arbitrarily.
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.addConnectorBinding(java.lang.String, char[], AdminOptions)

deleteConnectorBinding

public void deleteConnectorBinding(java.lang.String identifier)
                            throws AdminException
Description copied from interface: ConfigurationAdmin
Delete the ConnectorBinding from the Configuration

Specified by:
deleteConnectorBinding in interface ConfigurationAdmin
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.deleteConnectorBinding(java.lang.String)

addVDB

public VDB addVDB(java.lang.String deployName,
                  byte[] vdbFile,
                  AdminOptions options)
           throws AdminException
Description copied from interface: ConfigurationAdmin
Import a VDB file.
A VDB file with internal definitions. Thise is the default VDB export configuration begining with MetaMatrix version 4.3.

Specified by:
addVDB in interface ConfigurationAdmin
Parameters:
deployName - VDB Name
vdbFile - byte array of the VDB Archive
options - The perferred options when executing this method. There are choices about what to do when a connector binding with the given identifier already exists in the system.
Returns:
the VDB representing the current property values and runtime state.
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.addVDB(java.lang.String, byte[], AdminOptions)

deleteVDB

public void deleteVDB(java.lang.String vdbName,
                      java.lang.String vdbVersion)
               throws AdminException
Description copied from interface: ConfigurationAdmin
Delete the VDB with the given name and version

Specified by:
deleteVDB in interface ConfigurationAdmin
Throws:
AdminException

addExtensionModule

public void addExtensionModule(java.lang.String type,
                               java.lang.String sourceName,
                               byte[] source,
                               java.lang.String description)
                        throws AdminException
Description copied from interface: ConfigurationAdmin
Adds an ExtensionModule to the end of the list of modules.
All caches (of Class objects) are cleared.

Specified by:
addExtensionModule in interface ConfigurationAdmin
Parameters:
type - one of the known types of extension file
sourceName - name (e.g. filename) of extension module
source - actual contents of module
description - (optional) description of the extension module - may be null
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.addExtensionModule(java.lang.String, java.lang.String, byte[], java.lang.String)

deleteExtensionModule

public void deleteExtensionModule(java.lang.String sourceName)
                           throws AdminException
Description copied from interface: ConfigurationAdmin
Deletes an ExtensionModule from the list of modules.
All caches (of Class objects) are cleared.

Specified by:
deleteExtensionModule in interface ConfigurationAdmin
Parameters:
sourceName - name (e.g. filename) of extension module
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.deleteExtensionModule(java.lang.String)

assignBindingToModel

public void assignBindingToModel(java.lang.String deployedConnectorBindingName,
                                 java.lang.String vdbName,
                                 java.lang.String vdbVersion,
                                 java.lang.String modelName)
                          throws AdminException
Description copied from interface: ConfigurationAdmin
Assign a ConnectorBinding to a VDB's Model

Specified by:
assignBindingToModel in interface ConfigurationAdmin
Parameters:
deployedConnectorBindingName - Name of the ConnectorBinding
vdbName - Name of the VDB
vdbVersion - Version of the VDB
modelName - Name of the Model to map Connector Binding
Throws:
AdminException - if there's a system error or if there's a user input error.
Since:
4.3
See Also:
ConfigurationAdmin.assignBindingToModel(java.lang.String, java.lang.String, java.lang.String, java.lang.String)

assignBindingsToModel

public void assignBindingsToModel(java.lang.String[] deployedConnectorBindingName,
                                  java.lang.String vdbName,
                                  java.lang.String vdbVersion,
                                  java.lang.String modelName)
                           throws AdminException
Specified by:
assignBindingsToModel in interface ConfigurationAdmin
Throws:
AdminException

getLogConfiguration

public LogConfiguration getLogConfiguration()
                                     throws AdminException
Description copied from interface: ConfigurationAdmin
Get the LogConfiguration

Specified by:
getLogConfiguration in interface ConfigurationAdmin
Returns:
LogConfiguration object
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.getLogConfiguration()

setLogConfiguration

public void setLogConfiguration(LogConfiguration config)
                         throws AdminException
Description copied from interface: ConfigurationAdmin
Set the LogConfiguration in the MetaMatrix Server

Specified by:
setLogConfiguration in interface ConfigurationAdmin
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.setLogConfiguration(org.teiid.adminapi.LogConfiguration)

setLogListener

public void setLogListener(EmbeddedLogger listener)
                    throws AdminException
Description copied from interface: ConfigurationAdmin
Set the log listener to install into MM Query. This log listener will receive all log messages written by the MM Query at it's current log level and log contexts. Note: Logging changes are not persistent. This will be fixed in future versions.

Specified by:
setLogListener in interface ConfigurationAdmin
Parameters:
listener - The listener component
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
com.metamatrix.admin.api.embedded.EmbeddedRuntimeStateAdmin#setLogListener(java.lang.Object)

exportExtensionModule

public byte[] exportExtensionModule(java.lang.String sourceName)
                             throws AdminException
Description copied from interface: ConfigurationAdmin
Export an ExtensionModule to byte array

Specified by:
exportExtensionModule in interface ConfigurationAdmin
Parameters:
sourceName - unique identifier for the ExtensionModule.
Returns:
byte array of the extension module
Throws:
AdminException
Since:
4.3
See Also:
ConfigurationAdmin.exportExtensionModule(java.lang.String)

exportConfiguration

public char[] exportConfiguration()
                           throws AdminException
Description copied from interface: ConfigurationAdmin
Export Configuration to character Array in XML format

Specified by:
exportConfiguration in interface ConfigurationAdmin
Returns:
character array of Configuration
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.exportConfiguration()

exportConnectorBinding

public char[] exportConnectorBinding(java.lang.String identifier)
                              throws AdminException
Description copied from interface: ConfigurationAdmin
Export a ConnectorBinding to character Array in XML format

Specified by:
exportConnectorBinding in interface ConfigurationAdmin
Parameters:
identifier - the unique identifier for a ConnectorBinding.
Returns:
character Array in XML format
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.exportConnectorBinding(java.lang.String)

exportConnectorType

public char[] exportConnectorType(java.lang.String identifier)
                           throws AdminException
Description copied from interface: ConfigurationAdmin
Export Connector Type to character array

Specified by:
exportConnectorType in interface ConfigurationAdmin
Parameters:
identifier - the unique identifier for for a ConnectorType
Returns:
character Array in XML format
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.exportConnectorType(java.lang.String)

exportVDB

public byte[] exportVDB(java.lang.String name,
                        java.lang.String version)
                 throws AdminException
Description copied from interface: ConfigurationAdmin
Export VDB to byte array

Specified by:
exportVDB in interface ConfigurationAdmin
Parameters:
name - identifier of the VDB
version - VDB version
Returns:
byte array of the MetaMatrix VDB Archive
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.exportVDB(java.lang.String, java.lang.String)

addConnectorArchive

public void addConnectorArchive(byte[] contents,
                                AdminOptions options)
                         throws AdminException
Description copied from interface: ConfigurationAdmin
Add Connector Type and all the required extension modules required by the this connector type into the system from the given file byte stream which is encoded inthe Connector Archive format.

Specified by:
addConnectorArchive in interface ConfigurationAdmin
Parameters:
contents - contents of File
options - resolution option in case of conflict in the connector type
Throws:
AdminException - if there's a system error.
Since:
4.3.2
See Also:
ConfigurationAdmin.addConnectorArchive(byte[], org.teiid.adminapi.AdminOptions)

exportConnectorArchive

public byte[] exportConnectorArchive(java.lang.String identifier)
                              throws AdminException
Description copied from interface: ConfigurationAdmin
Export Connector Archive, which is bundled connector type with its xml properties file and all the extension modules required by the this connector type

Specified by:
exportConnectorArchive in interface ConfigurationAdmin
Parameters:
identifier - the unique identifier for for a ConnectorType
Returns:
byte array of the connector archive.
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
ConfigurationAdmin.exportConnectorArchive(java.lang.String)

addUDF

public void addUDF(byte[] modelFileContents,
                   java.lang.String classpath)
            throws AdminException
Description copied from interface: ConfigurationAdmin
Add User Defined Function model to the system. If one is already deployed before this will replace the previous, otherwise add this as the new UDF model. Once the UDF is added the new UDF model is loaded.

Specified by:
addUDF in interface ConfigurationAdmin
Parameters:
modelFileContents - - UDF contents
classpath - - classpath for the UDF
Throws:
AdminException

deleteUDF

public void deleteUDF()
               throws AdminException
Description copied from interface: ConfigurationAdmin
Delete the User Defined Function model. Note that this will not delete any supporting extension jar files added, those need to be deleted separately.

Specified by:
deleteUDF in interface ConfigurationAdmin
Throws:
AdminException

extensionModuleModified

public void extensionModuleModified(java.lang.String name)
                             throws AdminException
Description copied from interface: ConfigurationAdmin
Indicates that an extension module has changed

Specified by:
extensionModuleModified in interface ConfigurationAdmin
Throws:
AdminException

setProcessProperty

public void setProcessProperty(java.lang.String processIdentifier,
                               java.lang.String propertyName,
                               java.lang.String propertyValue)
                        throws AdminException
Description copied from interface: ConfigurationAdmin
Set a process level property.

Specified by:
setProcessProperty in interface ConfigurationAdmin
Parameters:
processIdentifier - - identifier for the process where the property needs to be set
propertyName - - name of the property
propertyValue - - value of the property
Throws:
AdminException

accumulateSystemException

protected AdminException accumulateSystemException(AdminException parent,
                                                   java.lang.Exception e)

accumulateProcessingException

protected AdminException accumulateProcessingException(AdminException parent,
                                                       java.lang.Exception e)

prettyPrintBindingNames

protected java.lang.String prettyPrintBindingNames(java.util.List bindings)

getManager

public EmbeddedConnectionFactoryImpl getManager()
Returns:
Returns the manager.
Since:
4.3

convertToAdminObjects

protected java.lang.Object convertToAdminObjects(java.lang.Object src)

convertToAdminObjects

protected java.lang.Object convertToAdminObjects(java.lang.Object src,
                                                 java.lang.Object parent)

convertPropertyDefinitions

protected java.util.Collection convertPropertyDefinitions(ComponentType ctype,
                                                          java.util.Properties properties)
Convert a ComponentType and a set of properties into a Collection of com.metamatrix.admin.api.objects.PropertyDefinition objects

Parameters:
ctype -
properties -
Returns:
Since:
4.3

convertPropertyDefinitions

protected java.util.Collection convertPropertyDefinitions(java.util.Properties properties)
Convert a set of properties into a Collection of com.metamatrix.admin.api.objects.PropertyDefinition objects

Parameters:
ctype -
properties -
Returns:
Since:
4.3

validateSession

protected SessionToken validateSession()

changeVDBStatus

protected void changeVDBStatus(java.lang.String name,
                               java.lang.String version,
                               int status)
                        throws AdminException
Throws:
AdminException


Copyright © 2009. All Rights Reserved.