Function acquireRowOrderLock

apps/sim/lib/table/rows/ordering.ts:52–56

(trx: DbTransaction, tableId: string)

 * restores per-table serialization. Released at COMMIT/ROLLBACK.
 */
export async function acquireRowOrderLock(trx: DbTransaction, tableId: string) {
  await trx.execute(
    sql`SELECT pg_advisory_xact_lock(hashtextextended(${`user_table_rows_pos:${tableId}`}, 0))`
  )
}

/** Next append position for a table (max(position) + 1, or 0 if empty). */
export async function nextRowPosition(trx: DbTransaction, tableId: string): Promise<number> {