change to a subscription per collection alias rather than collection inside a live query #625

samwillis · 2025-10-01T19:47:48Z

This fixes this bug report from Discord: https://discord.com/channels/719702312431386674/1369767025723052134/1422935844175614072

That report identified that a self query with a where clause on the main alias would result in the join not seeing the whole collection. It also tries to tidy up the terminology we use, dropping "table" and using source & collection.

This has grown in to a larger refactor of the compiler that changes it to do a subscription per source alias rather than a single subscription per collection.

Per-Alias Subscriptions: Fix Self-Joins and Enable Independent Filtering

The Problem

Live queries previously subscribed once per collection ID. This caused critical bugs when the same collection appeared multiple times in a query with different aliases:

// This query would FAIL before this PR
const query = db.query((q) => 
  q.from({ employee: employeesCollection })
   .join({ manager: employeesCollection }, 
     ({ employee, manager }) => eq(employee.managerId, manager.id))
   .where(({ employee }) => eq(employee.department, 'Engineering'))
)

What went wrong:

Both employee and manager aliases mapped to the same collection
The live query layer created only ONE subscription for employeesCollection
The WHERE filter meant for employee was incorrectly applied to manager too
Lazy loading couldn't distinguish between the two aliases
Result: managers were filtered by department when they shouldn't be

The Solution

Subscribe once per source alias, not once per collection.

Now employee and manager each get their own independent subscription with:

Their own filters
Their own lazy loading state
Their own input streams into the query pipeline

Key Changes

1. Compiler Output Tracking

Added two new fields to CompilationResult:

interface CompilationResult {
  // NEW: Maps every alias to its collection ID
  // Example: { employee: 'employees-id', manager: 'employees-id' }
  aliasToCollectionId: Record<string, string>
  
  // NEW: Maps outer subquery aliases to inner aliases
  // Example: { activeUser: 'user' } when join alias differs from subquery's internal alias
  aliasRemapping: Record<string, string>
}

2. Alias-Keyed Everything

Before:

inputs[collection.id]  // One input per collection
subscriptions[collection.id]  // One subscription per collection

After:

inputs[alias]  // One input per alias: { employee: input1, manager: input2 }
subscriptions[alias]  // One subscription per alias

3. Subquery Alias Resolution

When a subquery uses different aliases than the parent query:

const activeUsers = q.from({ user: usersCollection })
                     .where(({ user }) => eq(user.active, true))

q.from({ post: posts })
 .join({ author: activeUsers }, ...)  // Outer: 'author', Inner: 'user'

The compiler now tracks: aliasRemapping['author'] = 'user' so lazy loading can find the correct subscription.

4. Better Error Messages

// Before
throw new Error(`Input for collection "users" not found`)

// After  
throw new CollectionInputNotFoundError(
  'manager',  // The missing alias
  'employees-col-id',  // The collection it refers to
  ['employee', 'post']  // Available aliases for debugging
)
// Error: Input for alias "manager" (collection "employees-col-id") not found in inputs map. 
//        Available keys: employee, post

5. Terminology Consistency

collectionWhereClauses → sourceWhereClauses
"table alias" → "source alias" throughout comments
tables → sources in pipeline code

6. Code Simplification

Removed unnecessary two-phase compilation that was guarding against optimizer-generated aliases (which never actually happened). The compiler now runs once with cleaner logic.

What Now Works

✅ Self-Joins

// Employees who manage other employees
q.from({ employee: employeesCollection })
 .join({ manager: employeesCollection }, 
   ({ employee, manager }) => eq(employee.managerId, manager.id))
 .where(({ employee }) => eq(employee.department, 'Engineering'))
 .select(({ employee, manager }) => ({
   employeeName: employee.name,
   managerName: manager.name  // ✅ Manager not filtered by department
 }))

✅ Multiple Aliases with Independent Filters

q.from({ current: usersCollection })
 .join({ previous: usersCollection }, ...)
 .where(({ current }) => eq(current.active, true))
 .where(({ previous }) => eq(previous.active, false))
 // ✅ Each alias has its own filter

✅ Subquery Alias Resolution

