DeploymentDescEjb2.java

package org.objectweb.jonas_ejb.deployment.api;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import org.objectweb.jonas_ejb.deployment.xml.AssemblyDescriptor;
import org.objectweb.jonas_ejb.deployment.xml.EjbJar;
import org.objectweb.jonas_ejb.deployment.xml.EjbRelation;
import org.objectweb.jonas_ejb.deployment.xml.Entity;
import org.objectweb.jonas_ejb.deployment.xml.JonasEjbJar;
import org.objectweb.jonas_ejb.deployment.xml.JonasEjbRelation;
import org.objectweb.jonas_ejb.deployment.xml.JonasEntity;
import org.objectweb.jonas_ejb.deployment.xml.JonasMessageDriven;
import org.objectweb.jonas_ejb.deployment.xml.MessageDriven;
import org.objectweb.jonas_ejb.lib.RdbMappingBuilder;
import org.objectweb.jonas_lib.deployment.api.DeploymentDescException;
import org.objectweb.jonas_lib.deployment.xml.JLinkedList;
import org.objectweb.jorm.metainfo.api.Manager;
import org.objectweb.util.monolog.api.Logger;
import org.objectweb.util.monolog.api.BasicLevel;

public class DeploymentDescEjb2 extends DeploymentDesc {

    private RdbMappingBuilder rdbMapping = null;

    private ArrayList ejbRelations = new ArrayList();

