Snowflake
Snowflake is the only data platform built for the cloud for all your data and all your users.
Official Websitehttps://www.snowflake.com/
NodeJS packagehttps://www.npmjs.com/package/snowflake-sdk
Version1.6.15
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());
}
});