SQL Server数据库远程更新目标表数据的存储过程

2018-12-27 14:05 Grom 互联网
20 0
文章主要介绍了SQL Server 远程更新目标表数据的存储过程,适用于更新列名一致,主键为Int类型,具体实例代码大家参考下本文

本文给大家分享一个远程更新目标库数据的存储过程,适用于更新列名一致,主键为Int类型,可远程链接的数据库。

  1. USE [Table]--切换到源表,就是数据最新的那个表
  2. GO
  3. /****** Object: StoredProcedure [dbo].[proc_DataUpdate] Script Date: 2018/5/4 15:08:56 ******/
  4. SET ANSI_NULLS ON
  5. GO
  6. SET QUOTED_IDENTIFIER ON
  7. GO
  8. -- =============================================
  9. -- Author: <Grom>
  10. -- Create date: <2018-05-04>
  11. -- Description: <分批更新远程数据,仅支持主键为int表>
  12. -- =============================================
  13. CREATE PROCEDURE [dbo].[proc_DataUpdate]
  14. @TargetInstance nvarchar(max),
  15. @TargetDBName nvarchar(max),
  16. @TargetUID nvarchar(max),
  17. @TargetPWD nvarchar(max),
  18. @LocalDBName nvarchar(max),
  19. @PK_ID nvarchar(max),--主键列(必须为数字)
  20. @Column nvarchar(max),--更新列名集合
  21. @ExecSize int--每次执行数量
  22. AS
  23. declare @sql nvarchar(max),
  24. @NumMax int=0,
  25. @NumMin int=0,
  26. @MaxID int
  27. BEGIN
  28. -- SET NOCOUNT ON added to prevent extra result sets from
  29. -- interfering with SELECT statements.
  30. -- SET NOCOUNT ON;--打开注释可不显示执行过程,提高速度
  31. begin try
  32.   --取最大值
  33.   set @sql = 'select @MaxID=MAX('+@PK_ID+') from '+@LocalDBName;
  34.   exec sp_executesql @sql,N'@MaxID int out',@MaxID out
  35.   --循环
  36.   while(@NumMax<@MaxID)
  37.   begin
  38.     if exists (select * from tempdb.dbo.sysobjects where id = object_id(N'tempdb..##tmp_table') and type='U')
  39.     drop table ##tmp_table;
  40.     SET @sql = 'select top '+cast(@ExecSize as nvarchar(1000))+' '+ @Column +' into ##tmp_table from '+@LocalDBName+' where '+@PK_ID+'>'+cast(@NumMax as nvarchar(150));
  41.     exec sp_executesql @sql;
  42.     --记录执行最大值
  43.     SET @SQL='select @NumMax=MAX('+@PK_ID+') from ##tmp_table';
  44.     exec sp_executesql @sql,N'@NumMax int out',@NumMax out;
  45.     --记录执行最小值
  46.     SET @SQL='select @NumMin=MIN('+@PK_ID+') from ##tmp_table';
  47.     exec sp_executesql @sql,N'@NumMin int out',@NumMin out;
  48.     SET @sql='delete openrowset(''SQLOLEDB'','''+@TargetInstance+''';'''+@TargetUID+''';'''+@TargetPWD+''',['+@TargetDBName+'].[dbo].['+@LocalDBName+'])
  49.     where '+@PK_ID+' between '+cast(@NumMin as nvarchar(200))+' and '+cast(@NumMax as nvarchar(200));
  50.     exec sp_executesql @sql;
  51.     SET @sql='insert into openrowset(''SQLOLEDB'','''+@TargetInstance+''';'''+@TargetUID+''';'''+@TargetPWD+''',['+@TargetDBName+'].[dbo].['+@LocalDBName+'])
  52.     ('+@Column+')
  53.     select '+ @Column +' from ##tmp_table'
  54.     exec sp_executesql @sql;
  55.   end
  56.   --删除多余数据
  57.   SET @sql='delete openrowset(''SQLOLEDB'','''+@TargetInstance+''';'''+@TargetUID+''';'''+@TargetPWD+''',['+@TargetDBName+'].[dbo].['+@LocalDBName+'])
  58.   where '+@PK_ID+' >'+cast(@NumMax as nvarchar(200));
  59.   drop table ##tmp_table;
  60.   print 'Success';
  61. end try
  62. begin catch
  63.   select Error_number() as ErrorNumber, --错误代码
  64.   Error_severity() as ErrorSeverity, --错误严重级别,级别小于10 try catch 捕获不到
  65.   Error_state() as ErrorState , --错误状态码
  66.   Error_Procedure() as ErrorProcedure , --出现错误的存储过程或触发器的名称。
  67.   Error_line() as ErrorLine, --发生错误的行号
  68.   Error_message() as ErrorMessage --错误的具体信息
  69.   drop table ##tmp_table;
  70. end catch
  71. END

执行存储过程

  1. USE [table] --源表
  2. GO
  3. DECLARE @return_value int
  4. EXEC @return_value = [dbo].[proc_DataUpdate]
  5. @TargetInstance = N'',--远程数据库实例 如目标库不在一个域,切勿使用内网地址
  6. @TargetDBName = N'',--远程数据库名称
  7. @TargetUID = N'',--用户名
  8. @TargetPWD = N'',--密码
  9. @LocalDBName=N'',--用于更新表名 (源表)
  10. @PK_ID =N'',--主键列(必须为Int)
  11. @Column='ID,Name',--更新列名集合 例 'A,B,C'
  12. @ExecSize=200--每次执行条数
  13. SELECT 'Return Value' = @return_value
  14. GO

总结

 以上所述是小编给大家介绍的SQL Server 远程更新目标表数据的存储过程,希望对大家有所帮助,

收藏 举报

延伸 · 阅读