Только вставив строку, если ее там еще нет - PullRequest
66 голосов
/ 04 августа 2010

Я всегда использовал для этого что-то похожее на следующее:

INSERT INTO TheTable
SELECT
    @primaryKey,
    @value1,
    @value2
WHERE
    NOT EXISTS
    (SELECT
        NULL
    FROM
        TheTable
    WHERE
        PrimaryKey = @primaryKey)

... но при загрузке произошло нарушение первичного ключа.Это единственное утверждение, которое вообще вставляется в эту таблицу.Значит ли это, что приведенное выше утверждение не является атомарным?

Проблема в том, что это почти невозможно воссоздать по желанию.

Возможно, я мог бы изменить его на что-то вроде следующего:

INSERT INTO TheTable
WITH
    (HOLDLOCK,
    UPDLOCK,
    ROWLOCK)
SELECT
    @primaryKey,
    @value1,
    @value2
WHERE
    NOT EXISTS
    (SELECT
        NULL
    FROM
        TheTable
    WITH
        (HOLDLOCK,
        UPDLOCK,
        ROWLOCK)
    WHERE
        PrimaryKey = @primaryKey)

Хотя, возможно, я использую неправильные блокировки или использую слишком много блокировок или что-то в этом роде.

Я видел другие вопросы на stackoverflow.com, где ответы предлагают "ЕСЛИ (ВЫБРАТЬ)COUNT (*) ... INSERT "и т. Д., Но я всегда придерживался (возможно, неверного) предположения, что один SQL-оператор будет атомарным.

У кого-нибудь есть идеи?

Ответы [ 6 ]

56 голосов
/ 04 августа 2010

А как насчет шаблона "JFDI" ?

BEGIN TRY
   INSERT etc
END TRY
BEGIN CATCH
    IF ERROR_NUMBER() <> 2627
      RAISERROR etc
END CATCH

Серьезно, это самый быстрый и самый параллельный процесс без блокировок, особенно при больших объемах.Что, если UPDLOCK увеличен и вся таблица заблокирована?

Читать урок 4 :

Урок 4: При разработкеДо настройки индексов upsert proc сначала убедился, что строка If Exists(Select…) будет срабатывать для любого элемента и запрещать дублирование.Нада.За короткое время появились тысячи дубликатов, потому что один и тот же элемент попадал бы в верхний предел в одну и ту же миллисекунду, и обе транзакции увидели бы, что не существует, и выполнили вставку.После тщательного тестирования решение состояло в том, чтобы использовать уникальный индекс, перехватить ошибку и повторить попытку, чтобы транзакция увидела строку и выполнила обновление вместо вставки.

23 голосов
/ 04 августа 2010

Я добавил HOLDLOCK, которого изначально не было. Пожалуйста, не обращайте внимания на версию без этой подсказки.

Насколько мне известно, этого должно быть достаточно:

INSERT INTO TheTable 
SELECT 
    @primaryKey, 
    @value1, 
    @value2 
WHERE 
    NOT EXISTS 
    (SELECT 0
     FROM TheTable WITH (UPDLOCK, HOLDLOCK)
     WHERE PrimaryKey = @primaryKey) 

Кроме того, если вы действительно хотите обновить строку, если она существует, и вставить, если она не существует, вы можете найти этот вопрос полезным.

17 голосов
/ 04 августа 2010

Вы можете использовать MERGE:

MERGE INTO Target
USING (VALUES (@primaryKey, @value1, @value2)) Source (key, value1, value2)
ON Target.key = Source.key
WHEN MATCHED THEN
    UPDATE SET value1 = Source.value1, value2 = Source.value2
WHEN NOT MATCHED BY TARGET THEN
    INSERT (Name, ReasonType) VALUES (@primaryKey, @value1, @value2)
1 голос
/ 03 мая 2017

Во-первых, огромное спасибо нашему человеку @gbn за его вклад в сообщество.Даже не могу объяснить, как часто я следую его совету.

В любом случае, достаточно фанатов.

Чтобы немного добавить к своему ответу, возможно, "улучшить" его.Для тех, кто, как и я, осталось неуверенным, что делать в сценарии <> 2627 (и пустой CATCH не вариант).Я нашел этот маленький самородок из technet .

    BEGIN TRY
       INSERT etc
    END TRY
    BEGIN CATCH
        IF ERROR_NUMBER() <> 2627
          BEGIN
                DECLARE @ErrorMessage NVARCHAR(4000);
                DECLARE @ErrorSeverity INT;
                DECLARE @ErrorState INT;

                SELECT @ErrorMessage = ERROR_MESSAGE(),
                @ErrorSeverity = ERROR_SEVERITY(),
                @ErrorState = ERROR_STATE();

                    RAISERROR (
                        @ErrorMessage,
                        @ErrorSeverity,
                        @ErrorState
                    );
          END
    END CATCH
1 голос
/ 04 августа 2010

Я не знаю, является ли это "официальным" способом, но вы можете попробовать INSERT и вернуться к UPDATE, если это не удастся.

0 голосов
/ 04 августа 2010

Я делал аналогичную операцию в прошлом, используя другой метод. Сначала я объявляю переменную для хранения первичного ключа. Затем я заполняю эту переменную выводом оператора select, который ищет запись с этими значениями. Тогда я делаю и ЕСЛИ заявление. Если первичный ключ пуст, вставьте, иначе верните код ошибки.

     DECLARE @existing varchar(10)
    SET @existing = (SELECT primaryKey FROM TABLE WHERE param1field = @param1 AND param2field = @param2)

    IF @existing is not null
    BEGIN
    INSERT INTO Table(param1Field, param2Field) VALUES(param1, param2)
    END
    ELSE
    Return 0
END
...