Snowflake

Snowflake is the only data platform built for the cloud for all your data and all your users.

Official Websitehttps://www.snowflake.com/

TagsDatabaseSaas

JavaScript

Documentationhttps://docs.snowflake.com/en/user-guide/nodejs-driver-use.html

NodeJS packagehttps://www.npmjs.com/package/snowflake-sdk

Version1.6.18

Source Codehttps://github.com/snowflakedb/snowflake-connector-nodejs

Python

Documentationhttps://docs.snowflake.com/en/user-guide/python-connector

Pypi packagehttps://pypi.org/project/snowflake-connector-python/

Version3.0.0

Source Codehttps://github.com/snowflakedb/snowflake-connector-python

Credential configuration

To configure this credential you need the account, username, password, database and schema to connect to mysql.

Optionally you can set any of the extra config params you can see here.

Here you have an example of a filled credential configuration form in YepCode:

Snowflake snippets available in editor

note

The title is the triggering text for YepCode to autocomplete the script

JavaScript

Integration

New integration from credential

const snowflakeClient = yepcode.integration.snowflake('credential-slug')

New integration from plain authentication data

const snowflake = require('snowflake-sdk')

const snowflakeClient = snowflake.createConnection({
  account: account,
  username: username,
  password: password
});

Connect

Establish connection

snowflakeClient.connect(
    function(err, conn) {
        if (err) {
            console.error('Unable to connect: ' + err.message);
        } else {
            console.log('Successfully connected to Snowflake.');
        }
    }
);

Execute statement

Execute statement

const statement = snowflakeClient.execute({
  sqlText: "create database testdb",
  complete: function (err, stmt, rows) {
    if (err) {
      console.error(
        "Failed to execute statement due to the following error: " + err.message
      );
    } else {
      console.log("Successfully executed statement: " + statement.getSqlText());
    }
  },
});

Execute statement with parameters

Execute statement with binding statement parameters

const statement = snowflakeClient.execute({
  sqlText:
    "select c1 from (select :1 as c1 union all select :2 as c1) where c1 = :1;",
  binds: [1, 2],
  complete: function (err, stmt, rows) {
    if (err) {
      console.error(
        "Failed to execute statement due to the following error: " + err.message
      );
    } else {
      console.log("Successfully executed statement: " + statement.getSqlText());
    }
  },
});

Inline results

Select returning results inline

snowflakeClient.execute({
  sqlText: "select PRODUCT_ID from PRODUCTS",
  complete: function (err, stmt, rows) {
    if (err) {
      console.error(
        "Failed to execute statement due to the following error: " + err.message
      );
    } else {
      console.log("Number of rows produced: " + rows.length);
    }
    rows.forEach((row) => {
        console.log("Product id ", row.PRODUCT_ID)
    })
  },
});

Streaming results

Select streaming results

const statement = snowflakeClient.execute({
  sqlText: "select PRODUCT_ID from PRODUCTS",
});

const stream = statement.streamRows();

stream.on('error', function(err) {
  console.error('Unable to consume all rows');
});

stream.on('data', function(row) {
  console.log("Product id ", row.PRODUCT_ID)
});

stream.on('end', function() {
  console.log('All rows consumed');
});

Destroy connection

Terminating a connection

snowflakeClient.destroy(function (err, conn) {
  if (err) {
    console.error("Unable to disconnect: " + err.message);
  } else {
    console.log("Disconnected connection with id: " + snowflakeClient.getId());
  }
});

Python

Integration

New integration from credential

snowflake_connection = yepcode.integration.snowflake('credential-slug')

New integration from plain authentication data

from snowflake.connector import connect

snowflake_connection = connect(
    user="username",
    password="password",
# You should use a yepcode env variable to don't store plain password
# See: https://docs.yepcode.io/docs/processes/team-variables
    account="account",
    database="database",
    schema="schema",
)

Execute statement

Execute statement

cursor = snowflake_connection.cursor()

cursor.execute("SELECT * FROM sales_stock WHERE COLOR_ID = 38379663 LIMIT 10;")

for item in cursor:
    print(item)

Execute statement with parameters

Execute statement with parameters (literals)

cursor = snowflake_connection.cursor()

cursor.execute(
  "SELECT * FROM sales_stock WHERE COLOR_ID = %s LIMIT 10;", (
      "38379663"
    )
)

for item in cursor:
    print(item)

Execute statement with parameters

Execute statement with parameters (bind variables)

cursor = snowflake_connection.cursor()

cursor.execute(
    "SELECT * FROM sales_stock WHERE COLOR_ID = %(color_id)s LIMIT 10", {
        "color_id": 38379663,
    }
)


for item in cursor:
    print(item)

Insert statement

Insert statement

cursor = snowflake_connection.cursor()

cursor.execute(
    'INSERT INTO yourtable("Name","Number") VALUES(%s,%d)', (
        'some-name',
        4023
    )
 )

Select statement

Select statement

cursor = snowflake_connection.cursor()

cursor.execute("SELECT * FROM sales_stock WHERE COLOR_ID = 38379663 LIMIT 10;")

for item in cursor:
    print(item)

Destroy connection

Terminating a connection

snowflake_connection.close()