Référence de la configuration de la connexion¶

PUBLIC.SET_CONNECTION_CONFIGURATION (connection_configuration VARIANT)¶

Procédure de point d’entrée disponible au rôle ADMIN. Cette procédure appelle la fonction Java ConnectionConfigurationHandler.setConnectionConfiguration().

PUBLIC.SET_CONNECTION_CONFIGURATION_VALIDATE (connection_configuration VARIANT)¶

Procédure utilisée pour la validation de la configuration spécifique au connecteur. Elle peut également être utilisée pour transformer certaines parties de la configuration. La configuration transformée doit être renvoyée en tant que propriété "config" supplémentaire. Par défaut, elle renvoie 'response_code': 'OK'. Elle est appelée par le DefaultConnectionConfigurationInputValidator. Peut être écrasée à la fois en SQL et en Java.

PUBLIC.SET_CONNECTION_CONFIGURATION_INTERNAL (connection_configuration VARIANT)¶

Procédure utilisée pour la configuration de connexions supplémentaires spécifiques au connecteur, par exemple l’ajout d’une intégration d’accès externe à d’autres procédures. Par défaut, elle renvoie 'response_code': 'OK'. Elle est appelée par le InternalConnectionConfigurationCallback. Peut être écrasée à la fois en SQL et en Java.

PUBLIC.GET_CONNECTION_CONFIGURATION()¶

Une procédure pour récupérer la configuration actuelle de la connexion à partir de la table interne. Elle est disponible pour les utilisateurs ADMIN et VIEWER.

PUBLIC.TEST_CONNECTION()¶

Cette procédure n’est fournie par défaut dans aucun fichier, mais elle est nécessaire pour la fonction Connection Configuration. Cette procédure sera utilisée comme un moyen léger de vérifier l’accès au système source externe.

Approche de remplacement de procédure¶

Les composants suivants peuvent être remplacés à l’aide de SQL.

CREATE OR REPLACE PROCEDURE PUBLIC.SET_CONNECTION_CONFIGURATION(config VARIANT)
  RETURNS VARIANT
  LANGUAGE JAVA
  RUNTIME_VERSION = '11'
  PACKAGES = ('com.snowflake:snowpark:1.11.0')
  IMPORTS = ('/connectors-native-sdk.jar')
  HANDLER = 'com.custom.handler.CustomConnectionConfigurationHandler.setConnectionConfiguration';

GRANT USAGE ON PROCEDURE PUBLIC.CONFIGURE_CONNECTOR(VARIANT) TO APPLICATION ROLE ADMIN;

CREATE OR REPLACE PROCEDURE PUBLIC.SET_CONNECTION_CONFIGURATION_INTERNAL(config VARIANT)
  RETURNS VARIANT
  LANGUAGE SQL
  EXECUTE AS OWNER
  AS
  BEGIN
    -- SOME CUSTOM LOGIC BEGIN
    SELECT sysdate();
    -- SOME CUSTOM LOGIC END

    RETURN OBJECT_CONSTRUCT('response_code', 'OK', '"config"', '"transformed config variant"');
  END;

CREATE OR REPLACE PROCEDURE PUBLIC.SET_CONNECTION_CONFIGURATION_VALIDATE(config VARIANT)
  RETURNS VARIANT
  LANGUAGE JAVA
  RUNTIME_VERSION = '11'
  PACKAGES = ('com.snowflake:snowpark:1.11.0')
  IMPORTS = ('/connectors-native-sdk.jar')
  HANDLER = 'com.custom.handler.CustomConnectionConfigurationValidateHandler.setConnectionConfiguration';

L’approche du constructeur¶

ConnectionConfigurationHandler peut être personnalisé à l’aide de ConnectionConfigurationHandlerBuilder. Ce constructeur permet à l’utilisateur de fournir des implémentations personnalisées des interfaces suivantes :

• ConnectionConfigurationInputValidator

• ConnectionConfigurationCallback

• ConnectionValidator

• ConnectorErrorHelper

Dans le cas où l’une d’entre elles n’est pas fournie, l’implémentation par défaut fournie par le SDK sera utilisée.

class CustomConnectionConfigurationInputValidator implements ConnectionConfigurationInputValidator {
  @Override
  public ConnectorResponse validate(Variant config) {
    // CUSTOM LOGIC
    return ConnectorResponse.success();
  }
}

class CustomHandler {

  // Path to this method needs to be specified in the PUBLIC.SET_CONNECTION_CONFIGURATION procedure using SQL
  public static Variant configureConnection(Session session, Variant configuration) {
    //Using builder
    var handler = ConnectionConfigurationHandler.builder(session)
      .withInputValidator(new CustomConnectionConfigurationInputValidator())
      .build();
    return handler.connectionConfiguration(configuration).toVariant();
  }
}