node-cassandra-cql 是一个 Apache Cassandra CQL3 二进制协议的 Node.js CQL 驱动。CQL 是 Cassandra 的查询语言。该项目提供到多个主机的连接池、查询参数，以及可通过列名获取数值和支持 bigint。
示例代码：
// Creating a new connection pool to multiple hosts.
var cql = require('node-cassandra-cql');
var client = new cql.Client({hosts: ['host1:9042', 'host2:9042'], keyspace: 'keyspace1'});
// Reading
client.execute('SELECT key, email, last_name FROM user_profiles WHERE key=?', ['jbay'],
function(err, result) {
if (err) console.log('execute failed');
else console.log('got user profile with email ' + result.rows[0].get('email'));
}
);
// Writing
client.execute('UPDATE user_profiles SET birth=? WHERE key=?', [new Date(1950, 5, 1), 'jbay'],
cql.types.consistencies.quorum,
function(err) {
if (err) console.log("failure");
else console.log("success");
}
);
// Streaming query rows
client.streamRows('SELECT event_time, temperature FROM temperature WHERE station_id=', ['abc'],
function(err, row) {
//the callback will be invoked per each row as soon as they are received
if (err) console.log("Oh dear...");
else {
console.log('temperature value', row.get('temperature'));
}
}
);
// Streaming field
client.streamField('SELECT key, photo FROM user_profiles WHERE key=', ['jbay'],
function(err, row, photoStream) {
//the callback will be invoked per each row as soon as they are received.
if (err) console.log("Shame...");
else {
//The stream is a Readable Stream2 object
stdout.pipe(photoStream);
}
}
);-
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 = requ
-
我们习惯使用驱动程序连接到关系数据库。例如，在Java中，JDBC是一种API，它抽象关系数据库的供应商实现，以呈现使用语句，PreparedStatements，ResultSet等存储和检索数据的一致方法。要与数据库进行交互，您将获得一个与您正在使用的特定数据库一起使用的驱动程序，例如Oracle，SQL Server或MySQL;这种交互的实现细节对开发人员是隐藏的。通常为各种编程语言提供驱
-
Cassandra Tools cqlsh: the CQL shell Edit cqlsh: the CQL shell cqlsh is a command-line interface for interacting with Cassandra using CQL (the Cassandra Query Language). It is shipped with every Cassa
-
对于那些喜欢即时满足的人，我们首先要安装Cassandra。因为Cassandra引入了许多新词汇，所以我们可能会有一些不熟悉的术语。没关系;这里的想法是在一个简单的配置中快速设置，以确保一切正常运行。这将作为一个方向。然后，我们将退后一步，了解Cassandra在更大的背景下。 安装Apache Distribution Cassandra可从网站http://cassandra.apache.
-
Getting Started First, make sure you have the driver properly installed.
-
Cassandra是一套开源分布式NoSQL数据库，采用无中心对等分布式模型，具备高可用和高伸展性特点。最初由Facebook开发，后转变成了开源项目。以Amazon专有的完全分布式的Dynamo为基础，结合了Google BigTable基于列族（Column Family）的数据模型，很多方面都可以称之为Dynamo 2.0。本文基于CentOS7.6，部署Cassandra 3.11.6，详
-
现代信息系统应该是避不开大数据处理的。作为一个通用的系统集成工具也必须具备大数据存储和读取能力。cassandra是一种分布式的数据库，具备了分布式数据库高可用性（high-availability）特性，对于一个实时大型分布式集成系统来说是核心支柱。与传统的关系数据库对比，cassandra从数据存储结构、读取方式等可以说是皆然不同的。如：cassandra库表设计是反范式的（denor
-
摘要 CQL相比较于SQL有很多的限制，原因在于cassandra是为大数据存储设计的，而它的部署模式又都是基于分区方式的，不像mongo还有复制集这个小规模的数据库集群设计，当数据量大的时候再进行分片。为了提供检索效率，所以在CQL语法上做了限制，避免低效的查询语句。cassandra的数据是根据partition key做hash计算后分布到各个节点的，扫描各个节点的效率是很低的。所以cass
-
我正在使用php的Datastax Cassandra驱动程序，希望能够检查是否查询失败，在数据库中没有找到结果。现在，如果查询失败，日志报告如下 如果查询成功，它将返回预期的数据。下面是函数 根据发布的建议，我最后做了以下几点 谢谢你的建议
-
查询从something_data中选择username作为col6、性别作为col1、last_name作为col2、email作为col3、first_name作为col4、something_uuid作为col5、group_email作为col7、deleted作为col8、puars作为col9，其中username=？；在/xx.yy.91.205:9042上未准备，请在重试执行之前准
-
我使用python脚本，它传递给卡桑德拉批处理查询，如下所示： 这是一段时间的工作，但在启动脚本失败并打印后约2分钟内： 我将超时从 更改为： read_request_timeout_in_ms：15000 range_request_timeout_in_ms：20000 write_request_timeout_in_ms：20000 cas_contention_timeout_in_m
-
我被datastax cassandra驱动程序卡住了，它抛出了这个错误： 我已经用gradle导入了库，我看到org.slf4j： slf4j-api： 1.7.5在“外部库”树中（我正在使用Intellij IDEA）。 你有办法解决这个问题吗？我发现这个帖子接近我的问题(NoClassDefFoundError-datastax Java driver for Cassandra)，但没有人
-
我试图理解Datastax Cassandra驱动程序中的连池，因此我可以更好地在我的Web服务中使用它。 我有留档的1.0版。它说： Java驱动程序异步使用连接，因此可以在同一个连接上同时提交多个请求。 他们通过连接理解什么？当连接到集群时，我们有：一个生成器、一个集群和一个会话。他们中的哪一个是连接？ 例如，有一个参数： MaxSimultaneousRecestsPerConnection
-
所以我在Cassandra数据库中有一个UDT： 当我查询这个时，我可以得到UDTValue，但我不确定如何映射到UDTClass，因为我使用的是Cassandra Java驱动程序2.2.0rc3 在2.1中，有一些类似于本教程的说明。但在2.2.0中，这个（UDTMapper）似乎已经被删除或尚未添加。怎样才能做同样的事情，或者仅仅为了达到同样的效果？ 谢谢。