MERGE(Transact-SQL)

SQL Server 및 Azure SQL Database에 대한 구문:

[ WITH <common_table_expression> [,...n] ]
MERGE
    [ TOP ( expression ) [ PERCENT ] ]
    [ INTO ] <target_table> [ WITH ( <merge_hint> ) ] [ [ AS ] table_alias ]
    USING <table_source> [ [ AS ] table_alias ]
    ON <merge_search_condition>
    [ WHEN MATCHED [ AND <clause_search_condition> ]
        THEN <merge_matched> ] [ ...n ]
    [ WHEN NOT MATCHED [ BY TARGET ] [ AND <clause_search_condition> ]
        THEN <merge_not_matched> ]
    [ WHEN NOT MATCHED BY SOURCE [ AND <clause_search_condition> ]
        THEN <merge_matched> ] [ ...n ]
    [ <output_clause> ]
    [ OPTION ( <query_hint> [ ,...n ] ) ]
;

<target_table> ::=
{
    [ database_name . schema_name . | schema_name . ] [ [ AS ] target_table ]
    | @variable [ [ AS ] target_table ]
    | common_table_expression_name [ [ AS ] target_table ]
}

<merge_hint>::=
{
    { [ <table_hint_limited> [ ,...n ] ]
    [ [ , ] { INDEX ( index_val [ ,...n ] ) | INDEX = index_val }]
    }
}

<merge_search_condition> ::=
    <search_condition>

<merge_matched>::=
    { UPDATE SET <set_clause> | DELETE }

<merge_not_matched>::=
{
    INSERT [ ( column_list ) ]
        { VALUES ( values_list )
        | DEFAULT VALUES }
}

<clause_search_condition> ::=
    <search_condition>

Azure Synapse Analytics, Fabric Data Warehouse의 구문:

[ WITH <common_table_expression> [,...n] ]
MERGE
    [ INTO ] <target_table> [ [ AS ] table_alias ]
    USING <table_source> [ [ AS ] table_alias ]
    ON <merge_search_condition>
    [ WHEN MATCHED [ AND <clause_search_condition> ]
        THEN <merge_matched> ] [ ...n ]
    [ WHEN NOT MATCHED [ BY TARGET ] [ AND <clause_search_condition> ]
        THEN <merge_not_matched> ]
    [ WHEN NOT MATCHED BY SOURCE [ AND <clause_search_condition> ]
        THEN <merge_matched> ] [ ...n ]
    [ OPTION ( <query_hint> [ ,...n ] ) ]
;  -- The semi-colon is required, or the query will return a syntax error.

<target_table> ::=
{
    [ database_name . schema_name . | schema_name . ]
  target_table
}

<merge_search_condition> ::=
    <search_condition>

<merge_matched>::=
    { UPDATE SET <set_clause> | DELETE }

<merge_not_matched>::=
{
    INSERT [ ( column_list ) ]
        VALUES ( values_list )
}

<clause_search_condition> ::=
    <search_condition>

TOP ( 표정 ) [퍼센트]

영향을 받는 행의 개수 또는 비율을 지정합니다. 식은 행의 수 또는 비율일 수 있습니다. 식에서 TOP 참조되는 행은 순서대로 정렬되지 않습니다. 자세한 내용은 TOP(Transact-SQL)을 참조하세요.

이 절은 TOP 전체 원본 테이블과 전체 대상 테이블 조인 및 삽입, 업데이트 또는 삭제 작업에 적합하지 않은 조인된 행이 제거된 후에 적용됩니다. 이 절은 TOP 조인된 행 수를 지정된 값으로 더 줄입니다. 이러한 작업(삽입, 업데이트 또는 삭제)은 정렬되지 않은 방식으로 나머지 조인된 행에 적용됩니다. 즉, 절에 정의된 작업 간에 행이 분산되는 순서는 WHEN 없습니다. 예를 들어 (10)을 지정하면 TOP 10개의 행에 영향을 줍니다. 이러한 행 중 7개는 업데이트되고 3개는 삽입되거나 1개는 삭제되고 5개는 업데이트되고 4개는 삽입될 수 있습니다.

