Native SDK for Connectors Java – 版本说明¶

行为变更¶

• 新的标识符方法。

  重要

  这种新方法可能会改变标识符在连接器中的使用方式，请对新变更进行充分测试！

  • 现在 SDK 期望所有标识符都按照用户提供的方式发送；SDK 将自行评估标识符是否是否为带引号的标识符，以便进一步正确处理。

  • 只有在使用 Snowflake 查询返回的值时，才会自动为标识符加引号。

  • 要使用带有 UI 的新方法，连接器必须在 PUBLIC.APP_PROPERTIES 视图中返回一个新属性，其键为 UI_ADD_QUOTES_TO_EXISTING_QUOTED_IDENTIFIERS，值为 TRUE。

  • 变更了 com.snowflake.connectors.common.object.Identifier 类：

    • 移除了 fromWithAutoQuoting() 和 getName() 方法。

    • 移除了空标识符的概念；移除了 empty()、isNullOrEmpty()、validateNullOrEmpty() 和 isEmpty() 方法。

    • 添加了新的 from() 方法，允许在标识符实例创建期间启用自动加引号；如果提供的字符串是未加引号且完全大写的标识符，则不会自动为其加引号。

    • 将 validate() 方法变更为 isValid()。

    • 将 toSqlString() 方法变更为 getValue()。

    • 添加了 getUnquotedValue()、getQuotedValue()、getVariantValue() 和 isUnquoted() 方法。

• 变更了 com.snowflake.connectors.common.object.ObjectName 类：

  • 制作了数据库和架构属性 Optional。

  • 将 getDatabase() 和 getSchema() 的返回类型变更为 Optional。

  • 将 validate() 方法变更为 isValid()。

  • 将 validateDoubleDot() 方法变更为 isDoubleDot()。

  • 将 getEscapedName() 方法变更为 getValue()。

  • 添加了 getVariantValue() 和 getSchemaName() 方法。

• 变更了 com.snowflake.connectors.common.object.Reference 类：

  • 移除了空引用的概念；移除了 empty() 和 isEmpty() 方法。

  • 将 validate() 方法变更为 isValid()。

  • 将 referenceName() 方法变更为 getName()。

  • 将 value() 方法变更为 getValue()。

  • 添加了新的 com.snowflake.connectors.common.object.SchemaName 类来表示架构；与 com.snowflake.connectors.common.object.ObjectName 类的行为相似。

  • 添加了新的 com.snowflake.connectors.common.object.InvalidSchemaNameException 类。

新功能¶

• 资源管理过程：

  • 向 PUBLIC.CREATE_RESOURCE() 过程引入了新的回调函数，允许在过程流中执行自定义操作。另见 创建资源。

  • 新的 PUBLIC.ENABLE_RESOURCE() 过程允许启用禁用的资源。此外，还增加了回调函数，允许在过程流中执行自定义操作。另见 启用资源。

  • 新的 PUBLIC.DISABLE_RESOURCE() 流程允许禁用已启用的资源。此外，还增加了回调函数，允许在过程流中执行自定义操作。另见 禁用资源。

  • 新的 PUBLIC.UPDATE_RESOURCE() 过程允许更新特定资源的引入配置。此外，还增加了回调函数，允许在过程流中执行自定义操作。另见 更新资源。

• com.snowflake.connectors.util.sql.SqlTools：

  • 添加了 asVarchar() 方法用于替代 varcharArgument() 方法。

  • 添加了 asVariant() 方法用于替代 variantArgument() 方法。

  • 将 varcharArgument() 和 variantArgument() 方法标记为已弃用，并计划在未来将其移除。

• 其他添加：

  • 在 com.snowflake.connectors.application.ingestion.process.IngestionProcessStatuses 类中将引入过程状态定义为常量。

  • 向 com.snowflake.connectors.common.response.ConnectorResponse 类添加了 isNotOk() 方法。

  • 添加了 com.snowflake.connectors.util.snowflake.DefaultTransactionManager 类，该类允许通过使用 withTransaction() 方法在事务中执行 SQL 语句。

  • 改进了任务反应器中的日志记录。

错误修复¶

• 修复了一个错误，该错误导致在 CREATE_INSTANCE_OBJECTS() 过程中出现意外错误时，会删除任务反应器实例架构。