MERGE example

1. Update an existing product's UnitsInStock if it exists, otherwise insert a new product.

SQL Server Query 1

            
 -- Update an existing product's UnitsInStock if it exists, otherwise insert a new product.  

 -- Create a temporary  table to show MERGE  

 SELECT 1 AS ProductID, CAST('the product name' AS NVARCHAR(MAX)) AS ProductName,   

 	CAST(0.00 AS money) AS UnitPrice, CAST(0 AS INT) AS UnitsInStock, CAST(0 AS bit) AS Discontinued  

 INTO #PRODUCTTEMP  

 -- Clear the temporary table  

 DELETE FROM #PRODUCTTEMP WHERE ProductID = 1  

 -- Inserts some value in temporary table  

 INSERT INTO #PRODUCTTEMP VALUES (1, 'Chai', 18.00, 100, 0),  

 	(2, 'Chang', 19.00, 17, 0),  

 	(3, 'Aniseed Syrup', 10.00, 13, 0),  

 	(4, 'Ikura', 31.00, 32, 0),  

 	(5, 'Pavlova', 17.45, 29, 0)  

   

 MERGE INTO #PRODUCTTEMP AS Target   

 USING (VALUES  

 	(78, 'New Gadget', 120.35, 50, 0), -- New product (ProductID, ProductName, UnitPrice, UnitsInStock, Discontinued)  

 	(1, 'Chai', 18.00, 10000, 0) -- Existing product (Chai - ProductID 1)  

 ) AS Source (ProductID, ProductName, UnitPrice, UnitsInStock, Discontinued)  

 ON Target.ProductID = Source.ProductID  

 WHEN MATCHED THEN  

 	UPDATE SET  

         Target.UnitsInStock = Target.UnitsInStock + Source.UnitsInStock, -- Add to existing stock  

         Target.UnitPrice = Source.UnitPrice -- Update UnitPrice if changed  

 WHEN NOT MATCHED THEN  

 	INSERT (ProductID, ProductName, UnitPrice, UnitsInStock, Discontinued)  

     VALUES (Source.ProductID, Source.ProductName, Source.UnitPrice, Source.UnitsInStock, Source.Discontinued);  

   

 SELECT * FROM #PRODUCTTEMP  

   

 DROP TABLE #PRODUCTTEMP  

            
        

Create SQL query with SqlQueryBuilder 1

            
 var (sql1, parameters1) = new SqlQueryBuilder()  

     .Select()  

     .Columns("ProductName", "MetricType", "MetricValue")  

     .From(new SqlQueryBuilder().Select()  

         .Columns("ProductID","ProductName","UnitsInStock","UnitsOnOrder")  

         .From("Products")  

         .Where(new Where(new Column("Discontinued").Equale(0))  

             .AND(new Column("UnitsInStock").GreaterThan(0))  

             .AND(new Column("ProductID").LessThan(30))), "SourceTable"  

     )  

     .UnPivot(new UnPivot(new Column("MetricValue"))  

         .For(new Column("MetricType")).IN("UnitsInStock", "UnitsOnOrder")  

         .TableName(new Table("UnpivotTable"))  

     )  

     .OrderBy(new OrderBy().SetColumnAscending("ProductName")  

         .SetColumnAscending("MetricType"))  

     .Build();  

            
        

Query build by SqlQueryBuilder 1

            
SELECT CAST (1 AS INT) AS ProductID,
       CAST (@pMAIN_2608060426555655100 AS NVARCHAR (MAX)) AS ProductName,
       CAST (0.00 AS MONEY) AS UnitPrice,
       CAST (0 AS INT) AS UnitsInStock,
       CAST (0 AS BIT) AS Discontinued
INTO #PRODUCTTEMP;

DELETE #PRODUCTTEMP
WHERE ProductID = @pMAIN_2608060426555655101;

INSERT INTO #PRODUCTTEMP
VALUES (@pMAIN_2608060426555655102, @pMAIN_2608060426555655103, @pMAIN_2608060426555655104, @pMAIN_2608060426555655105, @pMAIN_2608060426555655106),
(@pMAIN_2608060426555655107, @pMAIN_2608060426555655108, @pMAIN_2608060426555655109, @pMAIN_260806042655565510_10, @pMAIN_260806042655565510_11),
(@pMAIN_260806042655565510_12, @pMAIN_260806042655565510_13, @pMAIN_260806042655565510_14, @pMAIN_260806042655565510_15, @pMAIN_260806042655565510_16),
(@pMAIN_260806042655565510_17, @pMAIN_260806042655565510_18, @pMAIN_260806042655565510_19, @pMAIN_260806042655565510_20, @pMAIN_260806042655565510_21),
(@pMAIN_260806042655565510_22, @pMAIN_260806042655565510_23, @pMAIN_260806042655565510_24, @pMAIN_260806042655565510_25, @pMAIN_260806042655565510_26);