원본 테이블에 대한 필터가 없으면 문은 원본 테이블에서 MERGE 테이블 검색 또는 클러스터형 인덱스 검색뿐만 아니라 대상 테이블의 테이블 검색 또는 클러스터형 인덱스 검색을 수행할 수 있습니다. 따라서 여러 일괄 처리를 만들어 큰 테이블을 수정하는 절을 TOP 사용하는 경우에도 I/O 성능이 영향을 받는 경우가 있습니다. 이러한 시나리오에서 연속된 모든 일괄 처리는 새로운 행을 대상으로 해야 합니다.

<merge_hint> 는 Azure Synapse Analytics에서 지원되지 않습니다.

<table_source> 는 Transact-SQL 테이블 값 생성자를 사용하여 여러 행을 지정하여 테이블을 생성하는 파생 테이블일 수 있습니다.

<table_source>는 SELECT ... UNION ALL을 사용해 여러 행을 지정하여 테이블을 생성하는 파생 테이블일 수 있습니다.

<table_hint_limited>

문에서 수행한 각 삽입, 업데이트 또는 삭제 작업에 대해 대상 테이블에 적용할 하나 이상의 테이블 힌트를 MERGE 지정합니다. WITH 키워드와 괄호가 필요합니다.

NOLOCK 허용되지 READUNCOMMITTED 않습니다. 테이블 힌트에 대한 자세한 내용은 테이블 힌트(Transact-SQL)를 참조하세요.

TABLOCK 문의 대상 INSERT 인 테이블에 힌트를 지정하면 힌트를 지정하는 것과 같은 효과가 있습니다TABLOCKX. 두 경우 모두 테이블이 배타적으로 잠깁니다. FORCESEEK를 지정할 경우 원본 테이블과 조인된 대상 테이블의 암시적 인스턴스에 이 힌트가 적용됩니다.

INDEX ( index_val [ ,... n ] )

원본 테이블과의 암시적 조인을 수행하는 대상 테이블에 있는 하나 이상의 인덱스에 대한 이름 또는 ID를 지정합니다. 자세한 내용은 테이블 힌트(Transact-SQL)를 참조하세요.

<output_clause>

업데이트, 삽입 또는 삭제되는 target_table의 모든 행과 일치하는 행을 임의의 순서로 반환합니다. $action 은 출력 절에 지정할 수 있습니다. $action는 각 행에 대해 수행된 작업에 따라 각 행INSERTUPDATE에 대한 세 가지 값 중 하나를 반환하는 nvarchar(10)DELETE의 열입니다. 절은 OUTPUT .의 영향을 받는 MERGE행을 쿼리하거나 계산하는 권장 방법입니다. 이 절의 인수 및 동작에 대한 자세한 내용은 OUTPUT 절(Transact-SQL)을 참조하세요.

기본값

삽입된 행에 각 열에 대해 정의된 기본값이 포함되도록 합니다.

이 절에 대한 자세한 내용은 INSERT(Transact-SQL)를 참조하세요.

<그래프 검색 패턴>

그래프 일치 패턴을 지정합니다. 이 절의 인수에 대한 자세한 내용은 MATCH(Transact-SQL)를 참조하세요.

Azure Synapse Analytics 고려 사항

Azure Synapse Analytics MERGE 에서 이 명령은 SQL Server 및 Azure SQL Database에 비해 다음과 같은 차이점이 있습니다.

• 배포 키 열을 업데이트하는 데 사용하는 MERGE 것은 10.0.17829.0보다 오래된 빌드에서 지원되지 않습니다. 일시 중지하거나 강제로 업그레이드할 수 없는 경우 버전 10.0.17829.0까지 ANSI UPDATE FROM ... JOIN 문을 해결 방법으로 사용합니다.
• MERGE 업데이트는 삭제 및 삽입 쌍으로 구현됩니다. 업데이트의 MERGE 영향을 받는 행 수에는 삭제된 행과 삽입된 행이 포함됩니다.
• MERGE...WHEN NOT MATCHED INSERT 는 열이 있는 IDENTITY 테이블에 대해 지원되지 않습니다.
• 원본 테이블의 절에는 USING 테이블 값 생성자를 사용할 수 없습니다. SELECT ... UNION ALL을 사용하여 여러 행이 있는 파생 원본 테이블을 만듭니다.
• 다음 표에서는 배포 유형이 다른 테이블에 대한 지원을 설명합니다.

