[teiid-commits] teiid SVN: r1291 - in trunk: client/src/main/java/com/metamatrix/common/comm/platform/client and 16 other directories.

Author: rareddy Date: 2009-08-28 18:27:14 -0400 (Fri, 28 Aug 2009) New Revision: 1291 Added: trunk/server/src/main/java/com/metamatrix/admin/api/AdminStatus.java trunk/server/src/main/java/com/metamatrix/admin/api/DQP.java trunk/server/src/main/java/com/metamatrix/admin/api/Host.java trunk/server/src/main/java/com/metamatrix/admin/api/Principal.java trunk/server/src/main/java/com/metamatrix/admin/api/Resource.java trunk/server/src/main/java/com/metamatrix/admin/api/ScriptsContainer.java trunk/server/src/main/java/com/metamatrix/admin/api/Service.java trunk/server/src/main/java/com/metamatrix/admin/api/SystemObject.java trunk/server/src/main/java/com/metamatrix/admin/objects/ trunk/server/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java trunk/server/src/main/java/com/metamatrix/admin/objects/MMDQP.java trunk/server/src/main/java/com/metamatrix/admin/objects/MMHost.java trunk/server/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java trunk/server/src/main/java/com/metamatrix/admin/objects/MMResource.java trunk/server/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java trunk/server/src/main/java/com/metamatrix/admin/objects/MMService.java trunk/server/src/main/java/com/metamatrix/admin/objects/MMSystem.java Removed: trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMDQP.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMHost.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMResource.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMService.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMSystem.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMUser.java trunk/client/src/main/java/org/teiid/adminapi/AdminStatus.java trunk/client/src/main/java/org/teiid/adminapi/DQP.java trunk/client/src/main/java/org/teiid/adminapi/Entitlement.java trunk/client/src/main/java/org/teiid/adminapi/Host.java trunk/client/src/main/java/org/teiid/adminapi/Principal.java trunk/client/src/main/java/org/teiid/adminapi/Resource.java trunk/client/src/main/java/org/teiid/adminapi/ScriptsContainer.java trunk/client/src/main/java/org/teiid/adminapi/Service.java trunk/client/src/main/java/org/teiid/adminapi/SystemObject.java trunk/client/src/main/java/org/teiid/adminapi/User.java Modified: trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminObject.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMGroup.java trunk/client/src/main/java/com/metamatrix/admin/objects/MMProcess.java trunk/client/src/main/java/com/metamatrix/common/comm/platform/client/ServerAdminFactory.java trunk/client/src/main/java/org/teiid/adminapi/ConfigurationAdmin.java trunk/client/src/main/java/org/teiid/adminapi/ConnectorBinding.java trunk/client/src/main/java/org/teiid/adminapi/Group.java trunk/client/src/main/java/org/teiid/adminapi/MonitoringAdmin.java trunk/client/src/main/java/org/teiid/adminapi/ProcessObject.java trunk/client/src/main/java/org/teiid/adminapi/RuntimeStateAdmin.java trunk/client/src/main/java/org/teiid/adminapi/SecurityAdmin.java trunk/client/src/main/resources/com/metamatrix/admin/i18n.properties trunk/client/src/test/java/com/metamatrix/common/comm/platform/client/TestSeverAdminFactory.java trunk/common-internal/src/main/java/com/metamatrix/common/config/api/HostType.java trunk/common-internal/src/main/java/com/metamatrix/common/config/api/VMComponentDefnType.java trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/BaseAdmin.java trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPConfigAdminImpl.java trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPMonitoringAdminImpl.java trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPRuntimeStateAdminImpl.java trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPSecurityAdminImpl.java trunk/runtime/src/main/java/com/metamatrix/jdbc/EmbeddedConnectionFactoryImpl.java trunk/runtime/src/main/resources/com/metamatrix/dqp/embedded/i18n.properties trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerConfigAdmin.java trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerMonitoringAdmin.java trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerRuntimeStateAdmin.java trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerSecurityAdmin.java trunk/server/src/main/java/com/metamatrix/admin/server/AbstractAdminImpl.java trunk/server/src/main/java/com/metamatrix/admin/server/ServerAdminImpl.java trunk/server/src/main/java/com/metamatrix/admin/server/ServerConfigAdminImpl.java trunk/server/src/main/java/com/metamatrix/admin/server/ServerMonitoringAdminImpl.java trunk/server/src/main/java/com/metamatrix/admin/server/ServerRuntimeStateAdminImpl.java trunk/server/src/main/java/com/metamatrix/admin/server/ServerSecurityAdminImpl.java trunk/server/src/main/java/com/metamatrix/common/config/CurrentConfiguration.java trunk/server/src/test/java/com/metamatrix/admin/server/TestServerConfigAdminImpl.java trunk/server/src/test/java/com/metamatrix/admin/server/TestServerMonitoringAdminImpl.java trunk/test-integration/src/test/java/com/metamatrix/server/integration/TestAdminApi.java trunk/test-integration/src/test/java/org/teiid/runtime/adminapi/TestEmbeddedAdmin.java Log: TEIID-697: Please look at JIRA for the changes made. Modified: trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminObject.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminObject.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminObject.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -24,15 +24,10 @@ import java.io.Serializable; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Properties; -import org.teiid.adminapi.AdminException; import org.teiid.adminapi.AdminObject; -import org.teiid.adminapi.AdminProcessingException; -import org.teiid.adminapi.ConnectionPool; -import org.teiid.adminapi.Transaction; import com.metamatrix.admin.AdminPlugin; import com.metamatrix.common.util.PropertiesUtils; @@ -46,92 +41,6 @@ /**SerialVersion used in serialization*/ public static final long serialVersionUID = -8280437282118346149L; - /**Package containing the sub-interfaces of AdminObjects*/ - public static final String OBJECTS_PACKAGE = "com.metamatrix.admin.api.objects."; //$NON-NLS-1$ - - - - /**Object type code for Cache*/ - public static final int OBJECT_TYPE_CACHE = 0; - /** Object Type code for Service */ - public static final int OBJECT_TYPE_SERVICE = 1; - /**Object type code for ConnectorBinding*/ - public static final int OBJECT_TYPE_CONNECTOR_BINDING = 2; - /**Object type code for ConnectorType*/ - public static final int OBJECT_TYPE_CONNECTOR_TYPE = 3; - /**Object type code for DQP*/ - public static final int OBJECT_TYPE_DQP = 4; - /**Object type code for Entitlement*/ - public static final int OBJECT_TYPE_ENTITLEMENT = 5; - /**Object type code for ExtensionModule*/ - public static final int OBJECT_TYPE_EXTENSION_MODULE = 6; - /**Object type code for Group*/ - public static final int OBJECT_TYPE_GROUP = 7; - /**Object type code for Host*/ - public static final int OBJECT_TYPE_HOST = 8; - /**Object type code for LogConfiguration*/ - public static final int OBJECT_TYPE_LOG_CONFIGURATION = 9; - /**Object type code for Model*/ - public static final int OBJECT_TYPE_MODEL = 10; - /**Object type code for ProcessObject*/ - public static final int OBJECT_TYPE_PROCESS_OBJECT = 11; - /**Object type code for PropertyDefinition*/ - public static final int OBJECT_TYPE_PROPERTY_DEFINITION = 12; - /**Object type code for QueueWorkerPool*/ - public static final int OBJECT_TYPE_QUEUE_WORKER_POOL = 13; - /**Object type code for Request*/ - public static final int OBJECT_TYPE_REQUEST = 14; - /**Object type code for Resource*/ - public static final int OBJECT_TYPE_RESOURCE = 15; - /**Object type code for Role*/ - public static final int OBJECT_TYPE_ROLE = 16; - /**Object type code for Session*/ - public static final int OBJECT_TYPE_SESSION = 17; - /**Object type code for SystemObject*/ - public static final int OBJECT_TYPE_SYSTEM_OBJECT = 19; - /**Object type code for User*/ - public static final int OBJECT_TYPE_USER = 20; - /**Object type code for VDB*/ - public static final int OBJECT_TYPE_VDB = 21; - /**Object type code for TRANSACTION*/ - public static final int OBJECT_TYPE_TRANSACTION = 22; - /**Object type code for CONNECTION_POOL*/ - public static final int OBJECT_TYPE_CONNECTION_POOL = 23; - - - //map of String (class name) to Integer (object type code) - private static HashMap objectTypeMap = new HashMap(); - - - static { - objectTypeMap.put(org.teiid.adminapi.Cache.class.getName(), new Integer(OBJECT_TYPE_CACHE)); - objectTypeMap.put(org.teiid.adminapi.Service.class.getName(), new Integer(OBJECT_TYPE_SERVICE)); - objectTypeMap.put(org.teiid.adminapi.ConnectorBinding.class.getName(), new Integer(OBJECT_TYPE_CONNECTOR_BINDING)); - objectTypeMap.put(org.teiid.adminapi.ConnectorType.class.getName(), new Integer(OBJECT_TYPE_CONNECTOR_TYPE)); - objectTypeMap.put(org.teiid.adminapi.DQP.class.getName(), new Integer(OBJECT_TYPE_DQP)); - objectTypeMap.put(org.teiid.adminapi.Entitlement.class.getName(), new Integer(OBJECT_TYPE_ENTITLEMENT)); - objectTypeMap.put(org.teiid.adminapi.ExtensionModule.class.getName(), new Integer(OBJECT_TYPE_EXTENSION_MODULE)); - objectTypeMap.put(org.teiid.adminapi.Group.class.getName(), new Integer(OBJECT_TYPE_GROUP)); - objectTypeMap.put(org.teiid.adminapi.Host.class.getName(), new Integer(OBJECT_TYPE_HOST)); - objectTypeMap.put(org.teiid.adminapi.LogConfiguration.class.getName(), new Integer(OBJECT_TYPE_LOG_CONFIGURATION)); - objectTypeMap.put(org.teiid.adminapi.Model.class.getName(), new Integer(OBJECT_TYPE_MODEL)); - objectTypeMap.put(org.teiid.adminapi.ProcessObject.class.getName(), new Integer(OBJECT_TYPE_PROCESS_OBJECT)); - objectTypeMap.put(org.teiid.adminapi.PropertyDefinition.class.getName(), new Integer(OBJECT_TYPE_PROPERTY_DEFINITION)); - objectTypeMap.put(org.teiid.adminapi.QueueWorkerPool.class.getName(), new Integer(OBJECT_TYPE_QUEUE_WORKER_POOL)); - objectTypeMap.put(org.teiid.adminapi.Request.class.getName(), new Integer(OBJECT_TYPE_REQUEST)); - objectTypeMap.put(org.teiid.adminapi.Resource.class.getName(), new Integer(OBJECT_TYPE_RESOURCE)); - objectTypeMap.put(org.teiid.adminapi.Role.class.getName(), new Integer(OBJECT_TYPE_ROLE)); - objectTypeMap.put(org.teiid.adminapi.Session.class.getName(), new Integer(OBJECT_TYPE_SESSION)); - objectTypeMap.put(org.teiid.adminapi.SystemObject.class.getName(), new Integer(OBJECT_TYPE_SYSTEM_OBJECT)); - objectTypeMap.put(org.teiid.adminapi.User.class.getName(), new Integer(OBJECT_TYPE_USER)); - objectTypeMap.put(org.teiid.adminapi.VDB.class.getName(), new Integer(OBJECT_TYPE_VDB)); - objectTypeMap.put(Transaction.class.getName(), Integer.valueOf(OBJECT_TYPE_TRANSACTION)); - objectTypeMap.put(ConnectionPool.class.getName(), Integer.valueOf(OBJECT_TYPE_CONNECTION_POOL)); - } - - - - /** * The fully-qualified name of the Admin Object. Will never be null. */ @@ -142,8 +51,6 @@ */ protected String[] identifierParts; - - /** * The base name of this Admin Object */ @@ -277,10 +184,6 @@ return(results.toString()); } - - - - /** * Get all the properties for this Object. * @@ -482,28 +385,4 @@ public void setProperties(java.util.Properties props) { this.props = props; } - - - /** - * Get the object type code for the specified classname. - * @param className This may be fully qualified or not, e.g. - * "com.metamatrix.admin.api.objects.ConnectorBinding" or "ConnectorBinding". - * @return Object type code. The will be one of the constants AdminObject.OBJECT_TYPE_xxx. - * @throws AdminException - * @since 4.3 - */ - public static int getObjectType(String className) throws AdminException { - //convert to the fully qualified className - if (className.indexOf(".") == -1) { //$NON-NLS-1$ - className = OBJECTS_PACKAGE + className; - } - - Integer codeInteger = (Integer) objectTypeMap.get(className); - if (codeInteger == null) { - String message = AdminPlugin.Util.getString("MMAdminObject.Unsupported_Admin_Object", new Object[] {className}); //$NON-NLS-1$ - throw new AdminProcessingException(message); - } - - return codeInteger.intValue(); - } } Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,111 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import java.io.Serializable; - -import org.teiid.adminapi.AdminStatus; - -import com.metamatrix.admin.AdminPlugin; - - -/** - * Simple Implementation of MMStatus. - * @since 4.3 - */ -public class MMAdminStatus implements AdminStatus, Serializable { - private static final long serialVersionUID = -3111591335358837218L; - private int code = AdminStatus.CODE_UNKNOWN; - private String message = null; - - - /** - * Construct a new MMAdminStatus - * @param code - * @param messageKey Key of the status message in i18n.properties. - * @since 4.3 - */ - public MMAdminStatus(int code, String messageKey) { - this.code = code; - - this.message = AdminPlugin.Util.getString(messageKey); - } - - /** - * Construct a new MMAdminStatus - * @param code - * @param messageKey Key of the status message in i18n.properties. - * @param value Value to substitute into the internationalized message. - * @since 4.3 - */ - public MMAdminStatus(int code, String messageKey, Object value) { - this.code = code; - - this.message = AdminPlugin.Util.getString(messageKey, value); - } - - /** - * Construct a new MMAdminStatus - * @param code - * @param messageKey Key of the status message in i18n.properties. - * @param values Values to substitute into the internationalized message. - * @since 4.3 - */ - public MMAdminStatus(int code, String messageKey, Object[] values) { - this.code = code; - - this.message = AdminPlugin.Util.getString(messageKey, values); - } - - - - /** - * @see org.teiid.adminapi.AdminStatus#getCode() - * @since 4.3 - */ - public int getCode() { - return code; - } - - /** - * @see org.teiid.adminapi.AdminStatus#getMessage() - * @since 4.3 - */ - public String getMessage() { - return message; - } - - - /** - * @see java.lang.Object#toString() - * @since 4.3 - */ - public String toString() { - StringBuffer result = new StringBuffer(); - result.append(AdminPlugin.Util.getString("MMAdminStatus.MMAdminStatus")); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMAdminStatus.Code")).append(getCode()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMAdminStatus.Message")).append(getMessage()); //$NON-NLS-1$ - return result.toString(); - } - -} Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMDQP.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMDQP.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMDQP.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,201 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import java.util.Date; - -import org.teiid.adminapi.DQP; - -import com.metamatrix.admin.AdminPlugin; - - -/** - * A Connector Binding is a Connector Type with properties that have been - * bond to a Connector. - * - * May are may not be assigned to a VDB - */ -public class MMDQP extends MMAdminObject implements DQP { - - private static final long serialVersionUID = -3212002022690786890L; - private String description = ""; //$NON-NLS-1$ - private int currentState; - private Date stateChangedTime; - private long serviceID = -1; - - - /** - * Constructor. - * @param identifierParts - * @since 4.3 - */ - public MMDQP(String[] identifierParts) { - super(identifierParts); - - } - - - - - /** - * @see java.lang.Object#toString() - */ - public String toString() { - StringBuffer result = new StringBuffer(); - result.append(AdminPlugin.Util.getString("MMDQP.MMDQP")).append(getIdentifier()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.Description")).append(description); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.Created")).append(getCreatedDate()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.Created_By")).append(getCreatedBy()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.Updated")).append(getLastChangedDate()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.Updated_By")).append(getLastChangedBy()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.State")).append(getStateAsString()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.IsRegistered")).append(isRegistered()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.State_Changed")).append(getStateChangedTime()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMDQP.Properties")).append(getPropertiesAsString()); //$NON-NLS-1$ - return result.toString(); - } - - - - /** - * Returns the description - * @return description - */ - public String getDescription() { - return description; - } - - /** - * Set the description - * @param description - */ - public void setDescription(String description) { - this.description = description; - } - - - - /** - * @return Returns the currentState as int. - * @since 4.3 - */ - public int getState() { - return currentState; - } - - - /** - * @return Returns the currentState as String. - * @since 4.3 - */ - public String getStateAsString() { - switch (currentState) { - case STATE_OPEN: - return AdminPlugin.Util.getString("MMDQP.open"); //$NON-NLS-1$ - case STATE_CLOSED: - return AdminPlugin.Util.getString("MMDQP.closed"); //$NON-NLS-1$ - case STATE_FAILED: - return AdminPlugin.Util.getString("MMDQP.failed"); //$NON-NLS-1$ - case STATE_INIT_FAILED: - return AdminPlugin.Util.getString("MMDQP.initializationFailed"); //$NON-NLS-1$ - case STATE_NOT_INITIALIZED: - return AdminPlugin.Util.getString("MMDQP.notInitialized"); //$NON-NLS-1$ - case STATE_NOT_REGISTERED: - return AdminPlugin.Util.getString("MMDQP.notRegistered"); //$NON-NLS-1$ - case STATE_DATA_SOURCE_UNAVAILABLE: - return AdminPlugin.Util.getString("MMDQP.dataSourceUnavailable"); //$NON-NLS-1$ - default: - return AdminPlugin.Util.getString("MMDQP.unknown"); //$NON-NLS-1$ - } - } - - /** - * Set the state - * @param state - * @since 4.3 - */ - public void setState(int state) { - this.currentState = state; - } - - - /** - * @return Returns time of last state change. - * @since 4.3 - */ - public Date getStateChangedTime() { - return stateChangedTime; - } - - /** - * Set the state changed time - * @param stateChangedTime - * @since 4.3 - */ - public void setStateChangedTime(Date stateChangedTime) { - this.stateChangedTime = stateChangedTime; - - //check on what states mean "registered" - setRegistered(currentState==STATE_OPEN || currentState==STATE_FAILED || currentState==STATE_DATA_SOURCE_UNAVAILABLE); - } - - - - /** - * @return Returns the serviceID. - * @since 4.3 - */ - public long getServiceID() { - return this.serviceID; - } - - /** - * @param serviceID The serviceID to set. - * @since 4.3 - */ - public void setServiceID(long serviceID) { - this.serviceID = serviceID; - } - - - - /** - * @return Returns the processID. - * @since 4.3 - */ - public String getProcessName() { - return this.identifierParts[1]; - } - - /** - * @return Returns the hostName. - * @since 4.3 - */ - public String getHostName() { - return identifierParts[0]; - } - - - - -} \ No newline at end of file Modified: trunk/client/src/main/java/com/metamatrix/admin/objects/MMGroup.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMGroup.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMGroup.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -28,15 +28,24 @@ /** * @since 4.3 */ -public class MMGroup extends MMPrincipal implements Group { +public class MMGroup extends MMAdminObject implements Group { private static final long serialVersionUID = 1102507655851078982L; /** - * @param principalName + * @param groupName * @since 4.3 */ - public MMGroup(String[] principalName) { - super(principalName, TYPE_GROUP); + public MMGroup(String[] groupName) { + super(groupName); } + @Override + public String toString() { + StringBuffer sb = new StringBuffer(); + sb.append("[Name=\""); //$NON-NLS-1$ + sb.append(this.getName()); + sb.append("\"]"); //$NON-NLS-1$ + return sb.toString(); + } + } Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMHost.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMHost.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMHost.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,91 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import org.teiid.adminapi.Host; - -import com.metamatrix.admin.AdminPlugin; - - -/** - * Simple Host object for the Admin API as represented in the Configuration - */ -public final class MMHost extends MMAdminObject implements Host { - - private static final long serialVersionUID = -779866213549875450L; - private boolean running = false; - - - - /** - * Constructor for creating a MMHost - * - * @param identifierParts of the Host - */ - public MMHost(String[] identifierParts) { - super(identifierParts); - } - - - - /** - * Create a String for this MMHost - * - * @see java.lang.Object#toString() - * @since 4.3 - */ - public String toString() { - StringBuffer result = new StringBuffer(); - result.append(AdminPlugin.Util.getString("MMHost.MMHost")).append(getName()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMHost.Properties")).append(getPropertiesAsString()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMHost.Created")).append(getCreatedDate()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMHost.Created_By")).append(getCreatedBy()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMHost.Updated")).append(getLastChangedDate()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMHost.Updated_By")).append(getLastChangedBy()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMHost.IsRunning")).append(isRegistered()); //$NON-NLS-1$ - return result.toString(); - } - - - - /** - * Return true if this Host is running - * @return if this Host is running - * @since 4.3 - */ - public boolean isRunning() { - return running; - } - - /** - * Set if this Host has been deployed and is executing - * @param running - * @since 4.3 - */ - public void setRunning(boolean running) { - this.running = running; - } - - - -} \ No newline at end of file Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,98 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import org.teiid.adminapi.Principal; - - -/** - * @since 4.3 - */ -public class MMPrincipal extends MMAdminObject implements Principal { - - private static final long serialVersionUID = -1383265398519744688L; - - private static final String[] TYPE_NAMES = new String[] { TYPE_LABEL_USER, TYPE_LABEL_GROUP, TYPE_LABEL_ADMIN }; - - private int type; - - /** - * Ctor - * @param principalName The name of the {@link Principal}. - * @param type The value of the {@link Principal}. - * @since 4.3 - */ - public MMPrincipal(String[] principalName, int type) { - super(principalName); - this.type = type; - } - - /** - * @see com.metamatrix.admin.objects.MMAdminObject#toString() - * @since 4.3 - */ - public String toString() { - StringBuffer sb = new StringBuffer(); - sb.append("[Name=\""); //$NON-NLS-1$ - sb.append(this.getName()); - sb.append("\" - Type=\""); //$NON-NLS-1$ - sb.append( TYPE_NAMES[this.type] ); - sb.append("\"]"); //$NON-NLS-1$ - return sb.toString(); - } - - /** - * @see org.teiid.adminapi.Principal#getType() - * @since 4.3 - */ - public int getType() { - return type; - } - - /** - * @see org.teiid.adminapi.Principal#getTypeLabel() - * @since 4.3 - */ - public String getTypeLabel() { - return TYPE_NAMES[this.type]; - } - - /** - * Determine whether the given <code>className</code> - * is either of {@link #TYPE_USER} or {@link #TYPE_GROUP}. - * @param className the className in question. - * @return <code>true</code> iff the given type represents - * one or the other; User or Group. - * @since 4.3 - */ - public static boolean isUserOrGroup(String className) { - try { - int type = MMAdminObject.getObjectType(className); - return (type == MMAdminObject.OBJECT_TYPE_USER || type == MMAdminObject.OBJECT_TYPE_GROUP); - } catch (Exception e) { - return false; - } - - } - -} Modified: trunk/client/src/main/java/com/metamatrix/admin/objects/MMProcess.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMProcess.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMProcess.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -23,6 +23,7 @@ package com.metamatrix.admin.objects; import java.net.InetAddress; +import java.util.Date; import org.teiid.adminapi.AdminObject; import org.teiid.adminapi.ProcessObject; @@ -36,7 +37,8 @@ public final class MMProcess extends MMAdminObject implements ProcessObject { private static final long serialVersionUID = 8454606907083408662L; private long freeMemory = 0; - private String hostIdentifier = ""; //$NON-NLS-1$ + private String processName = ""; //$NON-NLS-1$ + private String hostName = ""; //$NON-NLS-1$ private InetAddress inetAddress = null; private int port = 0; @@ -44,26 +46,23 @@ private int threadCount = 0; private long totalMemory = 0; - private int sockets = 0; - private int maxSockets = 0; - private int virtualSockets = 0; - private int maxVirtualSockets = 0; + private int sockets = 0; + private int maxSockets = 0; private long objectsRead = 0; private long objectsWritten = 0; + private Date startTime; private QueueWorkerPool queueWorkerPool = null; - - /** * Contruct a new MMProcess. * @param identifierParts */ public MMProcess(String[] identifierParts) { super(identifierParts); - - hostIdentifier = identifierParts[0]; + hostName = identifierParts[0]; + processName = identifierParts[1]; } @@ -94,12 +93,20 @@ return freeMemory; } + + /** + * @return host name for this process. + */ + public String getHostName() { + return hostName; + } + /** * @return host name for this process. */ - public String getHostIdentifier() { - return hostIdentifier; + public String getProcessName() { + return processName; } /** @@ -210,13 +217,13 @@ result.append(AdminPlugin.Util.getString("MMProcess.TotalMemory")).append(totalMemory); //$NON-NLS-1$ result.append(AdminPlugin.Util.getString("MMProcess.FreeMemory")).append(freeMemory); //$NON-NLS-1$ result.append(AdminPlugin.Util.getString("MMProcess.ThreadCount")).append(threadCount); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMProcess.HostIdentifier")).append(hostIdentifier); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMProcess.HostName")).append(hostName); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMProcess.ProcessName")).append(processName); //$NON-NLS-1$ result.append(AdminPlugin.Util.getString("MMProcess.Port")).append(port); //$NON-NLS-1$ result.append(AdminPlugin.Util.getString("MMProcess.InetAddress")).append(inetAddress); //$NON-NLS-1$ result.append(AdminPlugin.Util.getString("MMProcess.Sockets")).append(sockets); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMProcess.MaxSockets")).append(maxSockets); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMProcess.VirtualSockets")).append(virtualSockets); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMProcess.MaxVirtualSockets")).append(maxVirtualSockets); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMProcess.MaxSockets")).append(maxSockets); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMProcess.StartTime")).append(startTime); //$NON-NLS-1$ result.append(AdminPlugin.Util.getString("MMProcess.ObjectsRead")).append(objectsRead); //$NON-NLS-1$ result.append(AdminPlugin.Util.getString("MMProcess.ObjectsWritten")).append(objectsWritten); //$NON-NLS-1$ if (queueWorkerPool != null) { @@ -240,21 +247,8 @@ public void setMaxSockets(int maxSockets) { this.maxSockets = maxSockets; } + /** - * @return Returns the maxVirtualSockets. - * @since 4.3 - */ - public int getMaxVirtualSockets() { - return this.maxVirtualSockets; - } - /** - * @param maxVirtualSockets The maxVirtualSockets to set. - * @since 4.3 - */ - public void setMaxVirtualSockets(int maxVirtualSockets) { - this.maxVirtualSockets = maxVirtualSockets; - } - /** * @return Returns the objectsRead. * @since 4.3 */ @@ -282,6 +276,7 @@ public void setObjectsWritten(long objectsWritten) { this.objectsWritten = objectsWritten; } + /** * @return Returns the sockets. * @since 4.3 @@ -296,21 +291,8 @@ public void setSockets(int sockets) { this.sockets = sockets; } + /** - * @return Returns the virtualSockets. - * @since 4.3 - */ - public int getVirtualSockets() { - return this.virtualSockets; - } - /** - * @param virtualSockets The virtualSockets to set. - * @since 4.3 - */ - public void setVirtualSockets(int virtualSockets) { - this.virtualSockets = virtualSockets; - } - /** * @return Returns the queueWorkerPool. * @since 4.3 */ @@ -324,21 +306,13 @@ public void setQueueWorkerPool(QueueWorkerPool queueWorkerPool) { this.queueWorkerPool = queueWorkerPool; } - - - /** - * @return Returns the processID. - * @since 4.3 - */ - public String getProcessName() { - return identifierParts[1]; - } - - /** - * @return Returns the hostName. - * @since 4.3 - */ - public String getHostName() { - return identifierParts[0]; - } + + @Override + public Date getStartTime() { + return startTime; + } + + public void setStartTime(Date date) { + this.startTime = date; + } } Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMResource.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMResource.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMResource.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,84 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import org.teiid.adminapi.Resource; - -import com.metamatrix.admin.AdminPlugin; - -/** - * Dataholder for a resource. - */ -public class MMResource extends MMAdminObject implements Resource { - - private static final long serialVersionUID = -8732882869479091774L; - private String resourceType; - - /** - * Constructor - * @param identifierParts of the resource - */ - public MMResource(String[] identifierParts) { - super(identifierParts); - } - - - /** - * @see java.lang.Object#toString() - */ - public String toString() { - StringBuffer result = new StringBuffer(); - result.append(AdminPlugin.Util.getString("MMResource.MMResource")).append(getIdentifier()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMResource.Type")).append(resourceType); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMResource.Created")).append(getCreatedDate()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMResource.Created_By")).append(getCreatedBy()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMResource.Updated")).append(getLastChangedDate()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMResource.Updated_By")).append(getLastChangedBy()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMResource.Properties")).append(getPropertiesAsString()); //$NON-NLS-1$ - return result.toString(); - } - - - - /** - * Get the Resource Type for this Resource - * @return Returns the String value of the Resource Type for this Resouce. - * @since 4.3 - */ - public String getResourceType() { - return this.resourceType; - } - - - - /** - * Set the Resource Type - * @param resourceType The Resource Type to set. - * @since 4.3 - */ - public void setResourceType(String resourceType) { - this.resourceType = resourceType; - } - - -} Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,145 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import java.io.File; -import java.io.IOException; -import java.util.ArrayList; -import java.util.Collection; -import java.util.HashMap; -import java.util.Iterator; -import java.util.Map; - -import org.teiid.adminapi.AdminComponentException; -import org.teiid.adminapi.AdminException; -import org.teiid.adminapi.AdminOptions; -import org.teiid.adminapi.AdminProcessingException; -import org.teiid.adminapi.ScriptsContainer; - -import com.metamatrix.admin.AdminPlugin; -import com.metamatrix.core.util.FileUtils; - - -/** - * @since 4.3 - */ -public class MMScriptsContainer implements - ScriptsContainer { - - private static final long serialVersionUID = 1262888652939367623L; - // <String> fileName => <byte[]> file contents - private Map fileMap; - - /** - * - * @since 4.3 - */ - public MMScriptsContainer() { - super(); - fileMap = new HashMap(10); - } - - /** - * @see org.teiid.adminapi.ScriptsContainer#getFileNames() - * @since 4.3 - */ - public Collection getFileNames() { - return new ArrayList(this.fileMap.keySet()); - } - - /** - * @see org.teiid.adminapi.ScriptsContainer#saveAllToDirectory(java.lang.String, AdminOptions) - * @since 4.3 - */ - public void saveAllToDirectory(String directoryLocation, AdminOptions options) throws AdminException { - String fileSeparator = File.separator; - String path = (directoryLocation.endsWith(fileSeparator) ? directoryLocation : directoryLocation + fileSeparator); - - // Check that the directory exists and is writable - File directory = new File(path); - if ( ! directory.isDirectory() ) { - Object[] params = new Object[] {directoryLocation}; - throw new AdminProcessingException(AdminPlugin.Util.getString("MMScriptsContainer.unable_to_locate_directory", params)); //$NON-NLS-1$ - } - if ( ! directory.canWrite() ) { - Object[] params = new Object[] {directoryLocation}; - throw new AdminProcessingException(AdminPlugin.Util.getString("MMScriptsContainer.unable_to_write_to_directory", params)); //$NON-NLS-1$ - } - - // First check that we will not overwrite any of the files - Collection existingFiles = null; - for ( Iterator fileItr = fileMap.keySet().iterator(); fileItr.hasNext();) { - String fileName = path + (String) fileItr.next(); - File aFile = new File(fileName); - - if ( aFile.exists() ) { - if ( existingFiles == null ) { - existingFiles = new ArrayList(); - } - existingFiles.add(fileName); - } - } - if ( existingFiles != null && (options == null || options.containsOption(AdminOptions.OnConflict.EXCEPTION)) ) { - Object[] params = new Object[] {existingFiles.toString()}; - throw new AdminProcessingException(AdminPlugin.Util.getString("MMScriptsContainer.files_exist", params)); //$NON-NLS-1$ - } - - if ( existingFiles == null || options.containsOption(AdminOptions.OnConflict.OVERWRITE) ) { - // Now write each file - for (Iterator fileItr = fileMap.keySet().iterator(); fileItr.hasNext();) { - String fileName = (String)fileItr.next(); - File target = new File(path + fileName); - - try { - target.createNewFile(); - byte[] fileContents = (byte[])fileMap.get(fileName); - FileUtils.write(fileContents, target); - } catch (IOException err) { - throw new AdminProcessingException(AdminPlugin.Util.getString("MMScriptsContainer.error_writing_file", fileName), err); //$NON-NLS-1$ - } - } - } // if - } - - -//================================================================================================= -// SETTERS ARE NOT IN THE PUBLIIC INTERFACE -//================================================================================================= - - /** - * Add file contents by name. - * - * @param fileName - required - * @param fileContents - required - * @throws AdminComponentException if one of the required args are null or empty. - */ - public void addFile(String fileName, byte[] fileContents) throws AdminComponentException { - if ( fileName == null || fileName.length() == 0 ) { - throw new AdminComponentException(AdminPlugin.Util.getString("MMScriptsContainer.fileName_was_null")); //$NON-NLS-1$ - } - if ( fileContents == null || fileContents.length == 0 ) { - throw new AdminComponentException(AdminPlugin.Util.getString("MMScriptsContainer.fileContents_was_null")); //$NON-NLS-1$ - } - this.fileMap.put(fileName, fileContents); - } -} Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMService.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMService.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMService.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,209 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import java.util.Date; - -import org.teiid.adminapi.Service; - -import com.metamatrix.admin.AdminPlugin; - - -/** - * A Service - * - */ -public class MMService extends MMAdminObject implements Service { - - private static final long serialVersionUID = -338643922496948824L; - private String description = ""; //$NON-NLS-1$ - private String componentTypeName = ""; //$NON-NLS-1$ - private int currentState; - private Date stateChangedTime; - private long serviceID = -1; - - - /** - * Constructor. - * @param identifierParts - * @since 6.1 - */ - public MMService(String[] identifierParts) { - super(identifierParts); - } - - - - - - /** - * @see java.lang.Object#toString() - */ - public String toString() { - StringBuffer result = new StringBuffer(); - result.append(AdminPlugin.Util.getString("MMService.MMService")).append(getIdentifier()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.Description")).append(description); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.Created")).append(getCreatedDate()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.Created_By")).append(getCreatedBy()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.Updated")).append(getLastChangedDate()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.Updated_By")).append(getLastChangedBy()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.State")).append(getState()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.State_Changed")).append(getStateChangedTime()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.IsRegistered")).append(isRegistered()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMService.Properties")).append(getPropertiesAsString()); //$NON-NLS-1$ - return result.toString(); - } - - - - /** - * Returns the description - * @return description - */ - public String getDescription() { - return description; - } - - /** - * Set the description - * @param description - */ - public void setDescription(String description) { - this.description = description; - } - - - /** - * @return the current state of this connector binding. - */ - public int getState() { - return this.currentState; - } - - /** - * @return Returns the currentState as String. - * @since 6.1 - */ - public String getStateAsString() { - switch (currentState) { - case STATE_OPEN: - return AdminPlugin.Util.getString("MMService.open"); //$NON-NLS-1$ - case STATE_CLOSED: - return AdminPlugin.Util.getString("MMService.closed"); //$NON-NLS-1$ - case STATE_FAILED: - return AdminPlugin.Util.getString("MMService.failed"); //$NON-NLS-1$ - case STATE_INIT_FAILED: - return AdminPlugin.Util.getString("MMService.initializationFailed"); //$NON-NLS-1$ - case STATE_NOT_INITIALIZED: - return AdminPlugin.Util.getString("MMService.notInitialized"); //$NON-NLS-1$ - case STATE_NOT_REGISTERED: - return AdminPlugin.Util.getString("MMService.notRegistered"); //$NON-NLS-1$ - case STATE_DATA_SOURCE_UNAVAILABLE: - return AdminPlugin.Util.getString("MMService.dataSourceUnavailable"); //$NON-NLS-1$ - default: - return AdminPlugin.Util.getString("MMService.unknown"); //$NON-NLS-1$ - } - } - - /** - * Set the state - * @param state - * @since 6.1 - */ - public void setState(int state) { - this.currentState = state; - - //check on what states mean "registered" - setRegistered(currentState==STATE_OPEN || currentState==STATE_FAILED || currentState==STATE_DATA_SOURCE_UNAVAILABLE); - } - - - /** - * @return Returns time of last state change. - * @since 6.1 - */ - public Date getStateChangedTime() { - return stateChangedTime; - } - - /** - * Set the state changed time - * @param stateChangedTime - * @since 6.1 - */ - public void setStateChangedTime(Date stateChangedTime) { - this.stateChangedTime = stateChangedTime; - } - - - /** - * @return Returns the serviceID. - * @since 6.1 - */ - public long getServiceID() { - return this.serviceID; - } - - /** - * @param serviceID The serviceID to set. - * @since 6.1 - */ - public void setServiceID(long serviceID) { - this.serviceID = serviceID; - } - - - /** - * @return Returns the processID. - * @since 6.1 - */ - public String getProcessName() { - return identifierParts[1]; - } - - - /** - * @return Returns the hostName. - * @since 6.1 - */ - public String getHostName() { - return identifierParts[0]; - } - - - /** - * @param connectorTypeName the identifier for a connector type - * @since 6.1 - */ - public void setComponentTypeName(String componentTypeName) { - this.componentTypeName = componentTypeName; - } - - /** - * @see org.teiid.adminapi.Service#getComponentTypeName() - * @since 6.1 - */ - public String getComponentTypeName() { - return this.componentTypeName; - } -} \ No newline at end of file Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMSystem.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMSystem.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMSystem.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,119 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import java.util.Date; - -import org.teiid.adminapi.SystemObject; - -import com.metamatrix.admin.AdminPlugin; -import com.metamatrix.core.util.DateUtil; - -/** - * Dataholder for information about the system at-large - */ -public class MMSystem extends MMAdminObject implements SystemObject { - - private static final long serialVersionUID = 7913646658641775637L; - Date startTime; - boolean isStarted; - - - /**Dummy identifier for the system as a whole.*/ - private final static String SYSTEM_IDENTIFIER = "SYSTEM"; //$NON-NLS-1$ - - /** - * Construct a new MMSystem object - * - * @since 4.3 - */ - public MMSystem() { - super(new String[] {SYSTEM_IDENTIFIER}); - } - - - - - /** - * @return Returns whether the system is started. - * @since 4.3 - */ - public boolean isStarted() { - return this.isStarted; - } - - /** - * @param isStarted whether the system is started. - * @since 4.3 - */ - public void setStarted(boolean isStarted) { - this.isStarted = isStarted; - } - - - - - /** - * @return Returns the startTime. - * @since 4.3 - */ - public Date getStartTime() { - return this.startTime; - } - - - /** - * @param startTime The startTime to set. - * @since 4.3 - */ - public void setStartTime(Date startTime) { - this.startTime = startTime; - } - - /** - * Get The Start Date as a String - * @return String - * @since 4.3 - */ - public String getStartDateAsString() { - if( this.startTime != null) - return DateUtil.getDateAsString(getStartTime()); - return "Start Date not Set"; //$NON-NLS-1$ - } - - - /** - * @see java.lang.Object#toString() - */ - public String toString() { - StringBuffer result = new StringBuffer(); - result.append(AdminPlugin.Util.getString("MMSystem.MMSystem")).append(getIdentifier()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMSystem.properties")).append(getPropertiesAsString()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMSystem.isStarted")).append(isStarted()); //$NON-NLS-1$ - result.append(AdminPlugin.Util.getString("MMSystem.startTime")).append(getStartDateAsString()); //$NON-NLS-1$ - return result.toString(); - } - - -} - Deleted: trunk/client/src/main/java/com/metamatrix/admin/objects/MMUser.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/admin/objects/MMUser.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/admin/objects/MMUser.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,56 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package com.metamatrix.admin.objects; - -import org.teiid.adminapi.User; - - -/** - * @since 4.3 - */ -public class MMUser extends MMPrincipal implements User { - private static final long serialVersionUID = -5201466263343170010L; - - /** - * @param identifierParts - * @since 4.3 - */ - public MMUser(String[] identifierParts) { - super(identifierParts, TYPE_USER); - } - - /** - * Determine if the given property name is legal for a User. - * @param propName The name of a user property. - * @return <code>true</code> iff the given name is one of - * the allowed {@link User} properties. - * @since 4.3 - */ - public static final boolean isUserProperty(String propName) { - return (propName.equals(COMMON_NAME) || - propName.equals(GIVEN_NAME) || - propName.equals(SURNAME) || - propName.equals(LOCATION) || - propName.equals(TELEPHONE_NUMBER)); - } -} Modified: trunk/client/src/main/java/com/metamatrix/common/comm/platform/client/ServerAdminFactory.java =================================================================== --- trunk/client/src/main/java/com/metamatrix/common/comm/platform/client/ServerAdminFactory.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/com/metamatrix/common/comm/platform/client/ServerAdminFactory.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -31,6 +31,7 @@ import org.teiid.adminapi.Admin; import org.teiid.adminapi.AdminComponentException; import org.teiid.adminapi.AdminException; +import org.teiid.adminapi.AdminObject; import com.metamatrix.admin.AdminPlugin; import com.metamatrix.api.exception.security.LogonException; @@ -130,7 +131,7 @@ //we'll wait 30 seconds for the server to come back up for (int i = 0; i < 15; i++) { try { - getTarget().getSystem(); + getTarget().getProcesses(AdminObject.WILDCARD); return; } catch (Exception e) { //reestablish a connection and retry Deleted: trunk/client/src/main/java/org/teiid/adminapi/AdminStatus.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/AdminStatus.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/AdminStatus.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,68 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - - -/** - * Base interface of admin status objects. - * Status objects are returned by some admin methods to indicate warnings or additional information, - * that doesn't belong in an Exception. - * - * @since 4.3 - */ -public interface AdminStatus { - - - /** - * Status code indicating an unknown status - */ - public final static int CODE_UNKNOWN = -1; - /** - * Status code indicating that the operation succeeded. - */ - public final static int CODE_SUCCESS = 0; - - /** - * Warning status code indicating that an object could not be decrypted. - */ - public final static int CODE_DECRYPTION_FAILED = -101; - - - - - /** - * Get the status code. - * This will be one of the status codes specified by the constants <code>AdminStatus.CODE_*</code>. - * @return String the unique Identifier - * @since 4.3 - */ - int getCode(); - - /** - * Get the status message. - * @return String Name - * @since 4.3 - */ - String getMessage(); - -} Modified: trunk/client/src/main/java/org/teiid/adminapi/ConfigurationAdmin.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/ConfigurationAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/ConfigurationAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -28,44 +28,14 @@ /** - * This interface describes the methods to configure MetaMatrix. + * This interface describes the methods to configure Teiid. * - * <p>As a <i>core</i> interface, - * this administration is common to both the MetaMatrix server and MM Query.</p> * @since 4.3 */ @RolesAllowed(value=AdminRoles.RoleName.ADMIN_SYSTEM) public interface ConfigurationAdmin { - - /** - * Set system-wide property. This will be written to config_ns.xml - * - * @param propertyName - * Name of the System Property - * @param propertyValue - * Value of the System Property - * @throws AdminException - * if there's a system error or if there's a user input error. - * @since 4.3 - */ - void setSystemProperty(String propertyName, - String propertyValue) throws AdminException; - /** - * Set several system-wide properties. These will be written to config_ns.xml - * Any existing properties not specified will not be changed. - * - * @param properties - * Properties to set. - * @throws AdminException - * if there's a system error or if there's a user input error. - * @since 4.3 - */ - void updateSystemProperties(Properties properties) throws AdminException; - - - /** * Assign a {@link ConnectorBinding} to a {@link VDB}'s Model * * @param connectorBindingName @@ -91,51 +61,15 @@ String modelName) throws AdminException; /** - * Set a Property for an AdminObject - * - * @param identifier - * The unique identifier for for an {@link AdminObject}. - * @param className - * The class name of the sub-interface of {@link AdminObject} you are setting the property for. - * All of these sub-interfaces are in package <code>com.metamatrix.admin.api.objects</code>. - * You may specify either the fully-qualified or unqualified classname. - * For example "ConnectorBinding" or "com.metamatrix.admin.api.objects.ConnectorBinding". + * Set/update the property for the Connector Binding identified by the given deployed name. + * @param deployedName * @param propertyName - * String Property key * @param propertyValue - * String value to update * @throws AdminException - * if there's a system error. - * @since 4.3 */ - void setProperty(String identifier, - String className, - String propertyName, - String propertyValue) throws AdminException; + void setConnectorBindingProperty(String deployedName, String propertyName, String propertyValue) throws AdminException; - /** - * Set several properties for an AdminObject. Any existing properties not specified will not be changed. - * - * @param identifier - * The unique identifier for for an {@link AdminObject}. - * @param className - * The class name of the sub-interface of {@link AdminObject} you are setting the property for. - * All of these sub-interfaces are in package <code>com.metamatrix.admin.api.objects</code>. - * You may specify either the fully-qualified or unqualified classname. - * For example "ConnectorBinding" or "com.metamatrix.admin.api.objects.ConnectorBinding". - * @param properties - * Properties to set. - * @throws AdminException - * if there's a system error or if there's a user input error. - * @since 4.3 - */ - void updateProperties(String identifier, - String className, - Properties properties) throws AdminException; - - - /** * Add Connector Type, will import Connector Type from a file * * @param name @@ -249,6 +183,15 @@ */ VDB addVDB(String name, byte[] vdbFile, AdminOptions options) throws AdminException; + + + /** + * Delete the VDB with the given name and version + * @param vdbName + * @param version + * @throws AdminException + */ + void deleteVDB(String vdbName, String version) throws AdminException; /** * Get the {@link LogConfiguration} @@ -271,7 +214,20 @@ */ void setLogConfiguration(LogConfiguration config) throws AdminException; + /** + * 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. + * + * @param listener The listener component + * @throws AdminException if there's a system error. + * @since 4.3 + */ + void setLogListener(EmbeddedLogger listener) throws AdminException; + + /** * Adds an {@link ExtensionModule} to the end of the list of modules. * <br><i>All caches (of Class objects) are cleared.</i></br> * Modified: trunk/client/src/main/java/org/teiid/adminapi/ConnectorBinding.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/ConnectorBinding.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/ConnectorBinding.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -58,24 +58,16 @@ public static final String PASSWORD = "Password"; //$NON-NLS-1$ - /** - * Returns the String globally unique routing UUID for this - * Connector Binding - * @return Returns the routingUUID. - * @since 4.3 - */ - String getRoutingUUID(); - /** * Retrieve the current connector state. This will be one of the constants: - * {@link DQP#STATE_OPEN DQP.STATE_OPEN}. - * {@link DQP#STATE_NOT_INITIALIZED DQP.STATE_NOT_INITIALIZED}. - * {@link DQP#STATE_CLOSED DQP.STATE_CLOSED}. - * {@link DQP#STATE_FAILED DQP.STATE_FAILED}. - * {@link DQP#STATE_INIT_FAILED DQP.STATE_INIT_FAILED}. - * {@link DQP#STATE_NOT_REGISTERED DQP.STATE_NOT_REGISTERED}. - * {@link DQP#STATE_DATA_SOURCE_UNAVAILABLE DQP.STATE_DATA_SOURCE_UNAVAILABLE}. - * {@link DQP#STATE_NOT_DEPLOYED DQP.STATE_NOT_DEPLOYED}. + * {@link ConnectorBinding#STATE_OPEN DQP.STATE_OPEN}. + * {@link ConnectorBinding#STATE_NOT_INITIALIZED DQP.STATE_NOT_INITIALIZED}. + * {@link ConnectorBinding#STATE_CLOSED DQP.STATE_CLOSED}. + * {@link ConnectorBinding#STATE_FAILED DQP.STATE_FAILED}. + * {@link ConnectorBinding#STATE_INIT_FAILED DQP.STATE_INIT_FAILED}. + * {@link ConnectorBinding#STATE_NOT_REGISTERED DQP.STATE_NOT_REGISTERED}. + * {@link ConnectorBinding#STATE_DATA_SOURCE_UNAVAILABLE DQP.STATE_DATA_SOURCE_UNAVAILABLE}. + * {@link ConnectorBinding#STATE_NOT_DEPLOYED DQP.STATE_NOT_DEPLOYED}. * @return current connector state. */ int getState(); Deleted: trunk/client/src/main/java/org/teiid/adminapi/DQP.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/DQP.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/DQP.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,88 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - -import java.util.Date; - -/** - * The distributed query processor, which is the internal query engine component used by MetaMatrix products. - * - * @since 4.3 - */ -public interface DQP extends - AdminObject { - - - /**Registered by not initialized*/ - public static final int STATE_NOT_INITIALIZED = 0; - /**Open and running*/ - public static final int STATE_OPEN = 1; - /**Registered but closed*/ - public static final int STATE_CLOSED = 2; - /**Failed after running successfully*/ - public static final int STATE_FAILED = 3; - /**Failed during initialization*/ - public static final int STATE_INIT_FAILED = 4; - /**Not registered*/ - public static final int STATE_NOT_REGISTERED = 5; - /**Running, but the underlying data source is unavailable*/ - public static final int STATE_DATA_SOURCE_UNAVAILABLE = 6; - /**Running, not deployed*/ - public static final int STATE_NOT_DEPLOYED = 7; - - /** - * Retrieve the current connector state. This will be one of the constants: - * {@link DQP#STATE_OPEN DQP.STATE_OPEN}. - * {@link DQP#STATE_NOT_INITIALIZED DQP.STATE_NOT_INITIALIZED}. - * {@link DQP#STATE_CLOSED DQP.STATE_CLOSED}. - * {@link DQP#STATE_FAILED DQP.STATE_FAILED}. - * {@link DQP#STATE_INIT_FAILED DQP.STATE_INIT_FAILED}. - * {@link DQP#STATE_NOT_REGISTERED DQP.STATE_NOT_REGISTERED}. - * {@link DQP#STATE_DATA_SOURCE_UNAVAILABLE DQP.STATE_DATA_SOURCE_UNAVAILABLE}. - * {@link DQP#STATE_NOT_DEPLOYED DQP.STATE_NOT_DEPLOYED}. - * @return current connector state. - */ - int getState(); - - /** - * Retrieve the current connector state. - * - * @return current connector state. - */ - String getStateAsString(); - - /** - * Retrieve time of last state change. - * - * @return time of last state change. - * @since 4.3 - */ - Date getStateChangedTime(); - - /** - * Returns the description. - * - * @return description - */ - public String getDescription(); -} Deleted: trunk/client/src/main/java/org/teiid/adminapi/Entitlement.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/Entitlement.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/Entitlement.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,42 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - -import java.util.Collection; - - -/** - * @since 4.3 - */ -public interface Entitlement extends AdminObject { - - /** - * Get the Collection of {@link Principal}s that possess - * this Entitlement. - * @param principalIdentifier - * @return The collection of entitled {@link Principal}s. - * @since 4.3 - */ - Collection getPrincipals(String principalIdentifier); - -} Modified: trunk/client/src/main/java/org/teiid/adminapi/Group.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/Group.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/Group.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -22,18 +22,14 @@ package org.teiid.adminapi; + /** - * A Group is a MetaMatrix principal that can contain other Principals - * as members. A Group can contain {@link User}s and other Groups. - * - * <p>See {@link Principal} for identity pattern.</p> - * @since 4.3 + * This interface is used to represent a group of principals. */ -public interface Group extends Principal { +public interface Group extends AdminObject { /** - * Optional property for a group + * Optional property for a group; group description */ - /** The group description */ static final String DESCRIPTION = "description"; //$NON-NLS-1$ } Deleted: trunk/client/src/main/java/org/teiid/adminapi/Host.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/Host.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/Host.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,75 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - - - -/** - * Represents a host in the MetaMatrix system. - * - * <p>The identifier pattern for a host is <code>"hostName"</code>. - * A hostName is considered to be unique across the system.</p> - * @since 4.3 - */ -public interface Host extends AdminObject { - - /** - * Install Directory Property - */ - public static final String INSTALL_DIR = "metamatrix.installationDir"; //$NON-NLS-1$ - - /** - * Log Directory Property - */ - public static final String LOG_DIRECTORY = "metamatrix.log.dir"; //$NON-NLS-1$ - - /** - * Host Directory Property - */ - public static final String HOST_DIRECTORY = "metamatrix.host.dir"; //$NON-NLS-1$ - - /** - * Host Enabled Property - */ - public static final String HOST_ENABLED = "host.enabled"; //$NON-NLS-1$ - - /** - * Host Bind Address Property - */ - public static final String HOST_BIND_ADDRESS = "metamatrix.host.bind.address"; //$NON-NLS-1$ - - /** - * Host Physical Address Property - */ - public static final String HOST_PHYSICAL_ADDRESS = "metamatrix.host.physical.address"; //$NON-NLS-1$ - - - /** - * Return true if this Host is executing. - * - * @return if this Host is actively participating - * in the MetaMatrix system. - * @since 4.3 - */ - public boolean isRunning(); -} Modified: trunk/client/src/main/java/org/teiid/adminapi/MonitoringAdmin.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/MonitoringAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/MonitoringAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -27,13 +27,9 @@ import com.metamatrix.admin.RolesAllowed; - /** - * Used to access the monitorable components of the MetaMatrix system. + * Used to access the monitorable components of the Teiid system. * - * <p>As a <i>core</i> interface, - * this administration is common to both the MetaMatrix server and MM Query.</p> - * * <p>See the particular admin object in question for an example of * allowed identifier patterns.</p> * @@ -43,15 +39,6 @@ public interface MonitoringAdmin { /** - * Retrieve the single System object. - * - * @return The single {@link SystemObject} object, for interacting with system-wide configuration - * @throws AdminException if there's a system error. - * @since 4.3 - */ - SystemObject getSystem() throws AdminException; - - /** * Get the Connector Types that correspond to the specified identifier pattern. * * @param connectorTypeIdentifier the unique identifier for for a {@link ConnectorType} @@ -64,7 +51,7 @@ * @throws AdminException if there's a system error. * @since 4.3 */ - Collection getConnectorTypes(String connectorTypeIdentifier) throws AdminException; + Collection<ConnectorType> getConnectorTypes(String connectorTypeIdentifier) throws AdminException; /** * Get the VDBs that correspond to the specified identifier pattern. @@ -81,7 +68,7 @@ * @since 4.3 */ @RolesAllowed(value=AdminRoles.RoleName.ANONYMOUS) - Collection getVDBs(String vdbIdentifier) throws AdminException; + Collection<VDB> getVDBs(String vdbIdentifier) throws AdminException; /** * Get the Connector Bindings that correspond to the specified identifier pattern. @@ -96,7 +83,7 @@ * @throws AdminException if there's a system error. * @since 4.3 */ - Collection getConnectorBindings(String connectorBindingIdentifier) throws AdminException; + Collection<ConnectorBinding> getConnectorBindings(String connectorBindingIdentifier) throws AdminException; /** * Get all the Connector Bindings for the given VDB identifier pattern @@ -110,7 +97,7 @@ * @throws AdminException if there's a system error. * @since 4.3 */ - Collection getConnectorBindingsInVDB(String identifier) throws AdminException; + Collection<ConnectorBinding> getConnectorBindingsInVDB(String identifier) throws AdminException; /** * Get the Extension Modules that correspond to the specified identifier pattern @@ -141,7 +128,7 @@ * @throws AdminException if there's a system error. * @since 4.3 */ - Collection getQueueWorkerPools(String identifier) throws AdminException; + Collection<QueueWorkerPool> getQueueWorkerPools(String identifier) throws AdminException; /** @@ -175,7 +162,7 @@ * @throws AdminException if there's a system error. * @since 4.3 */ - Collection getCaches(String identifier) throws AdminException; + Collection<Cache> getCaches(String identifier) throws AdminException; /** * Get the Sessions that correspond to the specified identifier pattern @@ -222,23 +209,14 @@ */ Collection<Request> getSourceRequests(String identifier) throws AdminException; + /** * Get all of the available Configuration Properties for the specified AdminObject, and details about them. - * @param identifier - * The unique identifier for for an {@link AdminObject}. - * @param className - * The class name of the sub-interface of {@link AdminObject} you are setting the property for. These are all the - * supported class names. {@link SystemObject}, {@link Host}, {@link ProcessObject}, {@link ConnectorBinding}, - * {@link ConnectorType},{@link DQP}, {@link Resource} - * - * Note that in Embedded mode only supported classes are {@link ConnectorBinding}, {@link ConnectorType}, - * {@link SystemObject} - * @return Collection of PropertyDefinition objects. - * @throws AdminException if there's a system error. - * @since 4.3 + * @param connectorTypeIdentifier + * @return + * @throws AdminException */ - Collection getPropertyDefinitions(String identifier, - String className) throws AdminException; + Collection<PropertyDefinition> getConnectorTypePropertyDefinitions(String connectorTypeIdentifier) throws AdminException; /** Deleted: trunk/client/src/main/java/org/teiid/adminapi/Principal.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/Principal.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/Principal.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,68 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - - -/** - * A Principal may participate in entitlements (authorization). A Principal - * may also posess administrative roles for the system. - * - * <p>The identifier pattern for all principal types is <code>"name"</code>. - * A name is concidered to be unique across the system for all - * principal types.</p> - * @since 4.3 - */ -public interface Principal extends AdminObject { - - /** User internal type. Note that a User can be of type Admin and vice versa. */ - static final int TYPE_USER = 0; - /** Group internal type */ - static final int TYPE_GROUP = 1; - /** Admin internal type. Note that a User can be of type Admin and vice versa. */ - static final int TYPE_ADMIN = 2; - - /** Display String for User type */ - static final String TYPE_LABEL_USER = "User"; //$NON-NLS-1$ - /** Display String for Group type */ - static final String TYPE_LABEL_GROUP = "Group"; //$NON-NLS-1$ - /** Display String for Admin type */ - static final String TYPE_LABEL_ADMIN = "Admin"; //$NON-NLS-1$ - - /** User and Group names can be no longer then this */ - static final int NAME_LEN_LIMIT = 32; - - /** - * Get the Principal type for this principal. - * @return the internal type of this user. - * @since 4.3 - */ - int getType(); - - /** - * Get the Principal type String for this principal. - * @return the String representation type of this user. - * @since 4.3 - */ - String getTypeLabel(); - -} Modified: trunk/client/src/main/java/org/teiid/adminapi/ProcessObject.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/ProcessObject.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/ProcessObject.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -23,63 +23,35 @@ package org.teiid.adminapi; import java.net.InetAddress; +import java.util.Date; - /** - * A Process in the MetaMatrix system. + * A Process in the Teiid System * - * <p>The identifier pattern for a Process is <code>"hostName.processName"</code>. - * This Process identifier is concidered to be unique across the system.</p> + * <p>The identifier pattern for a Process is <code>"processName"</code>. + * This Process identifier is considered to be unique across the system.</p> * @since 4.3 */ public interface ProcessObject extends AdminObject { + /** - * Process Min Heap Size Property Name + * Get the Host name + * + * @return String host name where the process is running + * @since 4.3 */ - public static final String VM_MINIMUM_HEAP_SIZE_PROPERTY_NAME = "vm.starter.minHeapSize"; //$NON-NLS-1$ - /** - * Process Max Heap Size Property Name - */ - public static final String VM_MAXIMUM_HEAP_SIZE_PROPERTY_NAME = "vm.starter.maxHeapSize"; //$NON-NLS-1$ - /** - * Process Port Property Name - */ - public static final String SERVER_PORT = "vm.socketPort"; //$NON-NLS-1$ - /** - * Process Max Treads Property Name - */ - public static final String MAX_THREADS = "vm.maxThreads"; //$NON-NLS-1$ - /** - * Process Time To Live Property Name - */ - public static final String TIMETOLIVE = "vm.timetolive"; //$NON-NLS-1$ - /** - * Process Import Buffer Size Property Name - */ - public static final String INPUT_BUFFER_SIZE = "vm.inputBufferSize"; //$NON-NLS-1$ - /** - * Process Output Buffer Size Property Name - */ - public static final String OUTPUT_BUFFER_SIZE = "vm.outputBufferSize"; //$NON-NLS-1$ - /** - * Process Forced Shutdown Time Property Name - */ - public static final String FORCED_SHUTDOWN_TIME = "vm.forced.shutdown.time"; //$NON-NLS-1$ - /** - * Process Enabled Flag Property Name - */ - public static final String ENABLED_FLAG = "vm.enabled"; //$NON-NLS-1$ - - /** - * Get the {@link Host} Identifier for this MetaMatrix Process + public String getHostName(); + + /** + * Get the Process name * - * @return String A unique identifier for the Host of this Process. + * @return String A unique identifier for this Process. * @since 4.3 */ - public String getHostIdentifier(); + public String getProcessName(); /** @@ -127,37 +99,37 @@ * @since 4.3 */ public boolean isRunning(); - + /** - * @return Returns the maxSockets. - * @since 4.3 - */ - public int getMaxSockets(); - /** - * @return Returns the maxVirtualSockets. - * @since 4.3 - */ - public int getMaxVirtualSockets(); - /** * @return Returns the objectsRead. * @since 4.3 */ public long getObjectsRead(); + /** * @return Returns the objectsWritten. * @since 4.3 */ public long getObjectsWritten(); + + /** + * @return Returns the maxSockets. + * @since 4.3 + */ + public int getMaxSockets(); + + /** * @return Returns the sockets. * @since 4.3 */ public int getSockets(); + /** - * @return Returns the virtualSockets. + * @return Returns the startTime. * @since 4.3 */ - public int getVirtualSockets(); + public Date getStartTime(); /** Deleted: trunk/client/src/main/java/org/teiid/adminapi/Resource.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/Resource.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/Resource.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,36 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - - -/** - * @since 4.3 - */ -public interface Resource extends AdminObject { - - /** - * The environment property that indicates the name of the pool. - */ - public static final String RESOURCE_POOL = "metamatrix.common.pooling.resource.name"; //$NON-NLS-1$ - -} Modified: trunk/client/src/main/java/org/teiid/adminapi/RuntimeStateAdmin.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/RuntimeStateAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/RuntimeStateAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -28,12 +28,9 @@ /** - * This interface defines the methods to interact with the MetaMatrix system + * This interface defines the methods to interact with the Teiid system * during runtime. * - * <p>As a <i>core</i> interface, - * this administration is common to both the MetaMatrix server and MM Query.</p> - * * @since 4.3 */ @RolesAllowed(value=AdminRoles.RoleName.ADMIN_PRODUCT) @@ -136,18 +133,9 @@ * @throws AdminException */ void terminateTransaction(String transactionId, String sessionId) throws AdminException; + /** - * 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. - * - * @param listener The listener component - * @throws AdminException if there's a system error. - * @since 4.3 - */ - void setLogListener(EmbeddedLogger listener) throws AdminException; - - /** * Stop the MM Query. If millisToWait is >0, then close to incoming queries, wait the time period * for work to stop, then stop the MM Query. Otherwise, stop immediately, aborting all running queries. * @param millisToWait Milliseconds to wait (if >0) or <=0 for no wait before stopping Deleted: trunk/client/src/main/java/org/teiid/adminapi/ScriptsContainer.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/ScriptsContainer.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/ScriptsContainer.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,68 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - -import java.io.Serializable; -import java.util.Collection; - - - - -/** - * Contains all information nessecary to save the scripts that will be run - * by a MetaMatrix utility to load or refresh the data resident in a - * Materialized View. - * <p> - * Users can get the contents of each file and save each with the - * filename associated with it or, more easily, users can save all files - * to a local folder. (See {@link #saveAllToDirectory})</p> - * <p> - * @since 4.3 - */ -public interface ScriptsContainer extends Serializable { - - /** - * Get the file names of all scripts in this container. - * - * @return The <code>Collection</code> of <code>String</code> - * file names of all scripts in this container. This - * collection may be empty if an error has occured. - * @since 4.3 - */ - Collection getFileNames(); - - /** - * Save all of the scripts contained to the specified local - * directory. - * - * @param directoryLocation the directory location to save - * the contained scripts. Must be accessable from where - * this code is running. - * @param options Specify whether to {@link AdminOptions.OnConflict#OVERWRITE} - * or {@link AdminOptions.OnConflict#EXCEPTION} (default) when script files - * exist in the <code>directoryLocation</code>. - * @throws AdminException if there's an error saving the files. - * @since 4.3 - */ - void saveAllToDirectory(String directoryLocation, AdminOptions options) throws AdminException; -} Modified: trunk/client/src/main/java/org/teiid/adminapi/SecurityAdmin.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/SecurityAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/SecurityAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -40,9 +40,7 @@ /** * Get the Collection of administrative role names possessed by the given group, if any. * - * @param groupIdentifier - * The unique identifier for the {@link Group}. This is group name. A user is a {@link Principal} and a - * Principal name is considered to be unique throughout the MetaMatrix system across all Membership domains. + * @param groupIdentifier The unique identifier for the {@link Group}. This is group name. * The {@link AdminObject#WILDCARD WILDCARD} cannot be used here. * @return The Collection of {@link Role}s. * @throws AdminException @@ -55,8 +53,7 @@ * Get the group memberships for the given user. * * @param userIdentifier - * The unique identifier for the user. This is generally a user name. A user is a {@link Principal} and a - * Principal name is considered to be unique throughout the MetaMatrix system across all Membership domains. + * The unique identifier for the user. This is generally a user name. * The {@link AdminObject#WILDCARD WILDCARD} cannot be used here. * @return The collection of groups in which the given user has membership. * @throws AdminException @@ -70,9 +67,8 @@ * Get the group denoted by the given <code>groupIdentifier</code>. * * @param groupIdentifier - * The unique identifier for the {@link Group}. This is generally a group name. A group is a {@link Principal} and - * a Principal name is considered to be unique throughout the MetaMatrix system across all Membership domains. <br> - * Note that by supplying the {@link AdminObject#WILDCARD WILDCARD} identifier, all all users in the system will + * The unique identifier for the {@link Group}. This is generally a group name. + * Note that by supplying the {@link AdminObject#WILDCARD WILDCARD} identifier, all all groups in the system will * retrieved.</br> * @return The Collection of groups. * @throws AdminException @@ -87,7 +83,7 @@ * @param roleIdentifier * one of {@link AdminRoles}. * @param groupIdentifier - * the unique identifier for the Principal. The {@link AdminObject#WILDCARD WILDCARD} cannot be used here. + * the unique identifier for the Group. The {@link AdminObject#WILDCARD WILDCARD} cannot be used here. * @throws AdminException * if there's a system error. * @since 4.3 @@ -101,7 +97,7 @@ * @param roleIdentifier * one of {@link AdminRoles} * @param groupIdentifier - * the unique identifier for the Principal. The {@link AdminObject#WILDCARD WILDCARD} cannot be used here. + * the unique identifier for the group. The {@link AdminObject#WILDCARD WILDCARD} cannot be used here. * @throws AdminException * if there's a system error. * @since 4.3 Deleted: trunk/client/src/main/java/org/teiid/adminapi/Service.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/Service.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/Service.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,98 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - -import java.util.Date; - -/** - * Represents a service in the MetaMatrix system. - * - * <p>The unique identifier pattern is [host]<{@link #DELIMITER}>[process]<{@link #DELIMITER}>[Service Name] - * when running against a MetaMatrix server. The [Service Name] can itself have spaces in the name. - * In the case of the MM Query, a Service does not apply as MM Query is not running within a MM Server VM.</p> - * - * @since 4.3 - */ -public interface Service extends - AdminObject { - /**Registered by not initialized*/ - public static final int STATE_NOT_INITIALIZED = 0; - /**Open and running*/ - public static final int STATE_OPEN = 1; - /**Registered but closed*/ - public static final int STATE_CLOSED = 2; - /**Failed after running successfully*/ - public static final int STATE_FAILED = 3; - /**Failed during initialization*/ - public static final int STATE_INIT_FAILED = 4; - /**Not registered*/ - public static final int STATE_NOT_REGISTERED = 5; - /**Running, but the underlying data source is unavailable*/ - public static final int STATE_DATA_SOURCE_UNAVAILABLE = 6; - /**Running, not deployed*/ - public static final int STATE_NOT_DEPLOYED = 7; - - /** - * Retrieve the current connector state. This will be one of the constants: - * {@link DQP#STATE_OPEN DQP.STATE_OPEN}. - * {@link DQP#STATE_NOT_INITIALIZED DQP.STATE_NOT_INITIALIZED}. - * {@link DQP#STATE_CLOSED DQP.STATE_CLOSED}. - * {@link DQP#STATE_FAILED DQP.STATE_FAILED}. - * {@link DQP#STATE_INIT_FAILED DQP.STATE_INIT_FAILED}. - * {@link DQP#STATE_NOT_REGISTERED DQP.STATE_NOT_REGISTERED}. - * {@link DQP#STATE_DATA_SOURCE_UNAVAILABLE DQP.STATE_DATA_SOURCE_UNAVAILABLE}. - * {@link DQP#STATE_NOT_DEPLOYED DQP.STATE_NOT_DEPLOYED}. - * @return current connector state. - */ - int getState(); - - /** - * Retrieve the current connector state as a printable <code>String</code>. - * @return current connector state in String form. - */ - String getStateAsString(); - - /** - * Returns time of last state change. - * - * @return time of last state change. - * @since 4.3 - */ - Date getStateChangedTime(); - - /** - * Returns the description - * - * @return description - */ - String getDescription(); - - /** - * Get the component type identifier for this service {@link ComponentType}. - * @return the Component Type identifier which can be used to - * find the ComponentType. - * @since 6.1 - */ - String getComponentTypeName(); - -} Deleted: trunk/client/src/main/java/org/teiid/adminapi/SystemObject.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/SystemObject.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/SystemObject.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,50 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - -import java.util.Date; - - -/** - * @since 4.3 - */ -public interface SystemObject extends AdminObject { - - /** - * @return Returns whether the system is started. - * @since 4.3 - */ - public boolean isStarted(); - - - - /** - * @return Returns the startTime. - * @since 4.3 - */ - public Date getStartTime(); - - - - -} Deleted: trunk/client/src/main/java/org/teiid/adminapi/User.java =================================================================== --- trunk/client/src/main/java/org/teiid/adminapi/User.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/java/org/teiid/adminapi/User.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -1,52 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * See the COPYRIGHT.txt file distributed with this work for information - * regarding copyright ownership. Some portions may be licensed - * to Red Hat, Inc. under one or more contributor license agreements. - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA - * 02110-1301 USA. - */ - -package org.teiid.adminapi; - -/** - * A user of the MetaMatrix system may a participant or an - * administrator of the MetaMatrix system. - * <p> - * A User is an actor in the MetaMatrix system. A User - * can log in (authenticate) and perform actions on the system.</p> - * - * <p>See {@link Principal} for identity pattern and other - * abilities.</p> - * @since 4.3 - */ -public interface User extends Principal { - - /** - * Optional properties for Users - */ - /** User's common name */ - static final String COMMON_NAME = "commonName"; //$NON-NLS-1$ - /** User's given name */ - static final String GIVEN_NAME = "givenName"; //$NON-NLS-1$ - /** User's surname (last name) */ - static final String SURNAME = "surName"; //$NON-NLS-1$ - /** User's location */ - static final String LOCATION = "location"; //$NON-NLS-1$ - /** User's telephone number */ - static final String TELEPHONE_NUMBER = "telephoneNumber"; //$NON-NLS-1$ - -} Modified: trunk/client/src/main/resources/com/metamatrix/admin/i18n.properties =================================================================== --- trunk/client/src/main/resources/com/metamatrix/admin/i18n.properties 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/main/resources/com/metamatrix/admin/i18n.properties 2009-08-28 22:27:14 UTC (rev 1291) @@ -33,11 +33,6 @@ MMAdminObject.Unsupported_Admin_Object=Unable to load AdminObjects of Class {0}. -MMAdminStatus.MMAdminStatus=MMAdminStatus:\ -MMAdminStatus.Code=\n Code:\ -MMAdminStatus.Message=\n Message:\ - - MMConnectionPool.MMConnectionPool=MMConnectionPool:\n Identifier:\ MMConnectionPool.Type=\n Type:\ MMConnectionPool.Active=\n Active:\ @@ -65,77 +60,17 @@ MMConnectorBinding.IsRegistered=\n Is Running:\ MMConnectorBinding.Properties=\n Properties:\ - -MMService.unknown=Unknown -MMService.open=Open -MMService.closed=Closed -MMService.failed=Failed -MMService.initializationFailed=Initialization Failed -MMService.notInitialized=Not Initialized -MMService.notRegistered=Not Registered -MMService.dataSourceUnavailable=DataSourceUnavailable - -MMService.MMService=MMService: \n Identifier:\ -MMService.Description=\n Description:\ -MMService.Created=\n Created:\ -MMService.Created_By=\n Created By:\ -MMService.Updated=\n Updated:\ -MMService.Updated_By=\n Updated By:\ -MMService.State=\n State:\ -MMService.State_Changed=\n State Changed:\ -MMService.IsDeployed=\n Is Deployed:\ -MMService.IsRegistered=\n Is Running:\ -MMService.Properties=\n Properties:\ - - - MMConnectorType.MMConnectorType=MMConnectorType: \n Identifier:\ MMConnectorType.Created=\n Created:\ MMConnectorType.Created_By=\n Created By:\ MMConnectorType.Updated=\n Updated:\ MMConnectorType.Updated_By=\n Updated By:\ - - -MMDQP.unknown=Unknown -MMDQP.open=Open -MMDQP.closed=Closed -MMDQP.failed=Failed -MMDQP.initializationFailed=Initialization Failed -MMDQP.notInitialized=Not Initialized -MMDQP.notRegistered=Not Registered -MMDQP.dataSourceUnavailable=DataSourceUnavailable - -MMDQP.MMDQP=MMDQP: \n Identifier:\ -MMDQP.Description=\n Description:\ -MMDQP.Created=\n Created:\ -MMDQP.Created_By=\n Created By:\ -MMDQP.Updated=\n Updated:\ -MMDQP.Updated_By=\n Updated By:\ -MMDQP.State=\n State:\ -MMDQP.State_Changed=\n State Changed:\ -MMDQP.IsDeployed=\n Is Deployed:\ -MMDQP.IsRegistered=\n Is Running:\ -MMDQP.Properties=\n Properties:\ - - - MMExtensionModule.MMExtensionModule=MMExtensionModule: \n Identifier:\ MMExtensionModule.moduleType=\n Module Type:\ MMExtensionModule.description=\n Decription:\ - -MMHost.MMHost=MMHost:\n Identifier:\ -MMHost.Properties=\n Properties:\ -MMHost.Created=\ Created:\ -MMHost.Created_By=\n Created By:\ -MMHost.Updated=\n Updated:\ -MMHost.Updated_By=\n Updated By:\ -MMHost.IsRunning=\n Is Running:\ -MMHost.IsDeployed=\n Is Deployed:\ - - MMModel.MMModel=MMModel:\n Identifier:\ MMModel.type=\n Type:\ MMModel.physical=\n Physical:\ @@ -163,15 +98,15 @@ MMProcess.TotalMemory=\n Total Memory:\ MMProcess.FreeMemory=\n Free Memory:\ MMProcess.ThreadCount=\n Thread Count:\ -MMProcess.HostIdentifier=\n Host Identifier:\ +MMProcess.ProcessName=\n Process Name:\ +MMProcess.HostName=\n Host Name:\ MMProcess.Port=\n Port:\ MMProcess.InetAddress=\n InetAddress:\ MMProcess.IsDeployed=\n Is Deployed:\ MMProcess.IsRunning=\n Is Running:\ MMProcess.Sockets=\n Sockets:\ MMProcess.MaxSockets=\n Max Sockets:\ -MMProcess.VirtualSockets=\n Virtual Sockets:\ -MMProcess.MaxVirtualSockets=\n Max Virtual Sockets:\ +MMProcess.StartTime=\n StartTime:\ MMProcess.ObjectsRead=\n Objects Read:\ MMProcess.ObjectsWritten=\n Objects Written:\ MMProcess.QueueWorkerPool=\n Queue Worker Pool:\ Modified: trunk/client/src/test/java/com/metamatrix/common/comm/platform/client/TestSeverAdminFactory.java =================================================================== --- trunk/client/src/test/java/com/metamatrix/common/comm/platform/client/TestSeverAdminFactory.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/client/src/test/java/com/metamatrix/common/comm/platform/client/TestSeverAdminFactory.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -57,7 +57,7 @@ verify(sa, times(1)).restart(); //here's the test we issue to see that the system is up after the bounce - verify(sa, times(1)).getSystem(); + verify(sa, times(1)).getProcesses("*"); //$NON-NLS-1$ } } Modified: trunk/common-internal/src/main/java/com/metamatrix/common/config/api/HostType.java =================================================================== --- trunk/common-internal/src/main/java/com/metamatrix/common/config/api/HostType.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/common-internal/src/main/java/com/metamatrix/common/config/api/HostType.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -30,25 +30,25 @@ public static final String COMPONENT_TYPE_NAME = "Host"; //$NON-NLS-1$ - public static final String INSTALL_DIR = org.teiid.adminapi.Host.INSTALL_DIR; + public static final String INSTALL_DIR = "metamatrix.installationDir"; //$NON-NLS-1$ - public static final String LOG_DIRECTORY = org.teiid.adminapi.Host.LOG_DIRECTORY; + public static final String LOG_DIRECTORY = "metamatrix.log.dir"; //$NON-NLS-1$ - public static final String HOST_DIRECTORY = org.teiid.adminapi.Host.HOST_DIRECTORY; + public static final String HOST_DIRECTORY = "metamatrix.host.dir"; //$NON-NLS-1$ - public static final String HOST_ENABLED = org.teiid.adminapi.Host.HOST_ENABLED; + public static final String HOST_ENABLED = "host.enabled"; //$NON-NLS-1$ /** * When specified, indicates what address the host will be bound to. If this * is not specified, then the host (logical) name will be used. */ - public static final String HOST_BIND_ADDRESS = org.teiid.adminapi.Host.HOST_BIND_ADDRESS; + public static final String HOST_BIND_ADDRESS = "metamatrix.host.bind.address"; //$NON-NLS-1$ /** * The physical address represents a resolvable address for which the host can * be found. This may or may not be the same as the host name. */ - public static final String HOST_PHYSICAL_ADDRESS = org.teiid.adminapi.Host.HOST_PHYSICAL_ADDRESS; + public static final String HOST_PHYSICAL_ADDRESS = "metamatrix.host.physical.address"; //$NON-NLS-1$ } \ No newline at end of file Modified: trunk/common-internal/src/main/java/com/metamatrix/common/config/api/VMComponentDefnType.java =================================================================== --- trunk/common-internal/src/main/java/com/metamatrix/common/config/api/VMComponentDefnType.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/common-internal/src/main/java/com/metamatrix/common/config/api/VMComponentDefnType.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -29,22 +29,22 @@ public static final String COMPONENT_TYPE_NAME = "VM"; //$NON-NLS-1$ - public static final String VM_MINIMUM_HEAP_SIZE_PROPERTY_NAME = org.teiid.adminapi.ProcessObject.VM_MINIMUM_HEAP_SIZE_PROPERTY_NAME; - public static final String VM_MAXIMUM_HEAP_SIZE_PROPERTY_NAME = org.teiid.adminapi.ProcessObject.VM_MAXIMUM_HEAP_SIZE_PROPERTY_NAME; + public static final String VM_MINIMUM_HEAP_SIZE_PROPERTY_NAME = "vm.starter.minHeapSize"; //$NON-NLS-1$ + public static final String VM_MAXIMUM_HEAP_SIZE_PROPERTY_NAME = "vm.starter.maxHeapSize"; //$NON-NLS-1$ // Socket VM related properties /** * @see SocketVMController */ public static final String CLUSTER_PORT = "vm.unicast.port"; //$NON-NLS-1$ - public static final String SERVER_PORT = org.teiid.adminapi.ProcessObject.SERVER_PORT; - public static final String MAX_THREADS = org.teiid.adminapi.ProcessObject.MAX_THREADS; - public static final String TIMETOLIVE = org.teiid.adminapi.ProcessObject.TIMETOLIVE; + public static final String SERVER_PORT ="vm.socketPort"; //$NON-NLS-1$ + public static final String MAX_THREADS = "vm.maxThreads"; //$NON-NLS-1$ + public static final String TIMETOLIVE = "vm.timetolive"; //$NON-NLS-1$ - public static final String INPUT_BUFFER_SIZE = org.teiid.adminapi.ProcessObject.INPUT_BUFFER_SIZE; - public static final String OUTPUT_BUFFER_SIZE = org.teiid.adminapi.ProcessObject.OUTPUT_BUFFER_SIZE; - public static final String FORCED_SHUTDOWN_TIME = org.teiid.adminapi.ProcessObject.FORCED_SHUTDOWN_TIME; - public static final String ENABLED_FLAG = org.teiid.adminapi.ProcessObject.ENABLED_FLAG; + public static final String INPUT_BUFFER_SIZE = "vm.inputBufferSize"; //$NON-NLS-1$ + public static final String OUTPUT_BUFFER_SIZE = "vm.outputBufferSize"; //$NON-NLS-1$ + public static final String FORCED_SHUTDOWN_TIME = "vm.forced.shutdown.time"; //$NON-NLS-1$ + public static final String ENABLED_FLAG = "vm.enabled"; //$NON-NLS-1$ /** * When specified, indicates what address the vm will be bound to. If this is not Modified: trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/BaseAdmin.java =================================================================== --- trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/BaseAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/BaseAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -38,11 +38,9 @@ import org.teiid.adminapi.Cache; import org.teiid.adminapi.ExtensionModule; import org.teiid.adminapi.Session; -import org.teiid.adminapi.SystemObject; import org.teiid.dqp.internal.process.DQPWorkContext; import org.teiid.dqp.internal.process.Util; -import com.metamatrix.admin.objects.MMAdminObject; import com.metamatrix.admin.objects.MMConnectorBinding; import com.metamatrix.admin.objects.MMConnectorType; import com.metamatrix.admin.objects.MMExtensionModule; @@ -51,10 +49,10 @@ import com.metamatrix.admin.objects.MMPropertyDefinition; import com.metamatrix.admin.objects.MMRequest; import com.metamatrix.admin.objects.MMSession; -import com.metamatrix.admin.objects.MMSystem; import com.metamatrix.admin.objects.MMVDB; import com.metamatrix.api.exception.MetaMatrixComponentException; import com.metamatrix.api.exception.security.SessionServiceException; +import com.metamatrix.common.application.exception.ApplicationLifecycleException; import com.metamatrix.common.config.api.ComponentType; import com.metamatrix.common.config.api.ComponentTypeDefn; import com.metamatrix.common.config.api.ConnectorBinding; @@ -538,20 +536,6 @@ } } - /** - * Get the system state. - * @return - */ - public SystemObject getSystem() { - MMSystem system = new MMSystem(); - system.setStartTime(new Date(manager.getStartTime())); - system.setStarted(manager.isAlive()); - system.setProperties(getConfigurationService().getSystemProperties()); - return system; - } - - - boolean isMaskedProperty(String propName, ComponentType type) { if (type != null) { ComponentTypeDefn typeDef = type.getComponentTypeDefinition(propName); @@ -643,38 +627,29 @@ return results; } - - - /** - * Get admin objects of the specified className that match the specified identifier. - * @param identifier - * @param className - * @return - * @since 4.3 - */ - protected Collection getAdminObjects(String identifier, String className) throws AdminException { - - int code = MMAdminObject.getObjectType(className); - - ArrayList list = null; - switch(code) { - case MMAdminObject.OBJECT_TYPE_CONNECTOR_BINDING: - return getConnectorBindings(identifier); - case MMAdminObject.OBJECT_TYPE_CONNECTOR_TYPE: - return getConnectorTypes(identifier); - case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: - list = new ArrayList(); - list.add(getSystem()); - return list; - - default: - throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("AdminImpl.Unsupported_Admin_Object", className)); //$NON-NLS-1$ - - } - } - protected SessionToken validateSession() { return DQPWorkContext.getWorkContext().getSessionToken(); } + protected void changeVDBStatus(String name, String version, int status) + throws AdminException { + try { + + if (name == null || version == null || !name.matches(SINGLE_WORD_REGEX)) { + throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.Invalid_vdb_name")); //$NON-NLS-1$ + } + + // Now change the VDB status it self + this.getVDBService().changeVDBStatus(name, version, status); + + // If the VDB is modified and if its status changed to DELETED, then + // we can remove all the connector bindings associated with this VDB + // the above delete will also remove them + } catch (ApplicationLifecycleException e) { + throw new AdminComponentException(e); + } catch (MetaMatrixComponentException e) { + throw new AdminComponentException(e); + } + } + } Modified: trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPConfigAdminImpl.java =================================================================== --- trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPConfigAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPConfigAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -34,16 +34,13 @@ import org.teiid.adminapi.AdminComponentException; import org.teiid.adminapi.AdminException; -import org.teiid.adminapi.AdminObject; import org.teiid.adminapi.AdminOptions; import org.teiid.adminapi.AdminProcessingException; -import org.teiid.adminapi.AdminStatus; import org.teiid.adminapi.ConfigurationAdmin; +import org.teiid.adminapi.EmbeddedLogger; import org.teiid.adminapi.LogConfiguration; import org.teiid.adminapi.VDB; -import com.metamatrix.admin.objects.MMAdminObject; -import com.metamatrix.admin.objects.MMAdminStatus; import com.metamatrix.api.exception.MetaMatrixComponentException; import com.metamatrix.common.application.exception.ApplicationLifecycleException; import com.metamatrix.common.config.api.ComponentType; @@ -81,112 +78,38 @@ } /** - * @see org.teiid.adminapi.ConfigurationAdmin#setSystemProperty(java.lang.String, java.lang.String) - * @since 4.3 - */ - public void setSystemProperty(String propertyName,String propertyValue) - throws AdminException { - try { - // actually we should notify the DQP for this, then let DQP call the - // the Configuration Service. Since we do not have dynamic properties on - // DQP this should be OK for now. - getConfigurationService().setSystemProperty(propertyName, propertyValue); - } catch (MetaMatrixComponentException e) { - throw new AdminComponentException(e); - } - } - - - /** - * @see org.teiid.adminapi.ConfigurationAdmin#updateSystemProperties(java.util.Properties) - * @since 4.3 - */ - public void updateSystemProperties(Properties properties) throws AdminException { - try { - // actually we should notify the DQP for this, then let DQP call the - // the Configuration Service. Since we do not have dynamic properties on - // DQP this should be OK for now. - getConfigurationService().updateSystemProperties(properties); - }catch(MetaMatrixComponentException e) { - throw new AdminComponentException(e); - } - } - - /** * @see org.teiid.adminapi.ConfigurationAdmin#setProperty(java.lang.String, java.lang.String, java.lang.String, java.lang.String) * @since 4.3 */ - public void setProperty(String identifier, String className, String propertyName, String propertyValue) + public void setConnectorBindingProperty(String deployedName, String propertyName, String propertyValue) throws AdminException { - Properties properties = new Properties(); - properties.setProperty(propertyName, propertyValue); - - updateProperties(identifier, className, properties); - + try { + ConnectorBinding binding = getConfigurationService().getConnectorBinding(deployedName); + if (binding == null) { + throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.cb_doesnot_exist", deployedName)); //$NON-NLS-1$ + } + + ComponentTypeID id = binding.getComponentTypeID(); + ConnectorBindingType type = getConfigurationService().getConnectorType(id.getName()); + + boolean needsEncryption = isMaskedProperty(propertyName, type); + if (needsEncryption) { + propertyValue = encryptString(propertyValue); + } + + Properties p = new Properties(); + p.setProperty(propertyName, propertyValue); + + //update the configuration + binding = ConnectorConfigurationReader.addConnectorBindingProperties(binding, p); + getConfigurationService().updateConnectorBinding(binding); + } catch (MetaMatrixComponentException e) { + throw new AdminComponentException(e); + } } /** - * @see org.teiid.adminapi.ConfigurationAdmin#updateProperties(java.lang.String, java.lang.String, java.util.Properties) - * @since 4.3 - */ - public void updateProperties(String identifier, String className, Properties properties) throws AdminException { - - Collection adminObjects = getAdminObjects(identifier, className); - if (adminObjects == null || adminObjects.size() == 0) { - throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.No_Objects_Found", identifier, className)); //$NON-NLS-1$ - } - if (adminObjects.size() > 1) { - throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.Multiple_Objects_Found", identifier, className)); //$NON-NLS-1$ - } - AdminObject adminObject = (AdminObject) adminObjects.iterator().next(); - - - int typeCode = MMAdminObject.getObjectType(className); - switch(typeCode) { - - case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: - updateSystemProperties(properties); - break; - - case MMAdminObject.OBJECT_TYPE_CONNECTOR_BINDING: - try { - // there is lot of engineering under here.. - String bindingName = adminObject.getName(); - ConnectorBinding binding = getConfigurationService().getConnectorBinding(bindingName); - ComponentTypeID id = binding.getComponentTypeID(); - ConnectorBindingType type = getConfigurationService().getConnectorType(id.getName()); - - - //encrypt the properties - Properties encryptedProperties = new Properties(); - encryptedProperties.putAll(properties); - - for (Iterator iter = properties.keySet().iterator(); iter.hasNext(); ) { - String propertyName = (String) iter.next(); - boolean needsEncryption = isMaskedProperty(propertyName, type); - if (needsEncryption) { - String propertyValue = properties.getProperty(propertyName); - propertyValue = encryptString(propertyValue); - encryptedProperties.put(propertyName, propertyValue); - } - } - - //update the configuration - binding = ConnectorConfigurationReader.addConnectorBindingProperties(binding, encryptedProperties); - getConfigurationService().updateConnectorBinding(binding); - - } catch (MetaMatrixComponentException e) { - throw new AdminComponentException(e); - } - break; - - default: - throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.can_not_set_property")); //$NON-NLS-1$ - } - } - - /** * @see org.teiid.adminapi.ConfigurationAdmin#addConnectorType(java.lang.String, char[]) * @since 4.3 */ @@ -276,10 +199,12 @@ binding = ConnectorConfigurationReader.loadConnectorBinding(deployName, properties, ctype); // Check that the connector binding passwords can be decrypted - AdminStatus status = checkDecryption(binding, ctype); - if ( status.getCode() == AdminStatus.CODE_DECRYPTION_FAILED && - ! options.containsOption(AdminOptions.BINDINGS_IGNORE_DECRYPT_ERROR)) { - throw new AdminProcessingException(status.getCode(), status.getMessage()); + try { + checkDecryption(binding, ctype); + } catch(CryptoException e) { + if (!options.containsOption(AdminOptions.BINDINGS_IGNORE_DECRYPT_ERROR)) { + throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("AdminStatus.CODE_DECRYPTION_FAILED", binding.getFullName())); //$NON-NLS-1$ + } } // now that all of the input parameters validated, add the connector binding @@ -351,10 +276,12 @@ binding = ConnectorConfigurationReader.loadConnectorBinding(deployName, xmlFile); // Check that the connector binding passwords can be decrypted - AdminStatus status = checkDecryption(binding, type); - if ( status.getCode() == AdminStatus.CODE_DECRYPTION_FAILED && - ! options.containsOption(AdminOptions.BINDINGS_IGNORE_DECRYPT_ERROR)) { - throw new AdminProcessingException(status.getCode(), status.getMessage()); + try { + checkDecryption(binding, type); + } catch(CryptoException e) { + if (!options.containsOption(AdminOptions.BINDINGS_IGNORE_DECRYPT_ERROR)) { + throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("AdminStatus.CODE_DECRYPTION_FAILED", binding.getFullName())); //$NON-NLS-1$ + } } // now that all of the input parameters validated, add the connector binding @@ -526,11 +453,13 @@ ConnectorBindingType type = (ConnectorBindingType)def.getConnectorType(binding.getComponentTypeID().getName()); // Check that the connector binding passwords can be decrypted - AdminStatus status = checkDecryption(binding, type); - if ( status.getCode() == AdminStatus.CODE_DECRYPTION_FAILED && - ! options.containsOption(AdminOptions.BINDINGS_IGNORE_DECRYPT_ERROR)) { - throw new AdminProcessingException(status.getCode(), status.getMessage()); - } + try { + checkDecryption(binding, type); + } catch(CryptoException e) { + if (!options.containsOption(AdminOptions.BINDINGS_IGNORE_DECRYPT_ERROR)) { + throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("AdminStatus.CODE_DECRYPTION_FAILED", binding.getFullName())); //$NON-NLS-1$ + } + } } } @@ -540,21 +469,15 @@ * @return * @since 4.3 */ - private AdminStatus checkDecryption(ConnectorBinding binding, ConnectorBindingType type) { - - try { - Properties props = binding.getProperties(); - Iterator it = props.keySet().iterator(); - while (it.hasNext()) { - String name = (String)it.next(); - if (isMaskedProperty(name, type)) { - decryptProperty(props.getProperty(name)); - } + private void checkDecryption(ConnectorBinding binding, ConnectorBindingType type) throws CryptoException { + Properties props = binding.getProperties(); + Iterator it = props.keySet().iterator(); + while (it.hasNext()) { + String name = (String)it.next(); + if (isMaskedProperty(name, type)) { + decryptProperty(props.getProperty(name)); } - } catch (CryptoException e) { - return new MMAdminStatus(AdminStatus.CODE_DECRYPTION_FAILED, "AdminStatus.CODE_DECRYPTION_FAILED", binding.getFullName()); //$NON-NLS-1$ } - return new MMAdminStatus(AdminStatus.CODE_SUCCESS, "AdminStatus.CODE_SUCCESS"); //$NON-NLS-1$ } /** @@ -593,8 +516,12 @@ throws AdminException { return addVDB(deployName, vdbFile, null, options); } - + @Override + public void deleteVDB(String vdbName, String vdbVersion) throws AdminException { + super.changeVDBStatus(vdbName, vdbVersion, VDB.DELETED); + } + /** * @see org.teiid.adminapi.ConfigurationAdmin#addExtensionModule(java.lang.String, java.lang.String, byte[], java.lang.String) * @since 4.3 @@ -737,6 +664,20 @@ throws AdminException { LogManager.setLogConfiguration((com.metamatrix.common.log.LogConfiguration)convertToNativeObjects(config)); } + + /** + * @see com.metamatrix.admin.api.embedded.EmbeddedRuntimeStateAdmin#setLogListener(java.lang.Object) + * @since 4.3 + */ + public void setLogListener(EmbeddedLogger listener) + throws AdminException { + if(listener != null) { + LogManager.setLogListener(new DQPLogListener(listener)); + } + else { + throw new AdminProcessingException("Admin_invalid_log_listener"); //$NON-NLS-1$ + } + } /** * @see org.teiid.adminapi.ConfigurationAdmin#exportExtensionModule(java.lang.String) @@ -1065,7 +1006,7 @@ } } } - setSystemProperty(DQPEmbeddedProperties.COMMON_EXTENSION_CLASPATH, sb.toString()+commonpath); + getConfigurationService().setSystemProperty(DQPEmbeddedProperties.COMMON_EXTENSION_CLASPATH, sb.toString()+commonpath); // then update the properties Modified: trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPMonitoringAdminImpl.java =================================================================== --- trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPMonitoringAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPMonitoringAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -33,18 +33,23 @@ import org.teiid.adminapi.AdminComponentException; import org.teiid.adminapi.AdminException; -import org.teiid.adminapi.AdminObject; import org.teiid.adminapi.AdminProcessingException; +import org.teiid.adminapi.Cache; import org.teiid.adminapi.ConnectionPool; import org.teiid.adminapi.ConnectorBinding; +import org.teiid.adminapi.ConnectorType; +import org.teiid.adminapi.ExtensionModule; import org.teiid.adminapi.MonitoringAdmin; import org.teiid.adminapi.ProcessObject; -import org.teiid.adminapi.SystemObject; +import org.teiid.adminapi.PropertyDefinition; +import org.teiid.adminapi.QueueWorkerPool; +import org.teiid.adminapi.Request; +import org.teiid.adminapi.Session; import org.teiid.adminapi.Transaction; +import org.teiid.adminapi.VDB; -import com.metamatrix.admin.objects.MMAdminObject; import com.metamatrix.api.exception.MetaMatrixComponentException; -import com.metamatrix.common.config.api.ComponentType; +import com.metamatrix.common.config.api.ConnectorBindingType; import com.metamatrix.common.vdb.api.VDBArchive; import com.metamatrix.dqp.embedded.DQPEmbeddedPlugin; import com.metamatrix.dqp.service.TransactionService; @@ -66,7 +71,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getConnectorTypes(java.lang.String) * @since 4.3 */ - public Collection getConnectorTypes(String identifier) + public Collection<ConnectorType> getConnectorTypes(String identifier) throws AdminException { if (identifier == null || !identifier.matches(MULTIPLE_WORD_WILDCARD_REGEX)) { @@ -80,7 +85,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getVDBs(java.lang.String) * @since 4.3 */ - public Collection getVDBs(String identifier) + public Collection<VDB> getVDBs(String identifier) throws AdminException { if (identifier == null || !identifier.matches(VDB_REGEX)) { @@ -111,7 +116,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getConnectorBindings(java.lang.String) * @since 4.3 */ - public Collection getConnectorBindings(String identifier) + public Collection<ConnectorBinding> getConnectorBindings(String identifier) throws AdminException { if (identifier == null) { @@ -125,7 +130,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getConnectorBindingsInVDB(java.lang.String) * @since 4.3 */ - public Collection getConnectorBindingsInVDB(String identifier) throws AdminException{ + public Collection<ConnectorBinding> getConnectorBindingsInVDB(String identifier) throws AdminException{ Collection<VDBArchive> vdbs = null; HashMap bindings = new HashMap(); @@ -158,7 +163,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getExtensionModules(java.lang.String) * @since 4.3 */ - public Collection getExtensionModules(String identifier) + public Collection<ExtensionModule> getExtensionModules(String identifier) throws AdminException { if (identifier == null || !identifier.matches(WORD_AND_DOT_WILDCARD_REGEX)) { @@ -178,7 +183,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getQueueWorkerPools(java.lang.String) * @since 4.3 */ - public Collection getQueueWorkerPools(String identifier) + public Collection<QueueWorkerPool> getQueueWorkerPools(String identifier) throws AdminException { if (identifier == null || !identifier.matches(MULTIPLE_WORD_WILDCARD_REGEX)) { @@ -218,7 +223,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getCaches(java.lang.String) * @since 4.3 */ - public Collection getCaches(String identifier) + public Collection<Cache> getCaches(String identifier) throws AdminException { if (identifier == null || !identifier.matches(SINGLE_WORD_WILDCARD_REGEX)) { @@ -238,7 +243,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getSessions(java.lang.String) * @since 4.3 */ - public Collection getSessions(String identifier) + public Collection<Session> getSessions(String identifier) throws AdminException { if (identifier == null || !identifier.matches(NUMBER_REGEX)) { @@ -251,7 +256,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getRequests(java.lang.String) * @since 4.3 */ - public Collection getRequests(String identifier) + public Collection<Request> getRequests(String identifier) throws AdminException { if (identifier == null || !identifier.matches(NUMBER_DOT_REGEX)) { @@ -273,7 +278,7 @@ * @see org.teiid.adminapi.MonitoringAdmin#getSourceRequests(java.lang.String) * @since 4.3 */ - public Collection getSourceRequests(String identifier) + public Collection<Request> getSourceRequests(String identifier) throws AdminException { if (identifier == null || !identifier.matches(NUMBER_DOT_REGEX)) { @@ -289,64 +294,27 @@ } return matchedCollection(identifier, (List)convertToAdminObjects(atomicRequestList)); } - - - /** - * @see org.teiid.adminapi.MonitoringAdmin#getSystem() - * @since 4.3 - */ - public SystemObject getSystem(){ - return super.getSystem(); - } /** * @see org.teiid.adminapi.MonitoringAdmin#getPropertyDefinitions(java.lang.String, java.lang.String) * @since 4.3 */ - public Collection getPropertyDefinitions(String identifier, String className) throws AdminException { - Collection adminObjects = getAdminObjects(identifier, className); - if (adminObjects == null || adminObjects.size() == 0) { - throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.No_Objects_Found", identifier, className)); //$NON-NLS-1$ + public Collection<PropertyDefinition> getConnectorTypePropertyDefinitions(String typeName) throws AdminException { + + if (typeName == null || !typeName.matches(MULTIPLE_WORDS_REGEX)) { + throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.Invalid_ct_name")); //$NON-NLS-1$ } - if (adminObjects.size() > 1) { - throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.Multiple_Objects_Found", identifier, className)); //$NON-NLS-1$ - } - AdminObject adminObject = (AdminObject) adminObjects.iterator().next(); - - - try { - String objectIdentifier = adminObject.getIdentifier(); - ComponentType ctype = null; - - int type = MMAdminObject.getObjectType(className); - switch(type) { - - case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: - Properties properties = getConfigurationService().getSystemProperties(); - return convertPropertyDefinitions(properties); - - case MMAdminObject.OBJECT_TYPE_CONNECTOR_BINDING: - String ctypeName = ((ConnectorBinding) adminObject).getConnectorTypeName(); - ctype = getConfigurationService().getSystemConfiguration().getComponentType(ctypeName); - - //reload the properties so they are not stale - ConnectorBinding binding = (ConnectorBinding) getConnectorBindings(objectIdentifier).iterator().next(); - - return convertPropertyDefinitions(ctype, binding.getProperties()); - - case MMAdminObject.OBJECT_TYPE_CONNECTOR_TYPE: - ctype = getConfigurationService().getSystemConfiguration().getComponentType(adminObject.getName()); - - return convertPropertyDefinitions(ctype, new Properties()); - - default: - throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.Unsupported_Object_Class", className)); //$NON-NLS-1$ - - } - - } catch (MetaMatrixComponentException e) { - throw new AdminComponentException(e); - } + + try { + ConnectorBindingType type = getConfigurationService().getConnectorType(typeName); + if (type == null) { + throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.ct_doesnot_exist", typeName)); //$NON-NLS-1$ + } + + return convertPropertyDefinitions(type, new Properties()); + } catch (MetaMatrixComponentException e) { + throw new AdminComponentException(e); + } } @Override Modified: trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPRuntimeStateAdminImpl.java =================================================================== --- trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPRuntimeStateAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPRuntimeStateAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -281,40 +281,10 @@ */ public void changeVDBStatus(String name, String version, int status) throws AdminException { - try { - - if (name == null || version == null || !name.matches(SINGLE_WORD_REGEX)) { - throw new AdminProcessingException(DQPEmbeddedPlugin.Util.getString("Admin.Invalid_vdb_name")); //$NON-NLS-1$ - } - - // Now change the VDB status it self - this.getVDBService().changeVDBStatus(name, version, status); - - // If the VDB is modified and if its status changed to DELETED, then - // we can remove all the connector bindings associated with this VDB - // the above delete will also remove them - } catch (ApplicationLifecycleException e) { - throw new AdminComponentException(e); - } catch (MetaMatrixComponentException e) { - throw new AdminComponentException(e); - } + super.changeVDBStatus(name, version, status); } - - /** - * @see com.metamatrix.admin.api.embedded.EmbeddedRuntimeStateAdmin#setLogListener(java.lang.Object) - * @since 4.3 - */ - public void setLogListener(EmbeddedLogger listener) - throws AdminException { - if(listener != null) { - LogManager.setLogListener(new DQPLogListener(listener)); - } - else { - throw new AdminProcessingException("Admin_invalid_log_listener"); //$NON-NLS-1$ - } - } - + @Override public void terminateTransaction(String transactionId, String sessionId) throws AdminException { Modified: trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPSecurityAdminImpl.java =================================================================== --- trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPSecurityAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/runtime/src/main/java/com/metamatrix/dqp/embedded/admin/DQPSecurityAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -38,7 +38,6 @@ import org.teiid.adminapi.AdminOptions; import org.teiid.adminapi.AdminProcessingException; import org.teiid.adminapi.Group; -import org.teiid.adminapi.Principal; import org.teiid.adminapi.SecurityAdmin; import org.xml.sax.SAXException; @@ -56,8 +55,8 @@ import com.metamatrix.platform.security.api.AuthorizationPolicyFactory; import com.metamatrix.platform.security.api.AuthorizationRealm; import com.metamatrix.platform.security.api.Credentials; +import com.metamatrix.platform.security.api.MetaMatrixPrincipal; import com.metamatrix.platform.security.api.MetaMatrixPrincipalName; -import com.metamatrix.platform.security.api.SessionToken; /** @@ -167,7 +166,7 @@ } Collection roleNames = null; try { - roleNames = getAuthorizationService().getRoleNamesForPrincipal(new MetaMatrixPrincipalName(groupIdentifier, Principal.TYPE_GROUP)); + roleNames = getAuthorizationService().getRoleNamesForPrincipal(new MetaMatrixPrincipalName(groupIdentifier, MetaMatrixPrincipal.TYPE_GROUP)); } catch (InvalidSessionException e) { throw new AdminComponentException(e); } catch (AuthorizationMgmtException e) { Modified: trunk/runtime/src/main/java/com/metamatrix/jdbc/EmbeddedConnectionFactoryImpl.java =================================================================== --- trunk/runtime/src/main/java/com/metamatrix/jdbc/EmbeddedConnectionFactoryImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/runtime/src/main/java/com/metamatrix/jdbc/EmbeddedConnectionFactoryImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -389,6 +389,7 @@ process.setFreeMemory(rt.freeMemory()); process.setTotalMemory(rt.totalMemory()); process.setProperties(PropertiesUtils.clone(props)); + process.setStartTime(new Date(this.starttime)); if (this.socketTransport != null) { SocketListenerStats socketStats = this.socketTransport.getStats(); Modified: trunk/runtime/src/main/resources/com/metamatrix/dqp/embedded/i18n.properties =================================================================== --- trunk/runtime/src/main/resources/com/metamatrix/dqp/embedded/i18n.properties 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/runtime/src/main/resources/com/metamatrix/dqp/embedded/i18n.properties 2009-08-28 22:27:14 UTC (rev 1291) @@ -193,6 +193,8 @@ Admin.Multiple_Objects_Found=Multiple AdminObjects found for identifier {0} and class {1}. Admin.Unsupported_Object_Class=AdminObjects class {0} not supported for this operation. Admin.bindings_exceeded_limit=You have reached the MetaMatrix license limit of connector bindings, Failed to add connector bindings. +Admin.cb_doesnot_exist=The connector binding does not exist:{0} +Admin.ct_doesnot_exist=The connector type does not exist:{0} DQPEmbeddedManager.start_dqp=Teiid is started at time = {0} DQPEmbeddedManager.shutdown_dqp=Teiid is shutdown at time = {0} Copied: trunk/server/src/main/java/com/metamatrix/admin/api/AdminStatus.java (from rev 1279, trunk/client/src/main/java/org/teiid/adminapi/AdminStatus.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/AdminStatus.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/api/AdminStatus.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,68 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.api; + + +/** + * Base interface of admin status objects. + * Status objects are returned by some admin methods to indicate warnings or additional information, + * that doesn't belong in an Exception. + * + * @since 4.3 + */ +public interface AdminStatus { + + + /** + * Status code indicating an unknown status + */ + public final static int CODE_UNKNOWN = -1; + /** + * Status code indicating that the operation succeeded. + */ + public final static int CODE_SUCCESS = 0; + + /** + * Warning status code indicating that an object could not be decrypted. + */ + public final static int CODE_DECRYPTION_FAILED = -101; + + + + + /** + * Get the status code. + * This will be one of the status codes specified by the constants <code>AdminStatus.CODE_*</code>. + * @return String the unique Identifier + * @since 4.3 + */ + int getCode(); + + /** + * Get the status message. + * @return String Name + * @since 4.3 + */ + String getMessage(); + +} Copied: trunk/server/src/main/java/com/metamatrix/admin/api/DQP.java (from rev 1279, trunk/client/src/main/java/org/teiid/adminapi/DQP.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/DQP.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/api/DQP.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,90 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.api; + +import java.util.Date; + +import org.teiid.adminapi.AdminObject; + +/** + * The distributed query processor, which is the internal query engine component used by MetaMatrix products. + * + * @since 4.3 + */ +public interface DQP extends + AdminObject { + + + /**Registered by not initialized*/ + public static final int STATE_NOT_INITIALIZED = 0; + /**Open and running*/ + public static final int STATE_OPEN = 1; + /**Registered but closed*/ + public static final int STATE_CLOSED = 2; + /**Failed after running successfully*/ + public static final int STATE_FAILED = 3; + /**Failed during initialization*/ + public static final int STATE_INIT_FAILED = 4; + /**Not registered*/ + public static final int STATE_NOT_REGISTERED = 5; + /**Running, but the underlying data source is unavailable*/ + public static final int STATE_DATA_SOURCE_UNAVAILABLE = 6; + /**Running, not deployed*/ + public static final int STATE_NOT_DEPLOYED = 7; + + /** + * Retrieve the current connector state. This will be one of the constants: + * {@link DQP#STATE_OPEN DQP.STATE_OPEN}. + * {@link DQP#STATE_NOT_INITIALIZED DQP.STATE_NOT_INITIALIZED}. + * {@link DQP#STATE_CLOSED DQP.STATE_CLOSED}. + * {@link DQP#STATE_FAILED DQP.STATE_FAILED}. + * {@link DQP#STATE_INIT_FAILED DQP.STATE_INIT_FAILED}. + * {@link DQP#STATE_NOT_REGISTERED DQP.STATE_NOT_REGISTERED}. + * {@link DQP#STATE_DATA_SOURCE_UNAVAILABLE DQP.STATE_DATA_SOURCE_UNAVAILABLE}. + * {@link DQP#STATE_NOT_DEPLOYED DQP.STATE_NOT_DEPLOYED}. + * @return current connector state. + */ + int getState(); + + /** + * Retrieve the current connector state. + * + * @return current connector state. + */ + String getStateAsString(); + + /** + * Retrieve time of last state change. + * + * @return time of last state change. + * @since 4.3 + */ + Date getStateChangedTime(); + + /** + * Returns the description. + * + * @return description + */ + public String getDescription(); +} Copied: trunk/server/src/main/java/com/metamatrix/admin/api/Host.java (from rev 1279, trunk/client/src/main/java/org/teiid/adminapi/Host.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/Host.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/api/Host.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,77 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.api; + +import org.teiid.adminapi.AdminObject; + + + +/** + * Represents a host in the MetaMatrix system. + * + * <p>The identifier pattern for a host is <code>"hostName"</code>. + * A hostName is considered to be unique across the system.</p> + * @since 4.3 + */ +public interface Host extends AdminObject { + + /** + * Install Directory Property + */ + public static final String INSTALL_DIR = "metamatrix.installationDir"; //$NON-NLS-1$ + + /** + * Log Directory Property + */ + public static final String LOG_DIRECTORY = "metamatrix.log.dir"; //$NON-NLS-1$ + + /** + * Host Directory Property + */ + public static final String HOST_DIRECTORY = "metamatrix.host.dir"; //$NON-NLS-1$ + + /** + * Host Enabled Property + */ + public static final String HOST_ENABLED = "host.enabled"; //$NON-NLS-1$ + + /** + * Host Bind Address Property + */ + public static final String HOST_BIND_ADDRESS = "metamatrix.host.bind.address"; //$NON-NLS-1$ + + /** + * Host Physical Address Property + */ + public static final String HOST_PHYSICAL_ADDRESS = "metamatrix.host.physical.address"; //$NON-NLS-1$ + + + /** + * Return true if this Host is executing. + * + * @return if this Host is actively participating + * in the MetaMatrix system. + * @since 4.3 + */ + public boolean isRunning(); +} Copied: trunk/server/src/main/java/com/metamatrix/admin/api/Principal.java (from rev 1279, trunk/client/src/main/java/org/teiid/adminapi/Principal.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/Principal.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/api/Principal.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,70 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.api; + +import org.teiid.adminapi.AdminObject; + + +/** + * A Principal may participate in entitlements (authorization). A Principal + * may also posess administrative roles for the system. + * + * <p>The identifier pattern for all principal types is <code>"name"</code>. + * A name is concidered to be unique across the system for all + * principal types.</p> + * @since 4.3 + */ +public interface Principal extends AdminObject { + + /** User internal type. Note that a User can be of type Admin and vice versa. */ + static final int TYPE_USER = 0; + /** Group internal type */ + static final int TYPE_GROUP = 1; + /** Admin internal type. Note that a User can be of type Admin and vice versa. */ + static final int TYPE_ADMIN = 2; + + /** Display String for User type */ + static final String TYPE_LABEL_USER = "User"; //$NON-NLS-1$ + /** Display String for Group type */ + static final String TYPE_LABEL_GROUP = "Group"; //$NON-NLS-1$ + /** Display String for Admin type */ + static final String TYPE_LABEL_ADMIN = "Admin"; //$NON-NLS-1$ + + /** User and Group names can be no longer then this */ + static final int NAME_LEN_LIMIT = 32; + + /** + * Get the Principal type for this principal. + * @return the internal type of this user. + * @since 4.3 + */ + int getType(); + + /** + * Get the Principal type String for this principal. + * @return the String representation type of this user. + * @since 4.3 + */ + String getTypeLabel(); + +} Copied: trunk/server/src/main/java/com/metamatrix/admin/api/Resource.java (from rev 1279, trunk/client/src/main/java/org/teiid/adminapi/Resource.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/Resource.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/api/Resource.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,38 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.api; + +import org.teiid.adminapi.AdminObject; + + +/** + * @since 4.3 + */ +public interface Resource extends AdminObject { + + /** + * The environment property that indicates the name of the pool. + */ + public static final String RESOURCE_POOL = "metamatrix.common.pooling.resource.name"; //$NON-NLS-1$ + +} Copied: trunk/server/src/main/java/com/metamatrix/admin/api/ScriptsContainer.java (from rev 1279, trunk/client/src/main/java/org/teiid/adminapi/ScriptsContainer.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/ScriptsContainer.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/api/ScriptsContainer.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,72 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.api; + +import java.io.Serializable; +import java.util.Collection; + +import org.teiid.adminapi.AdminException; +import org.teiid.adminapi.AdminOptions; +import org.teiid.adminapi.AdminOptions.OnConflict; + + + + +/** + * Contains all information nessecary to save the scripts that will be run + * by a MetaMatrix utility to load or refresh the data resident in a + * Materialized View. + * <p> + * Users can get the contents of each file and save each with the + * filename associated with it or, more easily, users can save all files + * to a local folder. (See {@link #saveAllToDirectory})</p> + * <p> + * @since 4.3 + */ +public interface ScriptsContainer extends Serializable { + + /** + * Get the file names of all scripts in this container. + * + * @return The <code>Collection</code> of <code>String</code> + * file names of all scripts in this container. This + * collection may be empty if an error has occured. + * @since 4.3 + */ + Collection getFileNames(); + + /** + * Save all of the scripts contained to the specified local + * directory. + * + * @param directoryLocation the directory location to save + * the contained scripts. Must be accessable from where + * this code is running. + * @param options Specify whether to {@link AdminOptions.OnConflict#OVERWRITE} + * or {@link AdminOptions.OnConflict#EXCEPTION} (default) when script files + * exist in the <code>directoryLocation</code>. + * @throws AdminException if there's an error saving the files. + * @since 4.3 + */ + void saveAllToDirectory(String directoryLocation, AdminOptions options) throws AdminException; +} Copied: trunk/server/src/main/java/com/metamatrix/admin/api/Service.java (from rev 1279, trunk/client/src/main/java/org/teiid/adminapi/Service.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/Service.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/api/Service.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,100 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.api; + +import java.util.Date; + +import org.teiid.adminapi.AdminObject; + +/** + * Represents a service in the MetaMatrix system. + * + * <p>The unique identifier pattern is [host]<{@link #DELIMITER}>[process]<{@link #DELIMITER}>[Service Name] + * when running against a MetaMatrix server. The [Service Name] can itself have spaces in the name. + * In the case of the MM Query, a Service does not apply as MM Query is not running within a MM Server VM.</p> + * + * @since 4.3 + */ +public interface Service extends + AdminObject { + /**Registered by not initialized*/ + public static final int STATE_NOT_INITIALIZED = 0; + /**Open and running*/ + public static final int STATE_OPEN = 1; + /**Registered but closed*/ + public static final int STATE_CLOSED = 2; + /**Failed after running successfully*/ + public static final int STATE_FAILED = 3; + /**Failed during initialization*/ + public static final int STATE_INIT_FAILED = 4; + /**Not registered*/ + public static final int STATE_NOT_REGISTERED = 5; + /**Running, but the underlying data source is unavailable*/ + public static final int STATE_DATA_SOURCE_UNAVAILABLE = 6; + /**Running, not deployed*/ + public static final int STATE_NOT_DEPLOYED = 7; + + /** + * Retrieve the current connector state. This will be one of the constants: + * {@link DQP#STATE_OPEN DQP.STATE_OPEN}. + * {@link DQP#STATE_NOT_INITIALIZED DQP.STATE_NOT_INITIALIZED}. + * {@link DQP#STATE_CLOSED DQP.STATE_CLOSED}. + * {@link DQP#STATE_FAILED DQP.STATE_FAILED}. + * {@link DQP#STATE_INIT_FAILED DQP.STATE_INIT_FAILED}. + * {@link DQP#STATE_NOT_REGISTERED DQP.STATE_NOT_REGISTERED}. + * {@link DQP#STATE_DATA_SOURCE_UNAVAILABLE DQP.STATE_DATA_SOURCE_UNAVAILABLE}. + * {@link DQP#STATE_NOT_DEPLOYED DQP.STATE_NOT_DEPLOYED}. + * @return current connector state. + */ + int getState(); + + /** + * Retrieve the current connector state as a printable <code>String</code>. + * @return current connector state in String form. + */ + String getStateAsString(); + + /** + * Returns time of last state change. + * + * @return time of last state change. + * @since 4.3 + */ + Date getStateChangedTime(); + + /** + * Returns the description + * + * @return description + */ + String getDescription(); + + /** + * Get the component type identifier for this service {@link ComponentType}. + * @return the Component Type identifier which can be used to + * find the ComponentType. + * @since 6.1 + */ + String getComponentTypeName(); + +} Property changes on: trunk/server/src/main/java/com/metamatrix/admin/api/Service.java ___________________________________________________________________ Name: svn:mime-type + text/plain Copied: trunk/server/src/main/java/com/metamatrix/admin/api/SystemObject.java (from rev 1279, trunk/client/src/main/java/org/teiid/adminapi/SystemObject.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/SystemObject.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/api/SystemObject.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,52 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.api; + +import java.util.Date; + +import org.teiid.adminapi.AdminObject; + + +/** + * @since 4.3 + */ +public interface SystemObject extends AdminObject { + + /** + * @return Returns whether the system is started. + * @since 4.3 + */ + public boolean isStarted(); + + + + /** + * @return Returns the startTime. + * @since 4.3 + */ + public Date getStartTime(); + + + + +} Modified: trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerConfigAdmin.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerConfigAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerConfigAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -28,10 +28,10 @@ import org.teiid.adminapi.AdminRoles; import org.teiid.adminapi.ConfigurationAdmin; import org.teiid.adminapi.ConnectorBinding; -import org.teiid.adminapi.ScriptsContainer; import org.teiid.adminapi.VDB; import com.metamatrix.admin.RolesAllowed; +import com.metamatrix.admin.api.ScriptsContainer; /** @@ -72,7 +72,7 @@ * Add a Host with Properties to MetaMatrix System * * @param hostIdentifier - * Name of {@link org.teiid.adminapi.Host Host} to add + * Name of {@link com.metamatrix.admin.api.Host Host} to add * @param properties * name,value * @throws AdminException Modified: trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerMonitoringAdmin.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerMonitoringAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerMonitoringAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -44,10 +44,10 @@ /** * Get the hosts that correspond to the specified identifier pattern. * - * @param hostIdentifier the unique identifier for for a {@link org.teiid.adminapi.Host Host} + * @param hostIdentifier the unique identifier for for a {@link com.metamatrix.admin.api.Host Host} * in the system or "{@link org.teiid.adminapi.AdminObject#WILDCARD WILDCARD}" * if all hosts are desired. - * @return Collection of {@link org.teiid.adminapi.Host Host} + * @return Collection of {@link com.metamatrix.admin.api.Host Host} * @throws AdminException if there's a system error. * @since 4.3 */ @@ -71,10 +71,10 @@ * Get the Services that correspond to the specified identifer pattern. * These services represent what is defined for a given {@link Host} | {@link Process}; * - * @param resourceIdentifier the unique identifier for for a {@link org.teiid.adminapi.Service Service} + * @param resourceIdentifier the unique identifier for for a {@link com.metamatrix.admin.api.Service Service} * in the system or "{@link org.teiid.adminapi.AdminObject#WILDCARD WILDCARD}" * if all Services are desired. - * @return Collection of {@link org.teiid.adminapi.Service Service} + * @return Collection of {@link com.metamatrix.admin.api.Service Service} * @throws AdminException if there's a system error. * @since 6.1 */ @@ -85,22 +85,22 @@ /** * Get the Resources that correspond to the specified identifer pattern. * - * @param resourceIdentifier the unique resourceIdentifier for for a {@link org.teiid.adminapi.Resource Resource} + * @param resourceIdentifier the unique resourceIdentifier for for a {@link com.metamatrix.admin.api.Resource Resource} * in the system or "{@link org.teiid.adminapi.AdminObject#WILDCARD WILDCARD}" * if all Resources are desired. - * @return Collection of {@link org.teiid.adminapi.Resource Resource} + * @return Collection of {@link com.metamatrix.admin.api.Resource Resource} * @throws AdminException if there's a system error. * @since 4.3 */ Collection getResources(String resourceIdentifier) throws AdminException; /** - * Get the {@link org.teiid.adminapi.DQP DQP}s that correspond to the specified identifer pattern. + * Get the {@link com.metamatrix.admin.api.DQP DQP}s that correspond to the specified identifer pattern. * - * @param identifier the unique identifier for for a {@link org.teiid.adminapi.DQP DQP} + * @param identifier the unique identifier for for a {@link com.metamatrix.admin.api.DQP DQP} * in the system or "{@link org.teiid.adminapi.AdminObject#WILDCARD WILDCARD}" * if all Resources are desired. - * @return Collection of {@link org.teiid.adminapi.DQP DQP} + * @return Collection of {@link com.metamatrix.admin.api.DQP DQP} * @throws AdminException if there's a system error. * @since 4.3 */ Modified: trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerRuntimeStateAdmin.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerRuntimeStateAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerRuntimeStateAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -72,7 +72,7 @@ /** * Start the Host for this cluster - * @param hostIdentifier the unique identifier for for a {@link org.teiid.adminapi.Host Host} + * @param hostIdentifier the unique identifier for for a {@link com.metamatrix.admin.api.Host Host} * in the system. * @param waitUntilDone If true, this method waits until the operation is finished before returning. * This may take a long time to complete. If false, this method returns immediately, even though the operation @@ -84,7 +84,7 @@ /** * Stop the Host for this cluster - * @param hostIdentifier the unique identifier for for a {@link org.teiid.adminapi.Host Host} + * @param hostIdentifier the unique identifier for for a {@link com.metamatrix.admin.api.Host Host} * in the system. * @param stopNow If true, stop the host forcefully. If false, wait until any pending work is done. * @param waitUntilDone If true, this method waits until the operation is finished before returning. Modified: trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerSecurityAdmin.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerSecurityAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/api/server/ServerSecurityAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -31,11 +31,11 @@ import org.teiid.adminapi.AdminOptions; import org.teiid.adminapi.AdminRoles; import org.teiid.adminapi.Group; -import org.teiid.adminapi.Principal; import org.teiid.adminapi.Role; import org.teiid.adminapi.SecurityAdmin; import com.metamatrix.admin.RolesAllowed; +import com.metamatrix.admin.api.Principal; /** Copied: trunk/server/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java (from rev 1279, trunk/client/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/objects/MMAdminStatus.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,111 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.objects; + +import java.io.Serializable; + + +import com.metamatrix.admin.AdminPlugin; +import com.metamatrix.admin.api.AdminStatus; + + +/** + * Simple Implementation of MMStatus. + * @since 4.3 + */ +public class MMAdminStatus implements AdminStatus, Serializable { + private static final long serialVersionUID = -3111591335358837218L; + private int code = AdminStatus.CODE_UNKNOWN; + private String message = null; + + + /** + * Construct a new MMAdminStatus + * @param code + * @param messageKey Key of the status message in i18n.properties. + * @since 4.3 + */ + public MMAdminStatus(int code, String messageKey) { + this.code = code; + + this.message = AdminPlugin.Util.getString(messageKey); + } + + /** + * Construct a new MMAdminStatus + * @param code + * @param messageKey Key of the status message in i18n.properties. + * @param value Value to substitute into the internationalized message. + * @since 4.3 + */ + public MMAdminStatus(int code, String messageKey, Object value) { + this.code = code; + + this.message = AdminPlugin.Util.getString(messageKey, value); + } + + /** + * Construct a new MMAdminStatus + * @param code + * @param messageKey Key of the status message in i18n.properties. + * @param values Values to substitute into the internationalized message. + * @since 4.3 + */ + public MMAdminStatus(int code, String messageKey, Object[] values) { + this.code = code; + + this.message = AdminPlugin.Util.getString(messageKey, values); + } + + + + /** + * @see com.metamatrix.admin.api.AdminStatus#getCode() + * @since 4.3 + */ + public int getCode() { + return code; + } + + /** + * @see com.metamatrix.admin.api.AdminStatus#getMessage() + * @since 4.3 + */ + public String getMessage() { + return message; + } + + + /** + * @see java.lang.Object#toString() + * @since 4.3 + */ + public String toString() { + StringBuffer result = new StringBuffer(); + result.append(AdminPlugin.Util.getString("MMAdminStatus.MMAdminStatus")); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMAdminStatus.Code")).append(getCode()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMAdminStatus.Message")).append(getMessage()); //$NON-NLS-1$ + return result.toString(); + } + +} Copied: trunk/server/src/main/java/com/metamatrix/admin/objects/MMDQP.java (from rev 1279, trunk/client/src/main/java/com/metamatrix/admin/objects/MMDQP.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/objects/MMDQP.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/objects/MMDQP.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,201 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.objects; + +import java.util.Date; + + +import com.metamatrix.admin.AdminPlugin; +import com.metamatrix.admin.api.DQP; + + +/** + * A Connector Binding is a Connector Type with properties that have been + * bond to a Connector. + * + * May are may not be assigned to a VDB + */ +public class MMDQP extends MMAdminObject implements DQP { + + private static final long serialVersionUID = -3212002022690786890L; + private String description = ""; //$NON-NLS-1$ + private int currentState; + private Date stateChangedTime; + private long serviceID = -1; + + + /** + * Constructor. + * @param identifierParts + * @since 4.3 + */ + public MMDQP(String[] identifierParts) { + super(identifierParts); + + } + + + + + /** + * @see java.lang.Object#toString() + */ + public String toString() { + StringBuffer result = new StringBuffer(); + result.append(AdminPlugin.Util.getString("MMDQP.MMDQP")).append(getIdentifier()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.Description")).append(description); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.Created")).append(getCreatedDate()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.Created_By")).append(getCreatedBy()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.Updated")).append(getLastChangedDate()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.Updated_By")).append(getLastChangedBy()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.State")).append(getStateAsString()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.IsRegistered")).append(isRegistered()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.State_Changed")).append(getStateChangedTime()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMDQP.Properties")).append(getPropertiesAsString()); //$NON-NLS-1$ + return result.toString(); + } + + + + /** + * Returns the description + * @return description + */ + public String getDescription() { + return description; + } + + /** + * Set the description + * @param description + */ + public void setDescription(String description) { + this.description = description; + } + + + + /** + * @return Returns the currentState as int. + * @since 4.3 + */ + public int getState() { + return currentState; + } + + + /** + * @return Returns the currentState as String. + * @since 4.3 + */ + public String getStateAsString() { + switch (currentState) { + case STATE_OPEN: + return AdminPlugin.Util.getString("MMDQP.open"); //$NON-NLS-1$ + case STATE_CLOSED: + return AdminPlugin.Util.getString("MMDQP.closed"); //$NON-NLS-1$ + case STATE_FAILED: + return AdminPlugin.Util.getString("MMDQP.failed"); //$NON-NLS-1$ + case STATE_INIT_FAILED: + return AdminPlugin.Util.getString("MMDQP.initializationFailed"); //$NON-NLS-1$ + case STATE_NOT_INITIALIZED: + return AdminPlugin.Util.getString("MMDQP.notInitialized"); //$NON-NLS-1$ + case STATE_NOT_REGISTERED: + return AdminPlugin.Util.getString("MMDQP.notRegistered"); //$NON-NLS-1$ + case STATE_DATA_SOURCE_UNAVAILABLE: + return AdminPlugin.Util.getString("MMDQP.dataSourceUnavailable"); //$NON-NLS-1$ + default: + return AdminPlugin.Util.getString("MMDQP.unknown"); //$NON-NLS-1$ + } + } + + /** + * Set the state + * @param state + * @since 4.3 + */ + public void setState(int state) { + this.currentState = state; + } + + + /** + * @return Returns time of last state change. + * @since 4.3 + */ + public Date getStateChangedTime() { + return stateChangedTime; + } + + /** + * Set the state changed time + * @param stateChangedTime + * @since 4.3 + */ + public void setStateChangedTime(Date stateChangedTime) { + this.stateChangedTime = stateChangedTime; + + //check on what states mean "registered" + setRegistered(currentState==STATE_OPEN || currentState==STATE_FAILED || currentState==STATE_DATA_SOURCE_UNAVAILABLE); + } + + + + /** + * @return Returns the serviceID. + * @since 4.3 + */ + public long getServiceID() { + return this.serviceID; + } + + /** + * @param serviceID The serviceID to set. + * @since 4.3 + */ + public void setServiceID(long serviceID) { + this.serviceID = serviceID; + } + + + + /** + * @return Returns the processID. + * @since 4.3 + */ + public String getProcessName() { + return this.identifierParts[1]; + } + + /** + * @return Returns the hostName. + * @since 4.3 + */ + public String getHostName() { + return identifierParts[0]; + } + + + + +} \ No newline at end of file Copied: trunk/server/src/main/java/com/metamatrix/admin/objects/MMHost.java (from rev 1279, trunk/client/src/main/java/com/metamatrix/admin/objects/MMHost.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/objects/MMHost.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/objects/MMHost.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,91 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.objects; + + +import com.metamatrix.admin.AdminPlugin; +import com.metamatrix.admin.api.Host; + + +/** + * Simple Host object for the Admin API as represented in the Configuration + */ +public final class MMHost extends MMAdminObject implements Host { + + private static final long serialVersionUID = -779866213549875450L; + private boolean running = false; + + + + /** + * Constructor for creating a MMHost + * + * @param identifierParts of the Host + */ + public MMHost(String[] identifierParts) { + super(identifierParts); + } + + + + /** + * Create a String for this MMHost + * + * @see java.lang.Object#toString() + * @since 4.3 + */ + public String toString() { + StringBuffer result = new StringBuffer(); + result.append(AdminPlugin.Util.getString("MMHost.MMHost")).append(getName()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMHost.Properties")).append(getPropertiesAsString()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMHost.Created")).append(getCreatedDate()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMHost.Created_By")).append(getCreatedBy()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMHost.Updated")).append(getLastChangedDate()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMHost.Updated_By")).append(getLastChangedBy()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMHost.IsRunning")).append(isRegistered()); //$NON-NLS-1$ + return result.toString(); + } + + + + /** + * Return true if this Host is running + * @return if this Host is running + * @since 4.3 + */ + public boolean isRunning() { + return running; + } + + /** + * Set if this Host has been deployed and is executing + * @param running + * @since 4.3 + */ + public void setRunning(boolean running) { + this.running = running; + } + + + +} \ No newline at end of file Copied: trunk/server/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java (from rev 1279, trunk/client/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/objects/MMPrincipal.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,99 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.objects; + +import com.metamatrix.admin.api.Principal; +import com.metamatrix.admin.server.AbstractAdminImpl; + + +/** + * @since 4.3 + */ +public class MMPrincipal extends MMAdminObject implements Principal { + + private static final long serialVersionUID = -1383265398519744688L; + + private static final String[] TYPE_NAMES = new String[] { TYPE_LABEL_USER, TYPE_LABEL_GROUP, TYPE_LABEL_ADMIN }; + + private int type; + + /** + * Ctor + * @param principalName The name of the {@link Principal}. + * @param type The value of the {@link Principal}. + * @since 4.3 + */ + public MMPrincipal(String[] principalName, int type) { + super(principalName); + this.type = type; + } + + /** + * @see com.metamatrix.admin.objects.MMAdminObject#toString() + * @since 4.3 + */ + public String toString() { + StringBuffer sb = new StringBuffer(); + sb.append("[Name=\""); //$NON-NLS-1$ + sb.append(this.getName()); + sb.append("\" - Type=\""); //$NON-NLS-1$ + sb.append( TYPE_NAMES[this.type] ); + sb.append("\"]"); //$NON-NLS-1$ + return sb.toString(); + } + + /** + * @see com.metamatrix.admin.api.Principal#getType() + * @since 4.3 + */ + public int getType() { + return type; + } + + /** + * @see com.metamatrix.admin.api.Principal#getTypeLabel() + * @since 4.3 + */ + public String getTypeLabel() { + return TYPE_NAMES[this.type]; + } + + /** + * Determine whether the given <code>className</code> + * is either of {@link #TYPE_USER} or {@link #TYPE_GROUP}. + * @param className the className in question. + * @return <code>true</code> iff the given type represents + * one or the other; User or Group. + * @since 4.3 + */ + public static boolean isUserOrGroup(String className) { + try { + int type = AbstractAdminImpl.getObjectType(className); + return (type == AbstractAdminImpl.OBJECT_TYPE_GROUP); + } catch (Exception e) { + return false; + } + + } + +} Copied: trunk/server/src/main/java/com/metamatrix/admin/objects/MMResource.java (from rev 1279, trunk/client/src/main/java/com/metamatrix/admin/objects/MMResource.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/objects/MMResource.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/objects/MMResource.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,84 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.objects; + + +import com.metamatrix.admin.AdminPlugin; +import com.metamatrix.admin.api.Resource; + +/** + * Dataholder for a resource. + */ +public class MMResource extends MMAdminObject implements Resource { + + private static final long serialVersionUID = -8732882869479091774L; + private String resourceType; + + /** + * Constructor + * @param identifierParts of the resource + */ + public MMResource(String[] identifierParts) { + super(identifierParts); + } + + + /** + * @see java.lang.Object#toString() + */ + public String toString() { + StringBuffer result = new StringBuffer(); + result.append(AdminPlugin.Util.getString("MMResource.MMResource")).append(getIdentifier()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMResource.Type")).append(resourceType); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMResource.Created")).append(getCreatedDate()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMResource.Created_By")).append(getCreatedBy()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMResource.Updated")).append(getLastChangedDate()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMResource.Updated_By")).append(getLastChangedBy()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMResource.Properties")).append(getPropertiesAsString()); //$NON-NLS-1$ + return result.toString(); + } + + + + /** + * Get the Resource Type for this Resource + * @return Returns the String value of the Resource Type for this Resouce. + * @since 4.3 + */ + public String getResourceType() { + return this.resourceType; + } + + + + /** + * Set the Resource Type + * @param resourceType The Resource Type to set. + * @since 4.3 + */ + public void setResourceType(String resourceType) { + this.resourceType = resourceType; + } + + +} Copied: trunk/server/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java (from rev 1279, trunk/client/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/objects/MMScriptsContainer.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,145 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.objects; + +import java.io.File; +import java.io.IOException; +import java.util.ArrayList; +import java.util.Collection; +import java.util.HashMap; +import java.util.Iterator; +import java.util.Map; + +import org.teiid.adminapi.AdminComponentException; +import org.teiid.adminapi.AdminException; +import org.teiid.adminapi.AdminOptions; +import org.teiid.adminapi.AdminProcessingException; + +import com.metamatrix.admin.AdminPlugin; +import com.metamatrix.admin.api.ScriptsContainer; +import com.metamatrix.core.util.FileUtils; + + +/** + * @since 4.3 + */ +public class MMScriptsContainer implements + ScriptsContainer { + + private static final long serialVersionUID = 1262888652939367623L; + // <String> fileName => <byte[]> file contents + private Map fileMap; + + /** + * + * @since 4.3 + */ + public MMScriptsContainer() { + super(); + fileMap = new HashMap(10); + } + + /** + * @see com.metamatrix.admin.api.ScriptsContainer#getFileNames() + * @since 4.3 + */ + public Collection getFileNames() { + return new ArrayList(this.fileMap.keySet()); + } + + /** + * @see com.metamatrix.admin.api.ScriptsContainer#saveAllToDirectory(java.lang.String, AdminOptions) + * @since 4.3 + */ + public void saveAllToDirectory(String directoryLocation, AdminOptions options) throws AdminException { + String fileSeparator = File.separator; + String path = (directoryLocation.endsWith(fileSeparator) ? directoryLocation : directoryLocation + fileSeparator); + + // Check that the directory exists and is writable + File directory = new File(path); + if ( ! directory.isDirectory() ) { + Object[] params = new Object[] {directoryLocation}; + throw new AdminProcessingException(AdminPlugin.Util.getString("MMScriptsContainer.unable_to_locate_directory", params)); //$NON-NLS-1$ + } + if ( ! directory.canWrite() ) { + Object[] params = new Object[] {directoryLocation}; + throw new AdminProcessingException(AdminPlugin.Util.getString("MMScriptsContainer.unable_to_write_to_directory", params)); //$NON-NLS-1$ + } + + // First check that we will not overwrite any of the files + Collection existingFiles = null; + for ( Iterator fileItr = fileMap.keySet().iterator(); fileItr.hasNext();) { + String fileName = path + (String) fileItr.next(); + File aFile = new File(fileName); + + if ( aFile.exists() ) { + if ( existingFiles == null ) { + existingFiles = new ArrayList(); + } + existingFiles.add(fileName); + } + } + if ( existingFiles != null && (options == null || options.containsOption(AdminOptions.OnConflict.EXCEPTION)) ) { + Object[] params = new Object[] {existingFiles.toString()}; + throw new AdminProcessingException(AdminPlugin.Util.getString("MMScriptsContainer.files_exist", params)); //$NON-NLS-1$ + } + + if ( existingFiles == null || options.containsOption(AdminOptions.OnConflict.OVERWRITE) ) { + // Now write each file + for (Iterator fileItr = fileMap.keySet().iterator(); fileItr.hasNext();) { + String fileName = (String)fileItr.next(); + File target = new File(path + fileName); + + try { + target.createNewFile(); + byte[] fileContents = (byte[])fileMap.get(fileName); + FileUtils.write(fileContents, target); + } catch (IOException err) { + throw new AdminProcessingException(AdminPlugin.Util.getString("MMScriptsContainer.error_writing_file", fileName), err); //$NON-NLS-1$ + } + } + } // if + } + + +//================================================================================================= +// SETTERS ARE NOT IN THE PUBLIIC INTERFACE +//================================================================================================= + + /** + * Add file contents by name. + * + * @param fileName - required + * @param fileContents - required + * @throws AdminComponentException if one of the required args are null or empty. + */ + public void addFile(String fileName, byte[] fileContents) throws AdminComponentException { + if ( fileName == null || fileName.length() == 0 ) { + throw new AdminComponentException(AdminPlugin.Util.getString("MMScriptsContainer.fileName_was_null")); //$NON-NLS-1$ + } + if ( fileContents == null || fileContents.length == 0 ) { + throw new AdminComponentException(AdminPlugin.Util.getString("MMScriptsContainer.fileContents_was_null")); //$NON-NLS-1$ + } + this.fileMap.put(fileName, fileContents); + } +} Copied: trunk/server/src/main/java/com/metamatrix/admin/objects/MMService.java (from rev 1279, trunk/client/src/main/java/com/metamatrix/admin/objects/MMService.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/objects/MMService.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/objects/MMService.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,209 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.objects; + +import java.util.Date; + + +import com.metamatrix.admin.AdminPlugin; +import com.metamatrix.admin.api.Service; + + +/** + * A Service + * + */ +public class MMService extends MMAdminObject implements Service { + + private static final long serialVersionUID = -338643922496948824L; + private String description = ""; //$NON-NLS-1$ + private String componentTypeName = ""; //$NON-NLS-1$ + private int currentState; + private Date stateChangedTime; + private long serviceID = -1; + + + /** + * Constructor. + * @param identifierParts + * @since 6.1 + */ + public MMService(String[] identifierParts) { + super(identifierParts); + } + + + + + + /** + * @see java.lang.Object#toString() + */ + public String toString() { + StringBuffer result = new StringBuffer(); + result.append(AdminPlugin.Util.getString("MMService.MMService")).append(getIdentifier()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.Description")).append(description); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.Created")).append(getCreatedDate()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.Created_By")).append(getCreatedBy()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.Updated")).append(getLastChangedDate()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.Updated_By")).append(getLastChangedBy()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.State")).append(getState()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.State_Changed")).append(getStateChangedTime()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.IsRegistered")).append(isRegistered()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMService.Properties")).append(getPropertiesAsString()); //$NON-NLS-1$ + return result.toString(); + } + + + + /** + * Returns the description + * @return description + */ + public String getDescription() { + return description; + } + + /** + * Set the description + * @param description + */ + public void setDescription(String description) { + this.description = description; + } + + + /** + * @return the current state of this connector binding. + */ + public int getState() { + return this.currentState; + } + + /** + * @return Returns the currentState as String. + * @since 6.1 + */ + public String getStateAsString() { + switch (currentState) { + case STATE_OPEN: + return AdminPlugin.Util.getString("MMService.open"); //$NON-NLS-1$ + case STATE_CLOSED: + return AdminPlugin.Util.getString("MMService.closed"); //$NON-NLS-1$ + case STATE_FAILED: + return AdminPlugin.Util.getString("MMService.failed"); //$NON-NLS-1$ + case STATE_INIT_FAILED: + return AdminPlugin.Util.getString("MMService.initializationFailed"); //$NON-NLS-1$ + case STATE_NOT_INITIALIZED: + return AdminPlugin.Util.getString("MMService.notInitialized"); //$NON-NLS-1$ + case STATE_NOT_REGISTERED: + return AdminPlugin.Util.getString("MMService.notRegistered"); //$NON-NLS-1$ + case STATE_DATA_SOURCE_UNAVAILABLE: + return AdminPlugin.Util.getString("MMService.dataSourceUnavailable"); //$NON-NLS-1$ + default: + return AdminPlugin.Util.getString("MMService.unknown"); //$NON-NLS-1$ + } + } + + /** + * Set the state + * @param state + * @since 6.1 + */ + public void setState(int state) { + this.currentState = state; + + //check on what states mean "registered" + setRegistered(currentState==STATE_OPEN || currentState==STATE_FAILED || currentState==STATE_DATA_SOURCE_UNAVAILABLE); + } + + + /** + * @return Returns time of last state change. + * @since 6.1 + */ + public Date getStateChangedTime() { + return stateChangedTime; + } + + /** + * Set the state changed time + * @param stateChangedTime + * @since 6.1 + */ + public void setStateChangedTime(Date stateChangedTime) { + this.stateChangedTime = stateChangedTime; + } + + + /** + * @return Returns the serviceID. + * @since 6.1 + */ + public long getServiceID() { + return this.serviceID; + } + + /** + * @param serviceID The serviceID to set. + * @since 6.1 + */ + public void setServiceID(long serviceID) { + this.serviceID = serviceID; + } + + + /** + * @return Returns the processID. + * @since 6.1 + */ + public String getProcessName() { + return identifierParts[1]; + } + + + /** + * @return Returns the hostName. + * @since 6.1 + */ + public String getHostName() { + return identifierParts[0]; + } + + + /** + * @param connectorTypeName the identifier for a connector type + * @since 6.1 + */ + public void setComponentTypeName(String componentTypeName) { + this.componentTypeName = componentTypeName; + } + + /** + * @see com.metamatrix.admin.api.Service#getComponentTypeName() + * @since 6.1 + */ + public String getComponentTypeName() { + return this.componentTypeName; + } +} \ No newline at end of file Property changes on: trunk/server/src/main/java/com/metamatrix/admin/objects/MMService.java ___________________________________________________________________ Name: svn:mime-type + text/plain Copied: trunk/server/src/main/java/com/metamatrix/admin/objects/MMSystem.java (from rev 1279, trunk/client/src/main/java/com/metamatrix/admin/objects/MMSystem.java) =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/objects/MMSystem.java (rev 0) +++ trunk/server/src/main/java/com/metamatrix/admin/objects/MMSystem.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -0,0 +1,119 @@ +/* + * JBoss, Home of Professional Open Source. + * See the COPYRIGHT.txt file distributed with this work for information + * regarding copyright ownership. Some portions may be licensed + * to Red Hat, Inc. under one or more contributor license agreements. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA. + */ + +package com.metamatrix.admin.objects; + +import java.util.Date; + + +import com.metamatrix.admin.AdminPlugin; +import com.metamatrix.admin.api.SystemObject; +import com.metamatrix.core.util.DateUtil; + +/** + * Dataholder for information about the system at-large + */ +public class MMSystem extends MMAdminObject implements SystemObject { + + private static final long serialVersionUID = 7913646658641775637L; + Date startTime; + boolean isStarted; + + + /**Dummy identifier for the system as a whole.*/ + private final static String SYSTEM_IDENTIFIER = "SYSTEM"; //$NON-NLS-1$ + + /** + * Construct a new MMSystem object + * + * @since 4.3 + */ + public MMSystem() { + super(new String[] {SYSTEM_IDENTIFIER}); + } + + + + + /** + * @return Returns whether the system is started. + * @since 4.3 + */ + public boolean isStarted() { + return this.isStarted; + } + + /** + * @param isStarted whether the system is started. + * @since 4.3 + */ + public void setStarted(boolean isStarted) { + this.isStarted = isStarted; + } + + + + + /** + * @return Returns the startTime. + * @since 4.3 + */ + public Date getStartTime() { + return this.startTime; + } + + + /** + * @param startTime The startTime to set. + * @since 4.3 + */ + public void setStartTime(Date startTime) { + this.startTime = startTime; + } + + /** + * Get The Start Date as a String + * @return String + * @since 4.3 + */ + public String getStartDateAsString() { + if( this.startTime != null) + return DateUtil.getDateAsString(getStartTime()); + return "Start Date not Set"; //$NON-NLS-1$ + } + + + /** + * @see java.lang.Object#toString() + */ + public String toString() { + StringBuffer result = new StringBuffer(); + result.append(AdminPlugin.Util.getString("MMSystem.MMSystem")).append(getIdentifier()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMSystem.properties")).append(getPropertiesAsString()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMSystem.isStarted")).append(isStarted()); //$NON-NLS-1$ + result.append(AdminPlugin.Util.getString("MMSystem.startTime")).append(getStartDateAsString()); //$NON-NLS-1$ + return result.toString(); + } + + +} + Modified: trunk/server/src/main/java/com/metamatrix/admin/server/AbstractAdminImpl.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/server/AbstractAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/server/AbstractAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -41,10 +41,13 @@ import org.teiid.adminapi.AdminObject; import org.teiid.adminapi.AdminOptions; import org.teiid.adminapi.AdminProcessingException; +import org.teiid.adminapi.ConnectionPool; +import org.teiid.adminapi.Transaction; import org.teiid.adminapi.VDB; import org.teiid.dqp.internal.process.DQPWorkContext; import org.xml.sax.SAXException; +import com.metamatrix.admin.AdminPlugin; import com.metamatrix.admin.api.exception.security.InvalidSessionException; import com.metamatrix.admin.objects.MMAdminObject; import com.metamatrix.admin.objects.MMConnectorBinding; @@ -92,7 +95,69 @@ /** * @since 4.3 */ -public class AbstractAdminImpl { +public class AbstractAdminImpl { + + /**Package containing the sub-interfaces of AdminObjects*/ + public static final String OBJECTS_PACKAGE = "com.metamatrix.admin.api.objects."; //$NON-NLS-1$ + + + + /**Object type code for Cache*/ + public static final int OBJECT_TYPE_CACHE = 0; + /**Object type code for ConnectorBinding*/ + public static final int OBJECT_TYPE_CONNECTOR_BINDING = 2; + /**Object type code for ConnectorType*/ + public static final int OBJECT_TYPE_CONNECTOR_TYPE = 3; + /**Object type code for ExtensionModule*/ + public static final int OBJECT_TYPE_EXTENSION_MODULE = 6; + /**Object type code for Group*/ + public static final int OBJECT_TYPE_GROUP = 7; + /**Object type code for LogConfiguration*/ + public static final int OBJECT_TYPE_LOG_CONFIGURATION = 9; + /**Object type code for Model*/ + public static final int OBJECT_TYPE_MODEL = 10; + /**Object type code for ProcessObject*/ + public static final int OBJECT_TYPE_PROCESS_OBJECT = 11; + /**Object type code for PropertyDefinition*/ + public static final int OBJECT_TYPE_PROPERTY_DEFINITION = 12; + /**Object type code for QueueWorkerPool*/ + public static final int OBJECT_TYPE_QUEUE_WORKER_POOL = 13; + /**Object type code for Request*/ + public static final int OBJECT_TYPE_REQUEST = 14; + /**Object type code for Role*/ + public static final int OBJECT_TYPE_ROLE = 16; + /**Object type code for Session*/ + public static final int OBJECT_TYPE_SESSION = 17; + /**Object type code for VDB*/ + public static final int OBJECT_TYPE_VDB = 21; + /**Object type code for TRANSACTION*/ + public static final int OBJECT_TYPE_TRANSACTION = 22; + /**Object type code for CONNECTION_POOL*/ + public static final int OBJECT_TYPE_CONNECTION_POOL = 23; + + + //map of String (class name) to Integer (object type code) + private static HashMap objectTypeMap = new HashMap(); + + + static { + objectTypeMap.put(org.teiid.adminapi.Cache.class.getName(), new Integer(OBJECT_TYPE_CACHE)); + objectTypeMap.put(org.teiid.adminapi.ConnectorBinding.class.getName(), new Integer(OBJECT_TYPE_CONNECTOR_BINDING)); + objectTypeMap.put(org.teiid.adminapi.ConnectorType.class.getName(), new Integer(OBJECT_TYPE_CONNECTOR_TYPE)); + objectTypeMap.put(org.teiid.adminapi.ExtensionModule.class.getName(), new Integer(OBJECT_TYPE_EXTENSION_MODULE)); + objectTypeMap.put(org.teiid.adminapi.Group.class.getName(), new Integer(OBJECT_TYPE_GROUP)); + objectTypeMap.put(org.teiid.adminapi.LogConfiguration.class.getName(), new Integer(OBJECT_TYPE_LOG_CONFIGURATION)); + objectTypeMap.put(org.teiid.adminapi.Model.class.getName(), new Integer(OBJECT_TYPE_MODEL)); + objectTypeMap.put(org.teiid.adminapi.ProcessObject.class.getName(), new Integer(OBJECT_TYPE_PROCESS_OBJECT)); + objectTypeMap.put(org.teiid.adminapi.PropertyDefinition.class.getName(), new Integer(OBJECT_TYPE_PROPERTY_DEFINITION)); + objectTypeMap.put(org.teiid.adminapi.QueueWorkerPool.class.getName(), new Integer(OBJECT_TYPE_QUEUE_WORKER_POOL)); + objectTypeMap.put(org.teiid.adminapi.Request.class.getName(), new Integer(OBJECT_TYPE_REQUEST)); + objectTypeMap.put(org.teiid.adminapi.Role.class.getName(), new Integer(OBJECT_TYPE_ROLE)); + objectTypeMap.put(org.teiid.adminapi.Session.class.getName(), new Integer(OBJECT_TYPE_SESSION)); + objectTypeMap.put(org.teiid.adminapi.VDB.class.getName(), new Integer(OBJECT_TYPE_VDB)); + objectTypeMap.put(Transaction.class.getName(), Integer.valueOf(OBJECT_TYPE_TRANSACTION)); + objectTypeMap.put(ConnectionPool.class.getName(), Integer.valueOf(OBJECT_TYPE_CONNECTION_POOL)); + } private static final String DOUBLE_ESCAPED_DELIMITER = "\\" + AdminObject.ESCAPED_DELIMITER; //$NON-NLS-1$ @@ -501,54 +566,54 @@ */ protected Collection getAdminObjects(String identifier, String className) throws AdminException { - int code = MMAdminObject.getObjectType(className); + int code = AbstractAdminImpl.getObjectType(className); ArrayList list = null; switch(code) { - case MMAdminObject.OBJECT_TYPE_CACHE: + case AbstractAdminImpl.OBJECT_TYPE_CACHE: return parent.getCaches(identifier); - case MMAdminObject.OBJECT_TYPE_CONNECTOR_BINDING: + case AbstractAdminImpl.OBJECT_TYPE_CONNECTOR_BINDING: return parent.getConnectorBindings(identifier); - case MMAdminObject.OBJECT_TYPE_CONNECTOR_TYPE: + case AbstractAdminImpl.OBJECT_TYPE_CONNECTOR_TYPE: return parent.getConnectorTypes(identifier); - case MMAdminObject.OBJECT_TYPE_DQP: - return parent.getDQPs(identifier); - case MMAdminObject.OBJECT_TYPE_EXTENSION_MODULE: +// case MMAdminObject.OBJECT_TYPE_DQP: +// return parent.getDQPs(identifier); + case AbstractAdminImpl.OBJECT_TYPE_EXTENSION_MODULE: return parent.getExtensionModules(identifier); - case MMAdminObject.OBJECT_TYPE_GROUP: + case AbstractAdminImpl.OBJECT_TYPE_GROUP: return parent.getGroups(identifier); - case MMAdminObject.OBJECT_TYPE_HOST: - return parent.getHosts(identifier); - case MMAdminObject.OBJECT_TYPE_LOG_CONFIGURATION: +// case MMAdminObject.OBJECT_TYPE_HOST: +// return parent.getHosts(identifier); + case AbstractAdminImpl.OBJECT_TYPE_LOG_CONFIGURATION: list = new ArrayList(); list.add(parent.getLogConfiguration()); return list; - case MMAdminObject.OBJECT_TYPE_PROCESS_OBJECT: + case AbstractAdminImpl.OBJECT_TYPE_PROCESS_OBJECT: return parent.getProcesses(identifier); - case MMAdminObject.OBJECT_TYPE_QUEUE_WORKER_POOL: + case AbstractAdminImpl.OBJECT_TYPE_QUEUE_WORKER_POOL: return parent.getQueueWorkerPools(identifier); - case MMAdminObject.OBJECT_TYPE_REQUEST: + case AbstractAdminImpl.OBJECT_TYPE_REQUEST: return parent.getRequests(identifier); - case MMAdminObject.OBJECT_TYPE_SERVICE: - return parent.getServices(identifier); - case MMAdminObject.OBJECT_TYPE_RESOURCE: - return parent.getResources(identifier); - case MMAdminObject.OBJECT_TYPE_SESSION: +// case MMAdminObject.OBJECT_TYPE_SERVICE: +// return parent.getServices(identifier); +// case MMAdminObject.OBJECT_TYPE_RESOURCE: +// return parent.getResources(identifier); + case AbstractAdminImpl.OBJECT_TYPE_SESSION: return parent.getSessions(identifier); - case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: - list = new ArrayList(); - list.add(parent.getSystem()); - return list; - case MMAdminObject.OBJECT_TYPE_VDB: +// case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: +// list = new ArrayList(); +// list.add(parent.getSystem()); +// return list; + case AbstractAdminImpl.OBJECT_TYPE_VDB: return parent.getVDBs(identifier); - case MMAdminObject.OBJECT_TYPE_TRANSACTION: + case AbstractAdminImpl.OBJECT_TYPE_TRANSACTION: return parent.getTransactions(); - case MMAdminObject.OBJECT_TYPE_CONNECTION_POOL: + case AbstractAdminImpl.OBJECT_TYPE_CONNECTION_POOL: return parent.getConnectionPoolStats(identifier); - case MMAdminObject.OBJECT_TYPE_ENTITLEMENT: - case MMAdminObject.OBJECT_TYPE_MODEL: - case MMAdminObject.OBJECT_TYPE_PROPERTY_DEFINITION: - case MMAdminObject.OBJECT_TYPE_ROLE: + // case MMAdminObject.OBJECT_TYPE_ENTITLEMENT: + case AbstractAdminImpl.OBJECT_TYPE_MODEL: + case AbstractAdminImpl.OBJECT_TYPE_PROPERTY_DEFINITION: + case AbstractAdminImpl.OBJECT_TYPE_ROLE: default: throwProcessingException("AbstractAdminImpl.Unsupported_Admin_Object", new Object[] {className}); //$NON-NLS-1$ @@ -608,5 +673,28 @@ } catch (IOException e) { throw new AdminComponentException(e); } + } + + /** + * Get the object type code for the specified classname. + * @param className This may be fully qualified or not, e.g. + * "com.metamatrix.admin.api.objects.ConnectorBinding" or "ConnectorBinding". + * @return Object type code. The will be one of the constants AdminObject.OBJECT_TYPE_xxx. + * @throws AdminException + * @since 4.3 + */ + public static int getObjectType(String className) throws AdminException { + //convert to the fully qualified className + if (className.indexOf(".") == -1) { //$NON-NLS-1$ + className = OBJECTS_PACKAGE + className; + } + + Integer codeInteger = (Integer) objectTypeMap.get(className); + if (codeInteger == null) { + String message = AdminPlugin.Util.getString("MMAdminObject.Unsupported_Admin_Object", new Object[] {className}); //$NON-NLS-1$ + throw new AdminProcessingException(message); + } + + return codeInteger.intValue(); } } Modified: trunk/server/src/main/java/com/metamatrix/admin/server/ServerAdminImpl.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/server/ServerAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/server/ServerAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -36,11 +36,12 @@ import org.teiid.adminapi.EmbeddedLogger; import org.teiid.adminapi.Group; import org.teiid.adminapi.LogConfiguration; -import org.teiid.adminapi.ScriptsContainer; -import org.teiid.adminapi.SystemObject; +import org.teiid.adminapi.PropertyDefinition; import org.teiid.adminapi.Transaction; import org.teiid.adminapi.VDB; +import com.metamatrix.admin.api.ScriptsContainer; +import com.metamatrix.admin.api.SystemObject; import com.metamatrix.admin.api.server.ServerAdmin; import com.metamatrix.api.exception.MetaMatrixComponentException; import com.metamatrix.api.exception.MetaMatrixProcessingException; @@ -1020,4 +1021,19 @@ public void shutdown(int millisToWait) throws AdminException { } + @Override + public void deleteVDB(String vdbName, String version) throws AdminException { + } + + @Override + public void setConnectorBindingProperty(String deployedName, + String propertyName, String propertyValue) throws AdminException { + } + + @Override + public Collection<PropertyDefinition> getConnectorTypePropertyDefinitions( + String connectorTypeIdentifier) throws AdminException { + return null; + } + } \ No newline at end of file Modified: trunk/server/src/main/java/com/metamatrix/admin/server/ServerConfigAdminImpl.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/server/ServerConfigAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/server/ServerConfigAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -45,14 +45,15 @@ import org.teiid.adminapi.AdminObject; import org.teiid.adminapi.AdminOptions; import org.teiid.adminapi.AdminProcessingException; -import org.teiid.adminapi.AdminStatus; +import org.teiid.adminapi.EmbeddedLogger; import org.teiid.adminapi.LogConfiguration; import org.teiid.adminapi.ProcessObject; -import org.teiid.adminapi.ScriptsContainer; -import org.teiid.adminapi.SystemObject; import org.teiid.adminapi.VDB; import com.metamatrix.admin.AdminPlugin; +import com.metamatrix.admin.api.AdminStatus; +import com.metamatrix.admin.api.ScriptsContainer; +import com.metamatrix.admin.api.SystemObject; import com.metamatrix.admin.api.exception.security.InvalidSessionException; import com.metamatrix.admin.api.server.ServerConfigAdmin; import com.metamatrix.admin.objects.MMAdminObject; @@ -800,11 +801,11 @@ String mmHost = null; String mmPort = null; Collection hosts = parent.getHosts(AdminObject.WILDCARD); - org.teiid.adminapi.Host aHost = (org.teiid.adminapi.Host) hosts.iterator().next(); + com.metamatrix.admin.api.Host aHost = (com.metamatrix.admin.api.Host) hosts.iterator().next(); mmHost = aHost.getName(); Collection hostProcesses = parent.getProcesses(aHost.getIdentifier() + AdminObject.DELIMITER + AdminObject.WILDCARD); ProcessObject hostProcess = (ProcessObject) hostProcesses.iterator().next(); - mmPort = hostProcess.getPropertyValue(ProcessObject.SERVER_PORT); + mmPort = hostProcess.getPropertyValue(VMComponentDefnType.SERVER_PORT); //boolean useSSL = SSLConfiguration.isSSLEnabled(); boolean useSSL = false; @@ -1469,7 +1470,7 @@ /** - * Supported classes are {@link org.teiid.adminapi.Host}, {@link org.teiid.adminapi.ConnectorBinding}, + * Supported classes are {@link com.metamatrix.admin.api.Host}, {@link org.teiid.adminapi.ConnectorBinding}, * {@link SystemObject}, {@link ProcessObject} * @see com.metamatrix.admin.api.server.ServerConfigAdmin#setProperty(java.lang.String, java.lang.String, java.lang.String) * @since 4.3 @@ -1488,7 +1489,7 @@ /** - * Supported classes are {@link org.teiid.adminapi.ConnectorBinding}, {@link org.teiid.adminapi.Service}, + * Supported classes are {@link org.teiid.adminapi.ConnectorBinding}, {@link com.metamatrix.admin.api.Service}, * {@link SystemObject}, {@link ProcessObject} * @see org.teiid.adminapi.ConfigurationAdmin#updateProperties(java.lang.String, java.lang.String, java.util.Properties) * @since 4.3 @@ -1498,7 +1499,7 @@ Properties properties) throws AdminException { int nodeCount = getNodeCount(identifier); - int type = MMAdminObject.getObjectType(className); + int type = AbstractAdminImpl.getObjectType(className); AdminObject adminObject = null; String hostName; @@ -1506,15 +1507,15 @@ switch (type) { - case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: - this.updateSystemProperties(properties); - break; +// case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: +// this.updateSystemProperties(properties); +// break; - case MMAdminObject.OBJECT_TYPE_PROCESS_OBJECT: + case AbstractAdminImpl.OBJECT_TYPE_PROCESS_OBJECT: adminObject = getAdminObject(identifier, className); ProcessObject process = (ProcessObject)adminObject; String processName = adminObject.getName(); - hostName = process.getHostIdentifier(); + hostName = process.getHostName(); try { VMComponentDefn vmDefn = getVMByName(hostName, processName); Properties processProperties = vmDefn.getProperties(); @@ -1536,7 +1537,7 @@ break; - case MMAdminObject.OBJECT_TYPE_CONNECTOR_BINDING: + case AbstractAdminImpl.OBJECT_TYPE_CONNECTOR_BINDING: String connectorBindingName; if (nodeCount > 1) { adminObject = getAdminObject(identifier, className); @@ -1576,7 +1577,7 @@ throw new AdminComponentException(e); } break; - + /* case MMAdminObject.OBJECT_TYPE_SERVICE: String serviceName; if (nodeCount > 1) { @@ -1628,8 +1629,8 @@ e.printStackTrace(); } break; + */ - default: throwProcessingException("ServerConfigAdminImpl.Unsupported_Admin_Object", new Object[] {className}); //$NON-NLS-1$ } @@ -2380,5 +2381,21 @@ public void extensionModuleModified(String name) throws AdminException { } + + @Override + public void deleteVDB(String vdbName, String version) throws AdminException { + + } + + @Override + public void setConnectorBindingProperty(String deployedName, + String propertyName, String propertyValue) throws AdminException { + + } + + @Override + public void setLogListener(EmbeddedLogger listener) throws AdminException { + + } } \ No newline at end of file Modified: trunk/server/src/main/java/com/metamatrix/admin/server/ServerMonitoringAdminImpl.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/server/ServerMonitoringAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/server/ServerMonitoringAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -46,12 +46,13 @@ import org.teiid.adminapi.AdminObject; import org.teiid.adminapi.AdminProcessingException; import org.teiid.adminapi.Model; -import org.teiid.adminapi.Service; +import org.teiid.adminapi.PropertyDefinition; import org.teiid.adminapi.Session; -import org.teiid.adminapi.SystemObject; import org.teiid.adminapi.Transaction; import org.teiid.adminapi.VDB; +import com.metamatrix.admin.api.Service; +import com.metamatrix.admin.api.SystemObject; import com.metamatrix.admin.api.server.ServerMonitoringAdmin; import com.metamatrix.admin.objects.MMAdminObject; import com.metamatrix.admin.objects.MMConnectionPool; @@ -1206,18 +1207,18 @@ String objectIdentifier = adminObject.getIdentifier(); Configuration config; - int type = MMAdminObject.getObjectType(className); + int type = AbstractAdminImpl.getObjectType(className); switch (type) { - case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: - return convertPropertyDefinitions(getConfigurationServiceProxy().getCurrentConfiguration()); +// case MMAdminObject.OBJECT_TYPE_SYSTEM_OBJECT: +// return convertPropertyDefinitions(getConfigurationServiceProxy().getCurrentConfiguration()); - case MMAdminObject.OBJECT_TYPE_HOST: - return convertPropertyDefinitions(getHostComponent(objectIdentifier)); +// case MMAdminObject.OBJECT_TYPE_HOST: +// return convertPropertyDefinitions(getHostComponent(objectIdentifier)); - case MMAdminObject.OBJECT_TYPE_PROCESS_OBJECT: + case AbstractAdminImpl.OBJECT_TYPE_PROCESS_OBJECT: return convertPropertyDefinitions(getProcessComponent(objectIdentifier)); - case MMAdminObject.OBJECT_TYPE_CONNECTOR_BINDING: + case AbstractAdminImpl.OBJECT_TYPE_CONNECTOR_BINDING: config = getConfigurationServiceProxy().getCurrentConfiguration(); ConnectorBinding configBinding = config.getConnectorBinding(MMAdminObject.getNameFromIdentifier(objectIdentifier)); @@ -1225,27 +1226,27 @@ return convertPropertyDefinitions(component, configBinding.getProperties()); - case MMAdminObject.OBJECT_TYPE_SERVICE: - config = getConfigurationServiceProxy().getCurrentConfiguration(); - ServiceComponentDefn svc = config.getServiceComponentDefn(MMAdminObject.getNameFromIdentifier(objectIdentifier)); - - component = getDeployedComponent(objectIdentifier); - - return convertPropertyDefinitions(component, svc.getProperties()); +// case MMAdminObject.OBJECT_TYPE_SERVICE: +// config = getConfigurationServiceProxy().getCurrentConfiguration(); +// ServiceComponentDefn svc = config.getServiceComponentDefn(MMAdminObject.getNameFromIdentifier(objectIdentifier)); +// +// component = getDeployedComponent(objectIdentifier); +// +// return convertPropertyDefinitions(component, svc.getProperties()); - case MMAdminObject.OBJECT_TYPE_CONNECTOR_TYPE: + case AbstractAdminImpl.OBJECT_TYPE_CONNECTOR_TYPE: ComponentType componentType = getConnectorTypeComponentType(objectIdentifier); return convertPropertyDefinitions(componentType, new Properties()); - case MMAdminObject.OBJECT_TYPE_DQP: - config = getConfigurationServiceProxy().getCurrentConfiguration(); - ServiceComponentDefn defn = config.getServiceComponentDefn(MMAdminObject.getNameFromIdentifier(objectIdentifier)); +// case MMAdminObject.OBJECT_TYPE_DQP: +// config = getConfigurationServiceProxy().getCurrentConfiguration(); +// ServiceComponentDefn defn = config.getServiceComponentDefn(MMAdminObject.getNameFromIdentifier(objectIdentifier)); +// +// return convertPropertyDefinitions(getDQPComponent(objectIdentifier), defn.getProperties()); - return convertPropertyDefinitions(getDQPComponent(objectIdentifier), defn.getProperties()); - - case MMAdminObject.OBJECT_TYPE_RESOURCE: - return convertPropertyDefinitions(getResourceComponent(objectIdentifier)); +// case MMAdminObject.OBJECT_TYPE_RESOURCE: +// return convertPropertyDefinitions(getResourceComponent(objectIdentifier)); default: throwProcessingException("ServerMonitoringAdminImpl.Unsupported_Admin_Object", new Object[] {className}); //$NON-NLS-1$ @@ -1405,5 +1406,11 @@ throws AdminException { return getQueryServiceProxy().getTransactions(); } + + @Override + public Collection<PropertyDefinition> getConnectorTypePropertyDefinitions( + String connectorTypeIdentifier) throws AdminException { + return null; + } } \ No newline at end of file Modified: trunk/server/src/main/java/com/metamatrix/admin/server/ServerRuntimeStateAdminImpl.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/server/ServerRuntimeStateAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/server/ServerRuntimeStateAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -362,7 +362,7 @@ if (waitUntilDone) { boolean done = false; while (! done) { - done = isProcessStopped(process.getName(), process.getHostName()); + done = isProcessStopped(process.getName(), process.getProcessName()); try { Thread.sleep(ServerAdminImpl.SERVICE_WAIT_INTERVAL); } catch (InterruptedException e) { @@ -746,10 +746,6 @@ } @Override - public void setLogListener(EmbeddedLogger listener) throws AdminException { - } - - @Override public void bounceSystem(boolean waitUntilDone) throws AdminException { } Modified: trunk/server/src/main/java/com/metamatrix/admin/server/ServerSecurityAdminImpl.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/admin/server/ServerSecurityAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/admin/server/ServerSecurityAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -36,8 +36,8 @@ import org.teiid.adminapi.AdminProcessingException; import org.teiid.adminapi.AdminRoles; import org.teiid.adminapi.Group; -import org.teiid.adminapi.Principal; +import com.metamatrix.admin.api.Principal; import com.metamatrix.admin.api.exception.security.InvalidSessionException; import com.metamatrix.admin.api.exception.security.MetaMatrixSecurityException; import com.metamatrix.admin.api.server.ServerSecurityAdmin; Modified: trunk/server/src/main/java/com/metamatrix/common/config/CurrentConfiguration.java =================================================================== --- trunk/server/src/main/java/com/metamatrix/common/config/CurrentConfiguration.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/main/java/com/metamatrix/common/config/CurrentConfiguration.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -323,11 +323,11 @@ BasicHost host = new BasicHost(new ConfigurationID(name), new HostID(name), Host.HOST_COMPONENT_TYPE_ID); Properties props = new Properties(); - props.setProperty(org.teiid.adminapi.Host.INSTALL_DIR, getBootStrapProperties().getProperty(org.teiid.adminapi.Host.INSTALL_DIR, System.getProperty("user.dir"))); //$NON-NLS-1$ - props.setProperty(org.teiid.adminapi.Host.HOST_DIRECTORY, getBootStrapProperties().getProperty(org.teiid.adminapi.Host.HOST_DIRECTORY, System.getProperty("user.dir"))); //$NON-NLS-1$ - props.setProperty(org.teiid.adminapi.Host.LOG_DIRECTORY, getBootStrapProperties().getProperty(org.teiid.adminapi.Host.LOG_DIRECTORY, System.getProperty("user.dir"))); //$NON-NLS-1$ - props.setProperty(org.teiid.adminapi.Host.HOST_BIND_ADDRESS, getBootStrapProperties().getProperty(org.teiid.adminapi.Host.HOST_BIND_ADDRESS, "")); //$NON-NLS-1$ - props.setProperty(org.teiid.adminapi.Host.HOST_PHYSICAL_ADDRESS, getBootStrapProperties().getProperty(org.teiid.adminapi.Host.HOST_PHYSICAL_ADDRESS, "")); //$NON-NLS-1$ + props.setProperty(com.metamatrix.admin.api.Host.INSTALL_DIR, getBootStrapProperties().getProperty(com.metamatrix.admin.api.Host.INSTALL_DIR, System.getProperty("user.dir"))); //$NON-NLS-1$ + props.setProperty(com.metamatrix.admin.api.Host.HOST_DIRECTORY, getBootStrapProperties().getProperty(com.metamatrix.admin.api.Host.HOST_DIRECTORY, System.getProperty("user.dir"))); //$NON-NLS-1$ + props.setProperty(com.metamatrix.admin.api.Host.LOG_DIRECTORY, getBootStrapProperties().getProperty(com.metamatrix.admin.api.Host.LOG_DIRECTORY, System.getProperty("user.dir"))); //$NON-NLS-1$ + props.setProperty(com.metamatrix.admin.api.Host.HOST_BIND_ADDRESS, getBootStrapProperties().getProperty(com.metamatrix.admin.api.Host.HOST_BIND_ADDRESS, "")); //$NON-NLS-1$ + props.setProperty(com.metamatrix.admin.api.Host.HOST_PHYSICAL_ADDRESS, getBootStrapProperties().getProperty(com.metamatrix.admin.api.Host.HOST_PHYSICAL_ADDRESS, "")); //$NON-NLS-1$ host.setProperties(props); return host; Modified: trunk/server/src/test/java/com/metamatrix/admin/server/TestServerConfigAdminImpl.java =================================================================== --- trunk/server/src/test/java/com/metamatrix/admin/server/TestServerConfigAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/test/java/com/metamatrix/admin/server/TestServerConfigAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -33,12 +33,12 @@ import org.teiid.adminapi.AdminOptions; import org.teiid.adminapi.AdminProcessingException; import org.teiid.adminapi.ConnectorBinding; -import org.teiid.adminapi.Host; import org.teiid.adminapi.ProcessObject; -import org.teiid.adminapi.Service; import junit.framework.TestCase; +import com.metamatrix.admin.api.Host; +import com.metamatrix.admin.api.Service; import com.metamatrix.admin.objects.MMConnectorBinding; import com.metamatrix.admin.objects.MMProcess; import com.metamatrix.common.application.DQPConfigSource; Modified: trunk/server/src/test/java/com/metamatrix/admin/server/TestServerMonitoringAdminImpl.java =================================================================== --- trunk/server/src/test/java/com/metamatrix/admin/server/TestServerMonitoringAdminImpl.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/server/src/test/java/com/metamatrix/admin/server/TestServerMonitoringAdminImpl.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -159,10 +159,7 @@ * Expects service3 to be running, but not deployed. * @since 6.1 */ - public void testGetServices() throws AdminException { - - - + public void defer_testGetServices() throws AdminException { Collection<MMService> results = admin.getServices(AdminObject.WILDCARD + "dqp*"); assertEquals(3, results.size()); @@ -251,7 +248,7 @@ * Expects dqp3 to be running, but not deployed. * @since 4.3 */ - public void testGetDQPs() throws AdminException { + public void defer_testGetDQPs() throws AdminException { Collection<MMDQP> results = admin.getDQPs(AdminObject.WILDCARD); assertEquals(3, results.size()); Modified: trunk/test-integration/src/test/java/com/metamatrix/server/integration/TestAdminApi.java =================================================================== --- trunk/test-integration/src/test/java/com/metamatrix/server/integration/TestAdminApi.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/test-integration/src/test/java/com/metamatrix/server/integration/TestAdminApi.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -45,6 +45,7 @@ import org.teiid.adminapi.ExtensionModule; import org.teiid.adminapi.LogConfiguration; import org.teiid.adminapi.ProcessObject; +import org.teiid.adminapi.PropertyDefinition; import org.teiid.adminapi.VDB; import org.teiid.runtime.adminapi.Util; @@ -433,7 +434,7 @@ Collection<ConnectorBinding> bindings = getAdmin().getConnectorBindings("BQT_1.BQT1 Oracle 9i Simple Cap"); //$NON-NLS-1$ for (ConnectorBinding binding:bindings) { - getAdmin().setProperty(binding.getIdentifier(), ConnectorBinding.class.getName(), "RowCount", "10"); //$NON-NLS-1$ //$NON-NLS-2$ + getAdmin().setConnectorBindingProperty(binding.getIdentifier(), "RowCount", "10"); //$NON-NLS-1$ //$NON-NLS-2$ getAdmin().stopConnectorBinding(binding.getIdentifier(), true); getAdmin().startConnectorBinding(binding.getIdentifier()); } @@ -1014,7 +1015,32 @@ closeConnection(); } + @Test public void testPropertyDefinitions() throws Exception{ + getConnection(ADMIN, PROPS_FILE); + cleanDeploy(); + Collection<ConnectorType> c = getAdmin().getConnectorTypes("Oracle Connector"); //$NON-NLS-1$ + Collection<PropertyDefinition> defs = getAdmin().getConnectorTypePropertyDefinitions(c.iterator().next().getIdentifier()); + + for (PropertyDefinition d:defs) { + if (d.getName().equalsIgnoreCase("URL")) { //$NON-NLS-1$ + assertTrue(d.isRequired()); + assertTrue(d.getDefaultValue() != null); + assertEquals("JDBC URL", d.getDisplayName()); //$NON-NLS-1$ + assertEquals("String", d.getPropertyType()); //$NON-NLS-1$ + assertEquals("java.lang.String", d.getPropertyTypeClassName()); //$NON-NLS-1$ + assertTrue(d.getAllowedValues().isEmpty()); + assertTrue(!d.isMasked()); + } + + if (d.getName().equalsIgnoreCase("Password")) { //$NON-NLS-1$ + assertTrue(d.isMasked()); + } + } + + closeConnection(); + } + VDB addVDB(String name, String vdbFile) { try { Modified: trunk/test-integration/src/test/java/org/teiid/runtime/adminapi/TestEmbeddedAdmin.java =================================================================== --- trunk/test-integration/src/test/java/org/teiid/runtime/adminapi/TestEmbeddedAdmin.java 2009-08-28 22:23:06 UTC (rev 1290) +++ trunk/test-integration/src/test/java/org/teiid/runtime/adminapi/TestEmbeddedAdmin.java 2009-08-28 22:27:14 UTC (rev 1291) @@ -331,7 +331,7 @@ binding = current; } } - admin.setProperty(binding.getIdentifier(), ConnectorBinding.class.getName(), "RowCount", "10"); //$NON-NLS-1$ //$NON-NLS-2$ + admin.setConnectorBindingProperty(binding.getIdentifier(), "RowCount", "10"); //$NON-NLS-1$ //$NON-NLS-2$ admin.stopConnectorBinding(LOOPBACK, true); admin.startConnectorBinding(LOOPBACK);