Package com.snowflake.connectors.application.ingestion.create

Class CreateResourceHandlerTestBuilder

  • public class CreateResourceHandlerTestBuilder
extends com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder
    Test builder for the CreateResourceHandler.

    Allows for customization of the following handler components:

    • ConnectorErrorHelper
    • ResourceIngestionDefinitionRepository
    • IngestionProcessRepository
    • TransactionManager

    • Constructor Detail

      • CreateResourceHandlerTestBuilder

        public CreateResourceHandlerTestBuilder()
        Creates a new, empty CreateResourceHandlerTestBuilder.

        Properties of the new builder instance must be fully customized before a handler instance can be built.

      • CreateResourceHandlerTestBuilder

        public CreateResourceHandlerTestBuilder​(Session session)
        Creates a new CreateResourceHandlerTestBuilder.

        The properties of this builder are initialised with:

        • ConnectorErrorHelper built using buildDefault
        • a default implementation of ResourceIngestionDefinitionRepository, created for the VariantResource
        • a default implementation of IngestionProcessRepository
        Parameters:
        session - Snowpark session object
        Throws:
        NullPointerException - if the provided session object is null

    • Method Detail

      • withErrorHelper

        public CreateResourceHandlerTestBuilder withErrorHelper​(com.snowflake.connectors.common.exception.helper.ConnectorErrorHelper errorHelper)
        Sets the error helper used to build the handler instance.
        Overrides:
        withErrorHelper in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder
        Parameters:
        errorHelper - connector error helper
        Returns:
        this builder

      • withResourceIngestionDefinitionRepository

        public CreateResourceHandlerTestBuilder withResourceIngestionDefinitionRepository​(com.snowflake.connectors.application.ingestion.definition.ResourceIngestionDefinitionRepository<com.snowflake.connectors.application.ingestion.definition.VariantResource> resourceIngestionDefinitionRepository)
        Sets the resource ingestion definition repository used to build the handler instance.
        Parameters:
        resourceIngestionDefinitionRepository - resource ingestion definition repository
        Returns:
        this builder

      • withCreateResourceValidator

        public CreateResourceHandlerTestBuilder withCreateResourceValidator​(com.snowflake.connectors.application.ingestion.create.CreateResourceValidator validator)
        Sets the CreateResourceValidator used to build the handler instance. It allows to add connector-specific logic which validates whether a resource can be created.
        Overrides:
        withCreateResourceValidator in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder
        Parameters:
        validator - custom callback implementation
        Returns:
        this builder

      • withPreCreateResourceCallback

        public CreateResourceHandlerTestBuilder withPreCreateResourceCallback​(com.snowflake.connectors.application.ingestion.create.PreCreateResourceCallback callback)
        Sets the PreCreateResourceCallback used to build the handler instance. It allows to add connector-specific logic which is invoked before a resource is created.
        Overrides:
        withPreCreateResourceCallback in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder
        Parameters:
        callback - custom callback implementation
        Returns:
        this builder

      • withPostCreateResourceCallback

        public CreateResourceHandlerTestBuilder withPostCreateResourceCallback​(com.snowflake.connectors.application.ingestion.create.PostCreateResourceCallback callback)
        Sets the PostCreateResourceCallback used to build the handler instance. It allows to add connector-specific logic which is invoked after a resource is created.
        Overrides:
        withPostCreateResourceCallback in class com.snowflake.connectors.application.ingestion.create.CreateResourceHandlerBuilder
        Parameters:
        callback - custom callback implementation
        Returns:
        this builder

      • withIngestionProcessRepository

        public CreateResourceHandlerTestBuilder withIngestionProcessRepository​(com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository ingestionProcessRepository)
        Sets the ingestion process repository used to build the handler instance.
        Parameters:
        ingestionProcessRepository - ingestion process repository
        Returns:
        this builder

      • withTransactionManager

        public CreateResourceHandlerTestBuilder withTransactionManager​(com.snowflake.connectors.util.snowflake.TransactionManager transactionManager)
        Sets the transaction manager used to build the handler instance.
        Parameters:
        transactionManager - transaction manager
        Returns:
        this builder