Snowflake

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

Official Websitehttps://www.snowflake.com/

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

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

Version1.6.15

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

TagsDatabase, Saas

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

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());
  }
});