U Lk7g&@sddlZddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z m Z ddlmZd ZGd d d ejZeZd d ZddZddZGdddZGdddZejddZGdddZGdddZeddZeddZdS) N)contextmanager) ReadConcern) WriteConcern)_no_dereference_for_fields) _import_class)DEFAULT_CONNECTION_NAMEget_db)count_documents) switch_dbswitch_collectionno_dereferenceno_sub_classes query_counterset_write_concernset_read_write_concern!no_dereferencing_active_for_classc@seZdZddZdS)MyThreadLocalscCs i|_dSN)no_dereferencing_classselfr@/tmp/pip-unpacked-wheel-n1etwkgt/mongoengine/context_managers.py__init__szMyThreadLocals.__init__N)__name__ __module__ __qualname__rrrrrrsrcCs |tjkSr) thread_localsrclsrrrr"srcCs$tj|dtj|d7<dS)Nr)rr setdefaultrrrr$_register_no_dereferencing_for_class&sr"cCs0tj|d8<tj|dkr,tj|dS)Nr r)rrpoprrrr&_unregister_no_dereferencing_for_class+sr$c@s(eZdZdZddZddZddZdS) r aswitch_db alias context manager. Example :: # Register connections register_connection('default', 'mongoenginetest') register_connection('testdb-1', 'mongoenginetest2') class Group(Document): name = StringField() Group(name='test').save() # Saves in the default db with switch_db(Group, 'testdb-1') as Group: Group(name='hello testdb!').save() # Saves in testdb-1 cCs*||_||_||_|jdt|_dS)zConstruct the switch_db context manager :param cls: the class to change the registered db :param db_alias: the name of the specific database to use db_aliasN)r_get_collection collectionr%_metagetr ori_db_alias)rrr%rrrrCs zswitch_db.__init__cCs|j|jjd<d|j_|jS)z4Change the db_alias and clear the cached collection.r%N)r%rr( _collectionrrrr __enter__Nszswitch_db.__enter__cCs|j|jjd<|j|j_dS)z"Reset the db_alias and collection.r%N)r*rr(r'r+rtvalue tracebackrrr__exit__Tszswitch_db.__exit__Nrrr__doc__rr,r1rrrrr 1s r c@s(eZdZdZddZddZddZdS) r aDswitch_collection alias context manager. Example :: class Group(Document): name = StringField() Group(name='test').save() # Saves in the default db with switch_collection(Group, 'group1') as Group: Group(name='hello testdb!').save() # Saves in group1 collection cCs"||_||_|j|_||_dS)zConstruct the switch_collection context manager. :param cls: the class to change the registered db :param collection_name: the name of the collection to use N)rr&ori_collection_get_collection_nameori_get_collection_namecollection_name)rrr7rrrrhs zswitch_collection.__init__cs&tfdd}|j_dj_jS)z@Change the _get_collection_name and clear the cached collection.csjSr)r7rrrrr5vsz9switch_collection.__enter__.._get_collection_nameN) classmethodrr5r+)rr5rrrr,ss zswitch_collection.__enter__cCs|j|j_|j|j_dS)zReset the collection.N)r4rr+r6r5r-rrrr1~s zswitch_collection.__exit__Nr2rrrrr Zs   r c #snz^|}tdtdtdfdd|jD}t|t| dVW5QRXW5t|XdS)zno_dereference context manager. Turns off all dereferencing in Documents for the duration of the context manager:: with no_dereference(Group): Group.objects() ReferenceFieldGenericReferenceFieldComplexBaseFieldcs$g|]\}}t|fr|qSr) isinstance).0namefieldr;r:r9rr s z"no_dereference..N)r$r_fieldsitemsr"r)rZ deref_fieldsrr@rr s  r c@s(eZdZdZddZddZddZdS) r zno_sub_classes context manager. Only returns instances of this class and no sub (inherited) classes:: with no_sub_classes(Group) as Group: Group.objects.find() cCs||_d|_dS)ztConstruct the no_sub_classes context manager. :param cls: the class to turn querying subclasses on N)rcls_initial_subclasses)rrrrrrszno_sub_classes.__init__cCs|jj|_|jjf|j_|jS)z8Change the objects default and _auto_dereference values.)r _subclassesrDZ _class_namerrrrr,s zno_sub_classes.__enter__cCs|j|j_dS)z/Reset the default and _auto_dereference values.N)rDrrEr-rrrr1szno_sub_classes.__exit__Nr2rrrrr sr c@seZdZdZefddZddZddZdd Zd d Z d d Z ddZ ddZ ddZ ddZddZddZddZddZdS)raQuery_counter context manager to get the number of queries. This works by updating the `profiling_level` of the database so that all queries get logged, resetting the db.system.profile collection at the beginning of the context and counting the new entries. This was designed for debugging purpose. In fact it is a global counter so queries issued by other threads/processes can interfere with it Usage: .. code-block:: python class User(Document): name = StringField() with query_counter() as q: user = User(name='Bob') assert q == 0 # no query fired yet user.save() assert q == 1 # 1 query was fired, an 'insert' user_bis = User.objects().first() assert q == 2 # a 2nd query was fired, a 'find_one' Be aware that: - Iterating over large amount of documents (>101) makes pymongo issue `getmore` queries to fetch the next batch of documents (https://www.mongodb.com/docs/manual/tutorial/iterate-a-cursor/#cursor-batches) - Some queries are ignored by default by the counter (killcursors, db.system.indexes) cCs>t|d|_d|_d|_dd|jjiddiddid|_dS) N)aliasrz$nez%s.system.indexesZ killcursorsz$existsF)nsopzcommand.killCursors)rdbinitial_profiling_level_ctx_query_counterr>_ignored_query)rrFrrrrs zquery_counter.__init__cCs<|jddi}|d|_|jjj|jddidS)Nprofilerwas)rIcommandrJsystemrMZdrop)rZprofile_update_resrrr_turn_on_profilings z query_counter._turn_on_profilingcCs|jd|jidS)NrM)rIrPrJrrrr_resets_profilingszquery_counter._resets_profilingcCs ||Sr)rRrrrrr,szquery_counter.__enter__cCs |dSr)rSr-rrrr1szquery_counter.__exit__cCs|}||kSr _get_count)rr/counterrrr__eq__szquery_counter.__eq__cCs || Sr)rWrr/rrr__ne__szquery_counter.__ne__cCs ||kSrrTrXrrr__lt__szquery_counter.__lt__cCs ||kSrrTrXrrr__le__szquery_counter.__le__cCs ||kSrrTrXrrr__gt__szquery_counter.__gt__cCs ||kSrrTrXrrr__ge__ szquery_counter.__ge__cCs|SrrTrrrr__int__ szquery_counter.__int__cCs d|S)z,repr query_counter as the number of queries.z%srTrrrr__repr__szquery_counter.__repr__cCs*t|jjj|j|j}|jd7_|S)zGet the number of queries by counting the current number of entries in db.system.profile and substracting the queries issued by this context. In fact everytime this is called, 1 query is issued so we need to balance that r )r rIrQrMrLrK)rcountrrrrUszquery_counter._get_countN)rrrr3rrrRrSr,r1rWrYrZr[r\r]r^r_rUrrrrrs rccs2t|jj}|||jtf|dVdS)N) write_concern)dictradocumentrCupdate with_optionsr)r'write_concernsZcombined_concernsrrrr#s rccsdt|jj}|dk r"||t|jj}|dk rD|||jtf|tf|dVdS)N)ra read_concern) rbrarcrCrdrgrerr)r'rfZ read_concernsZcombined_write_concernsZcombined_read_concernsrrrr*s  r) contextlib threadingrZpymongo.read_concernrZpymongo.write_concernrZmongoengine.base.fieldsrZmongoengine.commonrZmongoengine.connectionrrZmongoengine.pymongo_supportr __all__localrrrr"r$r r r r rrrrrrrs0       )* b