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

.github/workflows/test.yml

@@ -68,8 +68,8 @@ jobs:
 
       - name: Install activerecord and testsuite
         run: |
-          pip install git+https://github.com/rhosocial/python-activerecord.git@release/v1.0.0.dev28#egg=rhosocial-activerecord
-          pip install rhosocial-activerecord-testsuite==1.0.0.dev15
+          pip install git+https://github.com/rhosocial/python-activerecord.git@release/v1.0.0.dev29#egg=rhosocial-activerecord
+          pip install git+https://github.com/rhosocial/python-activerecord-testsuite.git@release/v1.0.0.dev16#egg=rhosocial-activerecord-testsuite
 
       - name: Create postgres scenario config
         run: |
@@ -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" \
@@ -279,8 +279,8 @@ jobs:
 
       - name: Install activerecord and testsuite
         run: |
-          pip install git+https://github.com/rhosocial/python-activerecord.git@release/v1.0.0.dev28#egg=rhosocial-activerecord
-          pip install rhosocial-activerecord-testsuite==1.0.0.dev15
+          pip install git+https://github.com/rhosocial/python-activerecord.git@release/v1.0.0.dev29#egg=rhosocial-activerecord
+          pip install git+https://github.com/rhosocial/python-activerecord-testsuite.git@release/v1.0.0.dev16#egg=rhosocial-activerecord-testsuite
 
       - name: Create postgres scenario config
         run: |
@@ -391,8 +391,8 @@ jobs:
 
       - name: Install activerecord and testsuite
         run: |
-          pip install git+https://github.com/rhosocial/python-activerecord.git@release/v1.0.0.dev28#egg=rhosocial-activerecord
-          pip install rhosocial-activerecord-testsuite==1.0.0.dev15
+          pip install git+https://github.com/rhosocial/python-activerecord.git@release/v1.0.0.dev29#egg=rhosocial-activerecord
+          pip install git+https://github.com/rhosocial/python-activerecord-testsuite.git@release/v1.0.0.dev16#egg=rhosocial-activerecord-testsuite
 
       - name: Create postgres scenario config
         run: |
@@ -490,8 +490,8 @@ jobs:
 
       - name: Install activerecord and testsuite
         run: |
-          pip install git+https://github.com/rhosocial/python-activerecord.git@release/v1.0.0.dev28#egg=rhosocial-activerecord
-          pip install rhosocial-activerecord-testsuite==1.0.0.dev15
+          pip install git+https://github.com/rhosocial/python-activerecord.git@release/v1.0.0.dev29#egg=rhosocial-activerecord
+          pip install git+https://github.com/rhosocial/python-activerecord-testsuite.git@release/v1.0.0.dev16#egg=rhosocial-activerecord-testsuite
 
       - name: Create postgres scenario config
         run: |

changelog.d/46.added.md

@@ -0,0 +1 @@
+Added PostgreSQL-specific DataType subclasses and schema-diff support with `PostgresSchemaDiffer` for accurate schema introspection and column comparison.

changelog.d/47.added.md

@@ -0,0 +1 @@
+Added named-migration CLI subcommand with --async support and PostgreSQL-specific example migrations for the PostgreSQL backend.

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "rhosocial-activerecord-postgres"
-version = "1.0.0.dev15"
+version = "1.0.0.dev16"
 description = "postgres backend implementation for rhosocial-activerecord, providing a robust and optimized postgres database support."
 readme = "README.md"
 license = { file = "LICENSE" }
@@ -90,6 +90,12 @@ markers = [
     "requires_functions: marks tests requiring specific database functions",
     "requires_inner_join: marks tests requiring INNER JOIN support",
     "benchmark_fastapi: marks FastAPI benchmark tests",
+    "benchmark: marks benchmark tests",
+    "benchmark_backend: marks backend benchmark tests",
+    "benchmark_async: marks async benchmark tests",
+    "benchmark_sync: marks sync benchmark tests",
+    "benchmark_write: marks write benchmark tests",
+    "benchmark_read: marks read benchmark tests",
 ]
 
 [tool.coverage.run]

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

@@ -23,6 +23,55 @@
 from .dialect import PostgresDialect
 from .transaction import PostgresTransactionManager, AsyncPostgresTransactionManager
 from .types import PostgresEnumType
