ServiceSchemaModifications.java revision 6d1d235433e402873f33b933020f25c11aa2b9ab
/**
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
*
* Copyright (c) 2011-2014 ForgeRock AS. All Rights Reserved
*
* The contents of this file are subject to the terms
* of the Common Development and Distribution License
* (the License). You may not use this file except in
* compliance with the License.
*
* You can obtain a copy of the License at
* See the License for the specific language governing
* permission and limitations under the License.
*
* When distributing Covered Code, include this CDDL
* Header Notice in each file and include the License file
* If applicable, add the following below the CDDL Header,
* with the fields enclosed by brackets [] replaced by
* your own identifying information:
* "Portions Copyrighted [year] [name of copyright owner]"
*
*/
/**
* This class determines how a service schema has changed between the current
* version and the new version in the war file.
*
* @author steve
*/
public class ServiceSchemaModifications {
private boolean isServiceModified = false;
private boolean hasSubSchemaChanges = false;
private boolean hasSchemaChanges = false;
throws UpgradeException {
this.serviceName = serviceName;
this.serviceSchemaDoc = schemaDoc;
this.adminToken = adminToken;
}
public boolean isServiceModified() {
return isServiceModified;
}
public boolean hasSchemaChanges() {
return hasSchemaChanges;
}
public boolean hasSubSchemaChanges() {
return hasSubSchemaChanges;
}
return schemaModifications;
}
return modifications;
}
return subSchemaChanges;
}
private void parseServiceDefinition() throws UpgradeException {
//we should only fetch these once to prevent performance problems, also in case of fetchNew to prevent
//encrypting passwords multiple times.
try {
} catch (SMSException smse) {
} catch (SSOException ssoe) {
}
}
hasSchemaChanges = true;
}
// sub schemas added or removed?
}
hasSubSchemaChanges = true;
}
// has the service changed
}
isServiceModified = true;
}
}
}
}
return schemas;
}
//NB: only schema additions are currently supported.
}
}
return !schemaModifications.isEmpty();
}
try {
if (subSchemaAdded.subSchemaChanged()) {
}
}
} catch (SMSException smse) {
UpgradeUtils.debug.error("error whilst determining sub schema changes for service: " + serviceName, smse);
}
UpgradeUtils.debug.message("calculateSubSchemaChanges returning " + (!(subSchemaChanges.isEmpty())));
}
return !(subSchemaChanges.isEmpty());
}
throws SMSException {
} else {
if (subSchemaAddedResult.subSchemaChanged()) {
}
}
}
}
return subSchemaAddedResult;
}
try {
//this is a new schema, that's not available in the existing schema, should be covered by
//calculateSchemaChanges
continue;
}
schema);
schema);
schema);
if (attrsAdded.hasBeenModified() || attrsModified.hasBeenModified() || attrsDeleted.hasBeenModified()) {
}
}
} catch (SMSException smse) {
UpgradeUtils.debug.error("error whilst determining schema changes for service: " + serviceName, smse);
}
UpgradeUtils.debug.message("calculateServiceModifications returning " + (!(modifications.isEmpty())));
}
return !(modifications.isEmpty());
}
throws SMSException, UpgradeException {
ServiceSchemaModificationWrapper attrAddedResult = new ServiceSchemaModificationWrapper(serviceName, schemaName);
attrsAdded = getAttributesAdded(newSchema.getAttributeSchemas(), existingSchema.getAttributeSchemas());
}
if (!(attrsAdded.isEmpty())) {
}
// new sub schema so skip attribute checking
continue;
}
if (subSchemaResult.hasBeenModified()) {
}
}
}
return attrAddedResult;
}
throws SMSException, UpgradeException {
ServiceSchemaModificationWrapper attrModifiedResult = new ServiceSchemaModificationWrapper(serviceName, schemaName);
attrsModified = getAttributesModified(newSchema.getAttributeSchemas(), existingSchema.getAttributeSchemas());
}
if (!(attrsModified.isEmpty())) {
}
// new sub schema so skip attribute checking
continue;
}
if (subSchemaResult.hasBeenModified()) {
}
}
}
return attrModifiedResult;
}
throws SMSException {
ServiceSchemaModificationWrapper attrDeletedResult = new ServiceSchemaModificationWrapper(serviceName, schemaName);;
attrsDeleted = getAttributesDeleted(newSchema.getAttributeSchemas(), existingSchema.getAttributeSchemas());
}
if (!(attrsDeleted.isEmpty())) {
}
// new sub schema so skip attribute checking
continue;
}
if (subSchemaResult.hasBeenModified()) {
}
}
}
return attrDeletedResult;
}
boolean found = false;
found = true;
}
}
if (!found) {
if (serviceHelper != null) {
}
}
}
return attrAdded;
}
private Set<AttributeSchemaImpl> getAttributesModified(Set<AttributeSchemaImpl> newAttrs, Set<AttributeSchemaImpl> existingAttrs)
throws UpgradeException {
// skip attributes that are not explicitly named for upgrade
continue;
}
continue;
}
try {
if (upgradedAttr != null) {
}
} catch (UpgradeException ue) {
throw ue;
}
}
}
return attrMods;
}
private Set<AttributeSchemaImpl> getAttributesDeleted(Set<AttributeSchemaImpl> newAttrs, Set<AttributeSchemaImpl> existingAttrs) {
boolean found = false;
found = true;
}
}
if (!found) {
}
}
return attrDeleted;
}
throws UpgradeException {
try {
} catch (SMSException smse) {
throw new UpgradeException(smse);
}
return schemas;
}
private Map<String, ServiceSchemaImpl> fetchExistingServiceAttributes(String serviceName, SSOToken adminToken)
throws SMSException, SSOException {
return schemas;
}
}