@@ -413,36 +413,6 @@ def test_counters_should_be_cached_on_all_docs_collection(self):
413413 counter_value = session .counters_for ("orders/1-A" ).get ("downloads" )
414414 self .assertEqual (500 , counter_value )
415415
416- def test_counters_should_be_cached_on_collection (self ):
417- with self .store .open_session () as session :
418- session .store (Order (company = "companies/1-A" ), "orders/1-A" )
419- session .counters_for ("orders/1-A" ).increment ("downloads" , 100 )
420- session .save_changes ()
421-
422- with self .store .open_session () as session :
423- list (session .query (object_type = Order ).include (lambda i : i .include_counters ("downloads" )))
424- counter_value = session .counters_for ("orders/1-A" ).get ("downloads" )
425- self .assertEqual (100 , counter_value )
426-
427- session .counters_for ("orders/1-A" ).increment ("downloads" , 200 )
428- session .save_changes ()
429-
430- list (session .query (object_type = Order ).include (lambda i : i .include_counters ("downloads" )))
431-
432- counter_value = session .counters_for ("orders/1-A" ).get ("downloads" )
433- self .assertEqual (300 , counter_value )
434-
435- session .counters_for ("orders/1-A" ).increment ("downloads" , 200 )
436- session .save_changes ()
437-
438- list (session .query (object_type = Order ).include (lambda i : i .include_counters ("downloads" )))
439-
440- counter_value = session .counters_for ("orders/1-A" ).get ("downloads" )
441- self .assertEqual (500 , counter_value )
442-
443- with self .store .open_session () as session :
444- session .load ("orders/1-A" , Order )
445-
446416 def test_counters_caching_should_handle_deletion__include_counters (self ):
447417 self ._counters_caching_should_handle_deletion (
448418 lambda session : list (
@@ -655,3 +625,35 @@ def test_raw_query_js_projection_with_counter_raw_values(self):
655625 self .assertEqual ("Pigpen" , query [2 ].name )
656626 self .assertEqual (500 , query [2 ].likes .values ().__iter__ ().__next__ ())
657627 self .assertIsNone (query [2 ].downloads )
628+
629+ def test_counters_should_be_cached_on_collection (self ):
630+ with self .store .open_session () as session :
631+ session .store (Order (company = "companies/1-A" ), "orders/1-A" )
632+ session .counters_for ("orders/1-A" ).increment ("downloads" , 100 )
633+ session .save_changes ()
634+
635+ with self .store .open_session () as session :
636+ list (session .query (object_type = Order ).include (lambda i : i .include_counter ("downloads" )))
637+ self .assertEqual (100 , session .counters_for ("orders/1-A" ).get ("downloads" ))
638+ session .counters_for ("orders/1-A" ).increment ("downloads" , 200 )
639+ session .save_changes ()
640+
641+ list (session .query (object_type = Order ).include (lambda i : i .include_counters (["downloads" ])))
642+ self .assertEqual (300 , session .counters_for ("orders/1-A" ).get ("downloads" ))
643+ session .counters_for ("orders/1-A" ).increment ("downloads" , 200 )
644+ session .save_changes ()
645+
646+ list (session .query (object_type = Order ).include (lambda i : i .include_counters (["downloads" ])))
647+ self .assertEqual (500 , session .counters_for ("orders/1-A" ).get ("downloads" ))
648+
649+ with self .store .open_session () as session :
650+ session .load ("orders/1-A" , Order , lambda i : i .include_counter ("downloads" ))
651+ counter_value = session .counters_for ("orders/1-A" ).get ("downloads" )
652+ self .assertEqual (500 , counter_value )
653+
654+ session .counters_for ("orders/1-A" ).increment ("downloads" , 200 )
655+ session .save_changes ()
656+
657+ session .load ("order/1-A" , Order , lambda i : i .include_counter ("downloads" ))
658+ counter_value = session .counters_for ("orders/1-A" ).get ("downloads" )
659+ self .assertEqual (700 , counter_value )
0 commit comments