MERGE INTO #PRODUCTTEMP
 AS Target
USING (VALUES (@pMAIN_260806042655565510_27, @pMAIN_260806042655565510_28, @pMAIN_260806042655565510_29, @pMAIN_260806042655565510_30, @pMAIN_260806042655565510_31), (@pMAIN_260806042655565510_32, @pMAIN_260806042655565510_33, @pMAIN_260806042655565510_34, @pMAIN_260806042655565510_35, @pMAIN_260806042655565510_36)) AS Source(ProductID, ProductName, UnitPrice, UnitsInStock, Discontinued) ON Target.ProductID = Source.ProductID
WHEN MATCHED THEN UPDATE 
SET Target.UnitsInStock = Target.UnitsInStock + Source.UnitsInStock,
    Target.UnitPrice    = Source.UnitPrice
WHEN NOT MATCHED THEN INSERT (ProductID, ProductName, UnitPrice, UnitsInStock, Discontinued) VALUES (Source.ProductID, Source.ProductName, Source.UnitPrice, Source.UnitsInStock, Source.Discontinued);

SELECT *
FROM #PRODUCTTEMP;

DROP TABLE #PRODUCTTEMP;


            
        

Parameters (If used)

Query Results 1:

2. Update an existing product's UnitsInStock if it exists, otherwise insert a new product with table hints and insert without column names

SQL Server Query 2

            
 -- Update an existing product's UnitsInStock if it exists, otherwise insert a new product.  

 -- Create a temporary  table to show MERGE  

 SELECT 1 AS ProductID, CAST('the product name' AS NVARCHAR(MAX)) AS ProductName,   

 	CAST(0.00 AS money) AS UnitPrice, CAST(0 AS INT) AS UnitsInStock, CAST(0 AS bit) AS Discontinued  

 INTO #PRODUCTTEMP  

 -- Clear the temporary table  

 DELETE FROM #PRODUCTTEMP WHERE ProductID = 1  

 -- Inserts some value in temporary table  

 INSERT INTO #PRODUCTTEMP VALUES (1, 'Chai', 18.00, 100, 0),  

 	(2, 'Chang', 19.00, 17, 0),  

 	(3, 'Aniseed Syrup', 10.00, 13, 0),  

 	(4, 'Ikura', 31.00, 32, 0),  

 	(5, 'Pavlova', 17.45, 29, 0)  

   

 MERGE INTO #PRODUCTTEMP WITH(ROWLOCK) AS Target   

 USING (VALUES  

 	(78, 'New Gadget', 120.35, 50, 0), -- New product (ProductID, ProductName, UnitPrice, UnitsInStock, Discontinued)  

 	(1, 'Chai', 18.00, 10000, 0) -- Existing product (Chai - ProductID 1)  

 ) AS Source (ProductID, ProductName, UnitPrice, UnitsInStock, Discontinued)  

 ON Target.ProductID = Source.ProductID  

 WHEN MATCHED THEN  

 	UPDATE SET  

         Target.UnitsInStock = Target.UnitsInStock + Source.UnitsInStock, -- Add to existing stock  

         Target.UnitPrice = Source.UnitPrice -- Update UnitPrice if changed  

 WHEN NOT MATCHED THEN  

 	INSERT   

     VALUES (Source.ProductID, Source.ProductName, Source.UnitPrice, Source.UnitsInStock, Source.Discontinued);  

   

 SELECT * FROM #PRODUCTTEMP  

   

 DROP TABLE #PRODUCTTEMP  

            
        

