LINQ to SQL - обновление для увеличения поля, не являющегося первичным ключом - поточно-ориентированный - PullRequest
Новая
       13

LINQ to SQL - обновление для увеличения поля, не являющегося первичным ключом - поточно-ориентированный

3 голосов
/ 31 января 2009

У меня есть две таблицы (ну, две, относящиеся к этому вопросу):

Ставки (содержит ставки; Столбцы: Id, MessagesPosted,) Bets_Messages (содержит сообщения форума ставок; столбцы: Id, BetId,)

Когда я вставляю новое BetMessage в Bets_Messages, я хочу обновить (с точностью до приращения) соответствующее поле в Bets.

В чистом T-SQL это будет: 

INSERT INTO Bets_Messages (BetId, <bla bla>) VALUES (23, "asfasdfasdf");
UPDATE Bets SET MessagesPosted = MessagesPosted + 1 WHERE Id = 23;

Приведенный выше код работал бы замечательно, и он безопасен для потоков; Если два потока сделают к нему вызовы из БД (и для одной и той же ставки), столбец MessagesPosted будет красиво увеличен, так как первый UPDATE поместит в него хотя бы ROWLOCK, практически сериализуя UPDATE.

Однако использование LINQ to SQL приводит к более сложному подходу: 

    public void PostMessage(MyProject.Entities.BetMessage betMessageEntity)
    {
        DatabaseDataContext ctx = GetFreshContext(); // GetFreshContext is a private method that practically initializes a new DataContext
        Bets_Message msg = new Bets_Message(betMessageEntity);
        ctx.Bets_Messages.InsertOnSubmit(msg);
        Bet bet = (from b in ctx.Bets where b.Id == (long)betMessageEntity.BetId select b).Single();
        bet.MessagesPosted++;
        ctx.SubmitChanges();
    }

Хорошо выглядит, а? Ну вот что он сгенерирует: 

exec sp_executesql N'INSERT INTO [dbo].[Bets_Messages]([ParentMessageId], [BetsId], [UserId], [Subject], [DisplayXml], [Time], [ReplyDepth], [Text])
VALUES (@p0, @p1, @p2, @p3, @p4, @p5, @p6, @p7)

SELECT CONVERT(BigInt,SCOPE_IDENTITY()) AS [value]',N'@p0 bigint,@p1 bigint,@p2 uniqueidentifier,@p3 nvarchar(6),@p4 nvarchar(114),@p5 datetime2(7),@p6 tinyint,@p7 nvarchar(8)',@p0=NULL,@p1=1,@p2='A0D253AF-6261-49AE-8C11-BA6117EF35C7',@p3=N'aaawww',@p4=N'<m ai="a0d253af-6261-49ae-8c11-ba6117ef35c7" a="AndreiR" s="aaawww" t="2009-01-31T18:04:31.282+02:00">wwwwwaaa</m>',@p5='2009-01-31 18:04:31.2820000',@p6=0,@p7=N'wwwwwaaa'

(для вставки BetMessage) и для ОБНОВЛЕНИЯ: 