Azure Synapse Analytics MERGE 에서 10.0.17829.0 이전 빌드의 명령은 특정 조건에서 대상 테이블을 일관되지 않은 상태로 두고 행이 잘못된 배포에 배치되어 나중에 쿼리가 잘못된 결과를 반환하도록 할 수 있습니다. 이 문제는 다음과 같은 두 가지 경우에 발생할 수 있습니다.

두 시나리오의 업데이트는 이전 MERGE 실행의 영향을 받은 테이블을 복구하지 않습니다. 다음 스크립트를 사용하여 영향을 받는 테이블을 수동으로 식별하고 복구합니다.

데이터베이스의 분산 테이블이 문제가 될 수 있는지 확인 HASH 하려면(앞에서 언급한 경우에 사용되는 경우) 다음 문을 실행합니다.

-- Case 1
SELECT a.name,
    c.distribution_policy_desc,
    b.type
FROM sys.tables a
INNER JOIN sys.indexes b
    ON a.object_id = b.object_id
INNER JOIN sys.pdw_table_distribution_properties c
    ON a.object_id = c.object_id
WHERE b.type = 2
    AND c.distribution_policy_desc = 'HASH';

-- Subject to Case 2, if distribution key value is updated in MERGE statement
SELECT a.name,
    c.distribution_policy_desc
FROM sys.tables a
INNER JOIN sys.pdw_table_distribution_properties c
    ON a.object_id = c.object_id
WHERE c.distribution_policy_desc = 'HASH';

분산 테이블 HASH 이 사례 1 또는 사례 2의 영향을 받는지 MERGE 확인하려면 다음 단계에 따라 테이블에 행이 잘못된 분포로 배치되었는지 검사합니다. 반환되는 경우 no need for repair 이 테이블은 영향을 받지 않습니다.

IF object_id('[check_table_1]', 'U') IS NOT NULL
    DROP TABLE [check_table_1]
GO

IF object_id('[check_table_2]', 'U') IS NOT NULL
    DROP TABLE [check_table_2]
GO

CREATE TABLE [check_table_1]
    WITH (DISTRIBUTION = ROUND_ROBIN) AS

SELECT <DISTRIBUTION_COLUMN> AS x
FROM <MERGE_TABLE>
GROUP BY <DISTRIBUTION_COLUMN>;
GO

CREATE TABLE [check_table_2]
    WITH (DISTRIBUTION = HASH (x)) AS

SELECT x
FROM [check_table_1];
GO

IF NOT EXISTS (
        SELECT TOP 1 *
        FROM (
            SELECT <DISTRIBUTION_COLUMN> AS x
            FROM <MERGE_TABLE>

            EXCEPT

            SELECT x
            FROM [check_table_2]
            ) AS tmp
        )
    SELECT 'no need for repair' AS result
ELSE
    SELECT 'needs repair' AS result
GO

IF object_id('[check_table_1]', 'U') IS NOT NULL
    DROP TABLE [check_table_1]
GO

IF object_id('[check_table_2]', 'U') IS NOT NULL
    DROP TABLE [check_table_2]
GO

영향을 받는 테이블을 복구하려면 이 문을 실행하여 이전 테이블의 모든 행을 새 테이블로 복사해야 합니다.

IF object_id('[repair_table_temp]', 'U') IS NOT NULL
    DROP TABLE [repair_table_temp];
GO

IF object_id('[repair_table]', 'U') IS NOT NULL
    DROP TABLE [repair_table];
GO

CREATE TABLE [repair_table_temp]
    WITH (DISTRIBUTION = ROUND_ROBIN) AS

SELECT *
FROM <MERGE_TABLE>;
GO

-- [repair_table] will hold the repaired table generated from <MERGE_TABLE>
CREATE TABLE [repair_table]
    WITH (DISTRIBUTION = HASH (<DISTRIBUTION_COLUMN>)) AS

