FileDocCategorySizeDatePackage
GenericResource.javaAPI DocGlassfish v2 API22520Thu Jul 26 12:44:36 BST 2007com.sun.enterprise.tools.upgrade.transform.elements

GenericResource

public class GenericResource extends GenericElement
author
prakash

Fields Summary
private boolean
appendingResourceRefToCluster
private List
insertStructureForResourceRefInCluster
private boolean
appendJdbcResource
private boolean
appendJdbcConnPool
Constructors Summary
public GenericResource()
Creates a new instance of Element
Methods Summary
public voidaddJdbcConnPool(org.w3c.dom.Element element, org.w3c.dom.Element parentSource, org.w3c.dom.Element parentResult)
This method adds a jdbc-connection-pool corresponding to the DerbyPool which is the default in SJSAS8.2 EE . This method is used in AS8.1 EE to AS8.2EE upgrades

param
element The element being worked on now
param
parentSource the parent element in the Source document
param
parentResult the parent element of the element being processed in the Result document

        Element jdbcConnPool =
                (Element)parentResult.getOwnerDocument().createElement("jdbc-connection-pool");
        NodeList connPools = parentResult.getElementsByTagName("jdbc-connection-pool");
        Element firstConnPool = (Element)connPools.item(0);

        // set all the attributes
        jdbcConnPool.setAttribute("connection-validation-method", "auto-commit");
        jdbcConnPool.setAttribute("datasource-classname","org.apache.derby.jdbc.ClientDataSource");
        jdbcConnPool.setAttribute("fail-all-connections", "false");
        jdbcConnPool.setAttribute("idle-timeout-in-seconds", "300");
        jdbcConnPool.setAttribute("is-connection-validation-required", "false");
        jdbcConnPool.setAttribute("is-isolation-level-guaranteed", "true");
        jdbcConnPool.setAttribute("max-pool-size", "32");
        jdbcConnPool.setAttribute("max-wait-time-in-millis", "60000");
        jdbcConnPool.setAttribute("name",
                                  "DerbyPool");
        jdbcConnPool.setAttribute("pool-resize-quantity", "2");
        jdbcConnPool.setAttribute("res-type", "javax.sql.XADataSource");
        jdbcConnPool.setAttribute("steady-pool-size", "8");

        // Add properties to the JDBC connection pool
        this.addPropertyToConnPool(element,  parentSource, jdbcConnPool);
        parentResult.insertBefore(jdbcConnPool, firstConnPool);
public voidaddJdbcResource(org.w3c.dom.Element element, org.w3c.dom.Element parentSource, org.w3c.dom.Element parentResult)
This method add a JDBC Resource in the domain.xml that corresponds to the default Derby resource. It also adds a resource-ref in the servers and clusters

param
The element that i being processed now : jdbc-resource
param
The parent element of the jdbc-resource in the Source document
param
The parent element of the jdbc-resource is the Result document

        NodeList jdbcConnPool = parentResult.getElementsByTagName("jdbc-connection-pool");
        // First add the jdbc-resource
        Element jdbcResource =
                parentResult.getOwnerDocument().createElement("jdbc-resource");
        jdbcResource.setAttribute("enabled", "true");
        jdbcResource.setAttribute("jndi-name", "jdbc/__default");
        jdbcResource.setAttribute("object-type", "user");
        jdbcResource.setAttribute("pool-name", "DerbyPool");
        parentResult.insertBefore(jdbcResource, jdbcConnPool.item(0));


        // Now add the resource ref
        // get the server element
        NodeList serverList =
                ((Element)parentResult.getParentNode()).getElementsByTagName("servers");
        if(serverList != null && serverList.getLength() > 0 ) {
            // get the server elements from servers ( which will be a single occurence)
            NodeList servers =
                    ((Element)serverList.item(0)).getElementsByTagName("server");
            for(int sCount=0; sCount<servers.getLength(); sCount++) {
                Element resourceRef =
                   //Added for CR 6455396 EE->EE upgrade
                   servers.item(sCount).getOwnerDocument().createElement("resource-ref");
                   //servers.item(0).getOwnerDocument().createElement("resource-ref");
                resourceRef.setAttribute("enabled", "true");
                resourceRef.setAttribute("ref", "jdbc/__default");
                //Added for CR 6455396 EE->EE upgrade
                servers.item(sCount).appendChild(resourceRef);
                //servers.item(0).appendChild(resourceRef);
            }
        }

        //Added for CR 6455396 - EE->EE upgrade
        /*// get the cluster element
        NodeList clusterList =
                ((Element)parentResult.getParentNode()).getElementsByTagName("clusters");
        if(clusterList != null&& clusterList.getLength() > 0) {
            // get the server elements from servers ( which will be a single occurence)
            NodeList clusters =
                    ((Element)clusterList.item(0)).getElementsByTagName("cluster");
            for(int cCount=0; cCount<clusters.getLength(); cCount++) {
                Element resourceRef =
                   clusters.item(0).getOwnerDocument().createElement("resource-ref");
                resourceRef.setAttribute("enabled", "true");
                resourceRef.setAttribute("ref", "jdbc/__default");
                clusters.item(0).appendChild(resourceRef);
            }
        }*/
        //Added - End
        appendJdbcResource = true;
