Function updatePageByIds

apps/sim/lib/table/rows/ordering.ts:617–644

(
  tableId: string,
  workspaceId: string,
  rowIds: string[],
  patchJson: string
)

 * makes incremental, resumable progress. Returns the number of rows updated.
 */
export async function updatePageByIds(
  tableId: string,
  workspaceId: string,
  rowIds: string[],
  patchJson: string
): Promise<number> {
  const now = new Date()
  let updated = 0
  for (let i = 0; i < rowIds.length; i += TABLE_LIMITS.UPDATE_BATCH_SIZE) {
    const batch = rowIds.slice(i, i + TABLE_LIMITS.UPDATE_BATCH_SIZE)
    const rows = await db.transaction(async (trx) => {
      await setTableTxTimeouts(trx, { statementMs: 60_000 })
      return trx
        .update(userTableRows)
        .set({ data: sql`${userTableRows.data} || ${patchJson}::jsonb`, updatedAt: now })
        .where(
          and(
            eq(userTableRows.tableId, tableId),
            eq(userTableRows.workspaceId, workspaceId),
            inArray(userTableRows.id, batch)
          )
        )
        .returning({ id: userTableRows.id })
    })
    updated += rows.length
  }
  return updated
}