2

我有 2 张桌子。以下只是这些表的精简版。

TableA
Id <pk> incrementing
Name varchar(50)

TableB
TableAId <pk> non incrementing
Name varchar(50)

现在这些表彼此之间有关系。

设想

用户 1 来到我的站点并执行了一些操作（在这种情况下，将行添加到表 A）。所以我使用 SqlBulkCopy 表 A 中的所有这些数据。

但是，我还需要将数据添加到表 B，但我不知道表 A 中新创建的 Id，因为 SQLBulkCopy 不会返回这些。

所以我正在考虑有一个存储过程来查找表 B 中不存在的所有 id，然后将它们插入。

INSERT INTO TableB (TableAId , Name)
SELECT Id,Name FROM TableA as tableA
WHERE not exists( ...)

然而，这带来了一个问题。用户可以随时从 TableB 中删除某些内容，因此如果用户删除了一行，然后另一个用户出现，或者甚至同一个用户出现并对表 A 执行某些操作，我的存储过程将在表 B 中恢复该删除的行。因为它仍然存在于表 A 但不存在于表 B 中，因此满足存储过程条件。

那么有没有更好的方法来处理使用批量插入时需要更新的两个表？

4

3 回答 3

3

SQLBulkCopy 使这复杂化，所以我会考虑使用临时表和OUTPUT 子句

示例，混合使用客户端伪代码和 SQL

create SQLConnection

Create #temptable
Bulkcopy to #temptable

Call proc on same SQLConnection

proc:
   INSERT tableA (..)
   OUTPUT INSERTED.key, .. INTO TableB
   SELECT .. FROM #temptable

close connection

笔记：

  • temptable 将在连接本地并被隔离

  • 对 A 和 B 的写入将是原子的
  • 重叠或以后的写入不关心 A 和 B 以后会发生什么
  • 强调最后一点，A 和 B 只会从 #temptable 中的行集中填充

选择：

向 A 和 B 添加另一个名为 sessionid 的列，并使用它来标识行批次。

于 2010-08-12T19:21:47.017 回答
1

一种选择是使用 SQL Server 输出子句：

INSERT YourTable (name)
OUTPUT INSERTED.*
VALUES ('NewName')

这会将id, name插入的行返回给客户端，因此您可以在第二个表的插入操作中使用它们。

于 2010-08-12T19:25:18.303 回答
1

作为替代解决方案，您可以使用数据库触发器来更新第二个表。

于 2010-08-12T19:41:33.770 回答