Function createJoinTests

packages/db/tests/query/join.test.ts:803–2112

(autoIndex: `off` | `eager`)

}

function createJoinTests(autoIndex: `off` | `eager`): void {
  describe(`with autoIndex ${autoIndex}`, () => {
    // Generate tests for each join type
    joinTypes.forEach((joinType) => {
      testJoinType(joinType, autoIndex)
    })

    describe(`Complex Join Scenarios`, () => {
      let usersCollection: ReturnType<typeof createUsersCollection>
      let departmentsCollection: ReturnType<typeof createDepartmentsCollection>

      beforeEach(() => {
        usersCollection = createUsersCollection(autoIndex)
        departmentsCollection = createDepartmentsCollection(autoIndex)
      })

      test(`should handle multiple simultaneous updates`, () => {
        const innerJoinQuery = createLiveQueryCollection({
          startSync: true,
          query: (q) =>
            q
              .from({ user: usersCollection })
              .join(
                { dept: departmentsCollection },
                ({ user, dept }) => eq(user.department_id, dept.id),
                `inner`,
              )
              .select(({ user, dept }) => ({
                user_name: user.name,
                department_name: dept.name,
              })),
        })

        expect(innerJoinQuery.size).toBe(3)

        // Perform multiple operations in a single transaction
        usersCollection.utils.begin()
        departmentsCollection.utils.begin()

        // Delete Alice
        const alice = sampleUsers.find((u) => u.id === 1)!
        usersCollection.utils.write({ type: `delete`, value: alice })

        // Add new user Eve to Engineering
        const eve: User = {
          id: 5,
          name: `Eve`,
          email: `eve@example.com`,
          department_id: 1,
        }
        usersCollection.utils.write({ type: `insert`, value: eve })

        // Add new department IT
        const itDept: Department = { id: 4, name: `IT`, budget: 120000 }
        departmentsCollection.utils.write({ type: `insert`, value: itDept })

        // Update Dave to join IT
        const updatedDave: User = {