|
|
@@ -12,26 +12,22 @@
|
|
|
* @namespace mungedb-aggregate.pipeline.expressions
|
|
|
* @module mungedb-aggregate
|
|
|
* @constructor
|
|
|
- **/
|
|
|
-
|
|
|
-
|
|
|
+ */
|
|
|
var Expression = module.exports = function Expression() {
|
|
|
if (arguments.length !== 0) throw new Error("zero args expected");
|
|
|
-}, klass = Expression,
|
|
|
- base = Object,
|
|
|
- proto = klass.prototype = Object.create(base.prototype, {
|
|
|
- constructor: {
|
|
|
- value: klass
|
|
|
- }
|
|
|
- });
|
|
|
+}, klass = Expression, base = Object, proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});
|
|
|
+
|
|
|
+
|
|
|
+var Value = require("../Value"),
|
|
|
+ Document = require("../Document"),
|
|
|
+ Variables = require("./Variables");
|
|
|
|
|
|
|
|
|
-// NESTED CLASSES
|
|
|
/**
|
|
|
* Reference to the `mungedb-aggregate.pipeline.expressions.Expression.ObjectCtx` class
|
|
|
* @static
|
|
|
* @property ObjectCtx
|
|
|
- **/
|
|
|
+ */
|
|
|
var ObjectCtx = Expression.ObjectCtx = (function() {
|
|
|
// CONSTRUCTOR
|
|
|
/**
|
|
|
@@ -47,9 +43,9 @@ var ObjectCtx = Expression.ObjectCtx = (function() {
|
|
|
* @param [opts.isDocumentOk] {Boolean}
|
|
|
* @param [opts.isTopLevel] {Boolean}
|
|
|
* @param [opts.isInclusionOk] {Boolean}
|
|
|
- **/
|
|
|
+ */
|
|
|
var klass = function ObjectCtx(opts /*= {isDocumentOk:..., isTopLevel:..., isInclusionOk:...}*/ ) {
|
|
|
- if (!(opts instanceof Object && opts.constructor == Object)) throw new Error("opts is required and must be an Object containing named args");
|
|
|
+ if (!(opts instanceof Object && opts.constructor === Object)) throw new Error("opts is required and must be an Object containing named args");
|
|
|
for (var k in opts) { // assign all given opts to self so long as they were part of klass.prototype as undefined properties
|
|
|
if (opts.hasOwnProperty(k) && proto.hasOwnProperty(k) && proto[k] === undefined) this[k] = opts[k];
|
|
|
}
|
|
|
@@ -69,37 +65,32 @@ var ObjectCtx = Expression.ObjectCtx = (function() {
|
|
|
})();
|
|
|
|
|
|
|
|
|
-/**
|
|
|
- * Produce a field path string with the field prefix removed.
|
|
|
- * Throws an error if the field prefix is not present.
|
|
|
- *
|
|
|
- * @static
|
|
|
- * @param prefixedField the prefixed field
|
|
|
- * @returns the field path with the prefix removed
|
|
|
- **/
|
|
|
-klass.removeFieldPrefix = function removeFieldPrefix(prefixedField) {
|
|
|
- if (prefixedField.indexOf("\0") != -1) throw new Error("field path must not contain embedded null characters; uassert code 16419");
|
|
|
- if (prefixedField[0] !== "$") throw new Error("field path references must be prefixed with a '$' ('" + prefixedField + "'); uassert code 15982");
|
|
|
- return prefixedField.substr(1);
|
|
|
-};
|
|
|
+//
|
|
|
+// Diagram of relationship between parse functions when parsing a $op:
|
|
|
+//
|
|
|
+// { someFieldOrArrayIndex: { $op: [ARGS] } }
|
|
|
+// ^ parseExpression on inner $op BSONElement
|
|
|
+// ^ parseObject on BSONObject
|
|
|
+// ^ parseOperand on outer BSONElement wrapping the $op Object
|
|
|
+//
|
|
|
|
|
|
/**
|
|
|
- * Parse an Object. The object could represent a functional expression or a Document expression.
|
|
|
- *
|
|
|
- * An object expression can take any of the following forms:
|
|
|
- *
|
|
|
- * f0: {f1: ..., f2: ..., f3: ...}
|
|
|
- * f0: {$operator:[operand1, operand2, ...]}
|
|
|
- *
|
|
|
- * @static
|
|
|
+ * Parses a JSON Object that could represent a functional expression or a Document expression.
|
|
|
* @method parseObject
|
|
|
+ * @static
|
|
|
* @param obj the element representing the object
|
|
|
* @param ctx a MiniCtx representing the options above
|
|
|
* @param vps Variables Parse State
|
|
|
* @returns the parsed Expression
|
|
|
- **/
|
|
|
+ */
|
|
|
klass.parseObject = function parseObject(obj, ctx, vps) {
|
|
|
if (!(ctx instanceof ObjectCtx)) throw new Error("ctx must be ObjectCtx");
|
|
|
+ /*
|
|
|
+ An object expression can take any of the following forms:
|
|
|
+
|
|
|
+ f0: {f1: ..., f2: ..., f3: ...}
|
|
|
+ f0: {$operator:[operand1, operand2, ...]}
|
|
|
+ */
|
|
|
|
|
|
var expression, // the result
|
|
|
expressionObject, // the alt result
|
|
|
@@ -120,24 +111,27 @@ klass.parseObject = function parseObject(obj, ctx, vps) {
|
|
|
if (ctx.isTopLevel)
|
|
|
throw new Error("$expressions are not allowed at the top-level of $project; uassert code 16404");
|
|
|
|
|
|
- kind = OPERATOR; //we've determined this "object" is an operator expression
|
|
|
+ // we've determined this "object" is an operator expression
|
|
|
+ kind = OPERATOR;
|
|
|
|
|
|
expression = Expression.parseExpression(fieldName, obj[fieldName], vps); //NOTE: DEVIATION FROM MONGO: c++ code uses 2 arguments. See #parseExpression
|
|
|
} else {
|
|
|
if (kind === OPERATOR)
|
|
|
throw new Error("this object is already an operator expression, and can't be used as a document expression (at '" + fieldName + "'.; uassert code 15990");
|
|
|
|
|
|
- if (!ctx.isTopLevel && fieldName.indexOf(".") != -1)
|
|
|
+ if (!ctx.isTopLevel && fieldName.indexOf(".") !== -1)
|
|
|
throw new Error("dotted field names are only allowed at the top level; uassert code 16405");
|
|
|
|
|
|
- if (expression === undefined) { // if it's our first time, create the document expression
|
|
|
- if (!ctx.isDocumentOk)
|
|
|
- throw new Error("Assertion failure"); // CW TODO error: document not allowed in this context
|
|
|
+ // if it's our first time, create the document expression
|
|
|
+ if (expression === undefined) {
|
|
|
+ if (!ctx.isDocumentOk) throw new Error("Assertion failure");
|
|
|
+ // CW TODO error: document not allowed in this context
|
|
|
|
|
|
- expressionObject = new ObjectExpression(); //check for top level? //NOTE: DEVIATION FROM MONGO: the c++ calls createRoot() or create() here.
|
|
|
+ expressionObject = ctx.isTopLevel ? ObjectExpression.createRoot() : ObjectExpression.create();
|
|
|
expression = expressionObject;
|
|
|
|
|
|
- kind = NOTOPERATOR; //this "object" is not an operator expression
|
|
|
+ // this "object" is not an operator expression
|
|
|
+ kind = NOTOPERATOR;
|
|
|
}
|
|
|
|
|
|
var fieldValue = obj[fieldName];
|
|
|
@@ -153,8 +147,9 @@ klass.parseObject = function parseObject(obj, ctx, vps) {
|
|
|
|
|
|
break;
|
|
|
case "string":
|
|
|
- // it's a renamed field // CW TODO could also be a constant
|
|
|
- expressionObject.addField(fieldName, new FieldPathExpression.parse(fieldValue, vps));
|
|
|
+ // it's a renamed field
|
|
|
+ // CW TODO could also be a constant
|
|
|
+ expressionObject.addField(fieldName, FieldPathExpression.parse(fieldValue, vps));
|
|
|
break;
|
|
|
case "boolean":
|
|
|
case "number":
|
|
|
@@ -170,7 +165,7 @@ klass.parseObject = function parseObject(obj, ctx, vps) {
|
|
|
}
|
|
|
break;
|
|
|
default:
|
|
|
- throw new Error("disallowed field type " + (fieldValue instanceof Object ? fieldValue.constructor.name + ":" : typeof fieldValue) + typeof(fieldValue) + " in object expression (at '" + fieldName + "') uassert code 15992");
|
|
|
+ throw new Error("disallowed field type " + Value.getType(fieldValue) + " in object expression (at '" + fieldName + "') uassert code 15992");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -181,10 +176,11 @@ klass.parseObject = function parseObject(obj, ctx, vps) {
|
|
|
|
|
|
klass.expressionParserMap = {};
|
|
|
|
|
|
-/** Registers an ExpressionParser so it can be called from parseExpression and friends.
|
|
|
- *
|
|
|
- * As an example, if your expression looks like {"$foo": [1,2,3]} you would add this line:
|
|
|
- * REGISTER_EXPRESSION("$foo", ExpressionFoo::parse);
|
|
|
+
|
|
|
+/**
|
|
|
+ * Registers an ExpressionParser so it can be called from parseExpression and friends.
|
|
|
+ * As an example, if your expression looks like {"$foo": [1,2,3]} you would add this line:
|
|
|
+ * REGISTER_EXPRESSION("$foo", ExpressionFoo::parse);
|
|
|
*/
|
|
|
klass.registerExpression = function registerExpression(key, parserFunc) {
|
|
|
if (key in klass.expressionParserMap) {
|
|
|
@@ -194,6 +190,8 @@ klass.registerExpression = function registerExpression(key, parserFunc) {
|
|
|
return 1;
|
|
|
};
|
|
|
|
|
|
+
|
|
|
+//NOTE: DEVIATION FROM MONGO: the c++ version has 2 arguments, not 3. //TODO: could easily fix this inconsistency
|
|
|
/**
|
|
|
* Parses a BSONElement which has already been determined to be functional expression.
|
|
|
* @static
|
|
|
@@ -202,15 +200,17 @@ klass.registerExpression = function registerExpression(key, parserFunc) {
|
|
|
* That is the field name should be the $op for the expression.
|
|
|
* @param vps the variable parse state
|
|
|
* @returns the parsed Expression
|
|
|
- **/
|
|
|
-//NOTE: DEVIATION FROM MONGO: the c++ version has 2 arguments, not 3. //TODO: could easily fix this inconsistency
|
|
|
+ */
|
|
|
klass.parseExpression = function parseExpression(exprElementKey, exprElementValue, vps) {
|
|
|
- if (!(exprElementKey in Expression.expressionParserMap)) {
|
|
|
- throw new Error("Invalid operator : " + exprElementKey + "; code 15999");
|
|
|
- }
|
|
|
- return Expression.expressionParserMap[exprElementKey](exprElementValue, vps);
|
|
|
+ var opName = exprElementKey,
|
|
|
+ op = Expression.expressionParserMap[opName];
|
|
|
+ if (!op) throw new Error("invalid operator : " + exprElementKey + "; uassert code 15999");
|
|
|
+
|
|
|
+ // make the expression node
|
|
|
+ return op(exprElementValue, vps);
|
|
|
};
|
|
|
|
|
|
+
|
|
|
/**
|
|
|
* Parses a BSONElement which is an operand in an Expression.
|
|
|
*
|
|
|
@@ -224,89 +224,113 @@ klass.parseExpression = function parseExpression(exprElementKey, exprElementValu
|
|
|
* That is the field name should be the $op for the expression.
|
|
|
* @param vps the variable parse state
|
|
|
* @returns the parsed operand, as an Expression
|
|
|
- **/
|
|
|
+ */
|
|
|
klass.parseOperand = function parseOperand(exprElement, vps) {
|
|
|
var t = typeof(exprElement);
|
|
|
- if (t === "string" && exprElement[0] == "$") { //if we got here, this is a field path expression
|
|
|
- return new FieldPathExpression.parse(exprElement, vps);
|
|
|
+ if (t === "string" && exprElement[0] === "$") {
|
|
|
+ //if we got here, this is a field path expression
|
|
|
+ return FieldPathExpression.parse(exprElement, vps);
|
|
|
} else if (t === "object" && exprElement && exprElement.constructor === Object) {
|
|
|
- return Expression.parseObject(exprElement, new ObjectCtx({
|
|
|
+ var oCtx = new ObjectCtx({
|
|
|
isDocumentOk: true
|
|
|
- }), vps);
|
|
|
+ });
|
|
|
+ return Expression.parseObject(exprElement, oCtx, vps);
|
|
|
} else {
|
|
|
return ConstantExpression.parse(exprElement, vps);
|
|
|
}
|
|
|
};
|
|
|
|
|
|
-// PROTOTYPE MEMBERS
|
|
|
-/**
|
|
|
- * Evaluate the Expression using the given document as input.
|
|
|
- *
|
|
|
- * @method evaluate
|
|
|
- * @returns the computed value
|
|
|
- **/
|
|
|
-proto.evaluateInternal = function evaluateInternal(obj) {
|
|
|
- throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!");
|
|
|
-};
|
|
|
-
|
|
|
-
|
|
|
-/**
|
|
|
- * Evaluate expression with specified inputs and return result.
|
|
|
- *
|
|
|
- * While vars is non-const, if properly constructed, subexpressions modifications to it
|
|
|
- * should not effect outer expressions due to unique variable Ids.
|
|
|
- */
|
|
|
-proto.evaluate = function(vars) {
|
|
|
- return this.evaluateInternal(vars);
|
|
|
-};
|
|
|
-
|
|
|
|
|
|
/**
|
|
|
* Optimize the Expression.
|
|
|
*
|
|
|
* This provides an opportunity to do constant folding, or to collapse nested
|
|
|
- * operators that have the same precedence, such as $add, $and, or $or.
|
|
|
+ * operators that have the same precedence, such as $add, $and, or $or.
|
|
|
*
|
|
|
* The Expression should be replaced with the return value, which may or may
|
|
|
- * not be the same object. In the case of constant folding, a computed
|
|
|
- * expression may be replaced by a constant.
|
|
|
+ * not be the same object. In the case of constant folding, a computed
|
|
|
+ * expression may be replaced by a constant.
|
|
|
*
|
|
|
* @method optimize
|
|
|
* @returns the optimized Expression
|
|
|
- **/
|
|
|
+ */
|
|
|
proto.optimize = function optimize() {
|
|
|
- throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!");
|
|
|
+ return this;
|
|
|
};
|
|
|
|
|
|
+
|
|
|
/**
|
|
|
- * Add this expression's field dependencies to the set Expressions are trees, so this is often recursive.
|
|
|
- *
|
|
|
- * Top-level ExpressionObject gets pointer to empty vector.
|
|
|
- * If any other Expression is an ancestor, or in other cases where {a:1} inclusion objects aren't allowed, they get NULL.
|
|
|
+ * Add this expression's field dependencies to the set.
|
|
|
+ * Expressions are trees, so this is often recursive.
|
|
|
*
|
|
|
* @method addDependencies
|
|
|
- * @param deps output parameter
|
|
|
- * @param path path to self if all ancestors are ExpressionObjects.
|
|
|
- **/
|
|
|
+ * @param deps Fully qualified paths to depended-on fields are added to this set.
|
|
|
+ * Empty string means need full document.
|
|
|
+ * @param path path to self if all ancestors are ExpressionObjects.
|
|
|
+ * Top-level ExpressionObject gets pointer to empty vector.
|
|
|
+ * If any other Expression is an ancestor, or in other cases
|
|
|
+ * where {a:1} inclusion objects aren't allowed, they get
|
|
|
+ * NULL.
|
|
|
+ */
|
|
|
proto.addDependencies = function addDependencies(deps, path) {
|
|
|
throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!");
|
|
|
};
|
|
|
|
|
|
+
|
|
|
/**
|
|
|
* simple expressions are just inclusion exclusion as supported by ExpressionObject
|
|
|
- * @method getIsSimple
|
|
|
- **/
|
|
|
-proto.getIsSimple = function getIsSimple() {
|
|
|
+ * @method isSimple
|
|
|
+ */
|
|
|
+proto.isSimple = function isSimple() {
|
|
|
return false;
|
|
|
};
|
|
|
|
|
|
-proto.toMatcherBson = function toMatcherBson() {
|
|
|
- throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!"); //verify(false && "Expression::toMatcherBson()");
|
|
|
+/**
|
|
|
+ * Serialize the Expression tree recursively.
|
|
|
+ * If explain is false, returns a Value parsable by parseOperand().
|
|
|
+ * @method serialize
|
|
|
+ */
|
|
|
+proto.serialize = function serialize(explain) {
|
|
|
+ throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!");
|
|
|
};
|
|
|
|
|
|
+/**
|
|
|
+ * Evaluate expression with specified inputs and return result.
|
|
|
+ *
|
|
|
+ * While vars is non-const, if properly constructed, subexpressions modifications to it
|
|
|
+ * should not effect outer expressions due to unique variable Ids.
|
|
|
+ *
|
|
|
+ * @method evaluate
|
|
|
+ * @param vars
|
|
|
+ */
|
|
|
+proto.evaluate = function evaluate(vars) {
|
|
|
+ if (!(vars instanceof Variables)) vars = new Variables(0, vars); /// Evaluate expression with specified inputs and return result. (only used by tests)
|
|
|
+ return this.evaluateInternal(vars);
|
|
|
+};
|
|
|
+
|
|
|
+/**
|
|
|
+ * Produce a field path string with the field prefix removed.
|
|
|
+ * Throws an error if the field prefix is not present.
|
|
|
+ * @method removeFieldPrefix
|
|
|
+ * @static
|
|
|
+ * @param prefixedField the prefixed field
|
|
|
+ * @returns the field path with the prefix removed
|
|
|
+ */
|
|
|
+klass.removeFieldPrefix = function removeFieldPrefix(prefixedField) {
|
|
|
+ if (prefixedField.indexOf("\0") !== -1) throw new Error("field path must not contain embedded null characters; uassert code 16419");
|
|
|
+ if (prefixedField[0] !== "$") throw new Error("field path references must be prefixed with a '$' ('" + prefixedField + "'); uassert code 15982");
|
|
|
+ return prefixedField.substr(1);
|
|
|
+};
|
|
|
+
|
|
|
+/**
|
|
|
+ * Evaluate the subclass Expression using the given Variables as context and return result.
|
|
|
+ * @method evaluate
|
|
|
+ * @returns the computed value
|
|
|
+ */
|
|
|
+proto.evaluateInternal = function evaluateInternal(vars) {
|
|
|
+ throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!");
|
|
|
+};
|
|
|
|
|
|
-// DEPENDENCIES
|
|
|
-var Document = require("../Document");
|
|
|
-var ObjectExpression = require("./ObjectExpression");
|
|
|
-var FieldPathExpression = require("./FieldPathExpression");
|
|
|
-var ConstantExpression = require("./ConstantExpression");
|
|
|
+var ObjectExpression = require("./ObjectExpression"),
|
|
|
+ FieldPathExpression = require("./FieldPathExpression"),
|
|
|
+ ConstantExpression = require("./ConstantExpression");
|