[大数据]SQL逐行更新的实现

1、原始记录逐行更新

数据结构：

使用游标，对原始记录逐行进行更新：

DECLARE My_Cursor CURSOR --定义游标
FOR (select * from 仪表盘) --查出需要的集合放到游标中
OPEN My_Cursor; --打开游标
FETCH NEXT FROM My_Cursor ; --读取第一行数据
WHILE @@FETCH_STATUS = 0
? ? BEGIN
? ? ? ? UPDATE 仪表盘 SET 指标值 = rand()*100 ?WHERE CURRENT OF My_Cursor; --更新
? ? ? ? --DELETE FROM 表名 WHERE CURRENT OF My_Cursor; --删除
? ? ? ? FETCH NEXT FROM My_Cursor; --读取下一行数据
? ? END
CLOSE My_Cursor; --关闭游标
DEALLOCATE My_Cursor; --释放游标
GO
?

2、分组逐行更新

数据结构：

?

按照分组，对分组内的数据分别逐行更新：

DECLARE My_Cursor CURSOR --定义游标
FOR (select * from 设备分时数据 where 设备 in(select 设备 from 设备分时数据 group by 设备 having count(设备)>1)) --查出需要的集合放到游标中
OPEN My_Cursor; --打开游标
FETCH NEXT FROM My_Cursor ; --读取第一行数据
WHILE @@FETCH_STATUS = 0
? ? BEGIN
? ? ? ? UPDATE 设备分时数据 SET 指标 = rand() ?WHERE CURRENT OF My_Cursor; --更新
? ? ? ? --DELETE FROM 表名 WHERE CURRENT OF My_Cursor; --删除
? ? ? ? FETCH NEXT FROM My_Cursor; --读取下一行数据
? ? END
CLOSE My_Cursor; --关闭游标
DEALLOCATE My_Cursor; --释放游标
GO
?