private voidaddOrUpdateResourceRef(org.w3c.dom.Element parentForRef, org.w3c.dom.Element element, org.w3c.dom.Element parentResult)

        // Get resource refs.
        NodeList resourceRefs = parentForRef.getElementsByTagName("resource-ref");
        Element resourceRef = null;
        for(int lh =0; lh < resourceRefs.getLength(); lh++){
            // Compare one key attribute
            if((element.getAttribute("jndi-name")).equals(((Element)resourceRefs.item(lh)).getAttribute("ref"))){
                resourceRef = (Element)resourceRefs.item(lh);
                org.w3c.dom.Attr enAttr = element.getAttributeNode("enabled");
                if(enAttr != null){
                    resourceRef.setAttribute("enabled", element.getAttribute("enabled"));
                }
                break;
            }
        }
        if(resourceRef == null){
            resourceRef = parentResult.getOwnerDocument().createElement("resource-ref");
            resourceRef.setAttribute("ref", element.getAttribute("jndi-name"));
            org.w3c.dom.Attr enAttr = element.getAttributeNode("enabled");
            if(enAttr != null){
                resourceRef.setAttribute("enabled", element.getAttribute("enabled"));
            }
            this.appendElementToParent(parentForRef,resourceRef);
        }
public voidaddPropertyToConnPool(org.w3c.dom.Element element, org.w3c.dom.Element parentSource, org.w3c.dom.Element parentResult)
This method add properties to the connection pool.These properties need to be added for AS8.1 to 8.2 EE upgrade.

param
element Element being processsed now
param
parent Element in the source
param
parent Element in the result which is the jdbc-connection-pool


        // Add each propert
        Element serverNameProp =
             parentResult.getOwnerDocument().createElement("property");
        serverNameProp.setAttribute("name", "serverName");
        serverNameProp.setAttribute("value", "localhost");
        parentResult.appendChild(serverNameProp);

        Element portNumberProp =
                parentResult.getOwnerDocument().createElement("property");
        portNumberProp.setAttribute("name", "PortNumber");
        portNumberProp.setAttribute("value", "1527");
        parentResult.appendChild(portNumberProp);

        Element connSettingsProp =
                parentResult.getOwnerDocument().createElement("property");
        connSettingsProp.setAttribute("name",  "connectionAttributes");
        connSettingsProp.setAttribute("value", ";create=true");

        Element userProp =
             parentResult.getOwnerDocument().createElement("property");
        userProp.setAttribute("name", "User");
        userProp.setAttribute("value", "APP");
        parentResult.appendChild(userProp);

        Element passwordProp =
                parentResult.getOwnerDocument().createElement("property");
        passwordProp.setAttribute("name", "Password");
        passwordProp.setAttribute("value", "APP");
        parentResult.appendChild(passwordProp);

        Element databaseNameProp =
                parentResult.getOwnerDocument().createElement("property");
        databaseNameProp.setAttribute("name", "DatabaseName");
        databaseNameProp.setAttribute("value", "sun-appserv-samples");
        parentResult.appendChild(databaseNameProp);
protected java.util.ListgetInsertElementStructure(org.w3c.dom.Element element, org.w3c.dom.Element parentEle)

        java.util.List insertStrucure = ElementToObjectMapper.getMapper().getInsertElementStructure(element.getTagName());
        if(element.getTagName().equals("resource-ref") && this.appendingResourceRefToCluster){
            if(this.insertStructureForResourceRefInCluster == null){
                this.insertStructureForResourceRefInCluster = new java.util.ArrayList();
                this.insertStructureForResourceRefInCluster.add("application-ref");
                this.insertStructureForResourceRefInCluster.add("system-property");
                this.insertStructureForResourceRefInCluster.add("property");
            }
            return this.insertStructureForResourceRefInCluster;
        }
        return insertStrucure;
public voidmodifyConnPoolProps(org.w3c.dom.Element element, org.w3c.dom.Element connPool)
This method modified the properties in a connection pool

param
element - the connection pool elememt
param
connPool - the Element representing the connection-pool in the result Document

         NodeList propList = connPool.getElementsByTagName("property");
         if(connPool.getAttribute("name").equals("__TimerPool")) {
             transferTimerPoolProps(element, propList, connPool);
         }
private voidskipGenericElementTransform(org.w3c.dom.Element element, org.w3c.dom.Element parentSource, org.w3c.dom.Element parentResult)

        NodeList childNodes = element.getChildNodes();
        for(int index=0; index < childNodes.getLength(); index++){
            Node aNode = childNodes.item(index);
            try{
                if(aNode.getNodeType() == Node.ELEMENT_NODE){
                    BaseElement baseElement = ElementToObjectMapper.getMapper().getElementObject(aNode.getNodeName());
                    baseElement.transform((Element)aNode, element, parentResult);
                }
            }catch(Exception ex){
                ex.printStackTrace();
            }
        }
public voidtransferJdbcConnPool(org.w3c.dom.Element element, org.w3c.dom.Element parentSource, org.w3c.dom.Element parentResult)
Method to transfer the jdbc-connection-pool

         NodeList nodeList = parentResult.getElementsByTagName("jdbc-connection-pool");
         Element connPool = null;
         if( nodeList != null ) {
             for(int i=0; i<nodeList.getLength(); i++ ) {
                 connPool = (Element)nodeList.item(i);
                  if(connPool.getAttribute("name").equals("__TimerPool")) {
                     modifyConnPoolProps(element,connPool);
                     connPool.setAttribute("datasource-classname",
                               "org.apache.derby.jdbc.ClientDataSource");

                  }
             }
         }
public voidtransferTimerPoolProps(org.w3c.dom.Element element, org.w3c.dom.NodeList propList, org.w3c.dom.Element parentResult)
This method updates the properties for the Timer Pool

param
element the Element that represents the property that is being processed.
param
propertyList the NodeList that contains the property elements under this pool
param
parentResult the parent element in the result document * This method updates the properties for the Derby Pool

        for(int i=0; i<propList.getLength(); i++ ) {
            Element property = (Element)propList.item(i);
            if(property.getAttribute("name").equals("DatabaseName")) {
                property.setAttribute("value",
                        "${com.sun.aas.instanceRoot}/lib/databases/ejbtimer");
                parentResult.appendChild(property);
            }
            if(property.getAttribute("name").equals("User") ) {
                property.setAttribute("value", "APP");
                parentResult.appendChild(property);
             }
            if(property.getAttribute("name").equals("Password") ){
                property.setAttribute("value", "APP");
                parentResult.appendChild(property);
            }
        }
public voidtransform(org.w3c.dom.Element element, org.w3c.dom.Element parentSource, org.w3c.dom.Element parentResult)
element - one of the child of resources parentSource - resources element of source parentResult - resources element of result

        String resourceTagName = element.getTagName();
        logger.log(Level.FINE, stringManager.getString("upgrade.transform.transformingMSG", this.getClass().getName(), resourceTagName));
        boolean derbyPoolExists = false;
        // Check if this is an 8.1EE to 8.2 EE transformation
        if(commonInfoModel.checkUpgradefrom8xeeto9x() ) {

           // add jdbc/__default
           NodeList jdbcResources =
                   parentResult.getElementsByTagName("jdbc-resource");
           for(int i=0; i<jdbcResources.getLength(); i++ ) {
               if(((Element)jdbcResources.item(i)).
                       getAttribute("jndi-name").equals("jdbc/__default")) {
                   derbyPoolExists = true;
                   break;
               } else {
                   derbyPoolExists = false;
               }
           }
           logger.log(Level.FINE, this.getClass().getName()+ ":: derbyPoolExists ", derbyPoolExists);
           if(!derbyPoolExists)
           addJdbcResource(element, parentSource, parentResult);

           if( resourceTagName.equals("jdbc-connection-pool")) {
               // transform the __TimerPool
               transferJdbcConnPool(element, parentSource, parentResult);
           }
           NodeList jdbcConnPools =
                   parentResult.getElementsByTagName("jdbc-connection-pool");

           for(int j=0; j<jdbcConnPools.getLength(); j++ ) {
               if(((Element)jdbcConnPools.item(j)).
                       getAttribute("name").equals("DerbyPool")) {
                   appendJdbcConnPool = true;
                   break;
               } else {
                   appendJdbcConnPool = false;
               }
           }
           logger.log(Level.FINE, this.getClass().getName()+ ":: appendJdbcConnPool ", appendJdbcConnPool);
           if(!appendJdbcConnPool)
               addJdbcConnPool(element, parentSource, parentResult);
        }
        if(resourceTagName.equals("jms-resource"))
        {
            // There is this JMSResource class that handles it.
            this.skipGenericElementTransform(element, parentSource, parentResult);
            return;
        }
        //Added for CR 6363168
        if(resourceTagName.equals("jdbc-connection-pool")) {
            if(element.getAttribute("name").equals("__TimerPool") ||
                    element.getAttribute("name").equals("PointBasePool"))
                return;
        }
        //Added for CR 6363168
        if(resourceTagName.equals("jdbc-resource")) {
            if(element.getAttribute("pool-name").equals("PointBasePool"))
                return;
        }
        super.transform(element, parentSource, parentResult);
        //this.updateResourceRef(element, parentResult);  AS7.x is no longer supported.
