Snowflake REST SQL Connector

Last modified: December 17, 2024

Introduction

The Snowflake REST SQL connector allows you to use data from Snowflake in your Mendix application and enrich your app with the capabilities that Snowflake provides.

Typical Use Cases

The Snowflake REST SQL connector provides a way to first setup key-pair authentication with an RSA key pair according to PKCS #8 standard, and then execute SQL statements on Snowflake via a REST call from within your Mendix application. These statements allow you to perform the following tasks:

The current version of the connector supports the following:

  • Authentication with an RSA key pair according to PKCS #8 standard
  • Authentication with OAUTH through an OIDC provider
  • Execution of single SQL statements
  • Synchronous execution of calls
  • Execution of a Cortex Analyst query

Prerequisites

The Snowflake REST SQL connector requires Mendix Studio Pro version 9.18.0 or above.

To use the Snowflake REST SQL connector, you must also install and configure the following modules from the Mendix marketplace:

  • Community Commons - This module is a required dependency for the Snowflake REST SQL connector.
  • Encryption - This module is a required dependency for the Snowflake REST SQL connector. The EncryptionKey constant must be set up in your application settings.
  • GenAI Commons- This module is a required dependency for the Snowflake Cortex Analyst.

Licensing and Cost

This connector is available as a free download from the Mendix Marketplace, but the services in Snowflake to which is connects may incur a usage cost. For more information, refer to the Snowflake documentation.

Depending on your use case, your deployment environment, and the type of app that you want to build, you may also need a license for your Mendix app. For more information, refer to Licensing Apps.

Installation

Follow the instructions in How to Use Marketplace Content in Studio Pro to import the Snowflake REST SQL connector into your app.

Configuration

After you install the connector, you can find it in the App Explorer, in the SnowflakeRESTSQL section. The connector provides a domain model and several activities that you can use.

Configuring Snowflake Authentication

In order to use the capabilities of Snowflake in a Mendix app with the Snowflake REST SQL connector, an RSA key-pair authentication method must be used.

Configuring Key-pair Authentication in Snowflake

To configure RSA key-pair authentication for your account in Snowflake, perform the following steps:

  1. Generate the private key.
  2. Generate a public key.
  3. Assign the public key to a Snowflake user.

For more details about each step, refer to the official Snowflake documentation.

Setting up the Key-pair Authentication in a Mendix App

To make it easier for users to configure the key-pair authentication in a Mendix app, the Snowflake REST SQL connector includes pages and microflows that you can simply drag and drop them into your own modules.

To configure the authentication, perform the following steps:

  1. In the App Explorer, under the SnowflakeRESTSQL section, find the SNIPPET_SnowflakeConfiguration snippet and drag and drop it into a page in your module.

  2. Assign the module role SnowflakeRESTSQL.Administrator to the application role that will be used to set up the configuration, so that the added logic will be usable.

  3. Run the application and go to the page where you added the snippet.

  4. Click New.

  5. On the Connection details page, fill out all fields with the details of your Snowflake account. For more information, see ConnectionDetails.

  6. In the Snowflake console, click Copy account URL. This URL will be used as the Account URL parameter for Connection details.

  7. In the Snowflake console, click Copy account identifier. Before using it inside Mendix, you must replace the . separator with a -. The final string will be used as the Account identifier parameter for the Connection details.

  8. Enter the passphrase and upload your private key file in .p8 format.

  9. Click Save to save the connection, or click Save and test connection to generate a JSON Web Token (JWT) and validate your connection.

Configuring a Microflow for the Service

After you configure the authentication for Snowflake, you can implement the functions of the connector by using the provided activities in microflows. An extended microflow has been implemented and added to the Snowflake REST SQL connector as an example for users that would like to retrieve a list of objects from an existing table in Snowflake. In the SnowflakeRESTSQL module, see the ExampleImplementation microflow and the ExampleObject domain model entity to learn how the TransformResponsesToMxObjects operation can be used to easily convert the data received in HttpResponse objects into Mendix objects.

Asynchronous Query Execution

At present, the Snowflake REST SQL Connector does not provide any out of the box operation microflows for making asynchronous calls. However, you can still configure asynchronous calls manually using the connector.

To set this up:

  1. Locate the POST_v1_ExecuteStatement microflow.
  2. Open the Call REST (POST) action within this microflow and examine the Location field. Note a query parameter named async that is set to false.
  3. Duplicate the Call REST (POST) action, modify the async query parameter to true, and use this as a basis to build your custom asynchronous microflows.

Your custom microflows should consist of the following:

  • A request call microflow - Sends the request and returns the request ID.
  • A polling microflow - Uses the request ID to check if the response is available, and then returns the response once it is ready.

This approach allows you to achieve asynchronous behavior while leveraging the Snowflake REST SQL Connector.

Technical Reference

To help you work with the Snowflake REST SQL connector, the following sections of this document list the available entities, enumerations, and activities that you can use in your application.

Domain Model

The domain model is a data model that describes the information in your application domain in an abstract way. For more information, see Domain Model.

ConnectionDetails

Name Description
Name An identifier of the connection inside the Mendix app. This property is not passed to Snowflake.
AccountURL The unique account URL of the Snowflake account within your organization to connect to the Snowflake API. For more information, refer to the Snowflake documentation about account identifiers.
ResourcePath The path to a resource in Snowflake API, for example, /api/v2/statements.
AccountIdentifier A unique account identifier that identifies a Snowflake account within your organization, as well as throughout the global network of Snowflake-supported cloud platforms and cloud regions, for example, <orgname>-<account_name>. For more information, refer to the Snowflake documentation about account identifiers.
Username The username with which you sign in to your Snowflake account.

