Merge pull request #101 from killme2008/feature/2015.05.27

Added AV.BigQuery namespace to support bigquery

Author: killme2008

bower.json

@@ -1,6 +1,6 @@
 {
   "name": "leancloud-jssdk.js",
-  "version": "0.5.4",
+  "version": "0.5.5",
   "homepage": "https://github.com/leancloud/javascript-sdk",
   "authors": [
     "killme2008 <[email protected]>"

changelog.md

@@ -1,3 +1,9 @@
+# 0.5.5 日期：2015 年 6 月 29 日
+* AV.Promise 启用兼容 Promise+ 模式。
+* 增加 AV.BigQuery 相关 API 用于发起离线分析和查询结果等。
+* 修正 AV.Query 的 get 方法在遇到 undefined objectId 运行结果不符合预期的 Bug
+* 修复 AV.File 无法作为数组保存的 Bug。
+
 # 0.5.4 日期：2015 年 5 月 14 日
 * 紧急修复 localStorage 模块大小写名称错误。
 

dist/av-core-mini.js

@@ -1623,6 +1623,7 @@
         route !== "cloudQuery" &&
         route !== "qiniu" &&
         route !== "statuses" &&
+        route !== "bigquery" &&
         route !== 'search/select' &&
         route !== 'subscribe/statuses/count' &&
         route !== 'subscribe/statuses' &&
@@ -3410,6 +3411,9 @@
    * </p>
    */
   AV.Relation = function(parent, key) {
+    if (! _.isString(key)) {
+      throw TypeError('key must be a string');
+    }
     this.parent = parent;
     this.key = key;
     this.targetClassName = null;
@@ -3548,7 +3552,7 @@
 
   _.extend(AV.Promise, /** @lends AV.Promise */ {
 
-    _isPromisesAPlusCompliant: false,
+    _isPromisesAPlusCompliant: true,
 
     /**
      * Returns true iff the given object fulfils the Promise interface.
@@ -4449,6 +4453,10 @@
 
   AV.File.prototype = {
 
+    toJSON: function() {
+      return AV._encode(this);
+    },
+
     /**
      * Returns the ACL for this file.
      * @returns {AV.ACL} An instance of AV.ACL.
@@ -7501,11 +7509,17 @@
      * @param {Object} options A Backbone-style options object.
      */
     get: function(objectId, options) {
+      if(!objectId) {
+        var errorObject = new AV.Error(AV.Error.OBJECT_NOT_FOUND,
+                                          "Object not found.");
+        return AV.Promise.error(errorObject);
+      }
+
       var self = this;
       self.equalTo('objectId', objectId);
 
       return self.first().then(function(response) {
-        if (response) {
+        if (!AV._.isEmpty(response)) {
           return response;
         }
 
@@ -9023,3 +9037,145 @@
     }
   });
 })(this);
+
+(function(root) {
+  root.AV = root.AV || {};
+  var AV = root.AV;
+  var _ = AV._;
+
+  /**
+   * @namespace 包含了使用了 LeanCloud
+   *  <a href='/docs/bigquery_guide.html'>离线数据分析功能</a>的函数。
+   * <p><strong><em>
+   *   部分函数仅在云引擎运行环境下有效。
+   * </em></strong></p>
+   */
+  AV.BigQuery = AV.BigQuery || {};
+
+  _.extend(AV.BigQuery, /** @lends AV.BigQuery */ {
+
+    /**
+     * 开始一个 BigQuery 任务。结果里将返回 Job id，你可以拿得到的 id 使用
+     * AV.BigQuery.JobQuery 查询任务状态和结果。
+     * @param {Object} jobConfig 任务配置的 JSON 对象，例如：<code><pre>
+     *                   { "sql" : "select count(*) as c,gender from _User group by gender",
+     *                     "saveAs": {
+     *                         "className" : "UserGender",
+     *                         "limit": 1
+     *                      }
+     *                   }
+     *                  </pre></code>
+     *               sql 指定任务执行的 SQL 语句， saveAs（可选） 指定将结果保存在哪张表里，limit 最大 1000。
+     * @param {Object} options A Backbone-style options object
+     * options.success, if set, should be a function to handle a successful
+     * call to a cloud function.  options.error should be a function that
+     * handles an error running the cloud function.  Both functions are
+     * optional.  Both functions take a single argument.
+     * @return {AV.Promise} A promise that will be resolved with the result
+     * of the function.
+     */
+    startJob: function(jobConfig, options) {
+      if(!jobConfig || !jobConfig.sql) {
+        throw new Error('Please provide the sql to run the job.');
+      }
+      var data = {
+        jobConfig: jobConfig,
+        appId: AV.applicationId
+      }
+      var request = AV._request("bigquery", 'jobs', null, 'POST',
+                                   AV._encode(data, null, true));
+
+      return request.then(function(resp) {
+        return AV._decode(null, resp).id;
+      })._thenRunCallbacks(options);
+    },
+
+    /**
+     * 监听 BigQuery 任务事件，目前仅支持 end 事件，表示任务完成。
+     *  <p><strong><em>
+     *     仅在云引擎运行环境下有效。
+     *  </em></strong></p>
+     * @param {String} event 监听的事件，目前仅支持 'end' ，表示任务完成
+     * @param {Function} 监听回调函数，接收 (err, id) 两个参数，err 表示错误信息，
+     *                   id 表示任务 id。接下来你可以拿这个 id 使用AV.BigQuery.JobQuery 查询任务状态和结果。
+     *
+     */
+    on: function(event, cb) {
+    }
+  });
+
+  /**
+   * 创建一个对象，用于查询 BigQuery 任务状态和结果。
+   * @class
+   * @param {String} id 任务 id
+   * @since 0.5.5
+   */
+  AV.BigQuery.JobQuery = function(id, className) {
+    if(!id) {
+      throw new Error('Please provide the job id.');
+    }
+    this.id = id;
+    this.className = className;
+    this._skip = 0;
+    this._limit = 100;
+  };
+
+  AV.BigQuery.JobQuery.prototype = {
+
+    /**
+     * Sets the number of results to skip before returning any results.
+     * This is useful for pagination.
+     * Default is to skip zero results.
+     * @param {Number} n the number of results to skip.
+     * @return {AV.Query} Returns the query, so you can chain this call.
+     */
+    skip: function(n) {
+      this._skip = n;
+      return this;
+    },
+
+    /**
+     * Sets the limit of the number of results to return. The default limit is
+     * 100, with a maximum of 1000 results being returned at a time.
+     * @param {Number} n the number of results to limit to.
+     * @return {AV.Query} Returns the query, so you can chain this call.
+     */
+    limit: function(n) {
+      this._limit = n;
+      return this;
+    },
+
+    /**
+     * 查询任务状态和结果，任务结果为一个 JSON 对象，包括 status 表示任务状态， totalCount 表示总数，
+     * results 数组表示任务结果数组，previewCount 表示可以返回的结果总数，任务的开始和截止时间
+     * startTime、endTime 等信息。
+     *
+     * @param {Object} options A Backbone-style options object
+     * options.success, if set, should be a function to handle a successful
+     * call to a cloud function.  options.error should be a function that
+     * handles an error running the cloud function.  Both functions are
+     * optional.  Both functions take a single argument.
+     * @return {AV.Promise} A promise that will be resolved with the result
+     * of the function.
+     *
+     */
+    find: function(options) {
+      var params = {
+        skip: this._skip,
+        limit: this._limit
+      };
+
+      var request = AV._request("bigquery", 'jobs', this.id, "GET",
+                                   params);
+      var self = this;
+      return request.then(function(response) {
+        if(response.error) {
+          return AV.Promise.error(new AV.Error(response.code, response.error));
+        }
+        return AV.Promise.as(response);
+      })._thenRunCallbacks(options);
+    }
+
+  };
+
+}(this));