svn commit: r1035537 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java

[rajikak]

Author: rajikak
Date: Tue Nov 16 05:35:22 2010
New Revision: 1035537

URL: http://svn.apache.org/viewvc?rev=1035537&view=rev
Log:
Fixed SYNAPSE-707.

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java?rev=1035537&r1=1035536&r2=1035537&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/AbstractDBMediatorFactory.java
 Tue Nov 16 05:35:22 2010
@@ -273,7 +273,7 @@ public abstract class AbstractDBMediator
         while (iter.hasNext()) {
 
             OMElement stmntElt = (OMElement) iter.next();
-            Statement statement = new Statement(getValue(stmntElt, SQL_Q));
+            Statement statement = new 
Statement(decodeSQLString(getValue(stmntElt, SQL_Q)));
 
             Iterator paramIter = stmntElt.getChildrenWithName(PARAM_Q);
             while (paramIter.hasNext()) {
@@ -335,5 +335,9 @@ public abstract class AbstractDBMediator
     private void saveElementConfig(OMElement element, QName qname, 
AbstractDBMediator mediator) {
         mediator.addDataSourceProperty(qname, getValue(element, qname));
     }
+
+    private String decodeSQLString(String sql){
+        return sql.replaceAll("&lt;","<").replaceAll("&gt;", ">");
+    }
 }