Join

Join are available in both fetchOne and fetchAll.

Available join methods are:

• INNER JOIN
• LEFT JOIN
• CROSS JOIN

Note that SQLite doesn't support RIGHT JOIN neither FULL JOIN.

Implicit Inner Join

const qb = new D1QB(env.DB)

const fetched = await qb
  .fetchAll({
    tableName: 'employees',
    fields: ['role', 'department', 'payroll.salary'],
    where: {
      conditions: 'department = ?1',
      params: ['HR'],
    },
    join: {
      table: 'payroll',
      on: 'payroll.employee_id = employees.id',
    },
  })
  .execute()

Explicit Inner Join

const qb = new D1QB(env.DB)

const fetched = await qb
  .fetchAll({
    tableName: 'employees',
    fields: ['role', 'department', 'payroll.salary'],
    where: {
      conditions: 'department = ?1',
      params: ['HR'],
    },
    join: {
      type: JoinTypes.INNER,
      table: 'payroll',
      on: 'payroll.employee_id = employees.id',
    },
  })
  .execute()

Left Join

const qb = new D1QB(env.DB)

const fetched = await qb
  .fetchAll({
    tableName: 'employees',
    fields: '*',
    join: {
      type: JoinTypes.LEFT,
      table: 'payroll',
      on: 'payroll.employee_id = employees.id',
    },
  })
  .execute()

Multiple Joins

const qb = new D1QB(env.DB)

const fetched = await qb
  .fetchAll({
    tableName: 'employees',
    fields: '*',
    join: [
      {
        table: 'payroll',
        on: 'payroll.employee_id = employees.id',
      },
      {
        table: 'offices',
        on: 'testTable.office_id = offices.id',
      },
    ],
  })
  .execute()

Join with a sub-query

const qb = new D1QB(env.DB)

const result = new QuerybuilderTest()
  .fetchAll({
    tableName: 'testTable',
    fields: '*',
    where: {
      conditions: 'field = ?1',
      params: ['test'],
    },
    join: {
      table: {
        tableName: 'otherTable',
        fields: ['test_table_id', 'GROUP_CONCAT(attribute) AS attributes'],
        groupBy: 'test_table_id',
      },
      on: 'testTable.id = otherTableGrouped.test_table_id',
      alias: 'otherTableGrouped',
    },
  })
  .execute()