关于 Openflow Connector for Oracle¶

1.嵌入式许可证（Snowflake 提供）¶

Snowflake 直接向您提供 Oracle XStream 许可证，但需支付相应费用。在此模型下，您无需与 Oracle 直接签订合同即可使用 XStream 复制功能。有关更多信息，请参阅 嵌入式许可证详细信息 以及 Openflow Connector for Oracle 附录。

2.独立许可证（自带许可证 – BYOL)¶

您需要提供自己的 Oracle 许可证，其中包含 XStream 权限（例如，Oracle GoldenGate 许可证）。有关更多信息，请参阅 独立许可证 (BYOL) 详细信息。

计费¶

Oracle XStream 服务按月计费，并从您的 Snowflake 容量余额中扣除。该费用包含两个部分：许可证费用和支持与维护 (S&M) 费用。许可证费用根据源 Oracle 数据库中的处理器核心数量计算，并乘以 Oracle 处理器核心系数。

承诺期（“第 61 天”规则）¶

提供前 60 天的免费试用（最多 16 个许可核心）。在 60 天试用期后继续使用该连接器，将触发 36 个月的固定计费周期（“初始期限”），且期间不可取消。

• 自动转换：第 61 天起自动开始计费。为避免产生费用，必须在第 60 天之前通过 Admin » Terms » Openflow for Oracle 仪表板取消试用。

• 锁定：如果您的 Snowflake 协议在该初始期限内终止，则初始期限内剩余的全部费用将立即到期支付。

期限结束后的续订及相关条款¶

初始期限结束后，许可证费用将变为 0 美元，但支持与维护 (S&M) 费用仍将继续收取。

• 退出后果：您可以在 Admin » Terms » Openflow for Oracle 仪表板中选择退出 S&M 续订。但是，如果 S&M 服务终止，连接器处理器将被锁定。要恢复运行，您必须购买 NEW 嵌入式许可证（并重新开始 36 个月的全价承诺期）。

要求¶

您有责任在连接器配置中准确填写处理器核心数量以及正确的核心系数。如果源数据库硬件发生变化，则必须及时更新这些信息。

限制¶

以下情况不适用此选项：

• 公共部门实体（例如，政府和教育实体）。

• 通过 GCP Marketplace 购买 Snowflake 的客户。

• 通过第三方经销商与 Snowflake 签订合同的客户（例如，CDW、Optiv）。

配置¶

要配置嵌入式许可证，请执行以下操作：

• 在 UI 中查看并接受 Openflow Connector for Oracle 附录 中提供的条款。

• 选择 Embedded License 类型。

• 为源 Oracle 数据库输入 CPU 核心数量信息：**Total Cores**（源数据库服务器上的物理核心总数）以及 **Core Factor**（Oracle 处理器核心系数，例如 Intel 处理器为 0.5）。有关正确值，请参阅 Oracle 处理器核心系数表。

要求¶

您需要自行负责确保对该连接器的使用符合现有 Oracle 许可协议的相关条款。Snowflake 不会对您的 Oracle 权益进行验证或审计。

配置¶

配置独立许可证 (BYOL)：

• 在 UI 中查看并接受 Openflow Connector for Oracle 附录 中提供的条款。

• 选择 Independent License 类型。

在配置连接器时，无需填写任何核心数量或计费相关信息。

如何复制表¶

表的复制分为以下几个阶段：

1. 架构自检：连接器会发现源表中的列、包括列名和数据类型，然后根据 Snowflake 和连接器的 限制 来验证它们。连接器会发现源表中的列、包括列名和数据类型，然后根据 Snowflake 和连接器的 `限制`_ 来验证它们。验证失败会导致此阶段失败，并且周期完成。如果成功完成该阶段，连接器将会在 Snowflake 中创建一个空目标表。

2. 快照加载：连接器将源表中的所有可用数据复制到目标表中。如果此阶段失败，则不会再复制任何数据。成功完成后，源表中的数据将在目标表中可用。

3. 增量加载连接器跟踪源表中的更改并将这些更改应用到目标表。连接器跟踪源表中的更改并将这些更改应用到目标表。此过程将一直持续，直到从复制中移除该表。如果该阶段失败，将永久停止源表的复制，直到问题解决。

表复制状态¶

临时故障（例如连接错误）不会停止表的复制。但是，永久性故障（例如不支持的数据类型）会导致表复制无法进行。

要解决复制问题或验证表是否已成功从复制流中移除，请检查表状态存储：

1. 在 Openflow 运行时画布中，右键点击处理器组并选择 Controller Services。系统将显示一个列出控制器服务的表。

