SQL累積值

Question

我正在編寫一個SQLServer 2008存儲過程，該過程需要一張付款表並嘗試根據相關表中描述的一組規則（基本上是一組存儲桶）來分配這些付款。但是，分配（將支付價值放入一個桶中）是目前令我頭痛的原因。

比方說，支付表中包含支付的價值和表格。桶是關於應該投入每個存儲桶多少錢，直到要支付的初始值用盡（達到0）。

使用下面的表作爲示例（實際使用的情況下是作爲有一些複雜的標準來選擇哪一個是適合於每個付款桶略偏做作）：

PaymentId  Value     BucketId  MaxAmount 
--------------------------   -------------------------------- 
1    16.5     1    5.5 
2    7.0     2    10 
            3    8.3 

對於付款1：5.5個單位（該桶的最大值）應進入桶1，桶2中有10個單元（11.5是來自桶1的剩餘量，但仍超過桶2的最大值），應將1個單元（16.5-5.5-10）放入桶中3.重複所有付款。

這很容易在任何命令式語言中實現，甚至可能在SQL中使用for/while循環，但我試圖瞭解是否有更好的方法（即使它不可移植且特定於SQLServer 2005+）。

我已經做了一些研究（主要是遞歸CTE），但沒有什麼真正的輝煌想到。我確信有很多StackOverflowers與SQL-fu來回答他們的頭，所以我想把它放在那裏，看看...

非常感謝您的幫助。

Answer 1

我嘗試不使用光標：

DECLARE @Buckets TABLE (
    BucketId INT, 
    MaxAmount DECIMAL(18,6) 
) 

INSERT INTO @Buckets VALUES (1, 5.5) 
INSERT INTO @Buckets VALUES (2, 10) 
INSERT INTO @Buckets VALUES (3, 8.3) 

DECLARE @Payments TABLE (
    PaymentId INT, 
    Value DECIMAL(18,6) 
) 

INSERT INTO @Payments VALUES (1,16.5) 
INSERT INTO @Payments VALUES (2,7.0) 

SELECT 
    P1.PaymentId 
, P1.Value as TotalPayment 
, B4.BucketId 
, B4.MaxAmount 
, CASE WHEN B3.BucketId = B4.BucketId THEN P1.Value - MaxAmountRunningTotalOfPreviousBuckets ELSE B4.MaxAmount END AS BucketPaymentAmount 
FROM @Payments P1 
INNER JOIN (
    SELECT 
     B2.BucketId 
    , B2.MaxAmount as BucketMaxAmount 
    , SUM(B1.MaxAmount) - B2.MaxAmount as MaxAmountRunningTotalOfPreviousBuckets 
    FROM @Buckets B1 
    INNER JOIN @Buckets B2 
     ON B1.BucketId <= B2.BucketId 
    GROUP BY B2.BucketId, B2.MaxAmount 
) AS B3 
    ON P1.Value > B3.MaxAmountRunningTotalOfPreviousBuckets AND P1.Value <= (B3.MaxAmountRunningTotalOfPreviousBuckets + BucketMaxAmount) 
INNER JOIN @Buckets B4 
    ON B4.BucketId <= B3.BucketId 
ORDER BY P1.PaymentId, B3.BucketId 

Answer 2

把你的水桶表到一個臨時表，然後有一個叫做總運行一個額外的列。這將有運行總和，直到這個加入，然後交叉加入付款和tempbucket表，並指定付款< =運行totalin tempbucket表中的條件。這應該可以解決你的問題。 我用Mafu Josh的DDL創建了以下查詢，因此感謝他。我希望OP應該總是發佈這些東西讓其他人更容易生活。

它看起來像buckte表相當small.But如果是非常大的table.Then生成運行總使用與variables.That更新的效率比低於method.To我聽起來，這表是或多或少的靜態表，因此您可以將總計作爲表本身的一部分。

DECLARE @Buckets TABLE ( 
    BucketId INT, 
    MaxAmount DECIMAL(18,6) 
) 

INSERT INTO @Buckets VALUES (1, 5.5) 
INSERT INTO @Buckets VALUES (2, 10) 
INSERT INTO @Buckets VALUES (3, 8.3) 

DECLARE @Payments TABLE ( 
    PaymentId INT, 
    Value DECIMAL(18,6) 
) 

INSERT INTO @Payments VALUES (1,16.5) 
INSERT INTO @Payments VALUES (2,7.0) 
INSERT INTO @Payments VALUES (3,23.8) 

