-
Notifications
You must be signed in to change notification settings - Fork 3
/
read.js
92 lines (71 loc) · 2.61 KB
/
read.js
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
84
85
86
87
88
89
90
91
92
var DocumentDBClient = require('documentdb').DocumentClient;
var host = 'https://test-kademy.documents.azure.com:443/',
options = {
masterKey: 'hSui6X08mjlXQnTzsvUfLHIV56+OdNemziePwc/iqljXvRRGdLUOz2DZIye1ZB1/fv1PAargsR7UElTg7sJD8A==',
};
var databaseDefinition = { id: "test-kademy" };
var collectionDefinition = { id: "users" };
var client = new DocumentDBClient(host, options);
var readOrCreateDatabase = function (callback) {
var databaseId = databaseDefinition.id;
client.queryDatabases('SELECT * FROM root r WHERE r.id="' + databaseId + '"').toArray(function (err, results) {
if (err) {
// some error occured, rethrow up
throw (err);
}
if (!err && results.length === 0) {
// no error occured, but there were no results returned
// indicating no database exists matching the query
client.createDatabase({ id: databaseId }, function (err, createdDatabase) {
callback(createdDatabase);
});
} else {
// we found a database
callback(results[0]);
}
});
};
var readOrCreateCollection = function (database, callback) {
var collectionId = collectionDefinition.id;
client.queryCollections(database._self, 'SELECT * FROM root r WHERE r.id="' + collectionId + '"').toArray(function (err, results) {
if (err) {
// some error occured, rethrow up
throw (err);
}
if (!err && results.length === 0) {
// no error occured, but there were no results returned
//indicating no collection exists in the provided database matching the query
client.createCollection(database._self, { id: collectionId }, function (err, createdCollection) {
callback(createdCollection);
});
} else {
// we found a collection
callback(results[0]);
}
});
};
var listItems = function (collection, callback) {
client.queryDocuments(collection._self+'0', 'SELECT * FROM root r').toArray(function (err, docs) {
if (err) {
console.log(err)
}
callback(docs);
});
}
/*
readOrCreateDatabase(function (database) {
console.log(database)
readOrCreateCollection(database, function(collection){
console.log(collection)
//console.log(collection.indexingPolicy)
listItems(collection, function(docs){
console.log(docs)
})
});
});*/
client.queryDatabases('SELECT * FROM root r').toArray(function (err, results) {
if (err) {
console.log(err)
}
console.log(results)
});