条件付きUpsertストアドプロシージャを実装する方法は？

Question

は、私はあなたの基本的なUPSERT機能を実装しようとしているが、ひねりを加えた：時々、私は実際には、既存の行を更新する必要はありません。

基本的に私は、異なるリポジトリの間にいくつかのデータを同期しようとしている、とアップサート機能は、移動するための方法のように思えました。だから、主にSam Saffron's answer to this question、だけでなく、いくつかの他の研究や読書に基づいて、私はこのストアドプロシージャを思い付いた：

（注：私は、MS SQL Server 2005を使用していますので、MERGE文がオプションではありません）

CREATE PROCEDURE [dbo].[usp_UpsertItem] 
    -- Add the parameters for the stored procedure here 
    @pContentID varchar(30) = null, 
    @pTitle varchar(255) = null, 
    @pTeaser varchar(255) = null 
AS 
BEGIN 
    -- SET NOCOUNT ON added to prevent extra result sets from 
    -- interfering with SELECT statements. 
    SET NOCOUNT ON; 

    BEGIN TRANSACTION 

     UPDATE dbo.Item WITH (SERIALIZABLE) 
     SET Title = @pTitle, 
      Teaser = @pTeaser 
     WHERE ContentID = @pContentID 

     IF @@rowcount = 0 
      INSERT INTO dbo.Item (ContentID, Title, Teaser) 
      VALUES (@pContentID, @pTitle, @pTeaser) 

    COMMIT TRANSACTION 
END 

私は基本的なUp​​sertについてこれに満足していますが、実際の更新を別の列の値で条件付きにしたいと考えています。 Upsertプロシージャによってそれ以上の更新が行われないように行を「ロック」すると考えてください。私はそうのようなUPDATEステートメントを変更することができます：

UPDATE dbo.Item WITH (SERIALIZABLE) 
SET Title = @pTitle, 
    Teaser = @pTeaser 
WHERE ContentID = @pContentID 
AND RowLocked = false 

しかし、それはすでに存在している行を挿入しようとしますが、ので、更新されなかったとき、その後の挿入は、（コンテンツIDフィールドの）ユニーク制約違反で失敗しますそれは "ロックされていた"。

だから、これは私が行にそれを更新または挿入することができるかどうかを判断するためにあらゆる時間を選択する必要がありますこと、すなわち、私はもはや古典アップサートを持っていることを意味しないのでしょうか？私はそれはケースだ賭けているので、私は、私は本当に手順が安全に実行されるようにトランザクション分離レベル正しいヘルプのであるために求めているものを推測します。あなたが更新の順序を切り替えることができ

Answer 1

/周りに挿入します。したがって、try/catch内で挿入を行い、制約違反が発生した場合は更新を行います。しかし、少し汚い感じ。

Answer 2

私が証拠に、私が過去数年間に使用されるこのトリックを、次のスクリプトを一緒にたたきました。それを使用する場合は、目的に合わせて変更する必要があります。コメントは次のとおりです。

/* 
CREATE TABLE Item 
(
    Title  varchar(255) not null 
    ,Teaser  varchar(255) not null 
    ,ContentId varchar(30) not null 
    ,RowLocked bit not null 
) 


UPDATE item 
set RowLocked = 1 
where ContentId = 'Test01' 

*/ 


DECLARE 
    @Check varchar(30) 
,@pContentID varchar(30) 
,@pTitle varchar(255) 
,@pTeaser varchar(255) 

set @pContentID = 'Test01' 
set @pTitle  = 'TestingTitle' 
set @pTeaser = 'TestingTeasier' 

set @check = null 

UPDATE dbo.Item 
set 
    @Check = ContentId 
    ,Title = @pTitle 
    ,Teaser = @pTeaser 
where ContentID = @pContentID 
    and RowLocked = 0 

print isnull(@check, '<check is null>') 

IF @Check is null 
    INSERT dbo.Item (ContentID, Title, Teaser, RowLocked) 
    values (@pContentID, @pTitle, @pTeaser, 0) 

select * from Item 

ここでは、Updateステートメント内のローカル変数に値を設定できるということです。上記の "フラグ"値は、アップデートが機能している場合（つまりアップデート基準が満たされている場合）にのみ設定されます。それ以外の場合は変更されません（ここでは、nullのままです）、それを確認してそれに応じて処理することができます。

トランザクションについては、トランザクションをシリアライズ可能にするために、どのように進めるべきかを提案する前に、トランザクション内にカプセル化されなければならないものについてもっと知りたいと思います。

- 補遺、-----------

あなたの主キーが定義されているので氏サフランのアイデアは、このルーチンを実装するの徹底と固体方法である下記の2番目のコメントからのフォローアップ外に出てデータベースに渡されます（つまり、あなたはIDカラムを使用していません。

もう少しテストを行いました（ContentId列にプライマリキー制約を追加し、トランザクションにUPDATEとINSERTをラップし、シリアル化可能なヒントを更新に追加しました）。更新が失敗すると、インデックスのその部分の範囲ロックが解除され、その列に新しい値を挿入しようとすると同時にブロックされます。もちろん、N個のリクエストが同時に送信された場合は、 "最初の"行が作成され、2番目、3番目などですぐに更新されます。良いトリック！

（キー列のインデックスがないと、テーブル全体がロックされることに注意してください。また、範囲ロックによって、新しい値の「両側」の行がロックされる可能性があります。私はそれをテストしませんでした。操作の期間は[？] 1桁のミリ秒でなければならないので、問題ではありません。

