node app.js
app.js
var express = require("express");
var app = express();
app.use(express.static(__dirname + '/app'));
app.use(express.bodyParser());
app.use(express.methodOverride());
var cql = require('node-cassandra-cql');
var uuid = require('./node-uuid');
var connString = {
hosts: ['xxx'],
keyspace: 'xxx',
username:'xxx',
password:'xxx'
}
var client = new cql.Client(connString);
client.connect(function(error){
if(error)
console.log('error - ' + error);
else
console.log('Post Logged In to Cassandra');
});
从数据库中抽取数据发送到前端：
app.get('/objValuesResult/:key',function(req,res){
console.log('get2 objValues');
console.log('get2 objValues'+'/:'+req.params.key);
client.executeAsPrepared('select * from table ',
[req.params.key], cql.types.consistencies.one,
function(err, result) {
if(err){
console.log(err);
res.send('Sorry error');
res.end();
}else{
res.send(result.rows);
res.end();
}
});