Create SQL query with SqlQueryBuilder 2

            
 var (sql2, parameters2) = new SqlQueryBuilder()  

     .Select()  

     .Column(new CAST(new Column("1"), SqlDataType.INT), "ProductID")  

     .Column(new CAST(new Column().WithValue("the product name"), SqlDataType.NVARCHAR, "MAX"), "ProductName")  

     .Column(new CAST(new Column("0.00"), SqlDataType.MONEY), "UnitPrice")  

     .Column(new CAST(new Column("0"), SqlDataType.INT), "UnitsInStock")  

     .Column(new CAST(new Column("0"), SqlDataType.BIT), "Discontinued")  

     .INTO(new Table("#PRODUCTTEMP"))  

     .DeleteFrom("#PRODUCTTEMP").Where(new Where(new Column("ProductID").Equale(1)))  

     .InsertInto("#PRODUCTTEMP", new List<List<object>>() {  

         new List<object>() {1, "Chai", 18.00, 100, 0 },  

         new List<object>() {2, "Chang", 19.00, 17, 0},  

         new List<object>() {3, "Aniseed Syrup", 10.00, 13, 0},  

         new List<object>() {4, "Ikura", 31.00, 32, 0},  

         new List<object>() {5, "Pavlova", 17.45, 29, 0}  

     })  

     .Merge(new MERGE("#PRODUCTTEMP", new List<IHint>() { new NOLOCK() })  

         .AS("Target")  

         .USING_VALUES(new VALUES(new List<List<object>>()  

         {  

             new List<object>(){ 78, "New Gadget", 120.35, 50, 0 },  

             new List<object>(){ 1, "Chai", 18.00, 10000, 0 }  

         }, "Source", "ProductID", "ProductName", "UnitPrice", "UnitsInStock", "Discontinued"))  

         .ON(new Column("Target.ProductID").Equale(new Column("Source.ProductID")))  

         .WHEN_MATCHED_THEN(new SqlQueryBuilder()  

             .MergeUpdate(new List<ISetValue>()  

             {  

                 new SetValue("Target.UnitsInStock", new ColumnArithmatic("Target.UnitsInStock").ADD("Source.UnitsInStock")),  

                 new SetValue("Target.UnitPrice", new Column("Source.UnitPrice"))  

             })  

         )  

         .WHEN_NOT_MATCHED_THEN(new SqlQueryBuilder()  

             .MergeInsert(new List<IInsertValue>()  

             {  

                 new InsertValue("ProductID", new Column("Source.ProductID")),  

                 new InsertValue("ProductName", new Column("Source.ProductName")),  

                 new InsertValue("UnitPrice", new Column("Source.UnitPrice")),  

                 new InsertValue("UnitsInStock", new Column("Source.UnitsInStock")),  

                 new InsertValue("Discontinued", new Column("Source.Discontinued")),  

             }, true)  

         )  

     )  

     .Select().Star().From("#PRODUCTTEMP")  

     .DropTable(new Table("#PRODUCTTEMP"))  

     .Build();  

            
        

Query build by SqlQueryBuilder 2

            
SELECT CAST (1 AS INT) AS ProductID,
       CAST (@pMAIN_2608060426556098280 AS NVARCHAR (MAX)) AS ProductName,
       CAST (0.00 AS MONEY) AS UnitPrice,
       CAST (0 AS INT) AS UnitsInStock,
       CAST (0 AS BIT) AS Discontinued
INTO #PRODUCTTEMP;

DELETE #PRODUCTTEMP
WHERE ProductID = @pMAIN_2608060426556098281;

INSERT INTO #PRODUCTTEMP
VALUES (@pMAIN_2608060426556098282, @pMAIN_2608060426556098283, @pMAIN_2608060426556098284, @pMAIN_2608060426556098285, @pMAIN_2608060426556098286),
(@pMAIN_2608060426556098287, @pMAIN_2608060426556098288, @pMAIN_2608060426556098289, @pMAIN_260806042655609828_10, @pMAIN_260806042655609828_11),
(@pMAIN_260806042655609828_12, @pMAIN_260806042655609828_13, @pMAIN_260806042655609828_14, @pMAIN_260806042655609828_15, @pMAIN_260806042655609828_16),
(@pMAIN_260806042655609828_17, @pMAIN_260806042655609828_18, @pMAIN_260806042655609828_19, @pMAIN_260806042655609828_20, @pMAIN_260806042655609828_21),
(@pMAIN_260806042655609828_22, @pMAIN_260806042655609828_23, @pMAIN_260806042655609828_24, @pMAIN_260806042655609828_25, @pMAIN_260806042655609828_26);

MERGE INTO #PRODUCTTEMP
 AS Target
USING (VALUES (@pMAIN_260806042655609828_27, @pMAIN_260806042655609828_28, @pMAIN_260806042655609828_29, @pMAIN_260806042655609828_30, @pMAIN_260806042655609828_31), (@pMAIN_260806042655609828_32, @pMAIN_260806042655609828_33, @pMAIN_260806042655609828_34, @pMAIN_260806042655609828_35, @pMAIN_260806042655609828_36)) AS Source(ProductID, ProductName, UnitPrice, UnitsInStock, Discontinued) ON Target.ProductID = Source.ProductID
WHEN MATCHED THEN UPDATE 
SET Target.UnitsInStock = Target.UnitsInStock + Source.UnitsInStock,
    Target.UnitPrice    = Source.UnitPrice
WHEN NOT MATCHED THEN INSERT VALUES (Source.ProductID, Source.ProductName, Source.UnitPrice, Source.UnitsInStock, Source.Discontinued);

SELECT *
FROM #PRODUCTTEMP;

DROP TABLE #PRODUCTTEMP;


            
        

