Added the JS module for map function.

Author: Ajit George

test-complete/src/test/java/com/marklogic/client/functionaltest/TestOpticOnLiterals.java

@@ -1140,8 +1140,7 @@ public void testInvalidDefinitions() throws KeyManagementException, NoSuchAlgori
 		}
 		// Should have SQL-NOCOLUMN exceptions.
 		assertTrue("Exceptions not found", str.toString().contains("SQL-NOCOLUMN"));
-		assertTrue("Exceptions not found", str.toString().contains("Column not found: invalid_view.colorId"));
-		
+		assertTrue("Exceptions not found", str.toString().contains("Column not found: invalid_view.colorId"));		
 	}
 
 	/* 
@@ -1217,8 +1216,9 @@ public void testInvalidQualifier() throws KeyManagementException, NoSuchAlgorith
 
 	/* 
 	 * Test Map function
+	 * TODO Refer to Eric's test and make changes.
 	*/
-	@Test
+	@Ignore
 	public void testMapFunction() throws KeyManagementException, NoSuchAlgorithmException, IOException, SAXException, ParserConfigurationException
 	{
 		System.out.println("In testMapFunction method");
@@ -1287,29 +1287,8 @@ public void testMapFunction() throws KeyManagementException, NoSuchAlgorithmExce
 		// plans from literals
 		ModifyPlan plan1 = p.fromLiterals(literalsM1);
 		ModifyPlan plan2 = p.fromLiterals(literalsM2);
-		/*StringBuilder str = new StringBuilder();
-		str.append("function colorIdMapper(result) {");
-		str.append("switch(result.myColorId) {");
-		str.append("case 1:");
-		str.append("result.myColorId = 'RED';");
-		str.append("     break;");
-		str.append("case 2:");
-		str.append("result.myColorId = 'BLUE';");
-		str.append("break;");
-		str.append("case 3:");
-		str.append("result.myColorId = 'YELLOW';");
-		str.append("break;");
-		str.append("case 4:");
-		str.append("result.myColorId = 'BLACK';");
-		str.append("break;");
-		str.append("default:");
-		str.append("result.myColorId = 'NO COLOR';");
-		str.append("}");
-		str.append("return result;");
-		str.append("};");*/
-		
-		
-		ModifyPlan output = plan1.joinInner( plan2, p.on(p.col("colorId_shape"), p.col("colorId")))
+				
+		ModifyPlan output = plan1.joinInner(plan2, p.on(p.col("colorId_shape"), p.col("colorId")))
 		                         .select(
 		                                 "rowId", 
 		                                "desc", 
@@ -1318,22 +1297,25 @@ public void testMapFunction() throws KeyManagementException, NoSuchAlgorithmExce
 		                               )
 		        .orderBy(p.asc("rowId"));
 
-		PlanFunction pf = output.installedFunction("/marklogic.rest.resource/OpticsJSResourceModule/assets/resource.sjs", "colorIdMapper");		
+		PlanFunction pf = output.installedFunction("/marklogic.rest.resource/OpticsJSResourceModule/assets/resource.sjs", "colorIdMapper");	
+		
 		output.map(pf);
 
-JacksonHandle jacksonHandle = new JacksonHandle();
-jacksonHandle.setMimetype("application/json");
+		JacksonHandle jacksonHandle = new JacksonHandle();
+		jacksonHandle.setMimetype("application/json");
 
-rowMgr.resultDoc(output, jacksonHandle);
-JsonNode jsonBindingsNodes = jacksonHandle.get().path("rows");
+		rowMgr.resultDoc(output, jacksonHandle);
+		JsonNode jsonBindingsNodes = jacksonHandle.get().path("rows");
 
-// Should have 1 node returned.
-assertEquals("One node not returned from testIntersect method", 4, jsonBindingsNodes.size());
-		
-		
-		
+		// Should have 4 node returned.
+		assertEquals("Four nodes not returned from testMapFunction method", 4, jsonBindingsNodes.size());
+		assertEquals("Row 1 rowId value incorrect", "1", jsonBindingsNodes.path(0).path("rowId").path("value").asText());
+		assertEquals("Row 1 descAgg value incorrect", "red", jsonBindingsNodes.path(0).path("colorDesc").path("value").asText());
+		assertEquals("Row 1 rowId value incorrect", "2", jsonBindingsNodes.path(1).path("rowId").path("value").asText());
+		assertEquals("Row 1 descAgg value incorrect", "blue", jsonBindingsNodes.path(1).path("colorDesc").path("value").asText());
 	}
 
+		
 	@AfterClass
 	public static void tearDownAfterClass() throws Exception
 	{

test-complete/src/test/java/com/marklogic/client/functionaltest/data/OpticsTestJSResource.js

@@ -0,0 +1,95 @@
+/*
+ * Copyright 2014-2015 MarkLogic Corporation
+ *
+ * Licensed 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.
+ */
+
+// module that helps tests in TestOpticOnLiterals.class for map functionality
+function get(context, params) { 
+ context.outputTypes = ["application/json"];
+ var arg1 = params.arg1;
+ var arg2 = params.arg2;
+ var x = arg1.toString();
+
+   
+return {
+	"argument1": x,
+	"argument2": arg2,
+	"database-name":xdmp.databaseName(xdmp.database()),
+	"document-count":fn.count(fn.doc()),
+    "content": "This is a JSON document",
+    "document-content": fn.doc(),
+    "response": xdmp.getResponseCode(),
+	"outputTypes": context.outputTypes,
+	
+  }
+};
+function post(context, params, input) { 
+    
+   var argUrl = params.uri;
+        	
+    xdmp.eval(" \
+    declareUpdate(); \
+    var argUrl; \
+    var sibling=cts.doc(argUrl).root.content; \
+    var inputObject; \
+    var newNode = new NodeBuilder(); \
+	newNode.addNode(inputObject); \
+	var named = newNode.toNode().xpath('.//array-node()'); xdmp.nodeInsertAfter(sibling,named);\
+ ",{"inputObject":input,"argUrl":argUrl},{"isolation":"different-transaction"});
+   return ({"response": xdmp.getResponseCode()})
+
+ };
+ 
+// Function responding to PUT method - must use local name 'put'.
+function put(context, params, input) {
+    var argUrl = params.uri;
+    var inputObject = input;
+   //xdmp.documentInsert(argUrl,input);
+  xdmp.eval("declareUpdate(); var argUrl; var input;xdmp.documentInsert(argUrl,input)",{"argUrl":argUrl,"input":inputObject},{"isolation":"different-transaction"});
+  var count = xdmp.eval("fn.count(fn.doc())");
+  xdmp.log(count);
+   return ({"response": xdmp.getResponseCode()})
+};
+
+// Function responding to DELETE method - must use local name 'delete'.
+function deleteFunction(context, params) {
+    var docuri = params.uri;
+    xdmp.documentDelete(docuri);
+	return({"response": xdmp.getResponseCode()})
+};
+
+function colorIdMapper() {
+	console.log("Inside the func ==== ");
+    switch(colorId) { 
+      case 1:
+        colorDesc = 'RED';
+        break;
+      case 2:
+        colorDesc = 'BLUE';
+        break;
+      case 3:
+    	  colorDesc = 'YELLOW';
+        break;
+      case 4:
+    	  colorDesc = 'BLACK';
+        break;
+      default:
+    	  colorDesc = 'NO COLOR';
+    }
+    return colorDesc.;
+  };
+exports.GET = colorIdMapper;
+exports.POST = post;
+exports.PUT = put;
+exports.DELETE = deleteFunction;