Entsperrte Zeilen in einer "select top n" -Abfrage zurückgeben

Question

Ich muss eine MsSql-Datenbanktabelle und weitere 8 (identische) Prozesse haben, die parallel auf die gleiche Tabelle zugreifen - eine Auswahl top n machen, diese n Zeilen verarbeiten und a aktualisieren Spalte dieser Zeilen. Das Problem ist, dass ich jede Zeile nur einmal auswählen und verarbeiten muss. Das heißt, wenn ein Prozess in die Datenbank gelangt und die obersten n Zeilen ausgewählt hat, sollte er beim Blockieren des zweiten Prozesses diese Zeilen finden und die Zeilen von n bis 2 * n Zeilen auswählen, und so weiter ...

Ist es möglich, einige Zeilen zu sperren, wenn Sie sie auswählen, und wenn jemand oben n Zeilen anfordert, die gesperrt sind, um die nächsten Zeilen zurückzugeben und nicht auf die gesperrten zu warten? Scheint wie eine Totale, aber ...

Eine andere Sache, die ich dachte - vielleicht nicht so elegant, aber klingt einfach und sicher, ist in der Datenbank einen Zähler für die Instanzen zu haben, die Selects auf diesem Tisch gemacht. Die erste Instanz, die kommt, inkrementiert den Zähler und wählt top n aus, der nächste inkrementiert den Zähler und wählt Zeilen von n * (i-1) bis n * i und so weiter ...

Hört sich an Wie eine gute Idee? Hast du bessere Vorschläge? Jeder Gedanke wird sehr geschätzt!

Danke für Ihre Zeit.

Answer 1

Hier ist eine Probe I blogged about a while ago:

Der READPAST Hinweis ist, was mehrere Prozesse sorgt für einander nicht blockieren, wenn die Abfrage von Datensätzen zu verarbeiten. Außerdem habe ich in diesem Beispiel ein Bitfeld, um einen Datensatz physisch zu "sperren" - könnte bei Bedarf eine Datetime sein.

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

Die einfachste Methode ist row locking zu verwenden:

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 

Aber wenn Sie Ihre Daten zugreifen und dann das Schließen der Verbindung, werden Sie nicht in der Lage sein, diese Methode zu verwenden.

Wie lange müssen Sie die Zeilen sperren? Der beste Weg könnte tatsächlich sein, wie Sie sagen, um einen Zähler auf die Zeilen setzen, die Sie auswählen (am besten mit OUTPUT Klausel innerhalb einer UPDATE).

Answer 3

Die beste Idee, wenn Sie Datensätze auf diese Weise auswählen möchten, wäre ein Zähler in einer separaten Tabelle zu verwenden.

Sie möchten wirklich keine Reihen in einer Produktionsdatenbank ausschließlich für längere Zeit sperren, deshalb würde ich empfehlen, einen Zähler zu verwenden. Auf diese Weise ist nur einer Ihrer Prozesse in der Lage, diese Counter-Nummer zu einem bestimmten Zeitpunkt zu übernehmen (da sie während der Aktualisierung gesperrt wird), wodurch Sie die von Ihnen benötigte Parallelität erhalten.

Wenn Sie eine Hand brauchen, die Tabellen und Prozeduren schreibt, die das tun (einfach und sicher, wie Sie es sagen!), Fragen Sie einfach.

Answer 4

EDIT: ahh, vergiss, du arbeitest in einem getrennten Stil. Wie wäre es damit:

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

<do your stuff> 

---

Vielleicht suchen Sie für den READPAST Hinweis?

<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>