-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathfifo_test1.sql
233 lines (218 loc) · 7.41 KB
/
fifo_test1.sql
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
-- =====================================================
-- Listing 1: Create Table,
-- Insert Data,
-- Index Table
--
-- References :
-- https://www.simple-talk.com/sql/performance/t-sql-window-function-speed-phreakery-the-fifo-stock-inventory-problem/
--
-- Link :
-- http://sqlfiddle.com/#!6/05e3d/1
-- =====================================================
-- =====================================================
-- Step 1: Create Table Stock
-- =====================================================
CREATE TABLE dbo.Stock (
StockID INT IDENTITY(1, 1)
NOT NULL ,
DocumentID VARCHAR(10) NOT NULL ,
ItemID VARCHAR(10) NOT NULL ,
TranDate DATETIME NOT NULL ,
TranCode VARCHAR(3) NOT NULL ,
Qty INT NOT NULL ,
Price MONEY NULL ,
CONSTRAINT [PK_dbo.Stock] PRIMARY KEY CLUSTERED ( StockID ASC )
);
GO
-- =====================================================
-- Step 2: Insert Sample Data
-- =====================================================
INSERT INTO dbo.Stock SELECT 'PO-001', 'A021', '20120101','IN', 3, 100
INSERT INTO dbo.Stock SELECT 'SO-010', 'A021', '20120102', 'OUT', 2, 50
INSERT INTO dbo.Stock SELECT 'PO-002', 'A021', '20120110','IN', 7, 110
INSERT INTO dbo.Stock SELECT 'PO-003', 'A021', '20120201','IN', 9, 110
INSERT INTO dbo.Stock SELECT 'SO-011', 'A021', '20120211', 'OUT', 8, 80
INSERT INTO dbo.Stock SELECT 'SO-012', 'A023', '20120212', 'OUT', 6, 200
-- =====================================================
-- Step 3: Create Index "IN"
-- =====================================================
CREATE NONCLUSTERED INDEX IX_Input
ON dbo.Stock (TranCode, ItemID)
INCLUDE (TranDate, Qty)
WHERE TranCode IN ('IN', 'RET')
-- =====================================================
-- Step 4: Create Index "OUT"
-- =====================================================
CREATE NONCLUSTERED INDEX IX_Output ON dbo.Stock (TranCode, ItemID)
INCLUDE (TranDate, Qty)
WHERE TranCode = 'OUT'
-- =====================================================
-- Step 5: Select Maximum Rows In One Process Queque
-- =====================================================
IF OBJECT_ID('dbo.TallyNumbers') IS NULL
BEGIN
CREATE TABLE dbo.TallyNumbers ( Number INT NOT NULL )
INSERT INTO dbo.TallyNumbers
( Number
)
SELECT TOP ( 1000000 )
ROW_NUMBER() OVER ( ORDER BY A.OBJECT_ID ) - 1 AS Number
FROM
master.sys.objects AS A
CROSS JOIN master.sys.objects AS B
CROSS JOIN master.sys.objects AS C
CROSS JOIN master.sys.objects AS D
END;
GO
-- =====================================================
-- Step 6: Create Temporary Index
-- =====================================================
CREATE NONCLUSTERED INDEX [IX_Temp_General]
ON [dbo].[Stock]
(
[ItemID] ASC,
[TranDate] DESC,
[TranCode] ASC
)
INCLUDE ([Qty], [Price])
WITH
(
PAD_INDEX = OFF,
STATISTICS_NORECOMPUTE = OFF,
SORT_IN_TEMPDB = OFF,
IGNORE_DUP_KEY = OFF,
DROP_EXISTING = OFF,
ONLINE = OFF,
ALLOW_ROW_LOCKS = ON,
ALLOW_PAGE_LOCKS = ON
)
ON [PRIMARY];
GO
-- =====================================================
-- Step 7: Create Temporary Index Quantity
-- =====================================================
CREATE NONCLUSTERED INDEX [IX_Temp_Qty]
ON [dbo].[Stock]
(
[ItemID] ASC,
[TranDate] ASC
)
INCLUDE ([Qty])
WHERE ([TranCode] IN ('IN', 'RET'))
WITH
(
PAD_INDEX = OFF,
STATISTICS_NORECOMPUTE = OFF,
SORT_IN_TEMPDB = OFF,
IGNORE_DUP_KEY = OFF,
DROP_EXISTING = OFF,
ONLINE = OFF,
ALLOW_ROW_LOCKS = ON,
ALLOW_PAGE_LOCKS = ON
)
ON [PRIMARY];
GO
-- =====================================================
-- Step 8: Create Temporary Index Price
-- =====================================================
CREATE NONCLUSTERED INDEX [IX_Temp_Price]
ON [dbo].[Stock]
(
[ItemID] ASC,
[TranDate] ASC
)
INCLUDE ([Price])
WHERE ([TranCode] = 'IN')
WITH
(
PAD_INDEX = OFF,
STATISTICS_NORECOMPUTE = OFF,
SORT_IN_TEMPDB = OFF,
IGNORE_DUP_KEY = OFF,
DROP_EXISTING = OFF,
ONLINE = OFF,
ALLOW_ROW_LOCKS = ON,
ALLOW_PAGE_LOCKS = ON,
FILLFACTOR = 100
)
ON [PRIMARY];
GO
-- ------------------------------------------------------------------------
-- =====================================================
-- Step 9: FIFO Dave Ballantyne’s Solution
-- =====================================================
;
/* Sum up the ins and outs to calculate the remaining stock level */
WITH
cteStockSum
AS ( SELECT
ItemID ,
SUM(CASE WHEN TranCode = 'OUT' THEN 0 - Qty
ELSE Qty
END) AS TotalStock
FROM dbo.Stock
GROUP BY ItemID
),
cteReverseInSum
AS ( SELECT
s.ItemID ,
s.TranDate ,
( SELECT SUM(i.Qty)
FROM dbo.Stock AS i WITH ( INDEX ( IX_Temp_Qty ) )
WHERE i.ItemID = s.ItemID
AND i.TranCode IN ( 'IN', 'RET' )
AND i.TranDate >= s.TranDate
) AS RollingStock ,
s.Qty AS ThisStock
FROM dbo.Stock AS s
WHERE s.TranCode IN ( 'IN', 'RET' )
),
/* Using the rolling balance above find the first stock movement in that meets
(or exceeds) our required stock level */
/* and calculate how much stock is required from the earliest stock in */
cteWithLastTranDate
AS ( SELECT w.ItemID ,
w.TotalStock ,
LastPartialStock.TranDate ,
LastPartialStock.StockToUse ,
LastPartialStock.RunningTotal ,
w.TotalStock - LastPartialStock.RunningTotal
+ LastPartialStock.StockToUse AS UseThisStock
FROM cteStockSum AS w
CROSS APPLY (
SELECT TOP ( 1 )
z.TranDate ,
z.ThisStock AS StockToUse ,
z.RollingStock AS RunningTotal
FROM cteReverseInSum AS z
WHERE z.ItemID = w.ItemID
AND z.RollingStock >= w.TotalStock
ORDER BY z.TranDate DESC
) AS LastPartialStock
)
/* Sum up the cost of 100% of the stock movements in after the returned stockid and for that stockid we need 'UseThisStock' items' */
SELECT y.ItemID ,
y.TotalStock AS CurrentQty ,
SUM(CASE WHEN e.TranDate = y.TranDate
THEN y.UseThisStock
ELSE e.Qty
END * Price.Price) AS CurrentValue
FROM cteWithLastTranDate AS y
INNER JOIN dbo.Stock AS e WITH ( INDEX ( IX_Temp_Qty ) )
ON e.ItemID = y.ItemID
AND e.TranDate >= y.TranDate
AND e.TranCode IN ('IN', 'RET' )
CROSS APPLY (
/* Find the Price of the item in */
SELECT TOP ( 1 )
p.Price
FROM dbo.Stock AS p
WITH ( INDEX ( IX_Temp_Price ) )
WHERE
p.ItemID = e.ItemID
AND p.TranDate <= e.TranDate
AND p.TranCode = 'IN'
ORDER BY p.TranDate DESC
) AS Price
GROUP BY y.ItemID ,y.TotalStock
ORDER BY y.ItemID