PrivateKey

Name Description
Passphrase A passphrase which is used to encode and decode the private key file.

JWT

Name Description
Token Value of the JSON Web Token as a string.
ExpirationDate Expiration date of the JSON Web Token.

Statement

Name Description
SQLStatement The SQL statement to execute.
Timeout The amount of seconds after which the connection will be closed.
Database The database to use.
Schema The database schema to use, for example PUBLIC.
Warehouse The warehouse to use for computations.
Role The role to use to execute the SQL statement. The role sufficient permissions to execute the statement.

ResultSet

Name Description
Code Code that is returned from Snowflake as a response to the executed statement.
StatementHandle Unique handle given to the statement that has been executed. It is saved as part of the ResultSet object. It can be used to retrieve the ResultSet object for each request.
Message Message that is returned from Snowflake as a response to the executed statement.
NumRows The amount of rows which will be returned by the executed statement. This is a sum of all the rows in the partitions.

PartitionInfo

Name Description
RowCount The number of rows within this partition. The sum of all PartitionInfo.RowCount corresponds to ResultSet.NumRows.

Activities

Activities define the actions that are executed in a microflow or a nanoflow.

ExecuteStatement

The ExecuteStatement activity allows you to execute a command in Snowflake using the SQL statement and the configuration details given in a Statement object. It requires a Statement object and returns a list of HttpResponse objects.

The input and output for this service are shown in the table below:

Input Output
Statement {HttpResponseList}

TransformResponsesToMxObjects

The TransformResponsesToMxObjects activity allows you to transform the list of HttpResponse objects into objects of the entity of your choice.

It requires a list of HttpResponse objects and the entity of the objects that you would like to create with the received information. It returns a list of Mendix objects of the entity given in the input.

Input Output
HttpResponseList, EntityType {EntityType}ObjectList

To showcase this, we have created an example entity in the domain model of the connector:

ExampleObject
ATTR_TXT (string)
ATTR_INT (integer)
ATTR_LONG (long)
ATTR_BOOL (Boolean)
ATTR_DECI (decimal)
ATTR_ENUM (enumeration)
ParsedDate (date and time)

This entity is only an example. You must review properties such as the naming of the attributes, what datatypes they have or in which order they are added, and configure them according to your needs. This information is important after the entity has been decided on and the data will be received from a Snowflake account. The order in which you receive the columns from a Snowflake table, the name of these columns as well as the datatypes of these values must match the entity that you have selected.

For example, a table in Snowflake may contain multiple columns named column1, column2,.......,column8. To retrieve data from the column, create ExampleObject objects and display them on a page, you must execute an SQL statement that would retrieve the table columns with the name of my attributes and have the same datatypes. After making sure that the datatypes in Snowflake and Mendix match, you can execute a statement such as the one shown in the following example:

SELECT 
     column1 as ATTR_TXT,
     column2 as ATTR_INT,
     column3 as ATTR_LONG,
     column4 as ATTR_BOOL,
     column5 as ATTR_DECI,
     column6 as ATTR_ENUM
FROM your_table 

This statement returns data from a Snowflake table with the columns named as specified with the as **NewColumnName**" part of each line. If the attribute names, datatypes and their order match, the TransformResponsesToMxObjects activity automatically converts the retrieved data into Mendix objects.

Configuring Snowflake Cortex Analyst

Snowflake Cortex Analyst is a fully-managed, LLM-powered Snowflake Cortex feature that helps you create applications capable of reliably answering business questions based on your structured data in Snowflake.

Prerequisites

Configuration

To configure your Mendix app for Snowflake Cortex Analyst, perform the following steps:

  1. Create a microflow and add the Cortex Analyst: Create Cortex Analyst Connection action from the Toolbox.
  2. Provide the following mandatory information:
    • Token - The authentication token created from the OIDC provider, or the JWT Token
    • AccountURL - The URL of the Snowflake account that has access to Snowflake Cortex Analyst
    • Authentication Type
  3. Add the Cortex Analyst: Create Request action from the Toolbox, and then configure the Request to contain the path to the Snowflake semantic model file.
  4. Add the Chat: Add Message to Request action from the Toolbox and provide the following information:
    • Request - The request that you configured for the Cortex Analyst: Create Request action
    • ENUM_MessageRole - The role of the entity that creates the message; in the current version, the role must be set to user
    • ContentString - The text of the question for Cortex Analyst
  5. Add the Snowflake Cortex Analyst action from the Toolbox and provide the following information:
    • Connection - The Cortex Analyst connection that you configured for the Cortex Analyst: Create Cortex Analyst Connection action
    • Request - The request that you configured for the Cortex Analyst: Create Request action
  6. To get the response message from the response, add the Response: Get Cortex Analyst Response Message action from the Toolbox, and then add the Response entity as a parameter. The message contains the following information:
    • Content - This is the content of the response message. It includes the text and the SQL, or the suggestions if no SQL is returned
    • Cortex Role - The entity that produced the message; possible values are user or analyst
    • SQLText - The returned SQL suggestion
  7. To get the Cortex Analyst Response entity, add the Response: Get Cortex Analyst Response action from the Toolbox, and then add the Response entity as a parameter. The response contains the following information:
    • Request_ID - The returned RequestId

Example Implementation

The Snowflake showcase app contains example implementations of the Analyst, ANOMALY DETECTION, COMPLETE and TRANSLATE functionalities. For more information, see Snowflake Cortex Analyst.