github/sql-server-samples
1
0
Fork 0
mirror of https://github.com/Microsoft/sql-server-samples.git synced 2025-12-08 14:58:54 +00:00
Code Issues Releases Wiki Activity

Update MultithreadedOrderInsertMain.cs

Browse Source 
There is a bug in the code when it tries to append the union, it generates invalid SQL. By encapsulating the underlying select's into parens, it eliminates the issue in both cases (just the first query vs both queries unioned).
This commit is contained in:
Chad Baldwin
2023-03-31 16:46:38 -04:00
committed by GitHub
parent bccd6660ce
commit 03d6ee34be
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
samples/databases/wide-world-importers/workload-drivers/order-insert/MultithreadedOrderInsert/MultithreadedOrderInsertMain.cs
+2 -2
View File
@@ -151,10 +151,10 @@ namespace MultithreadedInMemoryTableInsert
var orderTable = new DataTable("Orders");
da.Fill(orderTable);
selectCommand.CommandText = "SELECT TOP(7) 1 AS OrderReference, si.StockItemID, si.StockItemName AS [Description], FLOOR(RAND() * 10) + 1 AS Quantity FROM Warehouse.StockItems AS si WHERE IsChillerStock = 0 ORDER BY NEWID()";
selectCommand.CommandText = "SELECT * FROM (SELECT TOP(7) 1 AS OrderReference, si.StockItemID, si.StockItemName AS [Description], FLOOR(RAND() * 10) + 1 AS Quantity FROM Warehouse.StockItems AS si WHERE IsChillerStock = 0 ORDER BY NEWID()) x";
if (rnd.Next(1, 100) < 4)
{
selectCommand.CommandText += "UNION ALL SELECT TOP(1) 1 AS OrderReference, si.StockItemID, si.StockItemName AS [Description], FLOOR(RAND() * 10) + 1 AS Quantity FROM Warehouse.StockItems AS si WHERE IsChillerStock <> 0 ORDER BY NEWID()";
selectCommand.CommandText += " UNION ALL SELECT * FROM (SELECT TOP(1) 1 AS OrderReference, si.StockItemID, si.StockItemName AS [Description], FLOOR(RAND() * 10) + 1 AS Quantity FROM Warehouse.StockItems AS si WHERE IsChillerStock <> 0 ORDER BY NEWID()) x";
}
selectCommand.CommandText += ";";
var orderLinesTable = new DataTable("OrderLines");