DECLARE @tempBuckets TABLE ( 
    BucketId INT, 
    MaxAmount DECIMAL(18,6) , 
    currentruntotal decimal(18,6) 
) 
insert into @tempBuckets select bucketid,maxamount ,(select SUM(maxamount) from @Buckets bin where b.bucketid >=bin.bucketid) 
--,isnull((select SUM(maxamount) from @Buckets bin where b.bucketid > bin.bucketid),0) 
from @Buckets b 

select * from @tempBuckets 
select PaymentId,Value,BucketId, 
case when p.Value >= tb.currentruntotal then tb.MaxAmount else p.Value - tb.currentruntotal + tb.MaxAmount end as bucketamount 
from @Payments p inner join @tempBuckets tb on (p.Value >= tb.currentruntotal or p.Value between tb.currentruntotal - tb.MaxAmount and tb.currentruntotal) 
order by PaymentId 
go 

Answer 3

這裏有一個遞歸CTE的方法給你：

WITH BucketsRanked AS (
    SELECT *, rnk = ROW_NUMBER() OVER (ORDER BY BucketId) FROM Buckets 
) 
, PaymentsRanked AS (
    SELECT *, rnk = ROW_NUMBER() OVER (ORDER BY PaymentId) FROM Payments 
) 
, PaymentsDistributed AS (
    SELECT 
    b.BucketId, 
    p.PaymentId, 
    Bucket  = b.MaxAmount, 
    Payment  = p.Value, 
    BucketRnk  = b.rnk, 
    PaymentRnk = p.rnk, 
    BucketPayment = CASE 
         WHEN p.Value > b.MaxAmount 
         THEN b.MaxAmount 
         ELSE p.Value 
        END, 
    CarryOver  = p.Value - b.MaxAmount 
    FROM 
    BucketsRanked b, 
    PaymentsRanked p 
    WHERE b.rnk = 1 AND p.rnk = 1 
    UNION ALL 
    SELECT 
    b.BucketId, 
    p.PaymentId, 
    Bucket  = b.MaxAmount, 
    Payment  = p.Value, 
    BucketRnk  = b.rnk, 
    PaymentRnk = p.rnk, 
    BucketPayment = CASE 
         WHEN x.PaymentValue > x.BucketValue 
         THEN x.BucketValue 
         ELSE x.PaymentValue 
        END, 
    CarryOver  = x.PaymentValue - x.BucketValue 
    FROM PaymentsDistributed d 
    INNER JOIN BucketsRanked b 
     ON b.rnk = d.BucketRnk + CASE SIGN(CarryOver) WHEN -1 THEN 0 ELSE 1 END 
    INNER JOIN PaymentsRanked p 
     ON p.rnk = d.PaymentRnk + CASE SIGN(CarryOver) WHEN +1 THEN 0 ELSE 1 END 
    CROSS APPLY (
     SELECT 
     CONVERT(
      decimal(18,6), 
      CASE SIGN(CarryOver) WHEN -1 THEN -d.CarryOver ELSE b.MaxAmount END 
     ), 
     CONVERT(
      decimal(18,6), 
      CASE SIGN(CarryOver) WHEN +1 THEN +d.CarryOver ELSE p.Value  END 
     ) 
    ) x (BucketValue, PaymentValue) 
) 
SELECT 
    BucketId, 
    PaymentId, 
    Bucket, 
    Payment, 
    BucketPayment 
FROM PaymentsDistributed 
; 

基本上，這個查詢需要的首付款和第一桶，計算出這是少，產生第一BucketPayment項目。記住支付值和存儲桶容量之間的差異，以便在下一次迭代中使用。

在下一次迭代中，根據其符號，差異將用作存儲量或付款。此外，根據差異的符號，查詢將從Payments表中獲取下一筆付款，或者從Buckets獲取下一筆存款。（但是，如果差值爲0，則查詢實際上會檢索下一個支付和下一個存儲桶。）然後，將與第一次迭代相同的邏輯應用於新的存儲桶數量和支付值。

迭代持續進行，直到沒有更多桶或沒有更多付款。或直至達到100默認MAXRECURSION值，在這種情況下，你可能想

OPTION (MAXRECURSION n)

追加到上面的查詢，其中n必須是一個非負整數高達32767規定的最大數量迭代（遞歸）。 （注意：0實際上代表無限）

你可以試試這個查詢at SQL Fiddle。