SELECT *
FROM [repair_table_temp];
GO

IF object_id('[repair_table_temp]', 'U') IS NOT NULL
    DROP TABLE [repair_table_temp];
GO

Troubleshooting

특정 시나리오에서 문은 MERGE 대상 또는 원본 테이블에 열이 1,024개 없는 경우에도 오류가 CREATE TABLE failed because column <> in table <> exceeds the maximum of 1024 columns.발생할 수 있습니다. 이 시나리오는 다음 조건 중 어느 것이라도 충족될 때 발생할 수 있습니다.

• 여러 열이 (절 DELETE 에 UPDATE SETINSERT특정되지 않음) 내 MERGE 의 WHEN [NOT] MATCHED 또는 연산에 지정됩니다.
• 조건의 모든 열에 JOIN NCI(비클러스터형 인덱스)가 있습니다.
• 대상 테이블이 HASH 분산됨

이 오류가 발견되면 제안된 해결 방법은 다음과 같습니다.

• 열에서 JOIN NCI(비클러스터형 인덱스)를 제거하거나 NCI가 없는 열에 조인합니다. 나중에 열 JOIN 에 MERGE NCI를 포함하도록 기본 테이블을 업데이트하는 경우 문이 런타임 시 이 오류에 취약할 수 있습니다. 자세한 내용은 DROP INDEX를 참조하세요.
• 대신 UPDATE, DELETE 및 INSERT 문을 MERGE사용합니다.

CREATE PROCEDURE dbo.InsertUnitMeasure @UnitMeasureCode NCHAR(3), @Name NVARCHAR(25)
AS
BEGIN
    SET NOCOUNT ON;

    -- Update the row if it exists.
    UPDATE Production.UnitMeasure
    SET Name = @Name
    WHERE UnitMeasureCode = @UnitMeasureCode

    -- Insert the row if the UPDATE statement failed.
    IF (@@ROWCOUNT = 0)
    BEGIN
        INSERT INTO Production.UnitMeasure (
            UnitMeasureCode,
            Name
        )
        VALUES (@UnitMeasureCode, @Name)
    END
END;
GO

-- Test the procedure and return the results.
EXEC InsertUnitMeasure @UnitMeasureCode = 'ABC', @Name = 'Test Value';

SELECT UnitMeasureCode, Name
FROM Production.UnitMeasure
WHERE UnitMeasureCode = 'ABC';
GO

-- Rewrite the procedure to perform the same operations using the
-- MERGE statement.
-- Create a temporary table to hold the updated or inserted values
-- from the OUTPUT clause.
CREATE TABLE #MyTempTable (
    ExistingCode NCHAR(3),
    ExistingName NVARCHAR(50),
    ExistingDate DATETIME,
    ActionTaken NVARCHAR(10),
    NewCode NCHAR(3),
    NewName NVARCHAR(50),
    NewDate DATETIME
);
GO

ALTER PROCEDURE dbo.InsertUnitMeasure @UnitMeasureCode NCHAR(3),
    @Name NVARCHAR(25)
AS
BEGIN
    SET NOCOUNT ON;

    MERGE Production.UnitMeasure AS tgt
    USING (SELECT @UnitMeasureCode, @Name) AS src(UnitMeasureCode, Name)
        ON (tgt.UnitMeasureCode = src.UnitMeasureCode)
    WHEN MATCHED
        THEN
            UPDATE
            SET Name = src.Name
    WHEN NOT MATCHED
        THEN
            INSERT (UnitMeasureCode, Name)
            VALUES (src.UnitMeasureCode, src.Name)
    OUTPUT deleted.*,
        $action,
        inserted.*
    INTO #MyTempTable;
END;
GO

-- Test the procedure and return the results.
EXEC InsertUnitMeasure @UnitMeasureCode = 'ABC', @Name = 'New Test Value';
EXEC InsertUnitMeasure @UnitMeasureCode = 'XYZ', @Name = 'Test Value';
EXEC InsertUnitMeasure @UnitMeasureCode = 'ABC', @Name = 'Another Test Value';

SELECT * FROM #MyTempTable;

