2

我需要在更新表期间应用一些逻辑。

existing_items 是目标表， received_items 包含对 existing_items 或新项目的更新。

逻辑是 - 对于每个分组的 received_items，应该在 existing_items 中标识一个匹配的行。如果未找到匹配项，则应创建一个新行。

更重要的是行可以匹配多个条件。它们应该始终在代码、line_no（如果给定）、ref（如果给定）上匹配。received_items 行应按 processing_seq 顺序处理，并可能按给定顺序检查匹配项。

当所有分组的 received_item 都与一个 existing_item 匹配时，任何剩余部分都是一个新行。

鉴于：

 create table #existing_items(id int identity(1,1), code varchar(10)
,qty numeric(10,2), line_no int, ref varchar(10))

create table #received_items(code varchar(10), qty numeric(10,2), line_no int
,ref varchar(10), processing_seq int)

insert into #existing_items (code, qty, line_no, ref)
    values('ABC123',2.0, 1, NULL)
insert into #existing_items (code, qty, line_no, ref)
    values('ABC123',3.0, 2, '1001')
insert into #received_items(code, qty, line_no, ref, processing_seq)
    values ('ABC123', 4, NULL, NULL, 1)
insert into #received_items(code, qty, line_no, ref, processing_seq)
    values ('ABC123', 3, NULL, NULL, 1)
insert into #received_items(code, qty, line_no, ref, processing_seq)
    values ('ABC123', 4, NULL, 1002, 2)
insert into #received_items(code, qty, line_no, ref, processing_seq)
    values ('ABC123', 4, 2, 1003, 3)
insert into #received_items(code, qty, line_no, ref, processing_seq)
    values ('ABC123', 5, NULL, NULL, 4)

从#received_items 中选择 *

        ABC123    4.00    NULL    NULL    1
        ABC123    3.00    NULL    NULL    1
        ABC123    4.00    NULL    1003    2
        ABC123    4.00    2       1002    3
        ABC123    5.00    NULL    NULL    4

从 #existing_items 中选择 *

        1    ABC123    2.00    1    NULL
        2    ABC123    3.00    2    1001

结果应该是：

        1    ABC123    7.00    1     NULL
        2    ABC123    4.00    2     1002
        3    ABC123    4.00    3     1003
        4    ABC123    5.00    4     NULL

解释：

id=1 的 existing_items 更新为 7，因为 received_items 应该被分组（code、line_no、ref、processing_seq）。该行仅在代码上匹配，因为没有提供 line_no 或 ref。

使用 id=3 创建一个新项目，因为没有找到与 ref 1003 匹配的项目。

id=2 的 existing_items 更新 qty 和 ref，因为在 line_no 上找到了匹配项。

使用 id=4 创建一个新行，因为没有要匹配的行（id=1 已经与 processing_seq = 1 的第一组匹配）。

不知道该怎么做，正在考虑光标，但可能有更简单的方法。我目前正在使用多个自我连接.. 像这样：

 Select grp.*
,fm.id as full_match, rm.id as ref_match, lm.id as line_match
,(select min(id) from #existing_items where code = grp.code
 and rm.id IS NULL and lm.id IS NULL and fm.id IS NULL and grp.ref IS NULL
) as code_match
-- ,cm.id as code_match 
FROM (
select ri.code, sum(ri.qty) qty,ri.line_no,ri.ref, ri.processing_seq
from #received_items ri
group by code, line_no, ref, processing_seq
) grp
LEFT OUTER JOIN 
 #existing_items fm
 ON grp.code = fm.code AND grp.line_no = fm.line_no and grp.ref = fm.ref
LEFT OUTER JOIN 
 #existing_items rm
 ON grp.code = rm.code AND  grp.ref = rm.ref
LEFT OUTER JOIN 
 #existing_items lm
 ON grp.code = lm.code AND  grp.line_no = lm.line_no
order by grp.processing_seq

这可以部分了解要更新哪一行并产生这个临时结果：

Code    Qty    Line_No  Ref    seq    fm.id   rm.id   lm.id       cm.id
ABC123  7.00    NULL    NULL    1     NULL    NULL    NULL        1
ABC123  4.00    NULL    1002    2     NULL    NULL    NULL        NULL
ABC123  4.00    2       1003    3     NULL    NULL    2           NULL
ABC123  5.00    NULL    NULL    4     NULL    NULL    NULL        1

需要一种方法来识别仅在代码上最接近的匹配，这已经奏效，但不适用于 seq=4 应该具有 NULL 的 cm.id - 所以我需要更改我的子查询以不在同一个子查询中返回先前匹配的 id？然后我应该能够在任何匹配列中没有 id 的地方插入。

任何有关如何解决问题的见解都非常感谢。

4

2 回答 2

0

你知道吗，你更新现有数据的方式有很多开销。您应该为每一行确定应该更新的内容，并再次运行更新命令。您可以自己计算服务器资源的成本。循环遍历每条记录，并识别它是否已更改并更新。并且，使用您声明的多个表，#EXISTINGITEM、#NEWITEMS 和您在其他表上的实际数据。这有很多超载。

我仍然不知道在您的情况下是否可能，但是。我想建议的是。假设，我的库存中有一个问题请求。为此，我有 2 个表名，ISSUE_MAST和ISSUE_DETL。Issue Mast 包含 ISSUE_DOC_NO，Detail 表包含ISSUE_DOC_NO和SEQ_NO。

现在，假设我们有一个要维护的新问题请求。然后，我可以简单地将数据保存在MAST和DETL表中，因为它是全新的请求，所以不会有任何问题。它不是你的问题所在。而且，现在，假设有一天，请求必须改变。然后，用户将向我提供 MAST 和 DETL 信息。而且，现在，我能做的只是删除 DOC_NO 属于当前 DOC NO 的所有 DETL 项目。而且，只需将所有给定的行再次插入为新鲜数据。

由于重载，我根本不喜欢更新逻辑。但是，在某些情况下，我们也必须这样做。但是，必须的情况下，我们不应该选择这种方式。如果可行，我们必须删除 DETL 信息并再次重新插入它，但这取决于您的事务复杂性。

于 2013-06-20T05:34:11.123 回答
0

一段时间后，我设法弄清楚了这一点：

;WITH existing as (
SELECT
    id, code, qty, line_no, ref
    ,ROW_NUMBER() OVER (ORDER BY line_no) AS code_inst
FROM #existing_items
)
,received as (
SELECT
    code, SUM(qty) qty, line_no, ref
    ,ROW_NUMBER() OVER (ORDER BY processing_seq) pseq
    ,ROW_NUMBER() OVER (PARTITION BY code ORDER BY processing_seq) code_inst
FROM
    #received_items
GROUP BY
    code, line_no, ref, processing_seq
)
SELECT
    recv.*, COALESCE(lm.ID, rm.id, cm.id) AS matched_id
FROM
    received recv
LEFT OUTER JOIN
    existing lm --line match
ON
    recv.code = lm.code and recv.line_no = lm.line_no
LEFT OUTER JOIN
    existing rm --ref match
ON
    recv.code = rm.code and recv.ref = rm.ref
LEFT OUTER JOIN
    existing cm --code match
ON
    recv.code = cm.code 
    AND recv.code_inst = cm.code_inst
    AND cm.ref IS NULL
    AND lm.id IS NULL AND rm.id IS NULL

链接 3 次并不理想，但考虑到所涉及的逻辑（不同的匹配标准），它是有道理的。我最终将此结果集加载到一个表变量中，然后我更新了 id 匹配的现有位置，并在 match_id 为 NULL 的位置插入。

于 2013-06-25T00:51:12.720 回答