Limitations

-- Not pushed down
SELECT COUNT(id) FROM mock_items
WHERE rating = 5;

-- Pushed down
SELECT COUNT(id) FROM mock_items
WHERE rating = 5
AND id @@@ pdb.all();

import { and, count, eq } from "drizzle-orm";
import { search } from "@paradedb/drizzle-paradedb";

// Not pushed down — no ParadeDB operator
await db
  .select({ count: count(mockItems.id) })
  .from(mockItems)
  .where(eq(mockItems.rating, 5));

// Pushed down — ParadeDB operator triggers aggregate pushdown
await db
  .select({ count: count(mockItems.id) })
  .from(mockItems)
  .where(and(eq(mockItems.rating, 5), search.all(mockItems.id)));

from paradedb import All, ParadeDB

# Not pushed down — no ParadeDB operator
MockItem.objects.filter(rating=5).count()

# Pushed down — ParadeDB operator triggers aggregate pushdown
MockItem.objects.filter(rating=5, id=ParadeDB(All())).count()

from sqlalchemy import func, select
from sqlalchemy.orm import Session
from paradedb.sqlalchemy import search

# Not pushed down.
count_without_operator_stmt = select(func.count(MockItem.id)).where(MockItem.rating == 5)

# Pushed down.
count_with_operator_stmt = select(func.count(MockItem.id)).where(
    MockItem.rating == 5,
    search.all(MockItem.id),
)

with Session(engine) as session:
    {
        "count_without_operator": session.execute(count_without_operator_stmt).scalar_one(),
        "count_with_operator": session.execute(count_with_operator_stmt).scalar_one(),
    }

# Not pushed down — no ParadeDB operator
MockItem.where(rating: 5).count

# Pushed down — ParadeDB operator triggers aggregate pushdown
MockItem.search(:id).match_all.where(rating: 5).count

// Not pushed down - no ParadeDB operator
await dbContext
    .MockItems.Where(item => item.Rating == 5)
    .CountAsync();

// Pushed down - ParadeDB operator triggers aggregate pushdown
await dbContext
    .MockItems.Where(item => item.Rating == 5 && EF.Functions.All(item.Id))
    .CountAsync();