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/14 16:43:05 UTC

[2/2] incubator-ignite git commit: #ignite-961-promise: add Javadoc for query cursor.

#ignite-961-promise:  add Javadoc for query cursor.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/82d15a00
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/82d15a00
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/82d15a00

Branch: refs/heads/ignite-961-promise
Commit: 82d15a00df16231d0035acde46691dd322ef31f8
Parents: 5150d39
Author: ivasilinets <iv...@gridgain.com>
Authored: Tue Jul 14 17:42:57 2015 +0300
Committer: ivasilinets <iv...@gridgain.com>
Committed: Tue Jul 14 17:42:57 2015 +0300

----------------------------------------------------------------------
 modules/nodejs/src/main/js/cache.js | 38 ++++++++++++++++----------------
 1 file changed, 19 insertions(+), 19 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/82d15a00/modules/nodejs/src/main/js/cache.js
----------------------------------------------------------------------
diff --git a/modules/nodejs/src/main/js/cache.js b/modules/nodejs/src/main/js/cache.js
index 92acc2b..bbd3455 100644
--- a/modules/nodejs/src/main/js/cache.js
+++ b/modules/nodejs/src/main/js/cache.js
@@ -266,10 +266,10 @@ Cache.prototype.size = function(callback) {
  * Execute sql query
  *
  * @param {SqlQuery|SqlFieldsQuery} qry Query
- * @returns {Cursor} Cursor for current query.
+ * @returns {QueryCursor} Cursor for current query.
  */
 Cache.prototype.query = function(qry) {
-    return new Cursor(this, qry, true, null);
+    return new QueryCursor(this, qry, true, null);
 }
 
 Cache.prototype.__createPromise = function(cmd) {
@@ -294,16 +294,16 @@ Cache.prototype._createCommand = function(name) {
 }
 
 /**
- * Creates an instance of Cursor
+ * Creates an instance of QueryCursor
  *
  * @constructor
- * @this {Cursor}
+ * @this {QueryCursor}
  * @param {Cache} cache Cache that runs query
  * @param {SqlQuery|SqlFieldsQuery} qry Sql query
  * @param {boolean} init True if query is not started
  * @param {Object[]} res Current page result
  */
-Cursor = function(cache, qry, init, res) {
+QueryCursor = function(cache, qry, init, res) {
     this._qry = qry;
     this._cache = cache;
     this._init = first;
@@ -318,10 +318,10 @@ Cursor = function(cache, qry, init, res) {
  * Since all the results will be fetched, all the resources will be closed
  * automatically after this call, e.g. there is no need to call close() method in this case.
  *
- * @this{Cursor}
+ * @this{QueryCursor}
  * @returns {Promise} Promise with query result
  */
-Cursor.prototype.getAll = function() {
+QueryCursor.prototype.getAll = function() {
     if (!this._init) {
         return new Promise(function(resolve, reject){
             reject("GetAll is called after nextPage.");
@@ -360,10 +360,10 @@ Cursor.prototype.getAll = function() {
 /**
  * Gets Promise with Cursor on next page of the query results.
  *
- * @this{Cursor}
+ * @this{QueryCursor}
  * @returns {Promise} Promise with Cursor on next page
  */
-Cursor.prototype.nextPage = function() {
+QueryCursor.prototype.nextPage = function() {
     if (this._res !== null && this._res["last"]) {
         throw "All pages are returned.";
     }
@@ -389,10 +389,10 @@ Cursor.prototype.nextPage = function() {
 /**
  * Gets collections of the query page results.
  *
- * @this{Cursor}
+ * @this{QueryCursor}
  * @returns {Object[]} Query page result.
  */
-Cursor.prototype.page = function() {
+QueryCursor.prototype.page = function() {
     if (this._res === null)
         return null;
 
@@ -402,10 +402,10 @@ Cursor.prototype.page = function() {
 /**
  * Closes all resources related to this cursor.
  *
- * @this{Cursor}
+ * @this{QueryCursor}
  * @returns {Promise} Promise on cursor close.
  */
-Cursor.prototype.close = function() {
+QueryCursor.prototype.close = function() {
     if (this._init) {
         return new Promise(function(resolve, reject) {
             return resolve(true);
@@ -430,17 +430,17 @@ Cursor.prototype.close = function() {
 /**
  * Returns True if the iteration has no more elements.
  *
- * @this{Cursor}
+ * @this{QueryCursor}
  * @returns {boolean} True if it is the last page
  */
-Cursor.prototype.isFinished = function() {
+QueryCursor.prototype.isFinished = function() {
     if (this._res === null)
         return false;
 
     return this._res["last"];
 }
 
-Cursor.prototype._getQueryCommand = function() {
+QueryCursor.prototype._getQueryCommand = function() {
     if (this._init) {
         if (this._qry.type() === "Sql") {
             return this._sqlQuery(this._qry);
@@ -455,17 +455,17 @@ Cursor.prototype._getQueryCommand = function() {
         addParam("psz", this._qry.pageSize());
 }
 
-Cursor.prototype._sqlFieldsQuery = function(qry) {
+QueryCursor.prototype._sqlFieldsQuery = function(qry) {
     return this._createQueryCommand("qryfieldsexecute", qry).
         setPostData(JSON.stringify({"arg" : qry.arguments()}));
 }
 
-Cursor.prototype._sqlQuery = function(qry) {
+QueryCursor.prototype._sqlQuery = function(qry) {
     return this._createQueryCommand("qryexecute", qry).addParam("type", qry.returnType()).
         setPostData(JSON.stringify({"arg" : qry.arguments()}));
 }
 
-Cursor.prototype._createQueryCommand = function(name, qry) {
+QueryCursor.prototype._createQueryCommand = function(name, qry) {
     return new Command(name).addParam("cacheName", this._cache._cacheName).
         addParam("qry", qry.query()).addParam("psz", qry.pageSize());
 }