Move Tuscany from Incubator to top level.

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@668359 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 147 insertions, 0 deletions

diff --git a/sandbox/amita/sca/modules/implementation-data-sdo/main/java/org/apache/tuscany/sca/implementation/sdo/SDOImplementationProcessor.java b/sandbox/amita/sca/modules/implementation-data-sdo/main/java/org/apache/tuscany/sca/implementation/sdo/SDOImplementationProcessor.java
new file mode 100644
index 0000000000..a0638179ef
--- /dev/null
+++ b/sandbox/amita/sca/modules/implementation-data-sdo/main/java/org/apache/tuscany/sca/implementation/sdo/SDOImplementationProcessor.java
@@ -0,0 +1,147 @@
+/*

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you 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.sca.implementation.sdo;

+

+import static javax.xml.stream.XMLStreamConstants.START_ELEMENT;

+

+import javax.xml.namespace.QName;

+import javax.xml.stream.XMLStreamConstants;

+import javax.xml.stream.XMLStreamException;

+import javax.xml.stream.XMLStreamReader;

+import javax.xml.stream.XMLStreamWriter;

+

+import org.apache.tuscany.sca.assembly.AssemblyFactory;

+import org.apache.tuscany.sca.assembly.xml.Constants;

+import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;

+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;

+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;

+import org.apache.tuscany.sca.contribution.service.ContributionReadException;

+import org.apache.tuscany.sca.contribution.service.ContributionResolveException;

+import org.apache.tuscany.sca.contribution.service.ContributionWriteException;

+import org.apache.tuscany.sca.data.engine.ConnectionInfoArtifactProcessor;

+import org.apache.tuscany.sca.data.engine.config.ConnectionInfo;

+import org.apache.tuscany.sca.implementation.sdo.impl.SDOImplementationFactoryImpl;

+import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory;

+

+

+/**

+ * Implements a STAX artifact processor for DATA implementations.

+ * 

+ * The artifact processor is responsible for processing <implementation.data>

+ * elements in SCA assembly XML composite files and populating the DATA

+ * implementation model, resolving its references to other artifacts in the SCA

+ * contribution, and optionally write the model back to SCA assembly XML.

+ * 

+ * @version $Rev$ $Date$

+ */

+public class SDOImplementationProcessor implements StAXArtifactProcessor<SDOImplementation> {

+    protected static final QName IMPLEMENTATION_SDO = new QName(Constants.SCA10_TUSCANY_NS, "implementation.sdo");

+    

+    private SDOImplementationFactory sdoFactory;

+    

+    private StAXArtifactProcessor<ConnectionInfo> connectionInfoProcessor;

+    

+    public SDOImplementationProcessor(ModelFactoryExtensionPoint modelFactories) {

+        AssemblyFactory assemblyFactory = modelFactories.getFactory(AssemblyFactory.class);

+        JavaInterfaceFactory javaFactory = modelFactories.getFactory(JavaInterfaceFactory.class);

+        

+        this.sdoFactory = new SDOImplementationFactoryImpl(assemblyFactory, javaFactory);

+        

+        this.connectionInfoProcessor = new ConnectionInfoArtifactProcessor(modelFactories);

+    }

+

+    public QName getArtifactType() {

+        // Returns the qname of the XML element processed by this processor

+        return IMPLEMENTATION_SDO;

+    }

+

+    public Class<SDOImplementation> getModelType() {

+        // Returns the type of model processed by this processor

+        return SDOImplementation.class;

+    }

+

+    /*

+     * <component name="CompanyDataComponent">

+     *   <implementation.sdo table="company">

+     *      <connectionInfo>

+     *         <connectionProperties 

+     *          driverClass="org.apache.derby.jdbc.EmbeddedDriver" 

+     *          databaseURL="jdbc:derby:target/test-classes/dastest; create = true" 

+     *          loginTimeout="600000"/>

+     *      </connectionInfo>

+     *   </implementation.data>

+     * </component>

+     */

+    public SDOImplementation read(XMLStreamReader reader) throws ContributionReadException, XMLStreamException {

+        assert IMPLEMENTATION_SDO.equals(reader.getName());

+

+        // Read an <implementation.data> element

+

+        // Create an initialize the DAS implementation model

+        SDOImplementation implementation = sdoFactory.createSDOImplementation();

+

+        //FIXME: validation sending info to monitor....

+        String table = reader.getAttributeValue(null, "table");

+        implementation.setTable(table); //required                        

+        String key = reader.getAttributeValue(null, "key");

+        if(key == null) {

+        	implementation.setKey("ID");

+        } else {

+        	implementation.setKey(key);

+        }

+        

+        while (true) {

+            int event = reader.next();

+            switch (event) {

+

+            case START_ELEMENT:

+                if (ConnectionInfoArtifactProcessor.CONNECTION_INFO.equals(reader.getName())) {

+                    

+                    // Read connection info

+                    ConnectionInfo connectionInfo = (ConnectionInfo) connectionInfoProcessor.read(reader);;

+                    implementation.setConnectionInfo(connectionInfo);

+                }

+                break;

+            case XMLStreamConstants.END_ELEMENT:

+                if (IMPLEMENTATION_SDO.equals(reader.getName())) {

+                    return implementation;

+                }                    

+                break;

+            }

+        }

+

+    }

+

+    public void resolve(SDOImplementation impl, ModelResolver resolver) throws ContributionResolveException {

+    }

+

+    public void write(SDOImplementation implementation, XMLStreamWriter writer) throws ContributionWriteException, XMLStreamException {

+        writer.writeStartElement(IMPLEMENTATION_SDO.getNamespaceURI(), IMPLEMENTATION_SDO.getLocalPart());

+        

+        if (implementation.getTable() != null) {

+            writer.writeAttribute("table", implementation.getTable());

+        }

+        

+        if (implementation.getConnectionInfo() != null) { 

+            connectionInfoProcessor.write(implementation.getConnectionInfo(), writer);

+        }

+        

+        writer.writeEndElement();

+    }

+}