package com.c2kernel.collection; import java.util.StringTokenizer; import com.c2kernel.common.ObjectNotFoundException; import com.c2kernel.entity.proxy.EntityProxy; import com.c2kernel.lookup.EntityPath; import com.c2kernel.lookup.InvalidEntityPathException; import com.c2kernel.persistency.ClusterStorage; import com.c2kernel.process.Gateway; import com.c2kernel.property.Property; import com.c2kernel.utils.CastorHashMap; import com.c2kernel.utils.KeyValuePair; import com.c2kernel.utils.Logger; /** * @version $Revision: 1.10 $ $Date: 2004/10/21 08:02:23 $ * @author $Author: abranson $ */ public class DependencyMember implements CollectionMember { private int mEntityKey = -1; private EntityProxy mEntity = null; private int mId = -1; private CastorHashMap mProperties = null; private String mClassProps; /************************************************************************** * **************************************************************************/ public DependencyMember() { mEntityKey = -1; mProperties = new CastorHashMap(); } public void setEntityKey(int entityKey) { mEntityKey = entityKey; mEntity = null; } public int getEntityKey() { return mEntityKey; } public void setProperties(CastorHashMap props) { mProperties = props; } public CastorHashMap getProperties() { return mProperties; } public KeyValuePair[] getKeyValuePairs() { return mProperties.getKeyValuePairs(); } public void setKeyValuePairs(KeyValuePair[] pairs) { mProperties.setKeyValuePairs(pairs); } public int getID() { return mId; } public void setID(int id) { mId = id; } public void setClassProps(String props) { mClassProps = props; } public String getClassProps() { return mClassProps; } public void assignEntity(int entityKey) throws MembershipException { if (entityKey > -1) { if (mClassProps == null || getProperties() == null) throw new MembershipException("ClassProps not yet set. Cannot check membership validity."); //for each mandatory prop check if its in the member property and has the matching value StringTokenizer sub = new StringTokenizer(mClassProps, ","); while (sub.hasMoreTokens()) { String aClassProp = sub.nextToken(); try { String memberValue = (String)getProperties().get(aClassProp); Property entityProperty = (Property)Gateway.getStorage().get(entityKey, ClusterStorage.PROPERTY+"/"+aClassProp, null); if (entityProperty == null) throw new MembershipException("Property "+aClassProp+ " does not exist for entityKey=" + entityKey ); if (!entityProperty.getValue().equalsIgnoreCase(memberValue)) throw new MembershipException("DependencyMember::checkProperty() Values of mandatory prop "+aClassProp+" do not match " + entityProperty.getValue()+"!="+memberValue); } catch (Exception ex) { Logger.error(ex); throw new MembershipException("Error checking properties"); } } } mEntityKey = entityKey; mEntity = null; } public void clearEntity() { mEntityKey = -1; mEntity = null; } public EntityProxy resolveEntity() throws ObjectNotFoundException { if (mEntity == null) { try { EntityPath path = new EntityPath(mEntityKey); mEntity = Gateway.getProxyManager().getProxy(path); } catch (InvalidEntityPathException ex) { throw new ObjectNotFoundException("No member defined", ""); } } return mEntity; } }