diff options
Diffstat (limited to 'branches/sca-java-1.1/modules/implementation-xquery/src/main/java/org/apache/tuscany/sca/implementation/xquery/xml')
2 files changed, 0 insertions, 437 deletions
diff --git a/branches/sca-java-1.1/modules/implementation-xquery/src/main/java/org/apache/tuscany/sca/implementation/xquery/xml/XQueryImplementationProcessor.java b/branches/sca-java-1.1/modules/implementation-xquery/src/main/java/org/apache/tuscany/sca/implementation/xquery/xml/XQueryImplementationProcessor.java deleted file mode 100644 index 0928232a4a..0000000000 --- a/branches/sca-java-1.1/modules/implementation-xquery/src/main/java/org/apache/tuscany/sca/implementation/xquery/xml/XQueryImplementationProcessor.java +++ /dev/null @@ -1,131 +0,0 @@ -/* - * 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.xquery.xml; - -import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; - -import javax.xml.namespace.QName; -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.resolver.ResourceReference; -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.implementation.xquery.XQueryImplementation; -import org.apache.tuscany.sca.implementation.xquery.XQueryImplementationFactory; -import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory; - -/** - * Processor for the xquery implementation type artifact - * @version $Rev$ $Date$ - */ -public class XQueryImplementationProcessor implements StAXArtifactProcessor<XQueryImplementation> { - - private static final String LOCATION = "location"; - private static final String IMPLEMENTATION_XQUERY = "implementation.xquery"; - private static final QName IMPLEMENTATION_XQUERY_QNAME = - new QName(Constants.SCA10_TUSCANY_NS, IMPLEMENTATION_XQUERY); - private static final String MSG_LOCATION_MISSING = "Reading implementation.xquery - location attribute missing"; - - private AssemblyFactory assemblyFactory; - private JavaInterfaceFactory javaFactory; - - public XQueryImplementationProcessor(ModelFactoryExtensionPoint modelFactoryExtensionPoint) { - this.assemblyFactory = modelFactoryExtensionPoint.getFactory(AssemblyFactory.class); - this.javaFactory = modelFactoryExtensionPoint.getFactory(JavaInterfaceFactory.class); - } - - public QName getArtifactType() { - return IMPLEMENTATION_XQUERY_QNAME; - } - - /** - * Reads from the stream and sets the location attribute of the implementation correspondingly - */ - public XQueryImplementation read(XMLStreamReader reader) - throws ContributionReadException, XMLStreamException { - - /* Read the location attribute for the xquery implementation */ - String xqueryLocation = reader.getAttributeValue(null, LOCATION); - if (xqueryLocation == null) { - throw new ContributionReadException(MSG_LOCATION_MISSING); - } - /* Create the XQuery implementation and set the location into it */ - XQueryImplementation xqueryImplementation = - XQueryImplementationFactory.INSTANCE.createXQueryImplementation(); - xqueryImplementation.setLocation(xqueryLocation); - - // Skip to end element - while (reader.hasNext()) { - if (reader.next() == END_ELEMENT && IMPLEMENTATION_XQUERY_QNAME.equals(reader.getName())) { - break; - } - } // end while - - xqueryImplementation.setUnresolved(true); - - return xqueryImplementation; - } - - public void write(XQueryImplementation xqueryImplementation, XMLStreamWriter writer) - throws ContributionWriteException, XMLStreamException { - - writer.writeStartElement(Constants.SCA10_TUSCANY_NS, IMPLEMENTATION_XQUERY); - if (xqueryImplementation.getLocation() != null) { - writer.writeAttribute(LOCATION, xqueryImplementation.getLocation()); - } - writer.writeEndElement(); - - } - - public Class<XQueryImplementation> getModelType() { - return XQueryImplementation.class; - } - - /** - * Resolves the implementation: its services and references, by invoking the xquery - * introspector - */ - public void resolve(XQueryImplementation xqueryImplementation, ModelResolver resolver) - throws ContributionResolveException { - - ResourceReference resourceRef = new ResourceReference(xqueryImplementation.getLocation()); - resourceRef = resolver.resolveModel(ResourceReference.class, resourceRef); - if (resourceRef.isUnresolved()) { - throw new ContributionResolveException("Could not locate file: " + xqueryImplementation.getLocation()); - } - xqueryImplementation.setLocationURL(resourceRef.getResource()); - - XQueryIntrospector introspector = new XQueryIntrospector(assemblyFactory, javaFactory); - - boolean success = introspector.introspect(xqueryImplementation, resolver); - - if (success) { - xqueryImplementation.setUnresolved(false); - } - } - -} diff --git a/branches/sca-java-1.1/modules/implementation-xquery/src/main/java/org/apache/tuscany/sca/implementation/xquery/xml/XQueryIntrospector.java b/branches/sca-java-1.1/modules/implementation-xquery/src/main/java/org/apache/tuscany/sca/implementation/xquery/xml/XQueryIntrospector.java deleted file mode 100644 index 0eac14b92f..0000000000 --- a/branches/sca-java-1.1/modules/implementation-xquery/src/main/java/org/apache/tuscany/sca/implementation/xquery/xml/XQueryIntrospector.java +++ /dev/null @@ -1,306 +0,0 @@ -/* - * 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.xquery.xml; - -import java.io.ByteArrayOutputStream; -import java.io.FileNotFoundException; -import java.io.IOException; -import java.io.InputStream; -import java.lang.reflect.Method; -import java.net.URL; -import java.util.Iterator; - -import javax.xml.namespace.QName; - -import net.sf.saxon.Configuration; -import net.sf.saxon.om.NamespaceResolver; -import net.sf.saxon.query.StaticQueryContext; -import net.sf.saxon.query.XQueryExpression; -import net.sf.saxon.trans.XPathException; - -import org.apache.tuscany.sca.assembly.AssemblyFactory; -import org.apache.tuscany.sca.assembly.Multiplicity; -import org.apache.tuscany.sca.assembly.Property; -import org.apache.tuscany.sca.assembly.Reference; -import org.apache.tuscany.sca.assembly.Service; -import org.apache.tuscany.sca.contribution.resolver.ClassReference; -import org.apache.tuscany.sca.contribution.resolver.ModelResolver; -import org.apache.tuscany.sca.contribution.service.ContributionResolveException; -import org.apache.tuscany.sca.implementation.xquery.XQueryImplementation; -import org.apache.tuscany.sca.interfacedef.InvalidInterfaceException; -import org.apache.tuscany.sca.interfacedef.java.JavaInterface; -import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceContract; -import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory; -import org.apache.tuscany.sca.interfacedef.util.JavaXMLMapper; - -/** - * This class introspects an XQuery file and extrats out of it - * all implemented service, references and properties - * It also creates expression extensions for each operation - * in the implemented services - * @version $Rev$ $Date$ - */ -public class XQueryIntrospector { - - private static final String SCA_SERVICE_PREFIX = "scaservice:java/"; - private static final String SCA_REFERENCE_PREFIX = "scareference:java/"; - private static final String SCA_PROPERTY_JAVA_PREFIX = "scaproperty:java/"; - private static final String SCA_PROPERTY_XML_PREFIX = "scaproperty:xml/"; - - private AssemblyFactory assemblyFactory; - private JavaInterfaceFactory javaFactory; - - public XQueryIntrospector(AssemblyFactory assemblyFactory, JavaInterfaceFactory javaFactory) { - super(); - this.assemblyFactory = assemblyFactory; - this.javaFactory = javaFactory; - } - - public boolean introspect(XQueryImplementation xqueryImplementation, ModelResolver resolver) throws ContributionResolveException { - - String xqExpression = null; - try { - xqExpression = loadXQExpression(xqueryImplementation.getLocationURL()); - } catch (FileNotFoundException e) { - throw new ContributionResolveException(e); - } catch (IOException e) { - throw new ContributionResolveException(e); - } - - if (xqExpression == null) { - return false; - } - - xqueryImplementation.setXqExpression(xqExpression); - - xqExpression += "\r\n<dummy></dummy>"; - - Configuration config = new Configuration(); - StaticQueryContext sqc = new StaticQueryContext(config); - XQueryExpression exp = null; - try { - exp = sqc.compileQuery(xqExpression); - } catch (XPathException e) { - throw new ContributionResolveException(e); - } - - if (exp == null) { - return false; - } - xqueryImplementation.getCompiledExpressionsCache().put(xqExpression, exp); - - try { - introspectServicesAndReferences(xqueryImplementation, exp, resolver); - } catch (ClassNotFoundException e) { - throw new ContributionResolveException(e); - } catch (InvalidInterfaceException e) { - throw new ContributionResolveException(e); - } - - fillExpressionExtensions(xqueryImplementation); - - return true; - } - - /** - * Loads the xquery expression from the location that is provided with the implementation - */ - private String loadXQExpression(URL locationURL) throws FileNotFoundException, IOException { - - InputStream xqResourceStream = locationURL.openStream(); - - if (xqResourceStream == null) { - return null; - } - - ByteArrayOutputStream baos = new ByteArrayOutputStream(); - int i = 0; - while ((i = xqResourceStream.read()) >= 0) { - baos.write(i); - } - xqResourceStream.close(); - baos.flush(); - baos.close(); - - String xqExpression = baos.toString(); - - return xqExpression; - } - - private Class<?> resolveClass(ModelResolver resolver, String className) throws ClassNotFoundException { - ClassReference classReference = new ClassReference(className); - classReference = resolver.resolveModel(ClassReference.class, classReference); - Class<?> javaClass = classReference.getJavaClass(); - if (javaClass == null) { - throw new ClassNotFoundException(className); - } else { - return javaClass; - } - } - - /** - * From the compiled xquery expression get all namespaces and see if they - * are services, references or properties declaraions - */ - private void introspectServicesAndReferences(XQueryImplementation xqueryImplementation, XQueryExpression exp, ModelResolver resolver) - throws ClassNotFoundException, InvalidInterfaceException { - NamespaceResolver namespaceResolver = exp.getStaticContext().getNamespaceResolver(); - Iterator declaredPrefixesIterator = namespaceResolver.iteratePrefixes(); - while (declaredPrefixesIterator.hasNext()) { - String prefix = (String)declaredPrefixesIterator.next(); - String uri = namespaceResolver.getURIForPrefix(prefix, false); - if (uri.startsWith(SCA_SERVICE_PREFIX)) { - String serviceName = prefix; - String className = uri.substring(SCA_SERVICE_PREFIX.length()); - Class<?> interfaze = resolveClass(resolver, className); - Service theService = createService(interfaze, serviceName); - xqueryImplementation.getServices().add(theService); - } else if (uri.startsWith(SCA_REFERENCE_PREFIX)) { - String referenceName = prefix; - String className = uri.substring(SCA_REFERENCE_PREFIX.length()); - Class<?> interfaze = resolveClass(resolver, className); - Reference theReference = createReference(interfaze, referenceName); - xqueryImplementation.getReferences().add(theReference); - } else if (uri.startsWith(SCA_PROPERTY_JAVA_PREFIX)) { - String propertyName = prefix; - String className = uri.substring(SCA_PROPERTY_JAVA_PREFIX.length()); - Class<?> clazz = resolveClass(resolver, className); - QName xmlType = JavaXMLMapper.getXMLType(clazz); - Property theProperty = createProperty(xmlType, propertyName); - xqueryImplementation.getProperties().add(theProperty); - } else if (uri.startsWith(SCA_PROPERTY_XML_PREFIX)) { - String propertyName = prefix; - String namespaceAndLocalname = uri.substring(SCA_PROPERTY_XML_PREFIX.length()); - int localNameDelimiterPostition = namespaceAndLocalname.lastIndexOf(':'); - String localName = null; - String namespace = null; - if (localNameDelimiterPostition < 0) { - localName = namespaceAndLocalname; - namespace = ""; - } else { - namespace = namespaceAndLocalname.substring(0, localNameDelimiterPostition); - localName = namespaceAndLocalname.substring(localNameDelimiterPostition + 1); - } - QName xmlType = new QName(namespace, localName); - Property theProperty = createProperty(xmlType, propertyName); - xqueryImplementation.getProperties().add(theProperty); - } - } - } - - /** - * Creates a Service for the component type based on its name and Java interface - */ - private Service createService(Class<?> interfaze, String name) throws InvalidInterfaceException { - Service service = assemblyFactory.createService(); - JavaInterfaceContract interfaceContract = javaFactory.createJavaInterfaceContract(); - service.setInterfaceContract(interfaceContract); - - // Set the name for the service - service.setName(name); - - // Set the call interface and, if present, the callback interface - JavaInterface callInterface = javaFactory.createJavaInterface(interfaze); - //setDataBindingForInterface(callInterface, DataObject.class.getName()); - service.getInterfaceContract().setInterface(callInterface); - if (callInterface.getCallbackClass() != null) { - JavaInterface callbackInterface = javaFactory.createJavaInterface(callInterface.getCallbackClass()); - //setDataBindingForInterface(callbackInterface, DataObject.class.getName()); - service.getInterfaceContract().setCallbackInterface(callbackInterface); - } - return service; - } // end method createService - - protected Property createProperty(QName type, String name) { - - Property property = assemblyFactory.createProperty(); - property.setName(name); - property.setXSDType(type); - - property.setMany(false); - return property; - - } - - /** - * Creates a Reference for the component type based on its name and Java interface - */ - private Reference createReference(Class<?> interfaze, String name) throws InvalidInterfaceException { - Reference reference = assemblyFactory.createReference(); - JavaInterfaceContract interfaceContract = javaFactory.createJavaInterfaceContract(); - reference.setInterfaceContract(interfaceContract); - - // Set the name of the reference to the supplied name and the multiplicity of the reference - // to 1..1 - for XQuery implementations, this is the only multiplicity supported - reference.setName(name); - reference.setMultiplicity(Multiplicity.ONE_ONE); - - // Set the call interface and, if present, the callback interface - JavaInterface callInterface = javaFactory.createJavaInterface(interfaze); - reference.getInterfaceContract().setInterface(callInterface); - if (callInterface.getCallbackClass() != null) { - JavaInterface callbackInterface = javaFactory.createJavaInterface(callInterface.getCallbackClass()); - reference.getInterfaceContract().setCallbackInterface(callbackInterface); - } - - return reference; - } - - /** - * For the methods of each implemented service corresponding expression extension - * is generated - * @param xqueryImplementation - */ - private void fillExpressionExtensions(XQueryImplementation xqueryImplementation) { - for (Service service : xqueryImplementation.getServices()) { - Class<?> interfaze = ((JavaInterface)service.getInterfaceContract().getInterface()).getJavaClass(); - - // For each of the methods - for (Method method : interfaze.getMethods()) { - String expressionExtension = createExpressionExtension(method, interfaze, service.getName()); - xqueryImplementation.getXqExpressionExtensionsMap().put(method, expressionExtension); - } - } - } - - private String createExpressionExtension(Method method, Class<?> interfaze, String serviceName) { - StringBuffer exprBuf = new StringBuffer(); - - exprBuf.append("\r\n"); - - String methodName = method.getName(); - - // For each of the declared parameters - for (int i = 0; i < method.getParameterTypes().length; i++) { - exprBuf.append("declare variable $" + methodName + "_" + i + " external;\r\n"); - } - - exprBuf.append(serviceName + ":" + methodName + "("); - - for (int i = 0; i < method.getParameterTypes().length; i++) { - exprBuf.append("$" + methodName + "_" + i); - if (i != method.getParameterTypes().length - 1) { - exprBuf.append(", "); - } - } - exprBuf.append(")"); - - return exprBuf.toString(); - } -} |