Parameters (If used)

Query Results 2:

3. Merge with Products table (Transcation is rollbacked)

SQL Server Query 3

            
 BEGIN TRANSACTION  

 MERGE Products AS Target   

 USING (VALUES  

     (78, 'New Gadget', 1, 1, 100, 50, 0), -- New product (ProductID, ProductName, SupplierID, CategoryID, UnitPrice, UnitsInStock, Discontinued)  

     (1, 'Chai', 1, 1, 18.00, 50, 0)   -- Existing product (Chai - ProductID 1)  

 ) AS Source (ProductID, ProductName, SupplierID, CategoryID, UnitPrice, UnitsInStock, Discontinued)  

 ON Target.ProductID = Source.ProductID -- Match condition  

 WHEN MATCHED THEN  

     UPDATE SET  

         Target.UnitsInStock = Target.UnitsInStock + Source.UnitsInStock, -- Add to existing stock  

         Target.UnitPrice = Source.UnitPrice -- Update UnitPrice if changed;  

 WHEN NOT MATCHED THEN  

     INSERT (ProductName, SupplierID, CategoryID, UnitPrice, UnitsInStock, Discontinued)  

     VALUES (Source.ProductName, Source.SupplierID, Source.CategoryID, Source.UnitPrice, Source.UnitsInStock, Source.Discontinued);  

 SELECT TOP 5 * FROM Products  

 ROLLBACK TRANSACTION  

            
        

Create SQL query with SqlQueryBuilder 3

            
 var (sql3, parameters3) = new SqlQueryBuilder()  

     .Merge(new MERGE("Products")  

         .AS("Target")  

         .USING_VALUES(new VALUES(new List<List<object>>()   

         {   

             new List<object>() { 78, "New Gadget", 1, 1, 100, 50, 0 },  

             new List<object>() { 1, "Chai", 1, 1, 18.00, 50, 0 }  

         }, "Source", "ProductID", "ProductName", "SupplierID", "CategoryID", "UnitPrice", "UnitsInStock", "Discontinued"))  

         .ON(new Column("Target.ProductID").Equale(new Column("Source.ProductID")))  

         .WHEN_MATCHED_THEN(new SqlQueryBuilder()  

             .MergeUpdate(new List<ISetValue>()   

             {   

                 new SetValue("Target.UnitsInStock", new ColumnArithmatic("Target.UnitsInStock").ADD("Source.UnitsInStock")),  

                 new SetValue("Target.UnitPrice", new Column("Source.UnitPrice"))  

             })  

         )  

         .WHEN_NOT_MATCHED_THEN(new SqlQueryBuilder()  

             .MergeInsert(new List<IInsertValue>()   

             {   

                 new InsertValue("ProductName", new Column("Source.ProductName")),  

                 new InsertValue("SupplierID", new Column("Source.SupplierID")),  

                 new InsertValue("CategoryID", new Column("Source.CategoryID")),  

                 new InsertValue("UnitPrice", new Column("Source.UnitPrice")),  

                 new InsertValue("UnitsInStock", new Column("Source.UnitsInStock")),  

                 new InsertValue("Discontinued", new Column("Source.Discontinued")),  

             })  

         )  

     )  

     .Select().Top(5).Star().From("Products")  

     .Build();  

            
        

Query build by SqlQueryBuilder 3

            
MERGE INTO Products
 AS Target
USING (VALUES (@pMAIN_2608060426556258060, @pMAIN_2608060426556258061, @pMAIN_2608060426556258062, @pMAIN_2608060426556258063, @pMAIN_2608060426556258064, @pMAIN_2608060426556258065, @pMAIN_2608060426556258066), (@pMAIN_2608060426556258067, @pMAIN_2608060426556258068, @pMAIN_2608060426556258069, @pMAIN_260806042655625806_10, @pMAIN_260806042655625806_11, @pMAIN_260806042655625806_12, @pMAIN_260806042655625806_13)) AS Source(ProductID, ProductName, SupplierID, CategoryID, UnitPrice, UnitsInStock, Discontinued) ON Target.ProductID = Source.ProductID
WHEN MATCHED THEN UPDATE 
SET Target.UnitsInStock = Target.UnitsInStock + Source.UnitsInStock,
    Target.UnitPrice    = Source.UnitPrice
WHEN NOT MATCHED THEN INSERT (ProductName, SupplierID, CategoryID, UnitPrice, UnitsInStock, Discontinued) VALUES (Source.ProductName, Source.SupplierID, Source.CategoryID, Source.UnitPrice, Source.UnitsInStock, Source.Discontinued);

SELECT TOP 5 *
FROM Products;


            
        

Parameters (If used)

Query Results 3: