1 files changed, 185 insertions, 0 deletions
diff --git a/sca-java-1.x/tags/java-stable-20060304/sca/binding.axis2/src/main/java/org/apache/tuscany/binding/axis2/util/AxiomHelper.java b/sca-java-1.x/tags/java-stable-20060304/sca/binding.axis2/src/main/java/org/apache/tuscany/binding/axis2/util/AxiomHelper.java
new file mode 100644
index 0000000000..3df1a4104d
--- /dev/null
+++ b/sca-java-1.x/tags/java-stable-20060304/sca/binding.axis2/src/main/java/org/apache/tuscany/binding/axis2/util/AxiomHelper.java
@@ -0,0 +1,185 @@
+/**
+ * 
+ * Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package org.apache.tuscany.binding.axis2.util;
+
+import java.io.IOException;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.util.List;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.FactoryConfigurationError;
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+
+import org.apache.axis2.om.OMAbstractFactory;
+import org.apache.axis2.om.OMElement;
+import org.apache.axis2.om.OMXMLParserWrapper;
+import org.apache.axis2.om.impl.llom.factory.OMXMLBuilderFactory;
+import org.apache.tuscany.sdo.helper.DataFactoryImpl;
+import org.apache.tuscany.sdo.helper.XMLHelperImpl;
+import org.apache.tuscany.sdo.helper.XSDHelperImpl;
+import org.osoa.sca.ServiceRuntimeException;
+
+import commonj.sdo.DataObject;
+import commonj.sdo.Property;
+import commonj.sdo.helper.TypeHelper;
+import commonj.sdo.helper.XMLDocument;
+import commonj.sdo.helper.XSDHelper;
+
+/**
+ * Utility methods to convert between Axis2 AXIOM, SDO DataObjects and Java objects.
+ * 
+ * Most of these methods rely on the schemas having been registered with XSDHelper.define
+ */
+public class AxiomHelper {
+
+    /**
+     * Deserialize an OMElement into Java Objects
+     * 
+     * @param om
+     *            the OMElement
+     * @return the array of deserialized Java objects
+     */
+    public static Object[] toObjects(TypeHelper typeHelper, OMElement om) {
+        DataObject dataObject = toDataObject(typeHelper, om);
+        Object[] os = toObjects(dataObject);
+        return os;
+    }
+
+    /**
+     * Convert a typed DataObject to Java objects
+     * 
+     * @param dataObject
+     * @return the array of Objects from the DataObject
+     */
+    public static Object[] toObjects(DataObject dataObject) {
+        List ips = dataObject.getInstanceProperties();
+        Object[] os = new Object[ips.size()];
+        for (int i = 0; i < ips.size(); i++) {
+            os[i] = dataObject.get((Property) ips.get(i));
+        }
+        return os;
+    }
+
+    /**
+     * Convert objects to an AXIOM OMElement
+     * 
+     * @param os
+     * @param typeNS
+     * @param typeName
+     * @return an AXIOM OMElement
+     */
+    public static OMElement toOMElement(TypeHelper typeHelper, Object[] os, QName typeQN) {
+        DataObject dataObject = toDataObject(typeHelper, os, typeQN);
+        OMElement omElement = toOMElement(typeHelper, dataObject, typeQN);
+        return omElement;
+    }
+
+    /**
+     * Convert a DataObject to AXIOM OMElement
+     * 
+     * @param dataObject
+     * @param typeNS
+     * @param typeName
+     * @return
+     * @throws XMLStreamException
+     * @throws IOException
+     */
+    public static OMElement toOMElement(TypeHelper typeHelper, DataObject dataObject, QName typeQN) {
+        try {
+
+            PipedOutputStream pos = new PipedOutputStream();
+            PipedInputStream pis = new PipedInputStream(pos);
+            new XMLHelperImpl(typeHelper).save(dataObject, typeQN.getNamespaceURI(), typeQN.getLocalPart(), pos);
+            pos.close();
+
+            XMLStreamReader parser;
+            ClassLoader ccl=Thread.currentThread().getContextClassLoader();
+            try {
+                Thread.currentThread().setContextClassLoader(AxiomHelper.class.getClassLoader());
+                parser = XMLInputFactory.newInstance().createXMLStreamReader(pis);
+            } finally {
+                Thread.currentThread().setContextClassLoader(ccl);
+            }
+            OMXMLParserWrapper builder = OMXMLBuilderFactory.createStAXOMBuilder(OMAbstractFactory.getOMFactory(), parser);
+            OMElement root = builder.getDocumentElement();
+
+            return root;
+
+        } catch (IOException e) {
+            throw new ServiceRuntimeException(e);
+        } catch (XMLStreamException e) {
+            throw new ServiceRuntimeException(e);
+        } catch (FactoryConfigurationError e) {
+            throw new ServiceRuntimeException(e);
+        }
+    }
+
+    /**
+     * Deserialize an AXIOM OMElement into a DataObject
+     * 
+     * @param omElement
+     * @return
+     */
+    public static DataObject toDataObject(TypeHelper typeHelper, OMElement omElement) {
+        try {
+
+            PipedOutputStream pos = new PipedOutputStream();
+            PipedInputStream pis = new PipedInputStream(pos);
+
+            ClassLoader ccl=Thread.currentThread().getContextClassLoader();
+            try {
+                Thread.currentThread().setContextClassLoader(AxiomHelper.class.getClassLoader());
+                omElement.serialize(pos);
+            } finally {
+                Thread.currentThread().setContextClassLoader(ccl);
+            }
+            
+            pos.flush();
+            pos.close();
+
+            XMLDocument document = new XMLHelperImpl(typeHelper).load(pis);
+
+            return document.getRootObject();
+
+        } catch (IOException e) {
+            throw new ServiceRuntimeException(e);
+        } catch (XMLStreamException e) {
+            throw new ServiceRuntimeException(e);
+        }
+    }
+
+    /**
+     * Convert objects to typed DataObject
+     * 
+     * @param typeNS
+     * @param typeName
+     * @param os
+     * @return the DataObject
+     */
+    public static DataObject toDataObject(TypeHelper typeHelper, Object[] os, QName typeQN) {
+        XSDHelper xsdHelper=new XSDHelperImpl(typeHelper);
+        Property property=xsdHelper.getGlobalProperty(typeQN.getNamespaceURI(), typeQN.getLocalPart(), true);
+        DataObject dataObject = new DataFactoryImpl(typeHelper).create(property.getType());
+        List ips = dataObject.getInstanceProperties();
+        for (int i = 0; i < ips.size(); i++) {
+            Property p = (Property) ips.get(i);
+            dataObject.set(i, os[i]);
+        }
+        return dataObject;
+    }
+    
+}