1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
//>>built
define("dojox/data/CouchDBRestStore", ["dojo", "dojox", "dojox/data/JsonRestStore"], function(dojo, dojox) {
// A CouchDBRestStore is an extension of JsonRestStore to handle CouchDB's idiosyncrasies, special features,
// and deviations from standard HTTP Rest.
// NOTE: CouchDB is not designed to be run on a public facing network. There is no access control
// on database documents, and you should NOT rely on client side control to implement security.
dojo.declare("dojox.data.CouchDBRestStore",
dojox.data.JsonRestStore,
{
save: function(kwArgs){
var actions = this.inherited(arguments); // do the default save and then update for version numbers
var prefix = this.service.servicePath;
for(var i = 0; i < actions.length; i++){
// need to update the item's version number after it has been committed
(function(item,dfd){
dfd.addCallback(function(result){
if(result){
item.__id = prefix + result.id; // update the object with the results of the post
item._rev = result.rev;
}
return result;
});
})(actions[i].content,actions[i].deferred);
}
},
fetch: function(args){
// summary:
// This only differs from JsonRestStore in that it, will put the query string the query part of the URL and it handles start and count
args.query = args.query || '_all_docs?';
if(args.start){
args.query = (args.query ? (args.query + '&') : '') + 'startkey=' + args.start;
delete args.start;
}
if(args.count){
args.query = (args.query ? (args.query + '&') : '') + 'limit=' + args.count;
delete args.count;
}
return this.inherited(arguments);
},
_processResults: function(results){
var rows = results.rows;
if(rows){
var prefix = this.service.servicePath;
var self = this;
for(var i = 0; i < rows.length;i++){
var realItem = rows[i].value;
realItem.__id= prefix + rows[i].id;
realItem._id= rows[i].id;
realItem._loadObject= dojox.rpc.JsonRest._loader;
rows[i] = realItem;
}
return {totalCount:results.total_rows, items:results.rows};
}else{
return {items:results};
}
}
}
);
// create a set of stores
dojox.data.CouchDBRestStore.getStores = function(couchServerUrl){
var dfd = dojo.xhrGet({
url: couchServerUrl+"_all_dbs",
handleAs: "json",
sync: true
});
var stores = {};
dfd.addBoth(function(dbs){
for(var i = 0; i < dbs.length; i++){
stores[dbs[i]] = new dojox.data.CouchDBRestStore({target:couchServerUrl + dbs[i],idAttribute:"_id"});
}
return stores;
});
return stores;
};
return dojox.data.CouchDBRestStore;
});
|
