在cassanda的官方驱动cassandra-driver-core-2.1.3.jar之前,创建表、修改表、创建索引操作,只能通过拼CQL语句,然后通过session去执行的方式。可能会经常导致语法格式错误。
在最新版的驱动cassandra-driver-core-2.1.3.jar中,提供了一种更方便的对表的修改方式。类似于用于增删改查操作的com.datastax.driver.core.querybuilder.QueryBuilder类,它提供了一个com.datastax.driver.core.schemabuilder.SchemaBuilder类用于对表的操作。
这个类可以构建几乎所有关于对表的操作,这里举例常用的操作:
先引入jar包:
<dependency> <groupId>com.datastax.cassandra</groupId> <artifactId>cassandra-driver-core</artifactId> <version>2.1.3</version> </dependency>
然后你就可以像写cql语句一样,流畅的使用SchemaBuilder了。其中省略了session的生成,可以参考《java实现cassandra的增删改查》
//创建表 Create createTbale = SchemaBuilder.createTable("mykeyspace", "mytable") .addPartitionKey("pk1", DataType.cint()) .addColumn("col1", DataType.text()) .addColumn("col2", DataType.bigint()); session.execute(createTbale); //增加一列 SchemaStatement addColumn = SchemaBuilder.alterTable("mykeyspace", "mytable") .addColumn("col3") .type(DataType.cdouble()); session.execute(addColumn); //删除一列 SchemaStatement dropColumn = SchemaBuilder.alterTable("mykeyspace", "mytable") .dropColumn("col2"); session.execute(dropColumn); //修改一列 SchemaStatement alterColumn = SchemaBuilder.alterTable("mykeyspace", "mytable") .alterColumn("col1") .type(DataType.cdouble()); session.execute(alterColumn); //列更改名字 SchemaStatement renameColumn = SchemaBuilder.alterTable("mykeyspace", "mytable") .renameColumn("col1") .to("col4"); session.execute(alterColumn); //增肌索引 SchemaStatement createIndex = SchemaBuilder.createIndex("idx_col4") .onTable("mykeyspace", "mytable") .andColumn("col4"); session.execute(createIndex); //删除索引 Drop dropIndex = SchemaBuilder.dropIndex("mykeyspace", "idx_col4") .ifExists(); session.execute(dropIndex); //删除表 Drop dropTable = SchemaBuilder.dropTable("mykeyspace", "mytable") .ifExists(); session.execute(dropTable);
相关推荐
编程方式设置Cassandra,主要包含以下5个包,W3C认证 slf4j-api-1.7.5.jar cassandra-driver-core-2.0.2.jar guava-16.0.1.jar metrics-core-3.0.2.jar netty-3.9.0.Final.jar
Cassandra JDBC Driver是一款专为Apache Cassandra数据库设计的Java数据库连接(JDBC)驱动程序,它使得Java应用程序能够通过遵循标准JDBC接口的方式来访问和操作Cassandra数据。Cassandra是一款分布式NoSQL数据库...
在本文中,我们将深入探讨如何将Spring Boot框架与Cassandra数据库集成,并利用其原生驱动进行数据操作。Spring Boot以其简化配置和快速启动的特点,深受开发者喜爱,而Cassandra作为分布式NoSQL数据库,广泛用于...
Spring Data Cassandra提供了对Cassandra的JPA支持,允许开发者使用注解驱动的方式进行数据操作。首先,定义一个Cassandra实体类,比如`User`,并使用`@Table`指定表名,`@Column`指定列名: ```java import org....
这个驱动程序使得开发者能够通过使用标准的 JDBC API 来与 Cassandra 数据库进行交互,这对于那些熟悉 JDBC 的开发人员来说是一个非常方便的工具。Cassandra 是一个分布式 NoSQL 数据库系统,常用于存储大规模、高...
Python程序与Cassandra数据库之间的通信通常需要使用驱动程序,而"cassandra-driver-3.11.0.tar.gz"正是这样的一个驱动包,适用于Python语言,用于在Python环境中连接和操作Cassandra数据库。 该驱动包的主要功能...
xandra, 快速,简单,可靠的Cassandra驱动器 Xandra 快速,简单,可靠的Cassandra驱动器。 Xandra是一个内置的Cassandra驱动器,内置 Elixir,以速度。简单和健壮性为重点。 这个驱动程序只与Cassandra查询语言( CQL...
本篇将深入探讨如何使用Java来操作Cassandra数据库,以及相关的重要概念和技术。 首先,我们需要引入Cassandra的Java驱动程序,即DataStax的`com.datastax.oss:java-driver-core`。这个驱动允许Java应用程序与...
在Java中,我们可以使用DataStax的Cassandra驱动程序来与Cassandra通信。 1. **安装和配置驱动** - 添加DataStax的Cassandra驱动依赖到你的`pom.xml`或`build.gradle`文件中。 - 配置Cassandra的连接信息,包括...
这份文档详细介绍了如何通过Java操作Cassandra,包括新增、删除、修改、查询数据等操作,并且提供了一些编程示例,帮助开发者理解如何在Java项目中集成和使用这个驱动。 文档的详细内容包括但不限于以下几个方面: ...
标签"**phpcassa**"是PHP与Cassandra之间的客户端库,允许PHP开发者通过简单的API来操作Cassandra集群,包括读写数据、管理表结构等。 **文件名称列表解析** 虽然未提供具体的文件列表,但通常在"phpcassa-0.1...
CassTcl 是 Tcl 编程语言的一个 C 扩展,实现了对 Cassandra 数据库的访问支持。 标签:CassTcl
1、cassandra的安装、维护使用 2、java操作cassandra实例 3、cql使用详解
### Cassandra技术详解与操作测试报告 #### 一、Cassandra概述 Cassandra是一个开源的分布式数据库管理系统,由Facebook开发,并随后捐赠给Apache基金会。它的设计灵感来源于Amazon的Dynamo和Google的Bigtable,...
这就是使用Java连接Cassandra数据库并执行基本操作的基本流程。在实际项目中,你可能需要处理异常、优化性能、使用预编译语句等更复杂的场景。如果你在`logdemo`文件中找到了日志相关的代码,可能还涉及了日志记录,...
在"CassandraTest"这个项目中,可能包含了一些示例代码,展示了如何在C#中使用Thrift API与Cassandra进行交互,比如添加数据、检索数据等基本操作。通过研究这些代码,开发者可以学习到如何在实际项目中实现...
它允许开发人员使用.NET的LINQ语法直接对Cassandra表进行操作,如筛选、排序、分组和投影,极大地提高了开发效率。通过这个库,你可以将C#的对象映射到Cassandra的键值对或列族,简化了数据存取的复杂性。 ...
Cassandra使用手册详细介绍了数据库的安装、配置、数据模型、命令行操作、Java编程接口Thrift的使用,测试以及具体的系统实例实现。手册的目的是为了让用户能够系统地理解和掌握Cassandra的使用方法,从而在实际的...