    public DeploymentDescEjb2(ClassLoader classLoader, EjbJar ejbJar,
                              JonasEjbJar jonasEjbJar, Logger l,
                              String fileName)
        throws DeploymentDescException {

        // Session and Entity bean descriptors are built here.
        // This part is common with EJB1.1 spec (no CMP2, no MDB)
        super(classLoader, ejbJar, jonasEjbJar, l, fileName);

        // HashMap of jonas-message-driven
        HashMap jonasMessageDriven = new HashMap();
        for (Iterator i = jonasEjbJar.getJonasMessageDrivenList().iterator(); i.hasNext(); ) {
            JonasMessageDriven jMd = (JonasMessageDriven) i.next();
            jonasMessageDriven.put(jMd.getEjbName(), jMd);
        }

        // message-driven beans
        for (Iterator i = ejbJar.getEnterpriseBeans().getMessageDrivenList().iterator(); i.hasNext(); ) {
            BeanDesc bd = null;
            MessageDriven md = (MessageDriven) i.next();
            /*
             * The Standard DTD allows a message-driven-bean without ejb-name
             * Problem to associate infos to this bean (trans-attribute, jonas-specific infos)
             * So the ejb-name must be specify and we check this
             */
            if (md.getEjbName() == null) {
                throw new DeploymentDescException("ejb-name missing for a message driven bean");
            }
            // find corresponding jonas message-driven
            JonasMessageDriven jMd = (JonasMessageDriven) jonasMessageDriven.get(md.getEjbName());
            if (jMd == null) {
                throw new DeploymentDescException("jonas-message-driven-bean missing for bean " + md.getEjbName());
            }

            bd = new MessageDrivenDesc(classLoader, md, asd, jMd,
                    jonasEjbJar.getJonasMessageDestinationList(), fileName);
            
            bd.setDeploymentDesc(this);
            bd.check();
            beanDesc.put(bd.getEjbName(), bd);
        }

        // Relations on Entity beans CMP2
        if (ejbJar.getRelationships() != null) {

            // ArrayList of standard-relation names (Strings)
            ArrayList stdRelations = new ArrayList();

            // HashMap of jonas-relation
            HashMap jonasRelations = new HashMap();
            for (Iterator i = jonasEjbJar.getJonasEjbRelationList().iterator(); i.hasNext(); ) {
                JonasEjbRelation jer = (JonasEjbRelation) i.next();
                String jerName = jer.getEjbRelationName();
                //if (!stdRelations.contains(jerName)) {
                //    throw new DeploymentDescException("ejb-relation missing in ejb-jar.xml for the relation " + jerName);
                //}
                jonasRelations.put(jerName, jer);
            }

            // ejb-relation
            for (Iterator i = ejbJar.getRelationships().getEjbRelationList().iterator(); i.hasNext();) {
                EjbRelation er = (EjbRelation) i.next();

                // build the descriptors for the relation.
                EjbRelationDesc erd = new EjbRelationDesc(er, logger);
                ejbRelations.add(erd);

                // Keep a list of relation names.
                stdRelations.add(erd.getName());

                // find corresponding jonas relation (may not exist)
                JonasEjbRelation jer = (JonasEjbRelation) jonasRelations.get(erd.getName());
                erd.setJonasInfo(jer);

                // makes the links between entity beans and relationship roles
                EjbRelationshipRoleDesc rsd1 = erd.getRelationshipRole1();
                EjbRelationshipRoleDesc rsd2 = erd.getRelationshipRole2();
                EntityCmp2Desc ed1 = (EntityCmp2Desc) beanDesc.get(rsd1.getSourceBeanName());
                EntityCmp2Desc ed2 = (EntityCmp2Desc) beanDesc.get(rsd2.getSourceBeanName());
                // Check the sources beans names are correct
                if ((ed1 == null) || (ed2 == null)) {
                    throw new DeploymentDescException("Invalid ejb-name for a relation-ship-role-source for the relation '"
                                                      + erd.getName()
                                                      + "' ('"
                                                      + rsd1.getSourceBeanName()
                                                      + "' or '"
                                                      + rsd2.getSourceBeanName()
                                                      + "' invalid)");
                }
                // Check if the source beans have local interfaces
                if ((ed1.getLocalHomeClass() == null) || (ed1.getLocalClass() == null)) {
                    throw new DeploymentDescException("The entity bean '" + ed1.getEjbName()
                                                      + "' involved in the relationship '"
                                                      + erd.getName()
                                                      + "' must have local interfaces");
                }
                if ((ed2.getLocalHomeClass() == null) || (ed2.getLocalClass() == null)) {
                    throw new DeploymentDescException("The entity bean '" + ed2.getEjbName()
                                                      + "' involved in the relationship '"
                                                      + erd.getName()
                                                      + "' must have local interfaces");
                }
                ed1.addEjbRelationshipRoleDesc(rsd1);
                ed2.addEjbRelationshipRoleDesc(rsd2);
                rsd1.setTargetBean(ed2);
                rsd1.setSourceBean(ed1);
                rsd2.setTargetBean(ed1);
                rsd2.setSourceBean(ed2);

                // Fill the mapping information with the values defined in jonas DD
                erd.fillMappingInfo();

                // Fill the mapping information for the relation with default values
                // if some mapping information is missing
                erd.fillMappingInfoWithDefault();
            }

            for (Iterator i = jonasEjbJar.getJonasEjbRelationList().iterator(); i.hasNext(); ) {
                JonasEjbRelation jer = (JonasEjbRelation) i.next();
                String jerName = jer.getEjbRelationName();
                if (!stdRelations.contains(jerName)) {
                    throw new DeploymentDescException("ejb-relation missing in ejb-jar.xml for the relation " + jerName);
                }
            }
        }

        // Trace
        if (logger.getCurrentIntLevel() == BasicLevel.DEBUG) {
            logger.log(BasicLevel.DEBUG, "DEPLOYMENT DESCRIPTOR = \n(" + this.toString() + "\n)");
        }
    }

    protected BeanDesc newEntityBeanDesc(ClassLoader classLoader,
                                         Entity ent,
                                         AssemblyDescriptor asd,
                                         JonasEntity jEnt,
                                         JLinkedList jMDRList)
        throws DeploymentDescException {

        if (ent.getCmpVersion() == null || ent.getCmpVersion().equals("2.x")) {
            return new EntityJdbcCmp2Desc(classLoader, ent, asd, jEnt, this, jMDRList, fileName);
        } else {
            return new EntityJdbcCmp1Desc(classLoader, ent, asd, jEnt, jMDRList, fileName);
        }
    }

    public Manager getJormManager() throws DeploymentDescException {
        if (rdbMapping == null) {
            rdbMapping = new RdbMappingBuilder(this, logger);
        }
        return rdbMapping.getJormMIManager();
    }

    public Iterator getEjbRelationDescIterator() {
        return ejbRelations.iterator();
    }

    public String toString() {
        StringBuffer ret = new StringBuffer();
        ret.append(super.toString());
        for (Iterator i = getEjbRelationDescIterator(); i.hasNext();) {
            ret.append("\nejbRelationDesc[]=" + i.next());
        }
        return ret.toString();
    }

}

---