Added samples for InsertDocumentAsJson and

Up(date/sert)Document(s)AsJson custom
output functions.

Author: leongor

samples/HelloWorldInsertSample/sample/HelloWorldInsertSample.spl

@@ -20,7 +20,8 @@ composite HelloWorldInsertSample {
             	greeting2 = "Hello again";
         }
 
-        stream<rstring error1, rstring error2, rstring error3, rstring error4, rstring error5, rstring error6> MongoSink = Insert(B1Stream; B2Stream){
+        stream<rstring error1, rstring error2, rstring error3, rstring error4, rstring error5, rstring error6, rstring error7, rstring error8> MongoSink =
+        	Insert(B1Stream; B2Stream) {
         	param
         		dbHost : "localhost";
 
@@ -83,7 +84,25 @@ composite HelloWorldInsertSample {
 				 * Store a constant map (map/tuple doesn't require key, but can use it to add a root key), the resulting document is:
 				 * { "_id" : ObjectId("53c795f7e66ebea0c454c813"), "greeting5_1" : "Hello", "greeting5_2" : "world" }
 				 */
-        		error5 = InsertDocument("streams", "sample", {"greeting5_1" : "Hello", "greeting5_2" : "world"});
+        		error5 = InsertDocument("streams", "sample", {"greeting5_1" : "Hello", "greeting5_2" : "world"}),
+
+        		/**
+				 * Store a constant rstring JSON, the resulting document is:
+				 * { "_id" : ObjectId("53c795f7e66ebea0c454c814"), "greeting6_1" : "Hello", "greeting6_2" : "world" }
+				 */
+        		error6 = InsertDocumentAsJson("streams", "sample", '{"greeting6_1" : "Hello", "greeting6_2" : "world"}'),
+
+        		/**
+				 * Store a constant rstring JSON (doesn't require key, but can use it to add a root key), the resulting document is:
+				 * { "_id" : ObjectId("53c795f7e66ebea0c454c815"), "greeting7_1" : { "greeting7_2" : [ "Hello", "world" ] } }
+				 */
+        		error7 = InsertDocumentAsJson("streams", "sample", "greeting7_1", '{"greeting7_2" : ["Hello", "world"]}'),
+
+        		/**
+				 * 	Store a constant rstring JSON with wrong syntax, the exception is:
+				 * FailedToParse: First character in field must be [A-Za-z$_]: offset:1 of:{[ : "Hello world"}
+				 */
+        		error8 = InsertDocumentAsJson("streams", "sample", '{[ : "Hello world"}');
         }
 
 		/**

samples/HelloWorldUpdateSample/sample/HelloWorldUpdateSample.spl

@@ -17,7 +17,7 @@ composite HelloWorldUpdateSample {
 		stream<rstring greeting2> B2Stream = Beacon()  {
             param iterations: 1;
             output B2Stream :
-            	greeting2 = "Hello again";
+            	greeting2 = '{"Hello" : "again"}';
         }
 
         stream<rstring error1> MongoSink = Update(B1Stream; B2Stream) {
@@ -60,8 +60,12 @@ composite HelloWorldUpdateSample {
 				 */
         		error1 = UpdateDocument("streams", "sample", B1Stream); // Updates one document where 'greeting1' exists
 //        		error1 = UpdateDocuments("streams", "sample", B1Stream); // Updates all documents where 'greeting1' exists
-//        		error1 = UpsertDocument("streams", "sample", "$set", B2Stream); // Upserts one document where 'greeting1' exists
-//        		error1 = UpsertDocuments("streams", "sample", "$set", B2Stream); // Upserts all document where 'greeting1' exists
+//        		error1 = UpsertDocument("streams", "sample", "$set", B1Stream); // Upserts one document where 'greeting1' exists
+//        		error1 = UpsertDocuments("streams", "sample", "$set", B1Stream); // Upserts all document where 'greeting1' exists
+//        		error1 = UpdateDocumentAsJson("streams", "sample", greeting2); // Updates one document with JSON where 'greeting1' exists
+//        		error1 = UpdateDocumentsAsJson("streams", "sample", greeting2); // Updates all documents with JSON where 'greeting1' exists
+//        		error1 = UpsertDocumentAsJson("streams", "sample", "$set", greeting2); // Upserts one document with JSON where 'greeting1' exists
+//        		error1 = UpsertDocumentsAsJson("streams", "sample", "$set", greeting2); // Upserts all documents with JSON where 'greeting1' exists
         }
 
 		/**