Plateforme Level Extreme
Abonnement
Profil corporatif
Produits & Services
Support
Légal
English
Locking a Record
Message
 
À
09/09/2014 12:53:19
Mike Cole
Yellow Lab Technologies
Stanley, Iowa, États-Unis
Information générale
Forum:
Microsoft SQL Server
Catégorie:
Autre
Versions des environnements
SQL Server:
SQL Server 2014
Application:
Web
Divers
Thread ID:
01607215
Message ID:
01607234
Vues:
69
>I need to retrieve a record out of a queue, and I want to lock it to make sure that only one user retrieves and is working on a record at a time.
>
>I don't think this is a complicated concept, but I've never done it before. Can somebody give me a crash course on what I'm looking for? I'm going to have a status on the record of Pending/Done I think to explicitly mark that the record has been processed, but I need to work on the locking part. This is the requirement that was provided to me:
>
>This action must be safe across multiple webservers, meaning no 2 users could possibly receive the same row at the same time (atomic operation? Cross-database locking?)

I had a similar issue for a system that sends messages to the PAs my solution (it works well, not sure if I am lucky thou) was a combination a transaction level and update command:

From WIkipedia:

Repeatable reads[edit]
In this isolation level, a lock-based concurrency control DBMS implementation keeps read and write locks (acquired on selected data) until the end of the transaction. However, range-locks are not managed, so phantom reads can occur.
		TEXT TO lcUpdate NOSHOW FLAGS 1 PRETEXT 1 + 2 + 4 TEXTMERGE
			SET TRANSACTION ISOLATION LEVEL REPEATABLE READ; 
			
			BEGIN TRANSACTION READQUEUE;

			WITH MQ(PK, Served, ServedBy) AS
				(
						SELECT		TOP 1
									MessagesQueue.PK,
									GETDATE(),
									Ports.PK
							FROM	SkyDB.SkyVoice.MessagesQueue
							JOIN	SkyDB.SkyVoice.Ports on Ports.PK = <<tnPortPK>>
							JOIN	SkyDB.SkyVoice.Priorities ON Priorities.PK = Ports.fkPriorities
							WHERE 	Served is null and MessagesQueue.Priority >= Priorities.Priority <<a bunch of other conditions>>
							ORDER	BY MessagesQueue.Priority, MessagesQueue.Queued
				)					
			UPDATE SkyDB.SkyVoice.MessagesQueue
				SET		Served		= MQ.Served,
						ServedBy	= MQ.ServedBy
				OUTPUT	Inserted.PK
				FROM	SkyDB.SkyVoice.MessagesQueue
				JOIN	MQ ON MQ.PK = MessagesQueue.PK;

	 		COMMIT TRANSACTION READQUEUE;
	 		
	 		SET TRANSACTION ISOLATION LEVEL READ COMMITTED;
		ENDTEXT
Imagine I have a number of "dialers" (in one or more computers) that are watching the MessagesQueue table, when a new message is requested and a record added to the queue I need only one of this programs to actually dial out and play the message, my thinking here is that the isolation level will put a lock on the record while selecting the records (only one, the oldest) and then does the update immediately on the field Served, which is one of the fields used to filter the select statement.

This has been working quite well for some time (2-3 years)
"The five senses obstruct or deform the apprehension of reality."
Jorge L. Borges?

"Premature optimization is the root of all evil in programming."
Donald Knuth, repeating C. A. R. Hoare

"To die for a religion is easier than to live it absolutely"
Jorge L. Borges
Précédent
Suivant
Répondre
Fil
Voir

Click here to load this message in the networking platform