cassendra driver examples

cassandra.js

var cassandra = require('cassandra-driver');
var PlainTextAuthProvider = cassandra.auth.PlainTextAuthProvider;


var client = new cassandra.Client({
    contactPoints: ["50.112.59.244"],
    authProvider: new PlainTextAuthProvider('iccassandra', '636fd7882101b8387d4fc43b1ea499ec'),
    localDataCenter: 'AWS_VPC_US_WEST_2',
    keyspace: 'keyspace'
});

const queries = [{
    query: 'INSERT INTO udt_tbl1 (name, email) VALUES (?, ?);',
    params: ['raj', '[email protected]']
}, {
    query: 'INSERT INTO udt_tbl1 (name, email) VALUES (?, ?);',
    params: ['kumar', '[email protected]']
}];


client.batch(queries)
    .then(result => console.log('Data updated on cluster')).catch(function (err) {
        console.log("err", err)
    });

client.execute('select * from emp', function (err, result) {
    if (err) throw err
    console.log('User with email', JSON.stringify(result.rows));
});