Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
var cassandra = require('cassandra-driver');
var async = require('async');
var client = new cassandra.Client({contactPoints: ['127.0.0.1'], keyspace: 'demo'});
// Use async series to run functions in serial (one after another)
async.series([
// Insert Bob
function (callback) {
client.execute("INSERT INTO users (lastname, age, city, email, firstname) VALUES ('Jones', 35, 'Austin', 'bob@example.com', 'Bob')", function (err, result) {
// Run next function in series
callback(err, null);
});
},
// Read users and print to console
function (callback) {
client.execute("SELECT lastname, age, city, email, firstname FROM users WHERE lastname='Jones'", function (err, result) {
if (!err){
if ( result.rows.length > 0 ) {
var user = result.rows[0];
console.log("name = %s, age = %d", user.firstname, user.age);
} else {
console.log("No results");
}
}
// Run next function in series
callback(err, null);
});
},
// Update Bob's age
function (callback) {
client.execute("UPDATE users SET age = 36 WHERE lastname = 'Jones'", function (err, result) {
// Run next function in series
callback(err, null);
});
},
// Read users and print to the console
function (callback) {
client.execute("SELECT firstname, age FROM users where lastname = 'Jones'", function (err, result) {
var user = result.rows[0];
console.log("name = %s, age = %d", user.firstname, user.age);
// Run next function in series
callback(err, null);
});
},
// Delete Bob
function (callback) {
client.execute("DELETE FROM users WHERE lastname = 'Jones'", function (err, result) {
if (!err) {
console.log("Deleted");
}
// Run next function in series
callback(err, null);
});
},
// Read users and print to the console
function (callback) {
client.execute("SELECT * FROM users WHERE lastname='Jones'", function (err, result) {
if ( result.rows.length > 0 ) {
var user = result.rows[0];
console.log("name = %s, age = %d", user.firstname, user.age);
} else {
console.log("No records");
}
// Run next function in series
callback(err, null);
});
}
], function (err, results) {
// All finished, quit
process.exit();
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment