// matcher.h /* JSMatcher is our boolean expression evaluator for "where" clauses */ /** * Copyright (C) 2008 10gen Inc. * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License, version 3, * as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ #pragma once #include "jsobj.h" #include namespace mongo { class CoveredIndexMatcher; class RegexMatcher { public: const char *fieldName; pcrecpp::RE *re; RegexMatcher() { re = 0; } ~RegexMatcher() { delete re; } }; struct element_lt { bool operator()(const BSONElement& l, const BSONElement& r) const { int x = (int) l.canonicalType() - (int) r.canonicalType(); if ( x < 0 ) return true; else if ( x > 0 ) return false; return compareElementValues(l,r) < 0; } }; class BasicMatcher { public: BasicMatcher(){ } BasicMatcher( BSONElement _e , int _op ) : toMatch( _e ) , compareOp( _op ){ if ( _op == BSONObj::opMOD ){ BSONObj o = _e.embeddedObject().firstElement().embeddedObject(); mod = o["0"].numberInt(); modm = o["1"].numberInt(); uassert( 10073 , "mod can't be 0" , mod ); } else if ( _op == BSONObj::opTYPE ){ type = (BSONType)(_e.embeddedObject().firstElement().numberInt()); } } BasicMatcher( BSONElement _e , int _op , const BSONObj& array ) : toMatch( _e ) , compareOp( _op ){ myset.reset( new set() ); BSONObjIterator i( array ); while ( i.more() ) { BSONElement ie = i.next(); myset->insert(ie); } } BSONElement toMatch; int compareOp; shared_ptr< set > myset; // these are for specific operators int mod; int modm; BSONType type; }; // SQL where clause equivalent class Where; class DiskLoc; /* Match BSON objects against a query pattern. e.g. db.foo.find( { a : 3 } ); { a : 3 } is the pattern object. See wiki documentation for full info. GT/LT: { a : { $gt : 3 } } Not equal: { a : { $ne : 3 } } TODO: we should rewrite the matcher to be more an AST style. */ class JSMatcher : boost::noncopyable { int matchesDotted( const char *fieldName, const BSONElement& toMatch, const BSONObj& obj, int compareOp, const BasicMatcher& bm, bool isArr = false); int matchesNe( const char *fieldName, const BSONElement &toMatch, const BSONObj &obj, const BasicMatcher&bm); public: static int opDirection(int op) { return op <= BSONObj::LTE ? -1 : 1; } // Only specify constrainIndexKey if matches() will be called with // index keys having empty string field names. JSMatcher(const BSONObj &pattern, const BSONObj &constrainIndexKey = BSONObj()); ~JSMatcher(); bool matches(const BSONObj& j); bool keyMatch() const { return !all && !haveSize && !hasArray; } bool atomic() const { return _atomic; } private: void addBasic(const BSONElement &e, int c) { // TODO May want to selectively ignore these element types based on op type. if ( e.type() == MinKey || e.type() == MaxKey ) return; basics.push_back( BasicMatcher( e , c ) ); } int valuesMatch(const BSONElement& l, const BSONElement& r, int op, const BasicMatcher& bm); Where *where; // set if query uses $where BSONObj jsobj; // the query pattern. e.g., { name: "joe" } BSONObj constrainIndexKey_; vector basics; // int n; // # of basicmatcher items bool haveSize; bool all; bool hasArray; /* $atomic - if true, a multi document operation (some removes, updates) should be done atomically. in that case, we do not yield - i.e. we stay locked the whole time. */ bool _atomic; RegexMatcher regexs[4]; int nRegex; // so we delete the mem when we're done: vector< shared_ptr< BSONObjBuilder > > _builders; friend class CoveredIndexMatcher; }; // If match succeeds on index key, then attempt to match full document. class CoveredIndexMatcher : boost::noncopyable { public: CoveredIndexMatcher(const BSONObj &pattern, const BSONObj &indexKeyPattern); bool matches(const BSONObj &o){ return _docMatcher.matches( o ); } bool matches(const BSONObj &key, const DiskLoc &recLoc); bool needRecord(){ return _needRecord; } JSMatcher& docMatcher() { return _docMatcher; } private: JSMatcher _keyMatcher; JSMatcher _docMatcher; bool _needRecord; }; } // namespace mongo