Merge pull request #3597 from DedunuKarunarathne/ds-sql

Add the original SQL query to the data service OMElement
wso2 · Sep 10, 2024 · ff9b535 · ff9b535
2 parents 2fab2c2 + c2e13eb
commit ff9b535
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/...n/java/org/wso2/micro/integrator/dataservices/core/description/query/ExpressionQuery.java b/...n/java/org/wso2/micro/integrator/dataservices/core/description/query/ExpressionQuery.java
@@ -44,6 +44,8 @@ public abstract class ExpressionQuery extends Query {
 
     private String query;
 
+    private String originalQuery;
+
     private List<String> namedParamNames;
 
     private int paramCount;
@@ -57,12 +59,17 @@ public ExpressionQuery(DataService dataService, String queryId, List<QueryParam>
         super(dataService, queryId, queryParams, result, configId, inputEventTrigger, outputEventTrigger,
               advancedProperties, inputNamespace);
         this.query = query;
+        this.originalQuery = query;
     }
 
     public String getQuery() {
         return query;
     }
 
+    public String getOriginalQuery() {
+        return originalQuery;
+    }
+
     public int getParamCount() {
         return paramCount;
     }

diff --git a/...n/java/org/wso2/micro/integrator/dataservices/core/description/query/QuerySerializer.java b/...n/java/org/wso2/micro/integrator/dataservices/core/description/query/QuerySerializer.java
@@ -121,7 +121,7 @@ private static void serializeAdvancedProps(Query query, OMElement queryEl, OMFac
 
 	private static void serializeSQLQueryProps(SQLQuery sqlQuery, OMElement queryEl, OMFactory fac) {
 		OMElement sqlEl = fac.createOMElement(new QName(DBSFields.SQL));
-		sqlEl.setText(sqlQuery.getQuery());
+		sqlEl.setText(sqlQuery.getOriginalQuery());
 		queryEl.addChild(sqlEl);
 		if (sqlQuery.isReturnGeneratedKeys()) {
 			queryEl.addAttribute(DBSFields.RETURN_GENERATED_KEYS, Boolean.TRUE.toString(), null);
@@ -310,7 +310,7 @@ private static void serializeQueryParams(List<QueryParam> queryParams,
 			}
 			defaultValue = queryParam.getDefaultValue();
 			if (defaultValue != null && defaultValue.getScalarValue() != null) {
-				queryParamEl.addAttribute(DBSFields.ORDINAL, defaultValue.getScalarValue(), null);
+				queryParamEl.addAttribute(DBSFields.DEFAULT_VALUE, defaultValue.getScalarValue(), null);
 			}
 			/* add validators */
 			serializeValidators(queryParam.getValidators(), queryParamEl, fac);