Answer 3

非常に一般的な問題です。いくつかのアプローチは、高い並行性の下で保持しません。説明とストレスがここでテスト：

Stress testing UPSERTs

Defensive database programming: eliminating IF statements.

をそれだけでいくつかのコードを記述するだけでは十分ではないような場合では、高い同時実行に を公開する必要があります。たとえば、私はCptSkippy の推奨事項を理解しているかどうかはわかりませんが、以下はストレステストの方法を示しています。

CREATE PROCEDURE Testers.UpsertLoop1 
AS 
BEGIN 
DECLARE @ID INT, @i1 INT, @i2 INT, @count INT, @ret INT; 
SET @count = 0; 
WHILE @count<50000 BEGIN 
     SELECT @ID = COALESCE(MAX(ID),0) + 1 FROM dbo.TwoInts; 
    EXEC @ret=dbo.SaveTwoINTs @ID, 1, 0; 
     SET @count = @count + 1; 
END; 
END; 
GO 
CREATE PROCEDURE Testers.UpsertLoop2 
AS 
BEGIN 
DECLARE @ID INT, @i1 INT, @i2 INT, @count INT, @ret INT; 
SET @count = 0; 
WHILE @count<50000 BEGIN 
     SELECT @ID = COALESCE(MAX(ID),0) + 1 FROM dbo.TwoInts; 
    EXEC @ret=dbo.SaveTwoINTs @ID, 0, 1; 
     SET @count = @count + 1; 
END; 
END; 

は二つのタブでこれらの手順を実行して、エラーの多くを得ることを自分の目で確かめてください：

CREATE TABLE [dbo].[TwoINTs](
     [ID] [int] NOT NULL, 
     [i1] [int] NOT NULL, 
     [i2] [int] NOT NULL, 
     [i3] [int] NOT NULL 
); 
CREATE PROCEDURE dbo.SaveTwoINTs(@ID INT, @i1 INT, @i2 INT) 
AS 
BEGIN 
     SET NOCOUNT ON; 
     SET XACT_ABORT OFF; 
     SET TRANSACTION ISOLATION LEVEL READ COMMITTED; 
     DECLARE @ret INT; 
     SET @ret=0; 
     BEGIN TRAN; 
IF EXISTS(SELECT 1 FROM dbo.TwoINTs WHERE ID=@ID) BEGIN 
     UPDATE dbo.TwoINTs WITH (SERIALIZABLE) 
     SET i1=i1+@i1, i2=i2+@i2 WHERE ID=@ID; 
     SET @ret=@@ERROR; 
END ELSE BEGIN 
    INSERT INTO dbo.TwoINTs(ID, i1, i2, i3)VALUES(@ID, @i1, @i2, @i1); 
     SET @ret=@@ERROR; 
END; 
COMMIT; 
RETURN @ret; 
END 
GO 

は、そのプロシージャを実行する二つのループを設定します。表と手順を設定

Testers.UpsertLoop1 --run in one tab 
Testers.UpsertLoop1 --run in one tab 

Msg 2601, Level 14, State 1, Procedure SaveTwoINTs, Line 15 
Cannot insert duplicate key row in object 'dbo.TwoINTs' with unique index 'UNQ_TwoInts_ID'. 
The statement has been terminated. 

私が提供したリンクをたどって、実際に並行処理を行う方法を確認してください。

Answer 4

PROCEDURE [DBO] [usp_UpsertItem] CREATE - 。ここで、ストアドプロシージャのパラメータを追加 @pContentIDのVARCHAR（30）= NULL、 @pTitle VARCHAR（255）= NULL、 @pTeaser VARCHAR（255 ）= null AS BEGIN - の余分な結果セットを防ぐためにSET NOCOUNT ONが追加されました。SELECTステートメントに干渉します。 SET NOCOUNT ON;

BEGIN TRANSACTION 
    IF EXISTS (SELECT 1 FROM dbo.Item WHERE ContentID = @pContentID 
      AND RowLocked = false) 
     UPDATE dbo.Item 
     SET Title = @pTitle, Teaser = @pTeaser 
     WHERE ContentID = @pContentID 
      AND RowLocked = false 
    ELSE IF NOT EXISTS (SELECT 1 FROM dbo.Item WHERE ContentID = @pContentID) 
      INSERT INTO dbo.Item (ContentID, Title, Teaser) 
      VALUES (@pContentID, @pTitle, @pTeaser) 

COMMIT TRANSACTION 

END

Answer 5

BEGIN TRANSACTION 

IF EXISTS(SELECT 1 FROM dbo.Item WHERE ContentID = @pContentID) 
    UPDATE dbo.Item WITH (SERIALIZABLE) 
    SET Title = @pTitle, Teaser = @pTeaser 
    WHERE ContentID = @pContentID 
    AND RowLocked = false 
ELSE 
    INSERT INTO dbo.Item 
      (ContentID, Title, Teaser) 
    VALUES 
      (@pContentID, @pTitle, @pTeaser) 

COMMIT TRANSACTION 

Answer 6

私はトランザクションをドロップしたいです。

プラス@@ rowcountはおそらく動作しますが、グローバル変数を条件チェックとして使用するとバグが発生します。

Exists（）チェックを行うだけです。とにかくテーブルを通過する必要があるので、スピードは問題ではありません。

私が見る限り、取引は必要ありません。