Native SDK pour les tests Connectors Java - Notes de version¶

Remplacement de l’outil SnowSQL par le nouvel outil CLI Snowflake

Mise à jour des dépendances Java

com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder :

• Remplacement du nom de la méthode withSchedulerCreator(SchedulerCreator) par withSchedulerManager(SchedulerManager).

com.snowflake.connectors.application.scheduler.InMemoryDefaultSchedulerCreator :

• Remplacement du nom de la classe par InMemoryDefaultSchedulerManager.

com.snowflake.connectors.taskreactor.commands.queue.InMemoryCommandsQueueRepository :

• Remplacement du nom de la classe par InMemoryCommandsQueue.

Nouveaux générateurs de tests pour divers gestionnaires (handlers) qui permettent de personnaliser entièrement les objets utilisés par les classes de gestionnaires :

• Ajout de com.snowflake.connectors.application.configuration.reset.ResetConfigurationHandlerTestBuilder.

com.snowflake.connectors.application.lifecycle.pause.PauseConnectorHandlerTestBuilder :

• Ajout de la méthode withSchedulerManager(SchedulerManager).

com.snowflake.connectors.application.lifecycle.resume.ResumeConnectorHandlerTestBuilder :

• Ajout de la méthode withSchedulerManager(SchedulerManager).

Ajout de nouvelles classes d’assertion :

• com.snowflake.connectors.common.assertions.ingestion.IngestionConfigurationAssert, qui permet d’affirmer des objets de classe com.snowflake.connectors.application.ingestion.definition.IngestionConfiguration.

• com.snowflake.connectors.common.assertions.UUIDAssertions, qui permet d’affirmer des représentations de chaîne d’UUIDs.

com.snowflake.connectors.common.assertions.task.TaskPropertiesAssert :

• Ajout de l’assertion hasPredecessors(List<TaskRef>).

com.snowflake.connectors.common.assertions.ingestion.IngestionRunAssert :

• Ajout de l’assertion hasIdAsUUID().

• Ajout de l’assertion hasIngestionConfigurationIdAsUUID().

• Ajout de l’assertion hasIngestionProcessIdAsUUID().

• Ajout de l’assertion hasStartedAt().

• Ajout de l’assertion hasCompletedAt().

• Ajout de l’assertion hasCompletedAtAfterStartedAt().

• Ajout de l’assertion hasIngestedRowsGreaterThan(int).

• Ajout de l’assertion hasUpdatedAt().

• Ajout de l’assertion hasMetadata().

• Ajout de l’assertion hasCompletedState().

Ajout de nouvelles classes à utiliser dans les tests d’intégration :

• com.snowflake.connectors.common.SharedObjects.

• com.snowflake.connectors.common.PathResolver.

• com.snowflake.connectors.common.procedure.ProcedureDescriptor.

• com.snowflake.connectors.common.procedure.ProcedureProperties.

com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository :

• Fourniture d’une implémentation de la méthode endProcess(String, String, String), au lieu de déclencher UnsupportedOperationException.

Classe com.snowflake.connectors.taskreactor.InMemoryConfiguredTaskReactorExistenceVerifier supprimée.

Classe com.snowflake.connectors.taskreactor.InMemoryNotConfiguredTaskReactorExistenceVerifier supprimée.

Classe com.snowflake.connectors.application.common.task.InMemoryTaskRepository supprimée.

Nouveaux générateurs de tests pour divers gestionnaires (handlers) qui permettent de personnaliser entièrement les objets utilisés par les classes de gestionnaires :

• Ajout de com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerTestBuilder.

• Ajout de com.snowflake.connectors.application.ingestion.enable.EnableResourceHandlerTestBuilder.

• Ajout de com.snowflake.connectors.application.ingestion.disable.DisableResourceHandlerTestBuilder.

• Ajout de com.snowflake.connectors.application.ingestion.update.UpdateResourceHandlerTestBuilder.

• Ajout de com.snowflake.connectors.application.scheduler.CreateSchedulerHandlerTestBuilder.

Nouvelles implémentations en mémoire :

• Ajout de com.snowflake.connectors.application.scheduler.InMemoryDefaultSchedulerCreator.

• Ajout de com.snowflake.connectors.application.configuration.connector.InMemoryConnectorConfigurationService.

• Ajout de com.snowflake.connectors.application.status.InMemoryConnectorStatusRepository.

• Ajout de com.snowflake.connectors.application.status.InMemoryConnectorStatusRepository.

• Ajout de com.snowflake.connectors.taskreactor.InMemoryTaskManagement.

• Ajout de com.snowflake.connectors.util.snowflake.InMemoryAccessTools.

• Ajout de com.snowflake.connectors.util.snowflake.InMemoryTransactionManager.

Ajout de nouvelles assertions dans com.snowflake.connectors.common.assertions.NativeSdkAssertions :

• Ajout de com.snowflake.connectors.common.assertions.task.CommandAssert qui permet l’assertion d’objets de la classe com.snowflake.connectors.taskreactor.commands.queue.Command.

• Ajout de com.snowflake.connectors.common.assertions.common.object.ObjectNameAssert qui permet l’assertion d’objets de la classe com.snowflake.connectors.common.object.ObjectName.

• Ajout de com.snowflake.connectors.common.assertions.common.object.SchemaNameAssert qui permet l’assertion d’objets de la classe com.snowflake.connectors.common.object.SchemaName.

• Ajout de com.snowflake.connectors.common.assertions.common.object.ReferenceAssert qui permet l’assertion d’objets de la classe com.snowflake.connectors.common.object.Reference.

com.snowflake.connectors.common.assertions.ingestion.definition.ResourceIngestionDefinitionAssert :

• Ajout de la méthode isEnabled().

• Ajout de la méthode isDisabled().

com.snowflake.connectors.common.assertions.common.response :

• Ajout de la méthode hasAdditionalPayload().