const admins = q.from({ user: usersCollection })
                .where(({ user }) => eq(user.role, 'admin'))

q.from({ post: posts })
 .join({ author: admins }, ...)  
 // ✅ Compiler maps 'author' → 'user' for subscription resolution

✅ Lazy Loading in Self-Joins

// Only loads managers for employees that pass the WHERE clause
q.from({ employee: employeesCollection })
 .join({ manager: employeesCollection }, ...)
 .where(({ employee }) => eq(employee.active, true))
 // ✅ Lazy loads only needed managers, using correct alias subscription

Breaking Changes

None for users. This is entirely internal to the query compilation and live layer.

The only "breaking" aspect is that previously broken queries (self-joins) now work correctly.

Performance Impact

Neutral to positive:

Avoids incorrect filter application across aliases
Enables more precise lazy loading (only load what each alias needs)
Slightly more memory (one subscription per alias vs per collection)
Opens door for future optimization: deduplicate identical alias pipelines

Testing

All existing tests pass. The fact that tests passed throughout development confirms:

No optimizer actually generates new aliases (validated with logging)
All aliases come from user declarations
The defensive checks never trigger in practice

Self-join scenarios that previously failed now work correctly.

Files Changed

packages/db/src/query/compiler/index.ts - Core compilation changes
packages/db/src/query/compiler/joins.ts - Join processing with alias tracking
packages/db/src/query/live/collection-config-builder.ts - Per-alias subscription creation
packages/db/src/query/live/collection-subscriber.ts - Alias-aware subscriptions
packages/db/src/errors.ts - New error classes with better context

Migration Guide

No migration needed. Existing queries work unchanged. Self-joins that were broken now work.

changeset-bot · 2025-10-01T19:47:52Z

🦋 Changeset detected

Latest commit: 88b3092

The changes in this PR will be included in the next version bump.

This PR includes changesets to release 12 packages

Name	Type
@tanstack/db	Patch
@tanstack/angular-db	Patch
@tanstack/electric-db-collection	Patch
@tanstack/query-db-collection	Patch
@tanstack/react-db	Patch
@tanstack/rxdb-db-collection	Patch
@tanstack/solid-db	Patch
@tanstack/svelte-db	Patch
@tanstack/trailbase-db-collection	Patch
@tanstack/vue-db	Patch
todos	Patch
@tanstack/db-example-react-todo	Patch

Not sure what this means? Click here to learn what changesets are.

Click here if you're a maintainer who wants to add another changeset to this PR

pkg-pr-new · 2025-10-01T19:49:18Z

More templates

@tanstack/angular-db

npm i https://pkg.pr.new/@tanstack/angular-db@625

@tanstack/db

npm i https://pkg.pr.new/@tanstack/db@625

@tanstack/db-ivm

npm i https://pkg.pr.new/@tanstack/db-ivm@625

@tanstack/electric-db-collection

npm i https://pkg.pr.new/@tanstack/electric-db-collection@625

@tanstack/query-db-collection

npm i https://pkg.pr.new/@tanstack/query-db-collection@625

@tanstack/react-db

npm i https://pkg.pr.new/@tanstack/react-db@625

@tanstack/rxdb-db-collection

npm i https://pkg.pr.new/@tanstack/rxdb-db-collection@625

@tanstack/solid-db

npm i https://pkg.pr.new/@tanstack/solid-db@625

@tanstack/svelte-db

npm i https://pkg.pr.new/@tanstack/svelte-db@625

@tanstack/trailbase-db-collection

npm i https://pkg.pr.new/@tanstack/trailbase-db-collection@625

@tanstack/vue-db

npm i https://pkg.pr.new/@tanstack/vue-db@625

commit: 88b3092

github-actions · 2025-10-01T19:50:36Z

Size Change: +1.33 kB (+1.77%)

Total Size: 76.5 kB

