Retorno de filas desbloqueadas en una consulta "seleccionar top n"

Question

Necesito tener una tabla de base de datos MsSql y otros 8 procesos (idénticos) accediendo a la misma tabla en paralelo - haciendo una selección superior n, procesando esas n filas, y actualizando una columna de esas filas. El problema es que necesito seleccionar y procesar cada fila solo una vez. Esto significa que si un proceso llegó a la base de datos y seleccionó las n primeras filas, cuando llegue el segundo proceso debería encontrar esas filas bloqueadas y seleccionar las filas de n a 2 * n filas, y así sucesivamente ...

¿Es posible poner un candado en algunas filas cuando las selecciona, y cuando alguien solicita las primeras n filas que están bloqueadas para devolver las siguientes filas, y no esperar las bloqueadas? Parece una posibilidad remota, pero ...

Otra cosa que estaba pensando - tal vez no tan elegante, pero suena simple y seguro, es tener en la base de datos un contador para las instancias que hicieron selects en esa tabla. La primera instancia que aparece aumentará el contador y seleccionará la parte superior n, la siguiente incrementará el contador y seleccionará filas de n * (i-1) a n * i, y así sucesivamente ...

¿Esto suena? como un buen ideea? ¿Tienes alguna mejor sugerencia? ¡Cualquier pensamiento es muy apreciado!

Gracias por su tiempo.

Answer 1

He aquí una muestra I blogged about a while ago:

La sugerencia READPAST es lo que asegura múltiples procesos no bloquean entre sí cuando los registros de votación para procesar. Además, en este ejemplo, tengo un campo de bit para "bloquear" físicamente un registro; podría ser una fecha y hora si fuera necesario.

DECLARE @NextId INTEGER 
BEGIN TRANSACTION 

-- Find next available item available 
SELECT TOP 1 @NextId = ID 
FROM QueueTable WITH (UPDLOCK, READPAST) 
WHERE IsBeingProcessed = 0 
ORDER BY ID ASC 

-- If found, flag it to prevent being picked up again 
IF (@NextId IS NOT NULL) 
    BEGIN 
     UPDATE QueueTable 
     SET IsBeingProcessed = 1 
     WHERE ID = @NextId 
    END 

COMMIT TRANSACTION 

-- Now return the queue item, if we have one 
IF (@NextId IS NOT NULL) 
    SELECT * FROM QueueTable WHERE ID = @NextId 

Answer 2

El método más sencillo es utilizar row locking:

BEGIN TRAN 

SELECT * 
FROM authors 
WITH (HOLDLOCK, ROWLOCK) 
WHERE au_id = '274-80-9391' 

/* Do all your stuff here while the record is locked */ 

COMMIT TRAN 

Pero si se accede a sus datos y luego cerrar la conexión, usted no será capaz de utilizar este método.

¿Cuánto tiempo necesitará bloquear las filas? La mejor manera podría ser, como dice, colocar un contador en las filas que seleccione (mejor hecho usando la cláusula OUTPUT dentro de un UPDATE).

Answer 3

La mejor idea si desea seleccionar registros de esta manera sería utilizar un contador en una tabla separada.

Realmente no desea estar bloqueando filas en una base de datos de producción exclusivamente por un gran período de tiempo, por lo tanto, recomendaría usar un contador. De esta forma, solo uno de sus procesos podrá obtener ese número de contador a la vez (ya que se bloqueará a medida que se actualice), lo que le proporcionará la concurrencia que necesita.

Si necesita una mano que escriba las tablas y los procedimientos que lo harán (¡de manera sencilla y segura como usted lo mencionó!) Solo pregunte.

Answer 4

EDITAR: ahh, nevermind, estás trabajando en un estilo desconectado. ¿Qué tal esto:

UPDATE TOP (@n) QueueTable SET Locked = 1 
OUTPUT INSERTED.Col1, INSERTED.Col2 INTO @this 
WHERE Locked = 0 

<do your stuff> 

---

Tal vez usted está buscando el READPAST pista?

<begin or save transaction> 

INSERT INTO @this (Col1, Col2) 
SELECT TOP (@n) Col1, Col2 
FROM Table1 WITH (ROWLOCK, HOLDLOCK, READPAST) 

<do your stuff> 

<commit or rollback>