如何合并两个无过滤SQL查询（禁用UNION）并验证结果准确性？

一、合并查询实现（禁用UNION） #

要覆盖两个查询的所有行（含重叠及独有数据），**全外连接（FULL OUTER JOIN）**是最直接的方案。核心思路是用唯一标识组合（如Date+SalesId+DocumentID）关联两个子查询，再通过字段函数统一输出格式：

SELECT
    COALESCE(a.Date, b.Date) AS Date,
    COALESCE(a.Value, b.Value) AS Value,
    -- 根据业务逻辑映射字段：示例假设QueryA对应发票ID，QueryB对应订单ID
    CASE WHEN a.DocumentID IS NOT NULL THEN a.DocumentID ELSE NULL END AS SalesInvoiceID,
    CASE WHEN b.DocumentID IS NOT NULL THEN b.DocumentID ELSE NULL END AS SalesOrderID
FROM
    (
        -- 替换为你的第一个原始查询
        SELECT Date, InvoiceDate, DocumentID, SalesId, Value FROM YourFirstSource
    ) a
FULL OUTER JOIN
    (
        -- 替换为你的第二个原始查询
        SELECT Date, InvoiceDate, DocumentID, SalesId, Value FROM YourSecondSource
    ) b
ON
    a.Date = b.Date
    AND a.SalesId = b.SalesId
    AND a.DocumentID = b.DocumentID;

关键细节： #

• COALESCE用于优先取非空字段值，避免重叠行出现重复数据
• 全外连接会自动保留两个子查询中所有不匹配的行，覆盖“仅存在于单个查询”的场景
• 字段映射需结合业务逻辑调整：比如明确哪个查询的DocumentID对应SalesInvoiceID，哪个对应SalesOrderID

二、现有方案的优劣判断维度 #

如果已经尝试了两种视图，从以下3点对比即可选出最优解：

• 行覆盖完整性：检查是否包含两个原始查询的所有独有行，且重叠行仅保留一次
• 字段准确性：验证SalesInvoiceID/SalesOrderID是否正确对应到来源查询的DocumentID
• 性能：查看执行计划，优先选择索引利用率高（如关联字段有复合索引）、扫描行数少的方案

三、准确性验证方案 #

1. 行数量校验 #

计算原始查询的理论总行数（去重后），与合并结果对比：

-- 计算理论总行数：A去重行数 + B去重行数 - 重叠行去重行数
SELECT 
    (SELECT COUNT(DISTINCT Date, SalesId, DocumentID) FROM QueryA) +
    (SELECT COUNT(DISTINCT Date, SalesId, DocumentID) FROM QueryB) -
    (SELECT COUNT(*) FROM (SELECT DISTINCT Date, SalesId, DocumentID FROM QueryA INTERSECT SELECT DISTINCT Date, SalesId, DocumentID FROM QueryB) t) AS ExpectedRowCount;

-- 对比合并结果的去重行数
SELECT COUNT(DISTINCT Date, SalesInvoiceID, SalesOrderID) AS ActualRowCount FROM MergedView;

两者数值需完全一致。

2. 字段值校验 #

• 重叠行验证：选取一组确定重叠的Date+SalesId+DocumentID，检查合并结果的Value是否与原始查询一致，且SalesInvoiceID/SalesOrderID同时存在
• 独有行验证：从QueryA中找一个QueryB没有的行，确认合并结果中该行的SalesOrderID为NULL；同理验证QueryB的独有行，SalesInvoiceID为NULL
• 数值总和校验：合并结果的Value总和应等于“QueryA总和 + QueryB总和 - 重叠行总和”：

-- 计算预期总和
SELECT 
    (SELECT SUM(Value) FROM QueryA) +
    (SELECT SUM(Value) FROM QueryB) -
    (SELECT SUM(Value) FROM (SELECT * FROM QueryA INTERSECT SELECT * FROM QueryB) t) AS ExpectedTotalValue;

-- 对比合并结果总和
SELECT SUM(Value) AS ActualTotalValue FROM MergedView;

3. 边界场景校验 #

• 检查Value为NULL的行是否正确保留
• 验证两个查询中最早/最晚的Date行是否都出现在合并结果中

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