exec sp_executesql N'UPDATE [dbo].[Bets]
SET [MessagesPosted] = @p17
WHERE ([Id] = @p0) AND ([UserId] = @p1) AND ([Bets_CategoriesId] = @p2) AND ([Bets_TypesId] = @p3) AND ([TotalSum] = @p4) AND ([TotalBetters] = @p5) AND ([CreateDate] = @p6) AND ([DeadlineDate] = @p7) AND ([ClosedDate] IS NULL) AND ([Bets_StatusesId] = @p8) AND ([LastBetAdded] IS NULL) AND ([Title] = @p9) AND ([ShortDescription] = @p10) AND ([Description] = @p11) AND ([DescriptionPlainText] = @p12) AND ([Version] = @p13) AND ([ReviewedBy] = @p14) AND ([UrlFragment] = @p15) AND ([MessagesPosted] = @p16) AND ([ClosedBy] IS NULL) AND ([OutcomeNumber] IS NULL)',N'@p0 bigint,@p1 uniqueidentifier,@p2 smallint,@p3 tinyint,@p4 money,@p5 int,@p6 datetime2(7),@p7 datetime2(7),@p8 tinyint,@p9 nvarchar(7),@p10 nvarchar(30),@p11 nvarchar(33),@p12 nvarchar(22),@p13 smallint,@p14 uniqueidentifier,@p15 varchar(7),@p16 int,@p17 int',@p0=1,@p1='A0D253AF-6261-49AE-8C11-BA6117EF35C7',@p2=2,@p3=1,@p4=$0.0000,@p5=0,@p6='2008-12-03 00:00:00',@p7='2008-12-31 00:00:00',@p8=2,@p9=N'Pariu 1',@p10=N'Descriere pariu 1 - text chior',@p11=N'Descriere pe larg 1 - html permis',@p12=N'descriere text chior 1',@p13=1,@p14='A0D253AF-6261-49AE-8C11-BA6117EF35C7',@p15='pariu-1',@p16=18,@p17=19

Проблема с T-SQL, сгенерированным для ОБНОВЛЕНИЯ, состоит в том, что, хотя он выглядит нормально для обеспечения безопасности потока, он, вероятно, выдаст ошибку во втором потоке, выполняющем обновление строки, вместо того, чтобы ждать его завершения. Будет ли это?

Вот почему я так думаю.

1-й поток делает это:

вставить соответствующее betMessage, обновить строку ставки, чтобы увеличить MessagePosted с 0 до 1

2-й поток сделает это:

вставить соответствующее betMessage, обновите строку ставки, чтобы увеличить значение MessagePosted с 0 до 1 (при прочтении было 0). Однако теперь оно равно 1, и предложение WHERE не обновляет его, поскольку предложение wHERE оценивается как ложное. 0 затронутых строк будут отправлены клиенту LINQ, что, в свою очередь, вызовет исключение.

Поэтому мне придется писать свой код попытки повторной попытки f * # $ ing вместо того, чтобы полагаться на блокировку строк в SQL Server.

Есть ли какой-нибудь достойный подход, который использует LINQ to SQL и NOT хранимые процедуры, специальные запросы и т. Д.?

Спасибо за ваше терпение читать этот длинный пост ..

1 Ответ

1 голос
/ 31 января 2009

РЕДАКТИРОВАТЬ : На самом деле после перечитывания вашего поста, я думаю, что автоматическая транзакция, созданная SubmitChanges, уже позаботится о том, чтобы все операторы были выполнены или не выполнены. Я думал, что, поскольку вы используете автоматически сгенерированный идентификатор, вы будете выполнять двухэтапное обновление в LINQ, но, похоже, SubmitChanges справится с этим за вас.

Я оставлю код ниже для справки, хотя я не думаю, что это требуется. Ссылка внизу объясняет различные способы совершения транзакции.

Вам нужна область транзакции, чтобы обернуть весь набор вставок / обновлений. 

using System.Transactions;

public void PostMessage(MyProject.Entities.BetMessage betMessageEntity)
{
    using (TransactionScope scope = new TransactionScope()) {
       DatabaseDataContext ctx = GetFreshContext();
       Bets_Message msg = new Bets_Message(betMessageEntity);
       ctx.Bets_Messages.InsertOnSubmit(msg);
       ctx.SubmitChanges();  // this is what I thought you did
       Bet bet = (from b in ctx.Bets
                  where b.Id == (long)betMessageEntity.BetId select b)
                 .Single();
       bet.MessagesPosted++;
       ctx.SubmitChanges();
       scope.Complete();
    }
}

Я не думаю, что это вызовет автоматическое продвижение к распределенной транзакции, поскольку все команды повторно используют одно и то же соединение в контексте данных. Если окажется, что это так, вы можете создать транзакцию для соединения контекста данных и назначить ее свойству Transaction контекста данных. Однако, если вы сделаете это, вам придется управлять им и распоряжаться им самостоятельно.

Дополнительная информация о LINQ2SQL и транзакциях на MSDN .

...