Author: jstrachan
Date: Thu Apr 5 09:51:48 2007
New Revision: 525869
URL: http://svn.apache.org/viewvc?view=rev&rev=525869
Log:
added a simple saxon plugin for performing XQuery
Added:
activemq/camel/trunk/camel-saxon/
activemq/camel/trunk/camel-saxon/pom.xml (with props)
activemq/camel/trunk/camel-saxon/src/
activemq/camel/trunk/camel-saxon/src/main/
activemq/camel/trunk/camel-saxon/src/main/java/
activemq/camel/trunk/camel-saxon/src/main/java/org/
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/ResultFormat.java
(with props)
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/XQueryBuilder.java
(with props)
activemq/camel/trunk/camel-saxon/src/main/resources/
activemq/camel/trunk/camel-saxon/src/main/resources/META-INF/
activemq/camel/trunk/camel-saxon/src/main/resources/META-INF/services/
activemq/camel/trunk/camel-saxon/src/main/resources/META-INF/services/org/
activemq/camel/trunk/camel-saxon/src/main/resources/META-INF/services/org/apache/
activemq/camel/trunk/camel-saxon/src/main/resources/META-INF/services/org/apache/camel/
activemq/camel/trunk/camel-saxon/src/main/resources/META-INF/services/org/apache/camel/component/
activemq/camel/trunk/camel-saxon/src/test/
activemq/camel/trunk/camel-saxon/src/test/java/
activemq/camel/trunk/camel-saxon/src/test/java/org/
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/XQueryTest.java
(with props)
activemq/camel/trunk/camel-saxon/src/test/resources/
Added: activemq/camel/trunk/camel-saxon/pom.xml
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-saxon/pom.xml?view=auto&rev=525869
==============================================================================
--- activemq/camel/trunk/camel-saxon/pom.xml (added)
+++ activemq/camel/trunk/camel-saxon/pom.xml Thu Apr 5 09:51:48 2007
@@ -0,0 +1,80 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+ 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.
+-->
+
+<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns="http://maven.apache.org/POM/4.0.0";>
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-parent</artifactId>
+ <version>1.0-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>camel-saxon</artifactId>
+ <name>Camel :: JMS</name>
+ <description>Camel SAXON support</description>
+
+ <dependencies>
+
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-core</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>org.springframework</groupId>
+ <artifactId>spring</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>commons-logging</groupId>
+ <artifactId>commons-logging</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>net.sf.saxon</groupId>
+ <artifactId>saxon</artifactId>
+ <version>${saxon-version}</version>
+ </dependency>
+ <dependency>
+ <groupId>net.sf.saxon</groupId>
+ <artifactId>saxon-dom</artifactId>
+ <version>${saxon-version}</version>
+ </dependency>
+ <dependency>
+ <groupId>net.sf.saxon</groupId>
+ <artifactId>saxon-sql</artifactId>
+ <version>${saxon-version}</version>
+ </dependency>
+
+
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
+
+
+ <properties>
+ <saxon-version>8.8</saxon-version>
+ </properties>
+</project>
Propchange: activemq/camel/trunk/camel-saxon/pom.xml
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: activemq/camel/trunk/camel-saxon/pom.xml
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Propchange: activemq/camel/trunk/camel-saxon/pom.xml
------------------------------------------------------------------------------
svn:mime-type = text/xml
Added:
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/ResultFormat.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/ResultFormat.java?view=auto&rev=525869
==============================================================================
---
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/ResultFormat.java
(added)
+++
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/ResultFormat.java
Thu Apr 5 09:51:48 2007
@@ -0,0 +1,8 @@
+package org.apache.camel.builder.saxon;
+
+/**
+ * @version $Revision$
+ */
+public enum ResultFormat {
+ Bytes, BytesSource, DOM, DOMSource, List, String, StringSource
+}
Propchange:
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/ResultFormat.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/ResultFormat.java
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Propchange:
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/ResultFormat.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added:
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/XQueryBuilder.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/XQueryBuilder.java?view=auto&rev=525869
==============================================================================
---
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/XQueryBuilder.java
(added)
+++
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/XQueryBuilder.java
Thu Apr 5 09:51:48 2007
@@ -0,0 +1,311 @@
+/**
+ *
+ * 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.camel.builder.saxon;
+
+import net.sf.saxon.Configuration;
+import net.sf.saxon.om.DocumentInfo;
+import net.sf.saxon.query.DynamicQueryContext;
+import net.sf.saxon.query.StaticQueryContext;
+import net.sf.saxon.query.XQueryExpression;
+import net.sf.saxon.trans.XPathException;
+import org.apache.camel.Exchange;
+import org.apache.camel.Expression;
+import org.apache.camel.Predicate;
+import org.apache.camel.RuntimeExpressionException;
+import org.apache.camel.converter.jaxp.BytesSource;
+import org.apache.camel.converter.jaxp.JaxpConverter;
+import org.apache.camel.converter.jaxp.StringSource;
+import org.w3c.dom.Node;
+
+import javax.xml.transform.Result;
+import javax.xml.transform.Source;
+import javax.xml.transform.dom.DOMResult;
+import javax.xml.transform.stream.StreamResult;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.Reader;
+import java.io.StringWriter;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import java.util.Set;
+
+/**
+ * Creates an XQuery builder
+ *
+ * @version $Revision$
+ */
+public abstract class XQueryBuilder<E extends Exchange> implements
Expression<E>, Predicate<E> {
+ private Configuration configuration;
+ private XQueryExpression expression;
+ private StaticQueryContext staticQueryContext;
+ private Map<String, Object> parameters = new HashMap<String, Object>();
+ private JaxpConverter converter = new JaxpConverter();
+ private ResultFormat resultsFormat = ResultFormat.DOM;
+ private Properties properties = new Properties();
+
+ public Object evaluate(E exchange) {
+ try {
+ switch (resultsFormat) {
+ case Bytes:
+ return evaluateAsBytes(exchange);
+ case BytesSource:
+ return evaluateAsBytesSource(exchange);
+ case DOM:
+ return evaluateAsDOM(exchange);
+ case List:
+ return evaluateAsList(exchange);
+ case StringSource:
+ return evaluateAsStringSource(exchange);
+ case String:
+ default:
+ return evaluateAsString(exchange);
+ }
+ }
+ catch (Exception e) {
+ throw new RuntimeExpressionException(e);
+ }
+ }
+
+ public List evaluateAsList(E exchange) throws Exception {
+ return getExpression().evaluate(createDynamicContext(exchange));
+ }
+
+ public Object evaluateAsStringSource(E exchange) throws Exception {
+ String text = evaluateAsString(exchange);
+ return new StringSource(text);
+ }
+
+ public Object evaluateAsBytesSource(E exchange) throws Exception {
+ byte[] bytes = evaluateAsBytes(exchange);
+ return new BytesSource(bytes);
+ }
+
+ public Node evaluateAsDOM(E exchange) throws Exception {
+ DOMResult result = new DOMResult();
+ getExpression().pull(createDynamicContext(exchange), result,
properties);
+ return result.getNode();
+ }
+
+ public byte[] evaluateAsBytes(E exchange) throws Exception {
+ ByteArrayOutputStream buffer = new ByteArrayOutputStream();
+ Result result = new StreamResult(buffer);
+ getExpression().pull(createDynamicContext(exchange), result,
properties);
+ byte[] bytes = buffer.toByteArray();
+ return bytes;
+ }
+
+ public String evaluateAsString(E exchange) throws Exception {
+ StringWriter buffer = new StringWriter();
+ Result result = new StreamResult(buffer);
+ getExpression().pull(createDynamicContext(exchange), result,
properties);
+ String text = buffer.toString();
+ return text;
+ }
+
+ public boolean matches(E exchange) {
+ try {
+ List list = evaluateAsList(exchange);
+ System.out.println("Found list: " + list);
+ return false;
+ }
+ catch (Exception e) {
+ throw new RuntimeExpressionException(e);
+ }
+ }
+
+ // Builder methods
+ //-------------------------------------------------------------------------
+ public static <E extends Exchange> XQueryBuilder<E> xquery(final String
queryText) {
+ return new XQueryBuilder<E>() {
+ protected XQueryExpression
createQueryExpression(StaticQueryContext staticQueryContext) throws
XPathException {
+ return staticQueryContext.compileQuery(queryText);
+ }
+ };
+ }
+
+ public static <E extends Exchange> XQueryBuilder<E> xquery(final Reader
reader) {
+ return new XQueryBuilder<E>() {
+ protected XQueryExpression
createQueryExpression(StaticQueryContext staticQueryContext) throws
XPathException, IOException {
+ return staticQueryContext.compileQuery(reader);
+ }
+ };
+ }
+
+ public static <E extends Exchange> XQueryBuilder<E> xquery(final
InputStream in, final String characterSet) {
+ return new XQueryBuilder<E>() {
+ protected XQueryExpression
createQueryExpression(StaticQueryContext staticQueryContext) throws
XPathException, IOException {
+ return staticQueryContext.compileQuery(in, characterSet);
+ }
+ };
+ }
+
+ public XQueryBuilder<E> asBytes() {
+ setResultsFormat(ResultFormat.Bytes);
+ return this;
+ }
+
+ public XQueryBuilder<E> asBytesSource() {
+ setResultsFormat(ResultFormat.BytesSource);
+ return this;
+ }
+
+ public XQueryBuilder<E> asDOM() {
+ setResultsFormat(ResultFormat.DOM);
+ return this;
+ }
+
+ public XQueryBuilder<E> asDOMSource() {
+ setResultsFormat(ResultFormat.DOMSource);
+ return this;
+ }
+
+ public XQueryBuilder<E> asList() {
+ setResultsFormat(ResultFormat.List);
+ return this;
+ }
+
+ public XQueryBuilder<E> asString() {
+ setResultsFormat(ResultFormat.String);
+ return this;
+ }
+
+ public XQueryBuilder<E> asStringSource() {
+ setResultsFormat(ResultFormat.StringSource);
+ return this;
+ }
+
+ // Properties
+ //-------------------------------------------------------------------------
+
+ public XQueryExpression getExpression() throws IOException, XPathException
{
+ if (expression == null) {
+ expression = createQueryExpression(getStaticQueryContext());
+ clearBuilderReferences();
+ }
+ return expression;
+ }
+
+ public Configuration getConfiguration() {
+ if (configuration == null) {
+ configuration = new Configuration();
+ configuration.setHostLanguage(Configuration.XQUERY);
+ }
+ return configuration;
+ }
+
+ public void setConfiguration(Configuration configuration) {
+ this.configuration = configuration;
+ }
+
+ public StaticQueryContext getStaticQueryContext() {
+ if (staticQueryContext == null) {
+ staticQueryContext = new StaticQueryContext(getConfiguration());
+ }
+ return staticQueryContext;
+ }
+
+ public void setStaticQueryContext(StaticQueryContext staticQueryContext) {
+ this.staticQueryContext = staticQueryContext;
+ }
+
+ public Map<String, Object> getParameters() {
+ return parameters;
+ }
+
+ public void setParameters(Map<String, Object> parameters) {
+ this.parameters = parameters;
+ }
+
+ public Properties getProperties() {
+ return properties;
+ }
+
+ public void setProperties(Properties properties) {
+ this.properties = properties;
+ }
+
+ public ResultFormat getResultsFormat() {
+ return resultsFormat;
+ }
+
+ public void setResultsFormat(ResultFormat resultsFormat) {
+ this.resultsFormat = resultsFormat;
+ }
+
+ // Implementation methods
+ //
-------------------------------------------------------------------------
+
+ /**
+ * A factory method to create the XQuery expression
+ */
+ protected abstract XQueryExpression
createQueryExpression(StaticQueryContext staticQueryContext) throws
XPathException, IOException;
+
+ /**
+ * Creates a dynamic context for the given exchange
+ */
+ protected DynamicQueryContext createDynamicContext(E exchange) throws
Exception {
+ Configuration config = getConfiguration();
+ DynamicQueryContext dynamicQueryContext = new
DynamicQueryContext(config);
+
+ Source source = exchange.getIn().getBody(Source.class);
+ if (source == null) {
+ source = converter.toSource(converter.createDocument());
+ }
+
+ DocumentInfo doc = getStaticQueryContext().buildDocument(source);
+ dynamicQueryContext.setContextItem(doc);
+ configureQuery(dynamicQueryContext, exchange);
+ return dynamicQueryContext;
+ }
+
+ /**
+ * Configures the dynamic context with exchange specific parameters
+ *
+ * @param dynamicQueryContext
+ * @param exchange
+ * @throws Exception
+ */
+ protected void configureQuery(DynamicQueryContext dynamicQueryContext,
Exchange exchange) throws Exception {
+ addParameters(dynamicQueryContext, exchange.getProperties());
+ addParameters(dynamicQueryContext, exchange.getIn().getHeaders());
+ addParameters(dynamicQueryContext, getParameters());
+
+ dynamicQueryContext.setParameter("exchange", exchange);
+ dynamicQueryContext.setParameter("in", exchange.getIn());
+ dynamicQueryContext.setParameter("out", exchange.getOut());
+ }
+
+ protected void addParameters(DynamicQueryContext dynamicQueryContext,
Map<String, Object> map) {
+ Set<Map.Entry<String, Object>> propertyEntries = map.entrySet();
+ for (Map.Entry<String, Object> entry : propertyEntries) {
+ dynamicQueryContext.setParameter(entry.getKey(), entry.getValue());
+ }
+ }
+
+ /**
+ * To avoid keeping around any unnecessary objects after the expresion has
been created lets
+ * nullify references here
+ */
+ protected void clearBuilderReferences() {
+ staticQueryContext = null;
+ configuration = null;
+ }
+}
Propchange:
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/XQueryBuilder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/XQueryBuilder.java
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Propchange:
activemq/camel/trunk/camel-saxon/src/main/java/org/apache/camel/builder/saxon/XQueryBuilder.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added:
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/XQueryTest.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/XQueryTest.java?view=auto&rev=525869
==============================================================================
---
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/XQueryTest.java
(added)
+++
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/XQueryTest.java
Thu Apr 5 09:51:48 2007
@@ -0,0 +1,47 @@
+/**
+ *
+ * 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.camel.builder.saxon;
+
+import junit.framework.TestCase;
+import org.apache.camel.Exchange;
+import static org.apache.camel.builder.saxon.XQueryBuilder.xquery;
+import org.apache.camel.impl.DefaultCamelContext;
+import org.apache.camel.impl.DefaultExchange;
+import static org.apache.camel.util.ObjectHelper.className;
+import org.w3c.dom.Document;
+
+/**
+ * @version $Revision$
+ */
+public class XQueryTest extends TestCase {
+ public void testXQuery() throws Exception {
+ Exchange exchange = new DefaultExchange(new DefaultCamelContext());
+ exchange.getIn().setBody("<products><product
type='food'><pizza/></product><product
type='beer'><stella/></product></products>");
+
+ Object result = xquery("//[EMAIL PROTECTED] =
'beer']").asList().evaluate(exchange);
+
+ System.out.println("Returned: " + result);
+/*
+
+ assertTrue("Should be a document but was: " + className(result),
result instanceof Document);
+
+ Document doc = (Document) result;
+ assertEquals("Root document element name", "",
doc.getDocumentElement().getLocalName());
+*/
+ }
+}
Propchange:
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/XQueryTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/XQueryTest.java
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Propchange:
activemq/camel/trunk/camel-saxon/src/test/java/org/apache/camel/builder/saxon/XQueryTest.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
