SQL SERVER 儲存過程和事務

前提：再實際業務中，有一個需求，即是根據A欄位和B欄位計算C欄位(批量的)考慮用的事務和WHILE迴圈，做成儲存過程，然後作業，定時10分鐘更新一次。其中A欄位的值，又是根據其他4個欄位為一組求的平均值。
那麼該儲存過程用到兩次事務，事務1先計算A值，事務2再計算C值。注意兩次事務的名稱應該不同，不然可能有錯誤。

USE [MSIS]
GO

/* Object: StoredProcedure [dbo].[AutoUpByLeft] Script Date: 2018/4/12 14:34:12 */
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO

– =============================================
– Author: zhangaz
– Create date: 2018/4/12
– Description: 同步分級
– =============================================
CREATE PROCEDURE [dbo].[AutoUpByLeft]
AS
BEGIN
IF OBJECT_ID(‘tempdb..#TEMPAL’) IS NOT NULL
DROP TABLE #TEMPA;
IF OBJECT_ID(‘tempdb..#TEMPBL’) IS NOT NULL
DROP TABLE #TEMPB;
IF OBJECT_ID(‘tempdb..#TEMPL’) IS NOT NULL
DROP TABLE #TEMP;
–1.先求平均值
WITH DETAIL
AS ( SELECT _CRF_Variable.Name ,
_CRFDataValue.CRF_Variable_Id ,
_CRFDataValue.ContentValue ,
_CRFDataValue.CRFData_Id ,
SUBSTRING(_CRF_Variable.Name, 0, 8) AS TempName
FROM dbo.CRFDataValue AS _CRFDataValue
INNER JOIN dbo.CRF_Variable AS _CRF_Variable ON _CRF_Variable.Id = _CRFDataValue.CRF_Variable_Id
WHERE _CRF_Variable.CRFForm_Id = 1287 AND Name LIKE ‘

—-1.往#TEMPA中插入資料 先查出4個術後PTA 氣導左和對應術後PTA 平均左
SELECT DETAIL.TempName AS aTempName ,
DETAIL.CRF_Variable_Id AS aCRF_Variable_Id ,
DETAIL.ContentValue AS aContentValue ,
DETAIL.CRFData_Id AS CRFData_Id ,
T.CRF_Variable_Id AS bCRF_Variable_Id ,
T.ContentValue AS bContentValue ,
DETAIL.TempName AS bTempName
INTO #TEMPAL
FROM DETAIL
INNER JOIN T ON T.CRFData_Id = DETAIL.CRFData_Id
AND T.TempName = DETAIL.TempName;
–2.往#TEMPB中插入資料
SELECT ROW_NUMBER() OVER ( ORDER BY CRFData_Id ) AS Id ,
AVG(CAST(#TEMPAL.aContentValue AS FLOAT)) AS TEMPAVG ,
bContentValue ,
CRFData_Id AS bCRFData_Id ,
bCRF_Variable_Id ,
COUNT(1) AS TEMPCOUNT
INTO #TEMPBL
FROM #TEMPAL
WHERE bContentValue IS NULL OR bContentValue=” –為空的計算平均值，已有平均值的不再計算
GROUP BY CRFData_Id ,
aTempName ,
bContentValue ,
bCRF_Variable_Id
HAVING COUNT(1) > 3;

–開啟事務A,先計算並更新平均值((術後PTA 氣導左500HZ+術後PTA 氣導左1000HZ+術後PTA 氣導左2000HZ+術後PTA 氣導左4000HZ)/4=術後PTA 平均左)———–

BEGIN TRAN TL01 ;
DECLARE @ERRORA INT
SET @ERRORA = 0;
DECLARE @TEMPAVG INT
DECLARE @bCRFData_Id INT
DECLARE @bCRF_Variable_Id INT
DECLARE @J INT
SET @J=1
DECLARE @COUNTA INT
SELECT @COUNTA = COUNT(1)
FROM #TEMPBL;
WHILE(@COUNTA>[email protected])
BEGIN
SELECT @TEMPAVG = TEMPAVG
FROM #TEMPBL
WHERE Id = @J;
SELECT @bCRFData_Id = bCRFData_Id
FROM #TEMPBL
WHERE Id = @J;
SELECT @bCRF_Variable_Id = bCRF_Variable_Id
FROM #TEMPBL
WHERE Id = @J;
UPDATE dbo.CRFDataValue SET [email protected] WHERE [email protected]_Id AND [email protected]_Variable_Id
SET @[email protected]+1
SET @ERRORA= @ERRORA + @@ERROR;
END
IF @ERRORA = 0
BEGIN
COMMIT TRAN TL01; –提交事務
END;
ELSE
BEGIN
ROLLBACK TRAN TL01; –回滾事務
END;

–根據平均值求分級
WITH SDSRIGHT
AS ( SELECT _CRF_Variable.Name ,
_CRFDataValue.CRF_Variable_Id ,
_CRFDataValue.ContentValue ,
_CRFDataValue.CRFData_Id ,
SUBSTRING(_CRF_Variable.Name, 0, 8) AS TempName
FROM dbo.CRFDataValue AS _CRFDataValue
INNER JOIN dbo.CRF_Variable AS _CRF_Variable ON _CRF_Variable.Id = _CRFDataValue.CRF_Variable_Id
WHERE _CRF_Variable.CRFForm_Id = 1287
AND Name LIKE ‘