Aggregation Methods

const count = await db.users.count({
  partitionKey: 'john@example.com',
  where: { isActive: true }
});
// Returns: number

const stats = await db.orders.aggregate({
  partitionKey: 'customer-123',
  where: { status: 'completed' },
  _count: true,
  _sum: { amount: true, tax: true },
  _avg: { amount: true },
  _min: { createdAt: true },
  _max: { amount: true }
});
// Returns: {
//   _count: number,
//   _sum: { amount: number | null, tax: number | null },
//   _avg: { amount: number | null },
//   _min: { createdAt: Date | null },
//   _max: { amount: number | null }
// }

const salesByCategory = await db.sales.groupBy({
  by: 'category',
  enableCrossPartitionQuery: true,
  _count: true,
  _sum: { amount: true },
  _avg: { amount: true },
  orderBy: { _sum_amount: 'desc' },
  take: 10
});
// Returns: Array<{
//   category: string,
//   _count: number,
//   _sum: { amount: number | null },
//   _avg: { amount: number | null }
// }>

// Sum
const totalRevenue = await db.orders.sum('amount', {
  partitionKey: 'customer-123',
  where: { status: 'completed' }
});
// Returns: number | null

// Average
const avgAge = await db.users.avg('age', {
  partitionKey: 'tenant-1'
});
// Returns: number | null

// Minimum
const minPrice = await db.products.min('price', {
  partitionKey: 'category-electronics'
});
// Returns: number | null

// Maximum
const maxPrice = await db.products.max('price', {
  partitionKey: 'category-electronics'
});
// Returns: number | null

partitionKey: 'john@example.com'        // Single value
partitionKey: ['tenant_1', 'org_a']      // Composite partition key (array)

where: {
  status: 'completed',
  amount: { gte: 100 },
  createdAt: { gte: new Date('2024-01-01') }
}

enableCrossPartitionQuery: true // Required for groupBy across partitions