一:下载cassandra
http://archive.apache.org/dist/cassandra/
我用的是2.1.8,3.9需要java8
wget http://archive.apache.org/dist/cassandra/2.1.8/apache-cassandra-2.1.8-bin.tar.gz
二:解压
tar -zxvf apache-cassandra-2.1.8-bin.tar.gz
三:新建目录
mkdir /usr/local/cassandra/data
mkdir /usr/local/cassandra/commitlog
mkdir /usr/local/cassandra/saved_caches
四:修改配置文件
vi conf/cassandra.yaml
data_file_directories:
- /usr/local/cassandra/data
commitlog_directory: /usr/local/cassandra/commitlog
saved_caches_directory: /usr/local/cassandra/saved_caches
vi conf/cassandra-env.sh
MAX_HEAP_SIZE="2G"
144 HEAP_NEWSIZE="800M"
五:运行
cd bin
./cassandra
六:启动cql
cd bin
./cqlsh
Cassandra CQL 使用
创建KEYSPACE
keyspace有两种策略,一个是 SimpleStrategy
,另一个是 NetworkTopologyStrategy
-
SimpleStrategy
该模式下需要指定复制策略,冗余几份数据,如: -
create KEYSPACE demodb WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 2};
-
NetworkTopologyStrategy
该模式是基于数据中心-机架的,创建基于此模式的KEYSPACE必须在配置文件中配置成该模式,否则将会报异常:
Unable to complete request: one or more nodes were unavailable
创建代码如下: -
CREATE KEYSPACE demodb WITH REPLICATION = { 'class' : 'NetworkTopologyStrategy', 'dc1' :3 };
表操作
-
创建表
-
create table blog(id timeuuid , title text, content text, tags list<text>, category text, primary key(id));
-
插入
-
INSERT INTO blog (id, title , tags ) VALUES ( now(), 'cassandra table test', ['cassandra','table']);
-
using ttl 如果和if not exists 或者 if exists 一起用, if 要放到 ttl 之前
-
INSERT INTO blog (id, title , tags ) VALUES ( now(), 'cassandra table test', ['cassandra','table'])
-
USING TTL 222; --单位为秒这个时间是针对整行起作用 UPDATE BLOG USING TTL=33 SET TITLE='SS' WHERE ID=1; --针对这个字段起作用,而不是整行数据
-
batch batch内的操作都成功时候才会真正执行这些操作
-
BEGIN BATCH INSERT INTO blog (id, title , tags ) VALUES ( now(), 'cassandra table test', ['cassandra','table']) USING TTL 222; --单位为秒这个时间是针对整行起作用 UPDATE BLOG USING TTL=33 SET TITLE='SS' WHERE ID=1; --针对这个字段起作用,而不是整行数据 APPLY BATCH;
相关推荐
- 连接 Cassandra:在 YCSB 的根目录下,使用 `./bin/ycsb load cassandra-cql` 或 `./bin/ycsb run cassandra-cql` 命令加载数据或执行压力测试。记得指定工作负载文件和必要的参数。 3. **结果分析** - 输出...
本项目将详细介绍如何利用Cassandra查询语言(CQL)、Python编程以及Jupyter Notebook环境来构建一个数据提取、转换和加载(ETL)流程,并在Cassandra数据库中实现数据存储。 一、Cassandra查询语言(CQL) CQL是...
标题与描述均提到了“MariaDB与Cassandra的互操作性”,这主要指的是MariaDB中的Cassandra存储引擎(Cassandra Storage ...通过持续的测试和优化,Cassandra存储引擎可以成为连接MariaDB和Cassandra世界的强大工具。
GatlingCql是一个针对Apache Cassandra查询语言(CQL)的扩展工具,它利用了Gatling的强大性能测试框架,为开发人员和运维人员提供了深入的Cassandra数据库性能评估能力。Gatling是一款用Scala编写的高可扩展性、高...
2. 使用CQL Shell(Cassandra查询语言的交互式工具)测试连接,输入`cqlsh`。默认情况下,它会连接到本地主机。在CQL Shell中尝试一些基本的CQL命令,如`CREATE KEYSPACE myks WITH replication = {'class': 'Simple...
3. **PHPcassa API**:phpcassa提供了易于使用的PHP接口,包括创建连接、执行CQL(Cassandra查询语言)语句、读写数据、管理键空间和列族等操作。 4. **CQL**:Cassandra Query Language,Cassandra的数据操作语言,...
Cassandra提供了丰富的API供应用程序使用,包括Thrift接口和更现代的CQL(Cassandra Query Language),使得操作Cassandra的数据更加直观和方便。此外,Cassandra还支持与Hadoop的集成,可以通过Hadoop MapReduce对...
**Cassandra 基准测试工具详解** Cassandra 是一个高度可扩展的分布式数据库系统,由 Apache 软件基金会开发并维护。...通过持续的基准测试和调优,可以确保 Cassandra 系统在处理大规模数据时保持高效稳定。
通过以上步骤,你已经掌握了Cassandra的基本操作:安装、配置、创建Keyspace、插入和查询数据,以及使用Pelops进行Java编程。随着对Cassandra的理解加深,你可以探索更多高级特性,如分布式数据模型、分区策略、复制...
java8源码 警告:您应该提交给 ASF dtest 存储库,而不是这里。...如果测试定期针对同一个现有目录运行,一个方便的选择是在~/.cassandra-dtest设置一个default_dir 。 创建文件并将其设置为: [main] defaul
使用DevCenter,开发人员可以更高效地进行Cassandra数据库的开发、测试和维护工作,而无需深入研究Cassandra的底层细节。这极大地简化了Cassandra的管理工作,降低了学习曲线,提高了生产力。因此,对于那些处理大...
Spring Boot以其简化配置和快速启动的特点,深受开发者喜爱,而Cassandra作为分布式NoSQL数据库,广泛用于处理大规模数据。我们将讨论以下几个方面: 1. **Spring Boot简介** Spring Boot是Spring Framework的一个...
### 性能测试和比较 为了优化性能,需要对Cassandra进行性能测试,并与其他数据库系统进行比较,以确定其在特定工作负载下的表现。 ### 配置说明 配置Cassandra涉及设置节点间通信、数据分区策略、内存分配、磁盘...
特征能够创建映射到表模式并针对表模式进行验证的模型使用链式方法创建查询的能力几乎支持所有 Cassandra 数据类型针对 Cassandra 进行单元测试用于执行 cql 文件的 CQL 实用程序安装首先安装和 。 然后: git clone...
打开和关闭与 Cassandra 服务器的连接。 function query(con::CQLConnection, msg::String) '普通' 同步查询 将等待,直到所有预定的命令都执行完毕,然后发送查询并等待结果。 处理后的结果以数组或行的形式返回,...
- **CQL交互**:支持Cassandra Query Language (CQL)的编写和执行,方便进行数据查询和操作。 - **实时监控**:提供集群性能指标的实时视图,如节点状态、CPU使用率、磁盘空间等。 - **数据导入导出**:支持将...
在Spark应用之前,你可能需要先运行这些CQL命令来准备测试数据。 7. **源码分析**:在`CassandraTest.scala`中,你可能会看到类似以下的代码片段: ```scala import com.datastax.spark.connector._ import org....
社区版通常包含了最新的开源Cassandra特性,适合开发者进行测试、学习和轻量级生产环境使用。 1. **增强特性**:Datastax社区版可能包含了一些优化和增强,比如性能提升、更好的监控工具、更完善的文档以及针对特定...
cql-protocol是一个库,它完全在纯 JavaScript 中实现了 Apache Cassandra 的原生 CQL 协议规范 v1 和 v2(几乎)。 Apache Cassandra 驱动程序的构建块 该库旨在供驱动程序作者(包括我自己)使用,而不是供用户...
cassandra6可能包含该版本的安装指南、配置示例、测试脚本或者代码示例,帮助读者理解Cassandra 6.0的功能和用法。 总结来说,这篇博客可能涵盖了以下知识点: 1. Cassandra基础:数据模型、分区策略、副本分布。 ...