Incremental reduce first checkin. Warning! Disk format change.

git-svn-id: https://svn.apache.org/repos/asf/incubator/couchdb/trunk@656861 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 17 insertions, 1 deletions

diff --git a/share/www/script/couch.js b/share/www/script/couch.js
index 5f42ac38..f72fb712 100644
--- a/share/www/script/couch.js
+++ b/share/www/script/couch.js
@@ -99,7 +99,23 @@ function CouchDB(name) {
       mapFun = mapFun.toSource ? mapFun.toSource() : "(" + mapFun.toString() + ")";
     var req = request("POST", this.uri + "_temp_view" + encodeOptions(options), {
       headers: {"Content-Type": "text/javascript"},
-      body: mapFun
+      body: JSON.stringify(mapFun)
+    });
+    var result = JSON.parse(req.responseText);
+    if (req.status != 200)
+      throw result;
+    return result;
+  }
+  
+  // Applies the map function to the contents of database and returns the results.
+  this.reduce_query = function(mapFun, reduceFun, options) {
+    if (typeof(mapFun) != "string")
+      mapFun = mapFun.toSource ? mapFun.toSource() : "(" + mapFun.toString() + ")";
+    if (typeof(reduceFun) != "string")
+      reduceFun = reduceFun.toSource ? reduceFun.toSource() : "(" + reduceFun.toString() + ")";
+    var req = request("POST", this.uri + "_temp_view" + encodeOptions(options), {
+      headers: {"Content-Type": "text/javascript"},
+      body: JSON.stringify({map:mapFun, reduce:reduceFun})
     });
     var result = JSON.parse(req.responseText);
     if (req.status != 200)