You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by iv...@apache.org on 2015/07/10 10:58:00 UTC
[38/50] [abbrv] incubator-ignite git commit: #ignite-964: change
cache-put-get-example.js
#ignite-964: change cache-put-get-example.js
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/bfc899e4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/bfc899e4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/bfc899e4
Branch: refs/heads/ignite-964
Commit: bfc899e42dcb652412e9a203dd46295ff6f5affa
Parents: 242c21b
Author: ivasilinets <iv...@gridgain.com>
Authored: Thu Jul 9 17:40:03 2015 +0300
Committer: ivasilinets <iv...@gridgain.com>
Committed: Thu Jul 9 17:40:03 2015 +0300
----------------------------------------------------------------------
examples/src/main/js/cache-api-example.js | 2 +-
examples/src/main/js/cache-put-get-example.js | 132 +++++++++------------
2 files changed, 59 insertions(+), 75 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bfc899e4/examples/src/main/js/cache-api-example.js
----------------------------------------------------------------------
diff --git a/examples/src/main/js/cache-api-example.js b/examples/src/main/js/cache-api-example.js
index d17276a..1514941 100644
--- a/examples/src/main/js/cache-api-example.js
+++ b/examples/src/main/js/cache-api-example.js
@@ -55,7 +55,7 @@ function main() {
cache.getAndPut(1, "1", onGetAndPut)
});
- onGetAndPut = function(err, entry) {
+ function onGetAndPut(err, entry) {
console.log(">>> Get and put finished [result=" + entry + "]");
// Put and do not return previous value.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bfc899e4/examples/src/main/js/cache-put-get-example.js
----------------------------------------------------------------------
diff --git a/examples/src/main/js/cache-put-get-example.js b/examples/src/main/js/cache-put-get-example.js
index 7a9b035..75da096 100644
--- a/examples/src/main/js/cache-put-get-example.js
+++ b/examples/src/main/js/cache-put-get-example.js
@@ -16,104 +16,88 @@
*/
var apacheIgnite = require("apache-ignite");
-
var Ignition = apacheIgnite.Ignition;
var CacheEntry = apacheIgnite.CacheEntry;
-Ignition.start(['127.0.0.1:9095'], null, onConnect);
-
-function onConnect(err, ignite) {
- if (err)
- throw err;
-
- ignite.getOrCreateCache("PutGetExampleCache", function(err, cache) {
- putGet(cache);
-
- putAllGetAll(cache);
- });
-}
-
-putGet = function(cache) {
- console.log(">>> Cache put-get example started.");
-
- var keyCnt = 20;
-
- var putCnt = 0;
-
- var onGet = function(err, res) {
- if (err) {
- console.log("Error: " + err);
-
- throw new Error(err);
- }
-
- console.log("Get val=" + res);
+/**
+ * This example demonstrates very basic operations on cache, such as 'put' and 'get'.
+ * <p>
+ * Remote nodes should always be started with special configuration file which
+ * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/js/example-js-cache.xml'}.
+ * <p>
+ * Alternatively you can run {@link ExampleJsNodeStartup} in another JVM which will
+ * start node with {@code examples/config/js/example-js-cache.xml} configuration.
+ */
+function main() {
+ /** Cache name. */
+ var cacheName = "PutGetExampleCache";
+
+ /** Connect to node that started with {@code examples/config/js/example-js-cache.xml} configuration. */
+ Ignition.start(['127.0.0.1:9095'], null, onConnect);
+
+ function onConnect(err, ignite) {
+ ignite.getOrCreateCache(cacheName, function(err, cache) { putGetExample(ignite, cache); });
}
- var onPut = function(err) {
- if (err) {
- console.log("Error: " + err);
+ /** Execute individual puts and gets. */
+ putGetExample = function(ignite, cache) {
+ console.log(">>> Cache put-get example started.");
- throw new Error(err);
- }
+ var key = 1;
+
+ // Store key in cache.
+ cache.put(key, "1", onPut);
- if (putCnt < keyCnt - 1) {
- putCnt++;
+ function onPut(err) {
+ console.log(">>> Stored values in cache.");
- return;
+ cache.get(key, onGet);
}
- console.log(">>> Stored values in cache.");
+ function onGet(err, res) {
+ console.log("Get val=" + res);
- for (var i = 0; i < keyCnt; i++) {
- cache.get(i, onGet);
+ putAllGetAll(ignite, cache);
}
}
- // Store keys in cache.
- for (var i = 0; i < keyCnt; i++) {
- cache.put(i, i.toString(), onPut);
- }
-}
-
-putAllGetAll = function(cache) {
- console.log(">>> Starting putAll-getAll example.");
-
- var keyCnt = 20;
+ /** Execute bulk {@code putAll(...)} and {@code getAll(...)} operations. */
+ function putAllGetAll(ignite, cache) {
+ console.log(">>> Starting putAll-getAll example.");
- var batch = [];
- var keys = [];
+ var keyCnt = 20;
- for (var i = keyCnt; i < keyCnt + keyCnt; ++i) {
- var key = i;
+ // Create batch.
+ var batch = [];
+ var keys = [];
- var val = "bulk-" + i;
+ for (var i = keyCnt; i < keyCnt + keyCnt; ++i) {
+ var key = i;
+ var val = "bulk-" + i;
- keys.push(key);
- batch.push(new CacheEntry(key, val));
- }
+ keys.push(key);
+ batch.push(new CacheEntry(key, val));
+ }
- var onGetAll = function(err, entries) {
- if (err) {
- console.log("Error: " + err);
+ cache.putAll(batch, onPutAll);
- throw new Error(err);
- }
+ function onPutAll(err) {
+ console.log(">>> Stored values in cache.");
- for (var e of entries) {
- console.log("Got entry [key=" + e.key + ", val=" + e.value + ']');
+ cache.getAll(keys, onGetAll);
}
- }
- var onPutAll= function(err) {
- if (err) {
- console.log("Error: " + err);
+ function onGetAll(err, entries) {
+ for (var e of entries) {
+ console.log("Got entry [key=" + e.key + ", val=" + e.value + ']');
+ }
- throw new Error(err);
+ // Destroying cache.
+ ignite.destroyCache(cacheName, function(err) {
+ console.log(">>> End of cache put-get example.");
+ });
}
-
- cache.getAll(keys, onGetAll);
}
+}
- cache.putAll(batch, onPutAll);
-}
\ No newline at end of file
+main();
\ No newline at end of file