-- Cleanup
DELETE FROM Production.UnitMeasure
WHERE UnitMeasureCode IN ('ABC', 'XYZ');

DROP TABLE #MyTempTable;
GO

CREATE PROCEDURE dbo.InsertUnitMeasure @UnitMeasureCode NCHAR(3),
    @Name NVARCHAR(25)
AS
BEGIN
    SET NOCOUNT ON;

    -- Update the row if it exists.
    UPDATE Production.UnitMeasure
    SET Name = @Name
    WHERE UnitMeasureCode = @UnitMeasureCode

    -- Insert the row if the UPDATE statement failed.
    IF (@@ROWCOUNT = 0)
    BEGIN
        INSERT INTO Production.UnitMeasure (
            UnitMeasureCode,
            Name
        )
        VALUES (@UnitMeasureCode, @Name)
    END
END;
GO

-- Test the procedure and return the results.
EXEC InsertUnitMeasure @UnitMeasureCode = 'ABC', @Name = 'Test Value';

SELECT UnitMeasureCode, Name
FROM Production.UnitMeasure
WHERE UnitMeasureCode = 'ABC';
GO

-- Rewrite the procedure to perform the same operations using the
-- MERGE statement.
ALTER PROCEDURE dbo.InsertUnitMeasure @UnitMeasureCode NCHAR(3),
    @Name NVARCHAR(25)
AS
BEGIN
    SET NOCOUNT ON;

    MERGE Production.UnitMeasure AS tgt
    USING (
        SELECT @UnitMeasureCode,
            @Name
        ) AS src(UnitMeasureCode, Name)
        ON (tgt.UnitMeasureCode = src.UnitMeasureCode)
    WHEN MATCHED
        THEN
            UPDATE SET Name = src.Name
    WHEN NOT MATCHED
        THEN
            INSERT (UnitMeasureCode, Name)
            VALUES (src.UnitMeasureCode, src.Name);
END;
GO

-- Test the procedure and return the results.
EXEC InsertUnitMeasure @UnitMeasureCode = 'ABC', @Name = 'New Test Value';
EXEC InsertUnitMeasure @UnitMeasureCode = 'XYZ', @Name = 'Test Value';
EXEC InsertUnitMeasure @UnitMeasureCode = 'ABC', @Name = 'Another Test Value';

-- Cleanup
DELETE FROM Production.UnitMeasure
WHERE UnitMeasureCode IN ('ABC', 'XYZ');
GO

CREATE PROCEDURE Production.usp_UpdateInventory @OrderDate DATETIME
AS
MERGE Production.ProductInventory AS tgt
USING (
    SELECT ProductID,
        SUM(OrderQty)
    FROM Sales.SalesOrderDetail AS sod
    INNER JOIN Sales.SalesOrderHeader AS soh
        ON sod.SalesOrderID = soh.SalesOrderID
            AND soh.OrderDate = @OrderDate
    GROUP BY ProductID
    ) AS src(ProductID, OrderQty)
    ON (tgt.ProductID = src.ProductID)
WHEN MATCHED
    AND tgt.Quantity - src.OrderQty <= 0
    THEN
        DELETE
WHEN MATCHED
    THEN
        UPDATE
        SET tgt.Quantity = tgt.Quantity - src.OrderQty,
            tgt.ModifiedDate = GETDATE()
OUTPUT $action,
    Inserted.ProductID,
    Inserted.Quantity,
    Inserted.ModifiedDate,
    Deleted.ProductID,
    Deleted.Quantity,
    Deleted.ModifiedDate;
GO

EXECUTE Production.usp_UpdateInventory '20030501';

CREATE PROCEDURE Production.usp_UpdateInventory @OrderDate DATETIME
AS
MERGE Production.ProductInventory AS tgt
USING (
    SELECT ProductID,
        SUM(OrderQty)
    FROM Sales.SalesOrderDetail AS sod
    INNER JOIN Sales.SalesOrderHeader AS soh
        ON sod.SalesOrderID = soh.SalesOrderID
            AND soh.OrderDate = @OrderDate
    GROUP BY ProductID
    ) AS src(ProductID, OrderQty)
    ON (tgt.ProductID = src.ProductID)