+from .expression.types import (
+    PostgresBigSerialType,
+    PostgresBitType,
+    PostgresBoxType,
+    PostgresByteaType,
+    PostgresCIDType,
+    PostgresCircleType,
+    PostgresDateMultirangeType,
+    PostgresDateRangeType,
+    PostgresGeographyType,
+    PostgresGeometryType,
+    PostgresHstoreType,
+    PostgresInetType,
+    PostgresInt4MultirangeType,
+    PostgresInt4RangeType,
+    PostgresInt8MultirangeType,
+    PostgresInt8RangeType,
+    PostgresJsonPathType,
+    PostgresLineSegmentType,
+    PostgresLineType,
+    PostgresMacAddr8Type,
+    PostgresMacAddrType,
+    PostgresMoneyType,
+    PostgresNumMultirangeType,
+    PostgresNumRangeType,
+    PostgresOIDType,
+    PostgresPathType,
+    PostgresPgLSNType,
+    PostgresPointType,
+    PostgresPolygonType,
+    PostgresRegClassType,
+    PostgresRegTypeType,
+    PostgresSerialType,
+    PostgresSmallSerialType,
+    PostgresTIDType,
+    PostgresTSQueryType,
+    PostgresTSVectorType,
+    PostgresTsMultirangeType,
+    PostgresTsRangeType,
+    PostgresTsTzMultirangeType,
+    PostgresTsTzRangeType,
+    PostgresUUIDType,
+    PostgresVarBitType,
+    PostgresVectorType,
+    PostgresXID8Type,
+    PostgresXIDType,
+    PostgresXMLType,
+    PostgresCidrType,
+)
 from .explain import PostgresExplainResult, PostgresExplainPlanLine
 from .expression.ddl import (
     PostgresCreateEnumTypeExpression,
@@ -505,4 +554,52 @@
     # hstore functions - Subscript
     "hstore_subscript_get",
     "hstore_subscript_set",
+    # PostgreSQL DataType subclasses for DDL
+    "PostgresBigSerialType",
+    "PostgresBitType",
+    "PostgresBoxType",
+    "PostgresByteaType",
+    "PostgresCIDType",
+    "PostgresCircleType",
+    "PostgresDateMultirangeType",
+    "PostgresDateRangeType",
+    "PostgresGeographyType",
+    "PostgresGeometryType",
+    "PostgresHstoreType",
+    "PostgresInetType",
+    "PostgresInt4MultirangeType",
+    "PostgresInt4RangeType",
+    "PostgresInt8MultirangeType",
+    "PostgresInt8RangeType",
+    "PostgresJsonPathType",
+    "PostgresLineSegmentType",
+    "PostgresLineType",
+    "PostgresMacAddr8Type",
+    "PostgresMacAddrType",
+    "PostgresMoneyType",
+    "PostgresNumMultirangeType",
+    "PostgresNumRangeType",
+    "PostgresOIDType",
+    "PostgresPathType",
+    "PostgresPgLSNType",
+    "PostgresPointType",
+    "PostgresPolygonType",
+    "PostgresRegClassType",
+    "PostgresRegTypeType",
+    "PostgresSerialType",
+    "PostgresSmallSerialType",
+    "PostgresTIDType",
+    "PostgresTSQueryType",
+    "PostgresTSVectorType",
+    "PostgresTsMultirangeType",
+    "PostgresTsRangeType",
+    "PostgresTsTzMultirangeType",
+    "PostgresTsTzRangeType",
+    "PostgresUUIDType",
+    "PostgresVarBitType",
+    "PostgresVectorType",
+    "PostgresXID8Type",
+    "PostgresXIDType",
+    "PostgresXMLType",
+    "PostgresCidrType",
 ]

src/rhosocial/activerecord/backend/impl/postgres/cli/__init__.py

@@ -5,7 +5,8 @@
 
 COMMAND_NAMES = [
     'info', 'query', 'introspect', 'status',
-    'named-expression', 'named-procedure', 'named-procedure-graph', 'named-connection',
+    'named-expression', 'named-procedure', 'named-procedure-graph',
+    'named-migration', 'named-connection',
 ]
 
 
@@ -18,6 +19,7 @@ def register_commands(subparsers):
     from .named_expression import create_parser as nq_parser
     from .named_procedure import create_parser as np_parser
     from .named_procedure_graph import create_parser as npg_parser
+    from .named_migration import create_parser as nm_parser
     from .named_connection import create_parser as nc_parser
     info_parser(subparsers)
     query_parser(subparsers)
@@ -26,6 +28,7 @@ def register_commands(subparsers):
     nq_parser(subparsers)
     np_parser(subparsers)
     npg_parser(subparsers)
+    nm_parser(subparsers)
     nc_parser(subparsers)
 
 

src/rhosocial/activerecord/backend/impl/postgres/cli/named_migration.py

