Search

PostgreSQL Upsert 配置

Version 24.3.9118

PostgreSQL Upsert 配置

Upsert 操作插入或更新 PostgreSQL 数据。 默认情况下，如果 PostgreSQL 中已存在记录，则使用输入提供的值对 PostgreSQL 中的现有数据执行更新。有关详细信息，请参阅 UPSERT-查询行为。

表格和列

如果为 PostgreSQL 端口选择 Upsert，则必须从 PostgreSQL 中选择一个（或多个）目标表。 单击 表格 面板上方的 + 添加 按钮。

一个模态框出现并列出所有可用的表格。 选择所需的表并单击+ 添加。

选定的表出现在 表格 面板下，表中的列出现在 列 面板下。 端口会自动检测具有特殊相关性的值（例如主键、外键等）并相应地标记它们。

默认情况下，所有列都被选中以包含在 PostgreSQL 端口的操作中。 你可以通过取消选中来删除单个列。

注意：你可以通过单击+ 添加 并重复此过程来选择更多表。 有关详细信息，请参阅 子表。

UPSERT 查询行为

默认情况下，列映射中的 UPSERT 滑块设置为 ON。 这意味着 UPSERT 映射在 INSERT 记录（如果没有匹配记录）或 UPDATE 记录（如果记录已存在）之前确定记录是否存在于目标中。

用于确定该值的查询由以下部分中描述的逻辑确定。

UPSERT 滑块设置为开

当滑块设置为 ON 时，查询行为会根据在 UPSERT By 和 执行此查询… 单选按钮中选择的内容而变化。

按 ID UPSERT

如果输入 XML 中存在键列，则会向数据库发出查询以确定是否存在具有匹配键的任何记录：

The action type is UPSERT and an UPSERT query is not specified. The key column [Id] is present and will be determined using an automatically generated UPSERT query.
SELECT COUNT(*) AS [count] FROM [Orders] WHERE [Id] = @Id; @Id='123'

匹配结果更新； 没有匹配结果导致插入。

如果输入 XML 中不存在键列，则始终插入记录：

The key column Id was not specified, INSERT will be executed.
The action type is UPSERT or an UPSERT query is specified. The key column is not present. Record will be INSERTED.

按非键列进行 UPSERT

通过选择表的主键，向数据库发出查询，以确定是否存在所选 UPSERT By 列包含匹配值的记录：

SELECT [Id] FROM [Orders] WHERE [OrderId] = @OrderId; @OrderId='12345'

SELECT 查询始终以 SELECT 语句中表的键列为目标。 如果匹配成功，则输入 XML 中的数据将更新到数据源中。 如果没有匹配，则插入记录。

注意：如果输入中未指定所选的 UPSERT By 列，则查找将与 NULL 值一起使用，如以下查询所示：

SELECT [Id] FROM [Orders] WHERE [OrderId] = @OrderId; @OrderId=NULL

使用自定义查询

还可以编写自定义查询来选择 UPSERT 键。 此选项允许使用比单列匹配更复杂的逻辑来执行查找。 考虑以下查询：

SELECT [Id] FROM [Orders] WHERE [OrderId] = @OrderId AND Status = 'Active'

在此示例中，必须选择表的键列，以便为 UPDATE 提供足够的条件。 @OrderID 语法用于引用匹配输入 XML 中的值。 还可以使用静态值：Active周围的引号表示该子句使用静态值。

同样，键列的成功匹配用于形成更新请求。 如果没有匹配，则插入记录。

提示：当对数据库插入的行为有疑问时，请查看 UPSERT 尝试的.log文件：用于指导该行为的逻辑的完整细分将发送到日志文件。

UPSERT 滑块设置为关闭

当滑块设置为 OFF 时，端口只需将所有查询插入数据库即可。 检查输入映射的代码视图显示表的action属性是insert：

<Items>
    <Orders table="`Orders`" action="insert">

无论主键是否存在，向表发出的所有查询都被视为插入。 要根据表更新所有收到的记录，可以将此操作关键字设置为update，如以下代码片段所示：

<Items>
    <Orders table="`Orders`" action="update">

警告：当操作定义为更新时，应用程序期望表的键列（例如，Id）存在。 如果未提供键列，则 UPDATE 命令的效果可能会因目标数据库类型而异，因此可能会看到更改的行数比预期多，或者根本没有更改。

知行之桥工作流示例

为 Upsert 配置的 PostgreSQL 端口选择表格和列后，将端口放置在知行之桥工作流的末尾。 下面的屏幕截图描述了一个示例流程，其中包含一个 CSV 端口、一个 XML Map 端口和一个 PostgreSQL Upsert 端口：

此示例工作流中的数据通过以下步骤：

  1. File 端口 从磁盘提取 CSV 文件并将其放入流程中。

  2. CSV1 端口将 CSV 文件转换为 XML。

  3. 此数据作为 源文件 传递给 XML_Map 端口，后者映射到 源 的树状结构中。

  4. 来自 PostgreSQL_Upsert 端口的数据作为 目标文件 传递给 XML_Map 端口，后者映射到 目标 树状结构。

  5. XML_Map 端口尝试自动将 源 元素映射到具有相同名称的 目标 元素。 你可以手动更改这些并通过将元素从 源 拖到 目标 来填充空白映射。

  6. PostgreSQL_Upsert 端口根据映射执行 Upsert 并将结果数据传递给 PostgreSQL。