WHEN MATCHED
    AND tgt.Quantity - src.OrderQty <= 0
    THEN
        DELETE
WHEN MATCHED
    THEN
        UPDATE
        SET tgt.Quantity = tgt.Quantity - src.OrderQty,
            tgt.ModifiedDate = GETDATE();
GO

EXECUTE Production.usp_UpdateInventory '20030501';

원본 테이블의 NewName 값이 대상 테이블 Name의 SalesReason 열에 있는 값과 일치하는 경우 대상 테이블에서 ReasonType 열이 업데이트됩니다. NewName 값이 일치하지 않으면 원본 행이 대상 테이블에 삽입됩니다. 원본 테이블은 Transact-SQL 테이블 값 생성자를 사용하여 원본 테이블의 여러 행을 지정하는 파생 테이블입니다. 파생 테이블에서 테이블 값 생성자를 사용하는 방법에 대한 자세한 내용은 테이블 값 생성자(Transact-SQL)를 참조하세요.

이 절은 OUTPUT 문의 결과를 MERGE 쿼리하는 데 유용할 수 있습니다. 자세한 내용은 OUTPUT 절(Transact-SQL)을 참조하세요. 이 예제에서는 절의 결과를 테이블 변수에 OUTPUT 저장하는 방법도 보여줍니다. 그런 다음 삽입 및 업데이트된 행 수를 MERGE 반환하는 간단한 선택 작업을 실행하여 문의 결과를 요약합니다.

-- Create a temporary table variable to hold the output actions.
DECLARE @SummaryOfChanges TABLE (Change VARCHAR(20));

MERGE INTO Sales.SalesReason AS tgt
USING (
    VALUES ('Recommendation', 'Other'),
        ('Review', 'Marketing'),
        ('Internet', 'Promotion')
    ) AS src(NewName, NewReasonType)
    ON tgt.Name = src.NewName
WHEN MATCHED
    THEN
        UPDATE
        SET ReasonType = src.NewReasonType
WHEN NOT MATCHED BY TARGET
    THEN
        INSERT (Name, ReasonType)
        VALUES (NewName, NewReasonType)
OUTPUT $action
INTO @SummaryOfChanges;

-- Query the results of the table variable.
SELECT Change,
    COUNT(*) AS CountPerChange
FROM @SummaryOfChanges
GROUP BY Change;

원본 테이블의 NewName 값이 대상 테이블 Name의 SalesReason 열에 있는 값과 일치하는 경우 대상 테이블에서 ReasonType 열이 업데이트됩니다. NewName 값이 일치하지 않으면 원본 행이 대상 테이블에 삽입됩니다. 원본 테이블은 SELECT ... UNION ALL을 사용하여 원본 테이블의 여러 행을 지정하는 파생 테이블입니다.

MERGE INTO Sales.SalesReason AS tgt
USING (
    SELECT 'Recommendation', 'Other'
    UNION ALL
    SELECT 'Review', 'Marketing'
    UNION ALL
    SELECT 'Internet', 'Promotion'
    ) AS src(NewName, NewReasonType)
    ON tgt.Name = src.NewName
WHEN MATCHED
    THEN
        UPDATE SET ReasonType = src.NewReasonType
WHEN NOT MATCHED BY TARGET
    THEN
        INSERT (Name, ReasonType)
        VALUES (NewName, NewReasonType);

D. MERGE 문의 결과를 다른 테이블에 삽입합니다.

다음 예제에서는 문 절 OUTPUT 에서 반환된 MERGE 데이터를 캡처하고 해당 데이터를 다른 테이블에 삽입합니다. 이 문은 MERGE 테이블에서 처리되는 주문에 따라 AdventureWorks2022 데이터베이스의 Quantity 테이블 열을 ProductInventory 업데이트 SalesOrderDetail 합니다. 이 예에서는 업데이트된 행을 캡처하여 재고 변경 내용을 추적하는 데 사용되는 다른 테이블에 삽입합니다.

CREATE TABLE Production.UpdatedInventory (
    ProductID INT NOT NULL,
    LocationID INT,
    NewQty INT,
    PreviousQty INT,
    CONSTRAINT PK_Inventory PRIMARY KEY CLUSTERED (
        ProductID,
        LocationID
        )
    );
