Fix emf flow and add subquery unit test

Author: WaVEV

django_mongodb_backend/fields/embedded_model_array.py

@@ -3,13 +3,13 @@
 from django.core.exceptions import FieldDoesNotExist
 from django.db import models
 from django.db.models.expressions import Col
-from django.db.models.lookups import Transform
+from django.db.models.lookups import Lookup, Transform
 
 from ..forms import EmbeddedModelArrayFormField
 from ..query_utils import process_lhs, process_rhs
 from . import EmbeddedModelField
 from .array import ArrayField
-from .embedded_model import EMFExact
+from .embedded_model import EMFExact, EMFMixin
 
 
 class EmbeddedModelArrayField(ArrayField):
@@ -52,17 +52,8 @@ def get_transform(self, name):
         return KeyTransformFactory(name, self)
 
 
-class ProcessRHSMixin:
-    def process_rhs(self, compiler, connection):
-        if isinstance(self.lhs, KeyTransform):
-            get_db_prep_value = self.lhs._lhs.output_field.get_db_prep_value
-        else:
-            get_db_prep_value = self.lhs.output_field.get_db_prep_value
-        return None, [get_db_prep_value(v, connection, prepared=True) for v in self.rhs]
-
-
 @EmbeddedModelArrayField.register_lookup
-class EMFArrayExact(EMFExact, ProcessRHSMixin):
+class EMFArrayExact(EMFExact):
     def as_mql(self, compiler, connection):
         lhs_mql = process_lhs(self, compiler, connection)
         value = process_rhs(self, compiler, connection)
@@ -105,12 +96,29 @@ def as_mql(self, compiler, connection):
 
 
 @EmbeddedModelArrayField.register_lookup
-class ArrayOverlap(EMFExact, ProcessRHSMixin):
+class ArrayOverlap(EMFMixin, Lookup):
     lookup_name = "overlap"
+    get_db_prep_lookup_value_is_iterable = True
+
+    def process_rhs(self, compiler, connection):
+        values = self.rhs
+        if self.get_db_prep_lookup_value_is_iterable:
+            values = [values]
+        # Compute how to serialize each value based on the query target.
+        # If querying a subfield inside the array (i.e., a nested KeyTransform), use the output
+        # field of the subfield. Otherwise, use the base field of the array itself.
+        if isinstance(self.lhs, KeyTransform):
+            get_db_prep_value = self.lhs._lhs.output_field.get_db_prep_value
+        else:
+            get_db_prep_value = self.lhs.output_field.base_field.get_db_prep_value
+        return None, [get_db_prep_value(v, connection, prepared=True) for v in values]
 
     def as_mql(self, compiler, connection):
         lhs_mql = process_lhs(self, compiler, connection)
         values = process_rhs(self, compiler, connection)
+        # Querying a subfield within the array elements (via nested KeyTransform).
+        # Replicates MongoDB's implicit ANY-match by mapping over the array and applying
+        # `$in` on the subfield.
         if isinstance(self.lhs, KeyTransform):
             lhs_mql, inner_lhs_mql = lhs_mql
             return {
@@ -129,11 +137,12 @@ def as_mql(self, compiler, connection):
             }
         conditions = []
         inner_lhs_mql = "$$item"
+        # Querying full embedded documents in the array.
+        # Builds `$or` conditions and maps them over the array to match any full document.
         for value in values:
-            if isinstance(value, models.Model):
-                value, emf_data = self.model_to_dict(value)
-                # Get conditions for any nested EmbeddedModelFields.
-                conditions.append({"$and": self.get_conditions({inner_lhs_mql: (value, emf_data)})})
+            value, emf_data = self.model_to_dict(value)
+            # Get conditions for any nested EmbeddedModelFields.
+            conditions.append({"$and": self.get_conditions({inner_lhs_mql: (value, emf_data)})})
         return {
             "$anyElementTrue": {
                 "$ifNull": [

tests/model_fields_/test_embedded_model.py

@@ -300,36 +300,20 @@ def test_overlap_emf(self):
             [self.clouds],
         )
 
-    """
-    def test_overlap_charfield_including_expression(self):
-        obj_1 = CharArrayModel.objects.create(field=["TEXT", "lower text"])
-        obj_2 = CharArrayModel.objects.create(field=["lower text", "TEXT"])
-        CharArrayModel.objects.create(field=["lower text", "text"])
-        self.assertSequenceEqual(
-            CharArrayModel.objects.filter(
-                field__overlap=[
-                    Upper(Value("text")),
-                    "other",
-                ]
-            ),
-            [obj_1, obj_2],
-        )
-
     def test_overlap_values(self):
-        qs = NullableIntegerArrayModel.objects.filter(order__lt=3)
+        qs = Movie.objects.filter(title__in=["Clouds", "Frozen"])
         self.assertCountEqual(
-            NullableIntegerArrayModel.objects.filter(
-                field__overlap=qs.values_list("field"),
+            Movie.objects.filter(
+                reviews__overlap=qs.values_list("reviews"),
             ),
-            self.objs[:3],
+            [self.clouds, self.frozen],
         )
         self.assertCountEqual(
-            NullableIntegerArrayModel.objects.filter(
-                field__overlap=qs.values("field"),
+            Movie.objects.filter(
+                reviews__overlap=qs.values("reviews"),
             ),
-            self.objs[:3],
+            [self.clouds, self.frozen],
         )
-    """
 
 
 class QueryingTests(TestCase):