Author: indika
Date: Thu Oct 18 09:55:52 2007
New Revision: 586034
URL: http://svn.apache.org/viewvc?rev=586034&view=rev
Log:
add samples for dblookup mediator + dbreport mediator
fixed some issues
Added:
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_200.xml
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_201.xml
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_202.xml
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorSerializer.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorFactory.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorSerializer.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorFactory.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorSerializer.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/AbstractDBMediator.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBLookupMediator.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Query.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Statement.java
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java
Thu Oct 18 09:55:52 2007
@@ -19,25 +19,22 @@
package org.apache.synapse.config.xml;
-import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMAttribute;
+import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.xpath.AXIOMXPath;
+import org.apache.commons.dbcp.BasicDataSource;
import org.apache.synapse.mediators.db.AbstractDBMediator;
import org.apache.synapse.mediators.db.Statement;
-import org.apache.synapse.SynapseException;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.tomcat.dbcp.dbcp.BasicDataSource;
import org.jaxen.JaxenException;
-import javax.xml.namespace.QName;
-import javax.sql.DataSource;
-import javax.naming.InitialContext;
import javax.naming.Context;
+import javax.naming.InitialContext;
import javax.naming.NamingException;
+import javax.sql.DataSource;
+import javax.xml.namespace.QName;
import java.sql.Connection;
-import java.util.Iterator;
import java.util.Hashtable;
+import java.util.Iterator;
/**
* <dbreport | dblookup | .. etc>
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorSerializer.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorSerializer.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorSerializer.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorSerializer.java
Thu Oct 18 09:55:52 2007
@@ -19,16 +19,14 @@
package org.apache.synapse.config.xml;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.synapse.mediators.db.Statement;
-import org.apache.synapse.mediators.db.AbstractDBMediator;
-import org.apache.synapse.SynapseException;
import org.apache.axiom.om.OMElement;
+import org.apache.synapse.SynapseException;
+import org.apache.synapse.mediators.db.AbstractDBMediator;
+import org.apache.synapse.mediators.db.Statement;
import javax.xml.namespace.QName;
-import java.util.Iterator;
import java.sql.Types;
+import java.util.Iterator;
/**
* <dbreport | dblookup | .. etc>
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorFactory.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorFactory.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorFactory.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorFactory.java
Thu Oct 18 09:55:52 2007
@@ -19,10 +19,10 @@
package org.apache.synapse.config.xml;
+import org.apache.axiom.om.OMElement;
import org.apache.synapse.Mediator;
import org.apache.synapse.SynapseConstants;
import org.apache.synapse.mediators.db.DBLookupMediator;
-import org.apache.axiom.om.OMElement;
import javax.xml.namespace.QName;
@@ -30,10 +30,18 @@
* <dblookup>
* <connection>
* <pool>
+ * (
* <driver/>
* <url/>
* <user/>
* <password/>
+ * |
+ * <dsName/>
+ * <icClass/>
+ * <url/>
+ * <user/>
+ * <password/>
+ * )
* <property name="name" value="value"/>*
* </pool>
* </connection>
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorSerializer.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorSerializer.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorSerializer.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBLookupMediatorSerializer.java
Thu Oct 18 09:55:52 2007
@@ -19,10 +19,8 @@
package org.apache.synapse.config.xml;
-import org.apache.synapse.Mediator;
import org.apache.axiom.om.OMElement;
-import org.apache.commons.logging.LogFactory;
-import org.apache.commons.logging.Log;
+import org.apache.synapse.Mediator;
import org.apache.synapse.mediators.db.DBLookupMediator;
/**
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorFactory.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorFactory.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorFactory.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorFactory.java
Thu Oct 18 09:55:52 2007
@@ -19,10 +19,10 @@
package org.apache.synapse.config.xml;
+import org.apache.axiom.om.OMElement;
import org.apache.synapse.Mediator;
import org.apache.synapse.SynapseConstants;
import org.apache.synapse.mediators.db.DBReportMediator;
-import org.apache.axiom.om.OMElement;
import javax.xml.namespace.QName;
@@ -30,10 +30,18 @@
* <dbreport>
* <connection>
* <pool>
+ * (
* <driver/>
* <url/>
* <user/>
* <password/>
+ * |
+ * <dsName/>
+ * <icClass/>
+ * <url/>
+ * <user/>
+ * <password/>
+ * )
* <property name="name" value="value"/>*
* </pool>
* </connection>
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorSerializer.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorSerializer.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorSerializer.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/DBReportMediatorSerializer.java
Thu Oct 18 09:55:52 2007
@@ -19,11 +19,9 @@
package org.apache.synapse.config.xml;
+import org.apache.axiom.om.OMElement;
import org.apache.synapse.Mediator;
import org.apache.synapse.mediators.db.DBReportMediator;
-import org.apache.axiom.om.OMElement;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
/**
* <dbreport>
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/AbstractDBMediator.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/AbstractDBMediator.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/AbstractDBMediator.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/AbstractDBMediator.java
Thu Oct 18 09:55:52 2007
@@ -19,24 +19,21 @@
package org.apache.synapse.mediators.db;
-import org.apache.synapse.mediators.AbstractMediator;
+import org.apache.commons.dbcp.BasicDataSource;
+import org.apache.commons.logging.Log;
import org.apache.synapse.ManagedLifecycle;
import org.apache.synapse.MessageContext;
-import org.apache.synapse.SynapseConstants;
-import org.apache.synapse.SynapseException;
import org.apache.synapse.config.xml.AbstractDBMediatorFactory;
import org.apache.synapse.core.SynapseEnvironment;
import org.apache.synapse.core.axis2.Axis2MessageContext;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.tomcat.dbcp.dbcp.BasicDataSource;
+import org.apache.synapse.mediators.AbstractMediator;
-import javax.xml.namespace.QName;
import javax.sql.DataSource;
+import javax.xml.namespace.QName;
+import java.math.BigDecimal;
import java.sql.*;
import java.sql.Date;
import java.util.*;
-import java.math.BigDecimal;
/**
* This abstract DB mediator will perform common DB connection pooling etc.
for all DB mediators
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBLookupMediator.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBLookupMediator.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBLookupMediator.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBLookupMediator.java
Thu Oct 18 09:55:52 2007
@@ -21,8 +21,10 @@
import org.apache.synapse.MessageContext;
-import java.sql.*;
-import java.util.*;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.Iterator;
/**
* Simple database table lookup mediator. Designed only for read/lookup
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java
Thu Oct 18 09:55:52 2007
@@ -19,10 +19,10 @@
package org.apache.synapse.mediators.db;
-import org.apache.synapse.mediators.db.Statement;
import org.apache.synapse.MessageContext;
-import java.sql.*;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
/**
* A mediator that writes (i.e. inserts one row) to a table using message
information
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Query.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Query.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Query.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Query.java
Thu Oct 18 09:55:52 2007
@@ -19,13 +19,13 @@
package org.apache.synapse.mediators.dblookup;
-import org.jaxen.JaxenException;
import org.apache.axiom.om.xpath.AXIOMXPath;
+import org.jaxen.JaxenException;
-import java.util.List;
-import java.util.ArrayList;
import java.sql.PreparedStatement;
import java.sql.Types;
+import java.util.ArrayList;
+import java.util.List;
public class Query {
String rawStatement = null;
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Statement.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Statement.java?rev=586034&r1=586033&r2=586034&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Statement.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/Statement.java
Thu Oct 18 09:55:52 2007
@@ -21,7 +21,6 @@
import org.apache.axiom.om.xpath.AXIOMXPath;
import org.apache.synapse.SynapseException;
-import org.jaxen.JaxenException;
import java.sql.Types;
import java.util.ArrayList;
Added:
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_200.xml
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_200.xml?rev=586034&view=auto
==============================================================================
---
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_200.xml
(added)
+++
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_200.xml
Thu Oct 18 09:55:52 2007
@@ -0,0 +1,115 @@
+<!--
+ ~ 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.
+ -->
+<!-- introduction to dblookp mediator -->
+<definitions xmlns="http://ws.apache.org/ns/synapse";>
+
+ <sequence name="myFaultHandler">
+ <makefault>
+ <code value="tns:Receiver"
xmlns:tns="http://www.w3.org/2003/05/soap-envelope"/>
+ <reason expression="get-property('ERROR_MESSAGE')"/>
+ </makefault>
+
+ <property name="RESPONSE" value="true"/>
+ <header name="To" expression="get-property('ReplyTo')"/>
+ <send/>
+ <drop/>
+ </sequence>
+
+ <sequence name="main" onError="myFaultHandler">
+ <in>
+ <log level="custom">
+ <property name="text"
+ value="** Looking up from the Database **"/>
+ </log>
+ <dblookup xmlns="http://ws.apache.org/ns/synapse";>
+ <connection>
+ <pool>
+ <driver>org.apache.derby.jdbc.ClientDriver</driver>
+
<url>jdbc:derby://localhost:1527/synapsedb;create=false</url>
+ <user>synapse</user>
+ <password>synapse</password>
+ </pool>
+ </connection>
+ <statement>
+ <sql>select * from company where name =?</sql>
+ <parameter expression="//m0:getQuote/m0:request/m0:symbol"
+ xmlns:m0="http://services.samples/xsd";
type="VARCHAR"/>
+ <result name="company_id" column="id"/>
+ </statement>
+ </dblookup>
+
+ <switch source="get-property('company_id')">
+ <case regex="c1">
+ <log level="custom">
+ <property name="text"
+ expression="fn:concat('Company ID -
',get-property('company_id'))"/>
+ </log>
+ <send>
+ <endpoint>
+ <address
uri="http://localhost:9000/soap/SimpleStockQuoteService"/>
+ </endpoint>
+ </send>
+ </case>
+ <case regex="c2">
+ <log level="custom">
+ <property name="text"
+ expression="fn:concat('Company ID -
',get-property('company_id'))"/>
+ </log>
+ <send>
+ <endpoint>
+ <address
uri="http://localhost:9000/soap/SimpleStockQuoteService"/>
+ </endpoint>
+ </send>
+ </case>
+ <case regex="c3">
+ <log level="custom">
+ <property name="text"
+ expression="fn:concat('Company ID -
',get-property('company_id'))"/>
+ </log>
+ <send>
+ <endpoint>
+ <address
uri="http://localhost:9000/soap/SimpleStockQuoteService"/>
+ </endpoint>
+ </send>
+ </case>
+ <default>
+ <log level="custom">
+ <property name="text" value="** Unrecognized Company
ID **"/>
+ </log>
+ <makefault>
+ <code value="tns:Receiver"
+
xmlns:tns="http://www.w3.org/2003/05/soap-envelope"/>
+ <reason value="** Unrecognized Company ID **"/>
+ </makefault>
+ <property name="RESPONSE" value="true"/>
+ <header name="To" action="remove"/>
+ <send/>
+ <drop/>
+ </default>
+ </switch>
+ <drop/>
+ </in>
+
+ <out>
+ <send/>
+ </out>
+
+ </sequence>
+
+</definitions>
\ No newline at end of file
Added:
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_201.xml
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_201.xml?rev=586034&view=auto
==============================================================================
---
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_201.xml
(added)
+++
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_201.xml
Thu Oct 18 09:55:52 2007
@@ -0,0 +1,57 @@
+<!--
+ ~ 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.
+ -->
+<!-- introduction to dbreport mediator -->
+<definitions xmlns="http://ws.apache.org/ns/synapse";>
+
+ <sequence name="main">
+ <in>
+ <send>
+ <endpoint>
+ <address
uri="http://localhost:9000/soap/SimpleStockQuoteService"/>
+ </endpoint>
+ </send>
+ </in>
+
+ <out>
+ <log level="custom">
+ <property name="text"
+ value="** Reporting to the Database **"/>
+ </log>
+ <dbreport xmlns="http://ws.apache.org/ns/synapse";>
+ <connection>
+ <pool>
+ <driver>org.apache.derby.jdbc.ClientDriver</driver>
+
<url>jdbc:derby://localhost:1527/synapsedb;create=false</url>
+ <user>synapse</user>
+ <password>synapse</password>
+ </pool>
+ </connection>
+ <statement>
+ <sql>update company set prize=? where name =?</sql>
+ <parameter expression="//m0:return/m0:last/child::text()"
+ xmlns:m0="http://services.samples/xsd";
type="DOUBLE"/>
+ <parameter expression="//m0:return/m0:symbol/child::text()"
+ xmlns:m0="http://services.samples/xsd";
type="VARCHAR"/>
+ </statement>
+ </dbreport>
+ <send/>
+ </out>
+ </sequence>
+
+</definitions>
\ No newline at end of file
Added:
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_202.xml
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_202.xml?rev=586034&view=auto
==============================================================================
---
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_202.xml
(added)
+++
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_202.xml
Thu Oct 18 09:55:52 2007
@@ -0,0 +1,84 @@
+<!--
+ ~ 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.
+ -->
+ <!-- dbreport mediator and dblookup mediator -->
+<definitions xmlns="http://ws.apache.org/ns/synapse";>
+
+ <sequence name="main">
+ <in>
+ <send>
+ <endpoint>
+ <address
uri="http://localhost:9000/soap/SimpleStockQuoteService"/>
+ </endpoint>
+ </send>
+ </in>
+
+ <out>
+ <log level="custom">
+ <property name="text"
+ value="** Reporting to the Database **"/>
+ </log>
+
+ <dbreport xmlns="http://ws.apache.org/ns/synapse";>
+ <connection>
+ <pool>
+ <driver>org.apache.derby.jdbc.ClientDriver</driver>
+
<url>jdbc:derby://localhost:1527/synapsedb;create=false</url>
+ <user>synapse</user>
+ <password>synapse</password>
+ </pool>
+ </connection>
+ <statement>
+ <sql>update company set prize=? where name =?</sql>
+ <parameter expression="//m0:return/m0:last/child::text()"
+ xmlns:m0="http://services.samples/xsd";
type="DOUBLE"/>
+ <parameter expression="//m0:return/m0:symbol/child::text()"
+ xmlns:m0="http://services.samples/xsd";
type="VARCHAR"/>
+ </statement>
+ </dbreport>
+ <log level="custom">
+ <property name="text"
+ value="** Looking up from the Database **"/>
+ </log>
+ <dblookup xmlns="http://ws.apache.org/ns/synapse";>
+ <connection>
+ <pool>
+ <driver>org.apache.derby.jdbc.ClientDriver</driver>
+
<url>jdbc:derby://localhost:1527/synapsedb;create=false</url>
+ <user>synapse</user>
+ <password>synapse</password>
+ </pool>
+ </connection>
+ <statement>
+ <sql>select * from company where name =?</sql>
+ <parameter expression="//m0:return/m0:symbol/child::text()"
+ xmlns:m0="http://services.samples/xsd";
type="VARCHAR"/>
+ <result name="stock_prize" column="prize"/>
+ </statement>
+ </dblookup>
+ <log level="custom">
+ <property name="text"
+ expression="fn:concat('Stock Prize -
',get-property('stock_prize'))"/>
+ </log>
+ <send/>
+ </out>
+ </sequence>
+
+</definitions>
+
+
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