GO

INSERT INTO Production.UpdatedInventory
SELECT ProductID, LocationID, NewQty, PreviousQty
FROM (
    MERGE Production.ProductInventory AS pi
    USING (
        SELECT ProductID, SUM(OrderQty)
        FROM Sales.SalesOrderDetail AS sod
        INNER JOIN Sales.SalesOrderHeader AS soh
            ON sod.SalesOrderID = soh.SalesOrderID
                AND soh.OrderDate BETWEEN '20030701'
                    AND '20030731'
        GROUP BY ProductID
        ) AS src(ProductID, OrderQty)
        ON pi.ProductID = src.ProductID
    WHEN MATCHED
        AND pi.Quantity - src.OrderQty >= 0
        THEN
            UPDATE SET pi.Quantity = pi.Quantity - src.OrderQty
    WHEN MATCHED
        AND pi.Quantity - src.OrderQty <= 0
        THEN
            DELETE
    OUTPUT $action,
        Inserted.ProductID,
        Inserted.LocationID,
        Inserted.Quantity AS NewQty,
        Deleted.Quantity AS PreviousQty
    ) AS Changes(Action, ProductID, LocationID, NewQty, PreviousQty)
WHERE Action = 'UPDATE';
GO

E. MERGE를 사용하여 그래프 데이터베이스의 대상 에지 테이블에서 INSERT 또는 UPDATE를 수행합니다.

이 예제에서는 노드 테이블 Person 및 City와 에지 테이블 livesIn을 만듭니다. 에지와 MERGE 에지 사이에 가장자리가 livesIn 아직 없는 경우 에지에서 문을 사용하고 새 행을 PersonCity삽입합니다. 에지가 이미 있는 경우 livesIn 에지에 대해 StreetAddress 특성만 업데이트하면 됩니다.

-- CREATE node and edge tables
CREATE TABLE Person
(
    ID INTEGER PRIMARY KEY,
    PersonName VARCHAR(100)
)
AS NODE
GO

CREATE TABLE City
(
    ID INTEGER PRIMARY KEY,
    CityName VARCHAR(100),
    StateName VARCHAR(100)
)
AS NODE
GO

CREATE TABLE livesIn
(
    StreetAddress VARCHAR(100)
)
AS EDGE
GO

-- INSERT some test data into node and edge tables
INSERT INTO Person VALUES (1, 'Ron'), (2, 'David'), (3, 'Nancy')
GO

INSERT INTO City VALUES (1, 'Redmond', 'Washington'), (2, 'Seattle', 'Washington')
GO

INSERT livesIn SELECT P.$node_id, C.$node_id, c
FROM Person P, City C, (values (1,1, '123 Avenue'), (2,2,'Main Street')) v(a,b,c)
WHERE P.id = a AND C.id = b
GO

-- Use MERGE to update/insert edge data
CREATE OR ALTER PROCEDURE mergeEdge
    @PersonId integer,
    @CityId integer,
    @StreetAddress varchar(100)
AS
BEGIN
    MERGE livesIn
        USING ((SELECT @PersonId, @CityId, @StreetAddress) AS T (PersonId, CityId, StreetAddress)
                JOIN Person ON T.PersonId = Person.ID
                JOIN City ON T.CityId = City.ID)
        ON MATCH (Person-(livesIn)->City)
    WHEN MATCHED THEN
        UPDATE SET StreetAddress = @StreetAddress
    WHEN NOT MATCHED THEN
        INSERT ($from_id, $to_id, StreetAddress)
        VALUES (Person.$node_id, City.$node_id, @StreetAddress) ;
END
GO

-- Following will insert a new edge in the livesIn edge table
EXEC mergeEdge 3, 2, '4444th Avenue'
GO

-- Following will update the StreetAddress on the edge that connects Ron to Redmond
EXEC mergeEdge 1, 1, '321 Avenue'
GO

-- Verify that all the address were added/updated correctly
SELECT PersonName, CityName, StreetAddress
FROM Person , City , livesIn
WHERE MATCH(Person-(livesIn)->city)
GO