2. 找到标记为 Table State Store 的行，点击该行右侧的 More 按钮，然后选择 View State。

系统将显示表及其当前状态的列表。在搜索框中输入内容，可按表名筛选列表。可能的状态如下：

• NEW：选择使用 时默认使用的角色和仓库。该表已加入复制计划，但复制尚未开始。

• SNAPSHOT_REPLICATION：选择使用 时默认使用的角色和仓库。连接器正在复制现有数据。该状态会持续显示，直到所有记录都已写入目标表。

• INCREMENTAL_REPLICATION：选择使用 时默认使用的角色和仓库。连接器正在主动复制变更。该状态会在快照复制结束后显示，并会一直保持，直到该表从复制中移除或复制失败。

• FAILED：选择使用 时默认使用的角色和仓库。由于发生错误，复制已永久停止。

Replication state for table <database_name>.<schema_name>.<table_name> changed from <old_state> to <new_state>

如果由于永久性故障导致表无法复制，请将该表从复制中移除。解决了导致失败的问题后，可以将该表重新加入复制。有关更多信息，请参阅 重新启动表复制。

目标表元数据列¶

每个目标表都包含以下用于跟踪复制信息的元数据列：

软删除的行¶

当某一行从源表中删除时，连接器不会将其从目标表中物理删除。相反，连接器会通过将 _SNOWFLAKE_DELETED 元数据列设置为 true 来标记该行已删除。

这种方法使您能够：

• 保留历史数据，以满足审计或合规要求。

• 在需要时查询已删除的记录。

• 根据自身需求决定何时以及如何永久移除数据。

要仅查询活动（未删除）的行，请在 _SNOWFLAKE_DELETED 列上进行筛选：

SELECT * FROM my_table WHERE _SNOWFLAKE_DELETED = FALSE;

要查询已删除的行，请执行以下操作：

SELECT * FROM my_table WHERE _SNOWFLAKE_DELETED = TRUE;

已删除的列¶

当源表中的列被删除时，连接器不会在目标表中删除对应的列。相反，该列会通过在列名后追加 __SNOWFLAKE_DELETED 后缀进行重命名，以保留历史数据。

例如，如果源表中名为 EMAIL 的列被删除，则在目标表中该列会被重命名为 EMAIL__SNOWFLAKE_DELETED。在列被删除之前已存在的行会保留原始值，而在删除之后新增的行在该列中将显示为 NULL。

您仍然可以从重命名的列中查询历史数据：

SELECT EMAIL__SNOWFLAKE_DELETED FROM my_table;

重命名的列¶

由于 CDC（变更数据捕获）机制的限制，连接器无法区分“列被重命名”与“列被删除后新增一个新列”这两种情况。因此，当您在源表中重命名列时，连接器会将其视为两个独立操作：删除原始列，然后新增一个具有新名称的列。

例如，如果在源表中将列名从 A 重命名为 B，则目标表将包含：

• A__SNOWFLAKE_DELETED：选择使用 时默认使用的角色和仓库。包含重命名前的值。重命名之后新增的行在此列中为 NULL。

• B：选择使用 时默认使用的角色和仓库。包含重命名后的值。在重命名之前存在的行在此列中为 NULL。

SELECT
    COALESCE(B, A__SNOWFLAKE_DELETED) AS A_RENAMED_TO_B
FROM my_table;

SELECT
    CASE
        WHEN B IS NOT NULL THEN B
        ELSE A__SNOWFLAKE_DELETED
    END AS A_RENAMED_TO_B
FROM my_table;

CREATE VIEW my_table_unified AS
SELECT
    *,
    COALESCE(B, A__SNOWFLAKE_DELETED) AS A_RENAMED_TO_B
FROM my_table;

日志表¶

在增量复制过程中，来自源数据库的变更会先写入日志表，然后再合并到目标表中。连接器不会自动删除日志表中的数据，因为这些数据可能用于审计、调试或重新处理。

日志表会在与对应目标表相同的架构中创建，并遵循以下命名规则：

<TABLE_NAME>_JOURNAL_<timestamp>_<number>

其中：

• <TABLE_NAME> 是目标表的名称。

• <timestamp> 表示 Unix 纪元格式的创建时间戳（自 1970 年 1 月 1 日以来的秒数），用于确保唯一性。

• <number> 从 1 开始，每当目标表架构发生变化时递增，这可能是由于源表架构变化或列筛选条件修改导致的。

例如，如果目标表名称为 SALES.ORDERS，则日志表名称可能为 SALES.ORDERS_JOURNAL_1705320000_1。