Closed koskimas closed 2 weeks ago
This should work
db.updateTable('Queues') .set('status', 'processing') .from((eb) => eb .selectFrom('Queues') .innerJoin('Messages', 'Queues.messageId', 'Messages.id') .selectAll('Queues') .select([ 'Messages.event', 'Messages.payload', 'Messages.id as messageId', 'Messages.createdAt' ]) .where('Queues.status', '=', 'pending') .forUpdate() .skipLocked() .as('query') ) .where('Queues.id', '=', 'query.id') .returningAll('query') // types doesn't work .execute()
This should work