select 결과의 각 행에 대해 INSERT 수행

Question

먼저, 문제에 대한 일반적인 설명 : 테이블의 총 숫자를 업데이트하는 정기 프로세스를 실행하고 있습니다. 문제는 프로세스를 실행할 때마다 여러 업데이트가 필요할 수 있으며 각 실행은 이전 결과에 따라 달라질 수 있다는 것입니다.

제 질문은 단일 SQL Server SP에서 할 수 있습니까?

는

내 코드 (나는 그것을 단순히 샘플을 약간 변경) :

INSERT INTO CustomerMinuteSessions(time, customer, sessions, bytes, previousTotalSessions) 
SELECT MS.time, 
      MS.customer, 
      MS.totalSessions, 
      MS.totalBytes, 
      CTS.previousTotalSessions 
FROM (SELECT time, customer, SUM(sessions) as totalSessions, SUM(bytes) AS totalBytes 
     FROM MinuteSessions 
     WHERE time > @time 
     GROUP BY time, x) MS 
CROSS APPLY TVF_GetPreviousCustomerTotalSessions(MS.customer) CTS 
ORDER BY time 

previousTotalSessions 열이 UpdatedTable에서 다른 행에 따라, 그 값은 CROSS APPLY이 TVF_GetPreviousCustomerTotalSessions을 보내고에 의해 검색되지만를 난을 실행할 경우 SP는 그대로, 모든 행은 동안 SP가 실행되는 동안 추가 된 행을 취하지 않고 함수가 검색 한 값을 사용합니다. 여기에 완성도를 위해서

는 TVF_GetPreviousCustomerTotalSessions입니다 :

FUNCTION [dbo].[TVF_GetCustomerCurrentSessions] 
( 
    @customerId int 
) 
RETURNS @result TABLE (PreviousNumberOfSessions int) 
AS 
BEGIN 
    INSERT INTO @result 
    SELECT TOP 1 (PreviousNumberOfSessions + Opened - Closed) AS PreviousNumberOfSessions 
    FROM CustomerMinuteSessions 
    WHERE CustomerId = @customerId 
    ORDER BY time DESC 

    IF @@rowcount = 0 
     INSERT INTO @result(PreviousNumberOfSessions) VALUES(0) 

    RETURN 
END 

은 무엇 최고 (즉, 루프없는 것 같아요 ...) 이후 행에 대한 쿼리 내에서 이전 행을 취할?

Answer 1

SQL-2005 이상을 사용하는 경우 한 번에 몇 개의 CTE를 사용하여 수행 할 수 있습니다. SQL-2000을 사용하는 경우 인라인 테이블 반환 함수를 사용할 수 있습니다.

저는 개인적으로 CTE 방식이 더 좋아서 CTE 구문에 대한 코드의 설계도 번역본을 포함하고 있습니다. (내가 시험해보기 위해 시험 준비를하지 않았다는 것을 염두에 두라.) 테이블 CustomerMinuteSessions 데이터베이스 성장하면 질문을 넘어 조금가는

는

WITH LastSessionByCustomer AS 
(
    SELECT CustomerID, MAX(Time) 
    FROM CustomerMinuteSessions 
    GROUP BY CustomerID 
) 
, GetPreviousCustomerTotalSessions AS 
(
    SELECT LastSession.CustomerID, LastSession.PreviousNumberOfSessions + LastSession.Opened - LastSession.Closed AS PreviousNumberOfSessions 
    FROM CustomerMinuteSessions LastSession 
    INNER JOIN LastSessionByCustomer ON LastSessionByCustomer.CustomerID = LastSession.CustomerID 
) 
, MS AS 
(
    SELECT time, customer, SUM(sessions) as totalSessions, SUM(bytes) AS totalBytes 
    FROM MinuteSessions 
    WHERE time > @time 
    GROUP BY time, x 
) 
INSERT INTO CustomerMinuteSessions(time, customer, sessions, bytes, previousTotalSessions) 
SELECT MS.time, 
      MS.customer, 
      MS.totalSessions, 
      MS.totalBytes, 
      ISNULL(GetPreviousCustomerTotalSessions.previousTotalSessions, 0) 
FROM MS 
RIGHT JOIN GetPreviousCustomerTotalSessions ON MS.Customer = GetPreviousCustomerTotalSessions.CustomerID 

, 나는 인덱스는 인덱스-탐색 얻기의 기회를 개선하고자 추가 할 십자가와 쿼리가 데이터베이스에 큰 손상을 만들 수 적용하는 것이 생각 :

CREATE INDEX IX_CustomerMinuteSessions_CustomerId 
    ON CustomerMinuteSessions (CustomerId, [time] DESC, PreviousNumberOfSessions, Opened, Closed);