我配置了指向Oracle数据库的链接服务器，该Oracle源表包含超过1400万条数据行。我使用以下语句将其与SQL Server中的目标表执行MERGE操作：

WITH SRC AS ( select * from [LINK_ORA]..[TEST].[SOURCE_TABLE] )
MERGE INTO [TARGET_TABLE] AS [Target]
USING SRC AS [Source]
ON [Target].Id = [Source].ID
WHEN MATCHED THEN UPDATE SET Target.IsDeleted = 0, Target.Attribute1 = Source.ATTRIBUTE1, Target.Attribute2 = Source.ATTRIBUTE2, Target.Attribute3 = Source.ATTRIBUTE3
WHEN NOT MATCHED BY TARGET THEN INSERT( IsDeleted, Id, Attribute1, Attribute2, Attribute3 ) VALUES( 0, Source.ID, Source.ATTRIBUTE1, Source.ATTRIBUTE2, Source.ATTRIBUTE3 )
WHEN NOT MATCHED BY SOURCE THEN UPDATE SET Target.IsDeleted = 1;

执行完成后，我发现仅51276行数据被加载到目标表，请问这是什么原因导致的？

以下是几种常见的原因，你可以逐一排查：

• 链接服务器的数据拉取限制
  链接服务器默认的Fetch Size可能设置得太小，导致SQL Server从Oracle拉取数据时只获取了部分行就中断了。你可以先单独执行SELECT COUNT(*) FROM [LINK_ORA]..[TEST].[SOURCE_TABLE]，看看返回的行数是否真的是1400万。如果不是，那就是链接服务器的配置问题：

  1. 打开SQL Server Management Studio，找到你的链接服务器LINK_ORA
  2. 右键选择「属性」→「服务器选项」
  3. 找到Fetch Size，把它调大（比如设置为100000），然后重新执行MERGE操作。

• 匹配键的数据类型不兼容
  检查Target.Id和Source.ID的数据类型是否完全一致：比如Oracle的ID是NUMBER(18)，而SQL Server的Id是INT，那么超过INT范围（2^31-1）的ID会被隐性截断，导致这些行无法匹配也无法插入；或者如果是字符串类型，大小写不一致也会导致匹配失败。
  你可以执行SELECT TOP 100 ID FROM [LINK_ORA]..[TEST].[SOURCE_TABLE]和SELECT TOP 100 Id FROM [TARGET_TABLE]，对比两者的数据格式和类型是否一致。

• 目标表已有大部分数据，仅少量新行被插入
  你提到的“仅51276行被加载”可能指的是新插入的行数，而大部分源数据已经存在于目标表中，所以执行的是更新操作而非插入。你可以查询目标表的总活跃行数：SELECT COUNT(*) FROM [TARGET_TABLE] WHERE IsDeleted = 0，如果这个数值接近1400万，说明MERGE已经正常完成，只是新插入的行只有5万多，这是符合预期的。

• 大事务超时或日志空间不足
  1400万行的MERGE是非常大的操作，很容易触发SQL Server的事务超时，或者因为事务日志占满磁盘导致操作中途终止。你可以查看SQL Server的错误日志（在「管理」→「SQL Server日志」里），看看有没有超时、磁盘空间不足的报错。
  解决方法是把MERGE拆成分批操作，比如每次处理10万行，避免一次性处理全量数据：

  DECLARE @BatchSize INT = 100000;
  DECLARE @MaxID INT = (SELECT MAX(ID) FROM [LINK_ORA]..[TEST].[SOURCE_TABLE]);
  DECLARE @CurrentID INT = 0;
  
  WHILE @CurrentID < @MaxID
  BEGIN
      WITH SRC AS (
          SELECT * FROM [LINK_ORA]..[TEST].[SOURCE_TABLE]
          WHERE ID BETWEEN @CurrentID AND @CurrentID + @BatchSize
      )
      MERGE INTO [TARGET_TABLE] AS [Target]
      USING SRC AS [Source]
      ON [Target].Id = [Source].ID
      WHEN MATCHED THEN UPDATE SET Target.IsDeleted = 0, Target.Attribute1 = Source.ATTRIBUTE1, Target.Attribute2 = Source.ATTRIBUTE2, Target.Attribute3 = Source.ATTRIBUTE3
      WHEN NOT MATCHED BY TARGET THEN INSERT( IsDeleted, Id, Attribute1, Attribute2, Attribute3 ) VALUES( 0, Source.ID, Source.ATTRIBUTE1, Source.ATTRIBUTE2, Source.ATTRIBUTE3 );
  
      SET @CurrentID = @CurrentID + @BatchSize;
      CHECKPOINT; -- 截断日志，避免日志膨胀
  END
  
  -- 最后处理NOT MATCHED BY SOURCE的逻辑
  UPDATE [TARGET_TABLE]
  SET IsDeleted = 1
  WHERE Id NOT IN (SELECT ID FROM [LINK_ORA]..[TEST].[SOURCE_TABLE]);
  

• Oracle源表的行级权限限制
  链接服务器使用的Oracle登录账号可能没有访问SOURCE_TABLE全量数据的权限，比如存在行级安全策略，只能看到5万多行数据。你可以用这个登录账号直接登录Oracle，执行SELECT COUNT(*) FROM TEST.SOURCE_TABLE，确认返回的行数是否为1400万。

内容的提问来源于stack exchange，提问作者Interloper