Filename	Size	Change
`./packages/db/dist/esm/errors.js`	3.5 kB	+401 B (+12.94%)	⚠️
`./packages/db/dist/esm/index.js`	1.61 kB	+52 B (+3.33%)
`./packages/db/dist/esm/query/compiler/index.js`	2.19 kB	+149 B (+7.3%)	🔍
`./packages/db/dist/esm/query/compiler/joins.js`	2.64 kB	+120 B (+4.76%)	🔍
`./packages/db/dist/esm/query/compiler/order-by.js`	1.25 kB	+45 B (+3.73%)
`./packages/db/dist/esm/query/live/collection-config-builder.js`	3.36 kB	+671 B (+24.99%)	🚨
`./packages/db/dist/esm/query/live/collection-subscriber.js`	1.75 kB	-106 B (-5.7%)	✅
`./packages/db/dist/esm/query/optimizer.js`	3.08 kB	-3 B (-0.1%)

ℹ️ View Unchanged

Filename	Size
`./packages/db/dist/esm/collection/change-events.js`	943 B
`./packages/db/dist/esm/collection/changes.js`	1.01 kB
`./packages/db/dist/esm/collection/events.js`	660 B
`./packages/db/dist/esm/collection/index.js`	3.18 kB
`./packages/db/dist/esm/collection/indexes.js`	1.16 kB
`./packages/db/dist/esm/collection/lifecycle.js`	1.8 kB
`./packages/db/dist/esm/collection/mutations.js`	2.5 kB
`./packages/db/dist/esm/collection/state.js`	3.82 kB
`./packages/db/dist/esm/collection/subscription.js`	1.65 kB
`./packages/db/dist/esm/collection/sync.js`	1.42 kB
`./packages/db/dist/esm/deferred.js`	230 B
`./packages/db/dist/esm/indexes/auto-index.js`	806 B
`./packages/db/dist/esm/indexes/base-index.js`	835 B
`./packages/db/dist/esm/indexes/btree-index.js`	2 kB
`./packages/db/dist/esm/indexes/lazy-index.js`	1.21 kB
`./packages/db/dist/esm/indexes/reverse-index.js`	577 B
`./packages/db/dist/esm/local-only.js`	827 B
`./packages/db/dist/esm/local-storage.js`	2.02 kB
`./packages/db/dist/esm/optimistic-action.js`	294 B
`./packages/db/dist/esm/proxy.js`	3.86 kB
`./packages/db/dist/esm/query/builder/functions.js`	615 B
`./packages/db/dist/esm/query/builder/index.js`	4.04 kB
`./packages/db/dist/esm/query/builder/ref-proxy.js`	938 B
`./packages/db/dist/esm/query/compiler/evaluators.js`	1.55 kB
`./packages/db/dist/esm/query/compiler/expressions.js`	631 B
`./packages/db/dist/esm/query/compiler/group-by.js`	2.04 kB
`./packages/db/dist/esm/query/compiler/select.js`	1.28 kB
`./packages/db/dist/esm/query/ir.js`	785 B
`./packages/db/dist/esm/query/live-query-collection.js`	340 B
`./packages/db/dist/esm/SortedMap.js`	1.24 kB
`./packages/db/dist/esm/transactions.js`	3 kB
`./packages/db/dist/esm/utils.js`	1.01 kB
`./packages/db/dist/esm/utils/browser-polyfills.js`	365 B
`./packages/db/dist/esm/utils/btree.js`	6.01 kB
`./packages/db/dist/esm/utils/comparison.js`	754 B
`./packages/db/dist/esm/utils/index-optimization.js`	1.73 kB

_{compressed-size-action::db-package-size}

github-actions · 2025-10-01T19:51:55Z

Size Change: 0 B

Total Size: 1.47 kB

ℹ️ View Unchanged

Filename	Size
`./packages/react-db/dist/esm/index.js`	152 B
`./packages/react-db/dist/esm/useLiveQuery.js`	1.32 kB

_{compressed-size-action::react-db-package-size}

samwillis · 2025-10-06T09:42:22Z

packages/db/src/query/compiler/index.ts

+   * Maps each source alias to its collection ID. Enables per-alias subscriptions for self-joins.
+   * Example: `{ employee: 'employees-col-id', manager: 'employees-col-id' }`
+   */
+  aliasToCollectionId: Record<string, string>


