fix textual filter bug and resolve conversation

endxxxx · endxxxx · commit 3b6578e821bc · 2025-12-01T10:23:31.000+08:00
diff --git a/src/memos/graph_dbs/polardb.py b/src/memos/graph_dbs/polardb.py
@@ -3654,11 +3654,11 @@ def build_filter_condition(condition_dict: dict) -> str:
                                     if isinstance(op_value, str):
                                         escaped_value = escape_sql_string(op_value)
                                         condition_parts.append(
-                                            f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype) @> '\"{escaped_value}\"'::agtype"
+                                            f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype]) @> '\"{escaped_value}\"'::agtype"
                                         )
                                     else:
                                         condition_parts.append(
-                                            f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype) @> {op_value}::agtype"
+                                            f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype]) @> {op_value}::agtype"
                                         )
                                 else:
                                     # Direct property access
@@ -3684,11 +3684,11 @@ def build_filter_condition(condition_dict: dict) -> str:
                                             .replace("_", "\\_")
                                         )
                                         condition_parts.append(
-                                            f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype)::text LIKE '%{escaped_value}%'"
+                                            f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype])::text LIKE '%{escaped_value}%'"
                                         )
                                     else:
                                         condition_parts.append(
-                                            f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype)::text LIKE '%{op_value}%'"
+                                            f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype])::text LIKE '%{op_value}%'"
                                         )
                                 else:
                                     # Direct property access
diff --git a/src/memos/memories/textual/preference.py b/src/memos/memories/textual/preference.py
@@ -87,7 +87,7 @@ def search(
         Returns:
             list[TextualMemoryItem]: List of matching memories.
         """
-        print(f"search_filter for preference memory: {search_filter}")
+        logger.info(f"search_filter for preference memory: {search_filter}")
         return self.retriever.retrieve(query, top_k, info, search_filter)
 
     def load(self, dir: str) -> None:

Original file line number	Diff line number	Diff line change
`@@ -3654,11 +3654,11 @@ def build_filter_condition(condition_dict: dict) -> str:`
`3654`	`3654`	`if isinstance(op_value, str):`
`3655`	`3655`	`escaped_value = escape_sql_string(op_value)`
`3656`	`3656`	`condition_parts.append(`
`3657`		`- f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype) @> '\"{escaped_value}\"'::agtype"`
	`3657`	`+ f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype]) @> '\"{escaped_value}\"'::agtype"`
`3658`	`3658`	`)`
`3659`	`3659`	`else:`
`3660`	`3660`	`condition_parts.append(`
`3661`		`- f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype) @> {op_value}::agtype"`
	`3661`	`+ f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype]) @> {op_value}::agtype"`
`3662`	`3662`	`)`
`3663`	`3663`	`else:`
`3664`	`3664`	`# Direct property access`
`@@ -3684,11 +3684,11 @@ def build_filter_condition(condition_dict: dict) -> str:`
`3684`	`3684`	`.replace("_", "\\_")`
`3685`	`3685`	`)`
`3686`	`3686`	`condition_parts.append(`
`3687`		`- f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype)::text LIKE '%{escaped_value}%'"`
	`3687`	`+ f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype])::text LIKE '%{escaped_value}%'"`
`3688`	`3688`	`)`
`3689`	`3689`	`else:`
`3690`	`3690`	`condition_parts.append(`
`3691`		`- f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype)::text LIKE '%{op_value}%'"`
	`3691`	`+ f"ag_catalog.agtype_access_operator(VARIADIC ARRAY[properties, '\"info\"'::ag_catalog.agtype, '\"{info_field}\"'::ag_catalog.agtype])::text LIKE '%{op_value}%'"`
`3692`	`3692`	`)`
`3693`	`3693`	`else:`
`3694`	`3694`	`# Direct property access`