@@ -0,0 +1,115 @@
+# src/rhosocial/activerecord/backend/impl/postgres/cli/named_migration.py
+"""named-migration subcommand — PostgreSQL adapter for the shared CLI helper."""
+
+from __future__ import annotations
+
+from rhosocial.activerecord.backend.impl.postgres import PostgresBackend, AsyncPostgresBackend
+
+from .connection import create_connection_parent_parser, resolve_connection_config_from_args
+from .output import create_provider
+
+
+def create_parser(subparsers):
+    """Create the named-migration subcommand parser.
+
+    Provides connection and output arguments via a parent parser.
+    """
+    from rhosocial.activerecord.backend.migration.cli import create_named_migration_parser
+
+    local_parent = create_connection_parent_parser()
+    nm_epilog = """Examples:
+  # Apply a migration
+  %(prog)s myapp.migrations.v001.CreateUsersTable --host localhost --database mydb --direction up
+
+  # Rollback
+  %(prog)s myapp.migrations.v001.CreateUsersTable --host localhost --database mydb --direction down
+
+  # Apply with record store
+  %(prog)s myapp.migrations.v001.CreateUsersTable --database mydb --record-store ./migrations.json
+
+  # Dry-run
+  %(prog)s myapp.migrations.v001.CreateUsersTable --database mydb --direction up --dry-run
+
+  # Apply asynchronously
+  %(prog)s myapp.migrations.v001.CreateUsersTable --database mydb --direction up --async
+
+  # Pass parameters to the migration
+  %(prog)s myapp.migrations.v001.CreateUsersTable --param table_name=custom_table
+
+  # List available migrations
+  %(prog)s myapp.migrations --list
+
+  # Describe a migration
+  %(prog)s myapp.migrations.v001.CreateUsersTable --describe
+
+  # Batch: apply all pending migrations in a module
+  %(prog)s myapp.migrations --all --record-store ./migrations.json
+
+  # Batch: dry-run all pending migrations
+  %(prog)s myapp.migrations --all --record-store ./migrations.json --dry-run
+
+  # Batch: rollback all applied migrations
+  %(prog)s myapp.migrations --all --record-store ./migrations.json --direction down
+
+  # Batch: wrap all migrations in a single transaction
+  %(prog)s myapp.migrations --all --record-store ./migrations.json --single-transaction
+
+End-to-end demo scripts with UP/DOWN round-trip verification:
+  https://github.com/rhosocial/python-activerecord-postgres/tree/main/src/rhosocial/activerecord/backend/impl/postgres/examples/named_migrations
+  PYTHONPATH=src bash demo_basic.sh
+  PYTHONPATH=src bash demo_chain.sh
+  PYTHONPATH=src bash demo_all.sh
+"""
+    return create_named_migration_parser(subparsers, local_parent, epilog=nm_epilog)
+
+
+def handle(args):
+    """Handle the named-migration subcommand."""
+    from rhosocial.activerecord.backend.migration.cli import handle_named_migration as handle_nm
+
+    provider = create_provider(args.output, ascii_borders=args.rich_ascii)
+
+    backend = None
+
+    def backend_factory():
+        nonlocal backend
+        config = resolve_connection_config_from_args(args)
+        backend = PostgresBackend(connection_config=config)
+        backend.connect()
+        backend.introspect_and_adapt()
+        return backend
+
+    def disconnect():
+        if backend and getattr(backend, "_connection", None):
+            backend.disconnect()
+
+    is_async = getattr(args, "is_async", False)
+    if is_async:
+        async_backend = None
+
+        def backend_async_factory():
+            nonlocal async_backend
+            config = resolve_connection_config_from_args(args)
+            async_backend = AsyncPostgresBackend(connection_config=config)
+            return async_backend
+
+        async def disconnect_async():
+            if async_backend and getattr(async_backend, "_connection", None):
+                await async_backend.disconnect()
+
+        handle_nm(
+            args,
+            provider,
+            backend_factory=backend_factory,
+            disconnect=disconnect,
+            backend_async_factory=backend_async_factory,
+            disconnect_async=disconnect_async,
+        )
+        return
+
+    handle_nm(
+        args,
+        provider,
+        backend_factory=backend_factory,
+        disconnect=disconnect,
+    )

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

@@ -90,6 +90,7 @@
     IntrospectionSupport,
     TransactionControlSupport,
     SQLFunctionSupport,
+    DDLTypeSupport,
 )
 from .mixins import (
     PostgresExtensionMixin,
@@ -169,6 +170,7 @@
     PostgresRangeTypeMixin,
     PostgresJSONBEnhancedMixin,
     PostgresArrayEnhancedMixin,
+    PostgresTypeFormatSupportMixin,
     # DDL/DML operation mixins (new)
     PostgresExtendedStatisticsMixin,
     PostgresStoredProcedureMixin,
@@ -400,6 +402,7 @@ class PostgresDialect(
     PostgresFullTextSearchMixin,
     PostgresRangeTypeMixin,
     PostgresArrayEnhancedMixin,
+    PostgresTypeFormatSupportMixin,
     # DDL/DML operation mixins (new)
     PostgresExtendedStatisticsMixin,
     PostgresStoredProcedureMixin,
@@ -524,6 +527,8 @@ class PostgresDialect(
     PostgresRangeTypeSupport,
     PostgresJSONBEnhancedSupport,
     PostgresArrayEnhancedSupport,
+    # DataType Support Protocol
+    DDLTypeSupport,
     # New feature protocols
     PostgresParallelQuerySupport,
     PostgresStoredProcedureSupport,
@@ -689,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.