This is a mapping of the alias used in a from or join to the collection id that is to be used for that source.

samwillis · 2025-10-06T09:46:33Z

packages/db/src/query/compiler/index.ts

+   * Maps outer alias to inner alias for subqueries (e.g., `{ activeUser: 'user' }`).
+   * Used to resolve subscriptions during lazy loading when aliases differ.
+   */
+  aliasRemapping: Record<string, string>


In this query below the alias mapping is used to track that activeUser is an alias of the user alias.

q.from(issue: issueCollection) .join( { activeUser: q.from({ user: userCollection }) }, ({ issue }) => ....

samwillis added 2 commits October 1, 2025 19:10

wip

1249a08

convert to a subscription per alias

8baf80c

samwillis changed the title ~~change to having a subscription per collection alias rather than collection inside a live query~~ change to a subscription per collection alias rather than collection inside a live query Oct 1, 2025

samwillis added 7 commits October 2, 2025 09:58

change to subscription per source alias, rather than per colleciton

42f81bb

address gpt5 review

85f51e9

wip

d9b2014

rename stuff

9a794a3

remove fallback to collecitonId

04688eb

better mapping of subquery aliases

4ee665a

rename stuff and tidy

0f7798b

samwillis force-pushed the samwillis/fix-self-join branch from c3e7c93 to 0f7798b Compare October 2, 2025 12:40

changeset

17ffc31

samwillis marked this pull request as ready for review October 2, 2025 13:06

samwillis requested a review from kevin-dp October 2, 2025 13:06

samwillis mentioned this pull request Oct 2, 2025

Add a scheduler that ensures single batch of changes from live query due to a transaction that touches multiple source collections #628

Open

samwillis added 2 commits October 4, 2025 16:41

better comments

50316cd

remove unnecessary second pass of the compiler

2f6ca4f

samwillis commented Oct 6, 2025

View reviewed changes

remove deplicate code

88b3092

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

change to a subscription per collection alias rather than collection inside a live query #625

change to a subscription per collection alias rather than collection inside a live query #625

samwillis commented Oct 1, 2025 •

edited

Loading

Uh oh!

changeset-bot bot commented Oct 1, 2025 •

edited

Loading

Uh oh!

pkg-pr-new bot commented Oct 1, 2025 •

edited

Loading

Uh oh!

github-actions bot commented Oct 1, 2025 •

edited

Loading

Uh oh!

github-actions bot commented Oct 1, 2025 •

edited

Loading

Uh oh!

samwillis Oct 6, 2025

Uh oh!

samwillis Oct 6, 2025

Uh oh!

Uh oh!

change to a subscription per collection alias rather than collection inside a live query #625

Are you sure you want to change the base?

change to a subscription per collection alias rather than collection inside a live query #625

Conversation

samwillis commented Oct 1, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Per-Alias Subscriptions: Fix Self-Joins and Enable Independent Filtering

The Problem

The Solution

Key Changes

1. Compiler Output Tracking

2. Alias-Keyed Everything

3. Subquery Alias Resolution

4. Better Error Messages

5. Terminology Consistency

6. Code Simplification

What Now Works

✅ Self-Joins

✅ Multiple Aliases with Independent Filters

✅ Subquery Alias Resolution

✅ Lazy Loading in Self-Joins

Breaking Changes

Performance Impact

Testing

Files Changed

Migration Guide

Uh oh!

changeset-bot bot commented Oct 1, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

🦋 Changeset detected

Uh oh!

pkg-pr-new bot commented Oct 1, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

github-actions bot commented Oct 1, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

github-actions bot commented Oct 1, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

samwillis Oct 6, 2025

Choose a reason for hiding this comment

Uh oh!

samwillis Oct 6, 2025

Choose a reason for hiding this comment

Uh oh!

Uh oh!

samwillis commented Oct 1, 2025 •

edited

Loading

changeset-bot bot commented Oct 1, 2025 •

edited

Loading

pkg-pr-new bot commented Oct 1, 2025 •

edited

Loading

github-actions bot commented Oct 1, 2025 •

edited

Loading

github-actions bot commented Oct 1, 2025 •

edited

Loading