npm 包 cassandra-driver 使用教程

简介

Cassandra 是一个开源的分布式 NoSQL 数据库，由于其高度可扩展、高性能、高可用性等特点，逐渐成为互联网公司的首选数据库之一。而 cassandra-driver 是 Cassandra 官方提供的 Node.js 驱动程序，可以方便地通过 Node.js 来访问 Cassandra 数据库。

本文将详细介绍如何使用 npm 包 cassandra-driver 连接、操作 Cassandra 数据库。

使用准备

在使用 cassandra-driver 之前，需要安装 Node.js 和 Cassandra 数据库。

安装 Node.js

Node.js 安装请参照官方文档。安装完成后，可在命令行中输入以下命令来查看 Node.js 版本：

node -v

安装 Cassandra

Cassandra 数据库安装请参照官方文档。安装完成后，可在命令行中输入以下命令启动 Cassandra：

cassandra -f

安装依赖

使用 npm 包 cassandra-driver 需要先安装依赖：

npm install cassandra-driver

连接 Cassandra 数据库

连接 Cassandra 数据库需要指定主机地址和端口号，并创建一个客户端对象。

const cassandra = require('cassandra-driver');
const client = new cassandra.Client({
  contactPoints: ['localhost:9042'],
  localDataCenter: 'datacenter1',
  keyspace: 'example'
});

其中，contactPoints 为 Cassandra 数据库的主机地址和端口号，localDataCenter 为数据中心名称，keyspace 为要操作的数据库名称。

查询数据

下面演示如何查询数据。

准备数据

在使用之前，需要先创建一个表，向表中插入一些数据：

CREATE KEYSPACE example WITH REPLICATION = {'class': 'SimpleStrategy', 'replication_factor': 1};
USE example;
CREATE TABLE test (id int primary key, name text);
INSERT INTO test (id, name) VALUES (1, 'John Doe');
INSERT INTO test (id, name) VALUES (2, 'Jane Doe');

查询数据

const query = 'SELECT * FROM test WHERE id = ?';
client.execute(query, [1], function(err, result) {
  if (err) throw err;
  console.log(result.rows[0]);
});

其中，query 为查询语句，[1] 为查询参数，result.rows[0] 存储了查询结果中的第一行数据。

插入数据

下面演示如何插入数据：

const query = 'INSERT INTO test (id, name) VALUES (?, ?)';
client.execute(query, [3, 'Tom Smith'], function(err, result) {
  if (err) throw err;
  console.log('Data inserted successfully!');
});

其中，query 为插入语句，[3, 'Tom Smith'] 为插入参数。

更新数据

下面演示如何更新数据：

const query = 'UPDATE test SET name = ? WHERE id = ?';
client.execute(query, ['Mike Brown', 1], function(err, result) {
  if (err) throw err;
  console.log('Data updated successfully!');
});

其中，query 为更新语句，['Mike Brown', 1] 为更新参数。

删除数据

下面演示如何删除数据：

const query = 'DELETE FROM test WHERE id = ?';
client.execute(query, [2], function(err, result) {
  if (err) throw err;
  console.log('Data deleted successfully!');
});

其中，query 为删除语句，[2] 为删除参数。

总结

本文介绍了如何使用 npm 包 cassandra-driver 连接、操作 Cassandra 数据库。在实际应用中，还可以使用事务、批量插入、分页查询等高级功能。希望本文对你有所帮助。

来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/65002