feat: PGQ enhancement - fulltext search, cursor pollution fix, and PG 19 compatibility

.github/workflows/test.yml

@@ -123,13 +123,13 @@ jobs:
             --rootdir=. \
             --confcutdir=. \
             "$TESTSUITE_DIR/benchmark/crud/test_delete_async.py" \
-            "$TESTSUITE_DIR/benchmark/crud/test_delete_sync.py" \
+            "$TESTSUITE_DIR/benchmark/crud/test_delete.py" \
             "$TESTSUITE_DIR/benchmark/crud/test_insert_async.py" \
-            "$TESTSUITE_DIR/benchmark/crud/test_insert_sync.py" \
+            "$TESTSUITE_DIR/benchmark/crud/test_insert.py" \
             "$TESTSUITE_DIR/benchmark/crud/test_query_async.py" \
-            "$TESTSUITE_DIR/benchmark/crud/test_query_sync.py" \
+            "$TESTSUITE_DIR/benchmark/crud/test_query.py" \
             "$TESTSUITE_DIR/benchmark/crud/test_update_async.py" \
-            "$TESTSUITE_DIR/benchmark/crud/test_update_sync.py" \
+            "$TESTSUITE_DIR/benchmark/crud/test_update.py" \
             "$TESTSUITE_DIR/benchmark/query" \
             "$TESTSUITE_DIR/benchmark/transaction" \
             "$TESTSUITE_DIR/benchmark/mixin" \

changelog.d/49.added.md

@@ -0,0 +1 @@
+Add PGQ enhancements: fulltext search capability, ON CONFLICT switches, JSON arrow operators, cursor result-set pollution fix, and PostgreSQL 19 compatibility gate for quantified path and comma-separated patterns

src/rhosocial/activerecord/backend/impl/postgres/backend/async_backend.py

@@ -346,8 +346,6 @@ async def get_server_version(self) -> Optional[Tuple[int, int, int]]:
             cursor = await self._get_cursor()
             await cursor.execute("SELECT version()")
             version_row = await cursor.fetchone()
-            # Defensively consume remaining results to prevent cursor.description pollution
-            remaining = await cursor.fetchall()
             if not version_row or not version_row[0]:
                 self.log(logging.WARNING, "PostgreSQL version query returned no result")
                 return None

src/rhosocial/activerecord/backend/impl/postgres/backend/sync.py

@@ -347,8 +347,6 @@ def get_server_version(self) -> Optional[Tuple[int, int, int]]:
             cursor = self._get_cursor()
             cursor.execute("SELECT version()")
             result = cursor.fetchone()
-            # Defensively consume remaining results to prevent cursor.description pollution
-            cursor.fetchall()
             if not result or not result[0]:
                 self.log(logging.WARNING, "PostgreSQL version query returned no result")
                 return None

src/rhosocial/activerecord/backend/impl/postgres/dialect.py

@@ -694,6 +694,10 @@ def supports_for_update(self) -> bool:
         """
         return True
 
+    def supports_json_arrow_operators(self) -> bool:
+        """PostgreSQL supports -> and ->> operators for JSON/JSONB access."""
+        return True
+
     def supports_lock_strength(self, strength) -> bool:
         """
         Check if a specific lock strength is supported.

src/rhosocial/activerecord/backend/impl/postgres/examples/conftest.py

@@ -262,6 +262,14 @@
         'min_version': '9',
         'max_version': '18',
     },
+    'pgq/recursive_cte_graph_traversal.py': {
+        'title': 'Recursive CTE Graph Traversal (PGQ Quantified Path Alternative)',
+        'dialect_protocols': [],
+        'priority': 5,
+        'min_version': '9',
+        'max_version': '18',
+        'note': 'Uses recursive CTE + UNION ALL to simulate PGQ quantified path patterns; works on all PG versions',
+    },
     'transaction/basic.py': {
         'title': 'Transaction Control',
         'dialect_protocols': [],