Comment on page
Create a connection to Snowflake
This quickstart guide shows you how to create a connection to Snowflake.
Upsolver uses a JDBC connection to write data to Snowflake. This connection creates temporary tables in Snowflake, while the data is continuously streamed. It also merges delta lakes into Snowflake tables. Thanks to Upsolver, the merging process can be automatically managed, that is, you no longer need to maintain delta files or tables. Ultimately, this eliminates the need for large-scale table scans on Snowflake, which can be slow or expensive.
Here’s the code for creating a connection to Snowflake:
CREATE SNOWFLAKE CONNECTION <SNOWFLAKE_CONNECTION_NAME>
/* example: CONNECTION_STRING = 'jdbc:snowflake://oeb05742.us-east-1.snowflakecomputing.com/?db=DEMO_DB' */
CONNECTION_STRING = 'jdbc:snowflake://<snowflake_connection_url>?db=<snowflake_database_name>'
USER_NAME = '<USERNAME>'
PASSWORD = '<PASSWORD>';
CREATE SNOWFLAKE CONNECTION SFCommerce
CONNECTION_STRING = 'jdbc:snowflake://baa12345.us-east-1.snowflakecomputing.com/?db=DEMO_DB'
USER_NAME = 'demouser'
PASSWORD = 'demopass';
To take full advantage of these jobs, we recommend that you explicitly create your output table, which enables you to define partitions, primary keys, and more.
You don’t need to define all your output columns, as Upsolver automatically adds missing columns. If you do want to strictly control which columns are added, you can define them using the
CREATE TABLEstatement and set the
ADD_MISSING_COLUMNSjob property to
Here's the code to create an output table in Snowflake:
CREATE or REPLACE TABLE <snowflake schema>.<snowflake table> (
<column_name> <data_type> );