protected voidupdateResourceRef(org.w3c.dom.Element element, org.w3c.dom.Element parentResult)

        // If the source version is AS8.x then the following is not necessary.
        // Otherwise, AS7.x didnt have server element so, need to add resource-ref to the server element and cluster elements
        if(!UpgradeConstants.VERSION_7X.equals(commonInfoModel.getSourceVersion()))
            return;
        org.w3c.dom.Attr jndiAttr = element.getAttributeNode("jndi-name");
        if(jndiAttr != null){
            // parentResult is resources, its parent should be domain.  From there get servers and server element.
            NodeList servers = ((Element)parentResult.getParentNode()).getElementsByTagName("servers");
            NodeList serverList = ((Element)servers.item(0)).getElementsByTagName("server");
            // PE there can be only one server.
            if(UpgradeConstants.EDITION_PE.equals(commonInfoModel.getSourceEdition())){
                Element serverElement = ((Element)serverList.item(0));
                this.addOrUpdateResourceRef(serverElement, element, parentResult);
            }else{
                if(commonInfoModel.getCurrentCluster() == null){
                    // This must be the scenario for stand alone instances or PE/SE upgrade
                    String serverName = commonInfoModel.getCurrentSourceInstance();
                    if((serverName == null) || ("".equals(serverName.trim()))){
                        // This is the case for AS 8.x PE source
                        serverName = "server";
                    }
                    if(serverName != null){
                        for(int lh =0; lh < serverList.getLength(); lh++){
                            if(serverName.equals(((Element)serverList.item(lh)).getAttribute("name"))){
                                this.addOrUpdateResourceRef((Element)serverList.item(lh), element, parentResult);
                                break;
                            }
                        }
                    }
                }else{
                    String clusterName = commonInfoModel.getCurrentCluster();
                    this.updateResourceRefsForCluster(clusterName, serverList,element,parentResult);
                }
            }
        }
private voidupdateResourceRefsForCluster(java.lang.String clusterName, org.w3c.dom.NodeList serverRefList, org.w3c.dom.Element element, org.w3c.dom.Element parentResult)

        for(java.util.Iterator dItr = ClustersInfoManager.getClusterInfoManager().getClusterInfoList().iterator(); dItr.hasNext();){
            ClusterInfo cInfo = (ClusterInfo)dItr.next();
            if(cInfo.getClusterName().equals(clusterName)){
                for(java.util.Iterator clItr = cInfo.getClusteredInstanceList().iterator(); clItr.hasNext();){
                    ClusteredInstance clInstance = (ClusteredInstance)clItr.next();
                    String clInstanceName = clInstance.getInstanceName();
                    for(int lh =0; lh < serverRefList.getLength(); lh++){
                        if(clInstanceName.equals(((Element)serverRefList.item(lh)).getAttribute("name"))){
                            this.addOrUpdateResourceRef((Element)serverRefList.item(lh), element, parentResult);
                            break;
                        }
                    }
                }
            }
        }
        NodeList clusters = ((Element)parentResult.getParentNode()).getElementsByTagName("clusters");
        if((clusters != null) && (clusters.getLength() > 0)){
            NodeList clustersList = ((Element)clusters.item(0)).getElementsByTagName("cluster");
            for(int lh =0; lh < clustersList.getLength(); lh++){
                if(clusterName.equals(((Element)clustersList.item(lh)).getAttribute("name"))){
                    this.appendingResourceRefToCluster = true;
                    this.addOrUpdateResourceRef((Element)clustersList.item(lh), element, parentResult);
                    this.appendingResourceRefToCluster = false;
                    break;
                }
            }
        }