`
longzhun
  • 浏览: 371866 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

cassandra新版驱动,使用SchemaBuilder进行表的操作

 
阅读更多

在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数据库驱动包

    编程方式设置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

    Cassandra JDBC Driver是一款专为Apache Cassandra数据库设计的Java数据库连接(JDBC)驱动程序,它使得Java应用程序能够通过遵循标准JDBC接口的方式来访问和操作Cassandra数据。Cassandra是一款分布式NoSQL数据库...

    dbeaver cassandra驱动

    dbeaver cassandra驱动

    spring boot与cassandra集成,使用原生驱动。

    在本文中,我们将深入探讨如何将Spring Boot框架与Cassandra数据库集成,并利用其原生驱动进行数据操作。Spring Boot以其简化配置和快速启动的特点,深受开发者喜爱,而Cassandra作为分布式NoSQL数据库,广泛用于...

    spring boot与cassandra集成,使用JPA方式。

    Spring Data Cassandra提供了对Cassandra的JPA支持,允许开发者使用注解驱动的方式进行数据操作。首先,定义一个Cassandra实体类,比如`User`,并使用`@Table`指定表名,`@Column`指定列名: ```java import org....

    Cassandra JDBC Driver 0.8.2

    这个驱动程序使得开发者能够通过使用标准的 JDBC API 来与 Cassandra 数据库进行交互,这对于那些熟悉 JDBC 的开发人员来说是一个非常方便的工具。Cassandra 是一个分布式 NoSQL 数据库系统,常用于存储大规模、高...

    cassandra-driver-3.11.0.tar.gz

    Python程序与Cassandra数据库之间的通信通常需要使用驱动程序,而"cassandra-driver-3.11.0.tar.gz"正是这样的一个驱动包,适用于Python语言,用于在Python环境中连接和操作Cassandra数据库。 该驱动包的主要功能...

    xandra, 快速,简单,可靠的Cassandra驱动器.zip

    xandra, 快速,简单,可靠的Cassandra驱动器 Xandra 快速,简单,可靠的Cassandra驱动器。 Xandra是一个内置的Cassandra驱动器,内置 Elixir,以速度。简单和健壮性为重点。 这个驱动程序只与Cassandra查询语言( CQL...

    JAVA操作cassandra数据库

    本篇将深入探讨如何使用Java来操作Cassandra数据库,以及相关的重要概念和技术。 首先,我们需要引入Cassandra的Java驱动程序,即DataStax的`com.datastax.oss:java-driver-core`。这个驱动允许Java应用程序与...

    java导出cassandra数据

    在Java中,我们可以使用DataStax的Cassandra驱动程序来与Cassandra通信。 1. **安装和配置驱动** - 添加DataStax的Cassandra驱动依赖到你的`pom.xml`或`build.gradle`文件中。 - 配置Cassandra的连接信息,包括...

    cassandra javaDriver21.pdf

    这份文档详细介绍了如何通过Java操作Cassandra,包括新增、删除、修改、查询数据等操作,并且提供了一些编程示例,帮助开发者理解如何在Java项目中集成和使用这个驱动。 文档的详细内容包括但不限于以下几个方面: ...

    php使用cassandra用到的phpcassa-0.1

    标签"**phpcassa**"是PHP与Cassandra之间的客户端库,允许PHP开发者通过简单的API来操作Cassandra集群,包括读写数据、管理表结构等。 **文件名称列表解析** 虽然未提供具体的文件列表,但通常在"phpcassa-0.1...

    Cassandra的Tcl驱动CassTcl.zip

    CassTcl 是 Tcl 编程语言的一个 C 扩展,实现了对 Cassandra 数据库的访问支持。 标签:CassTcl

    cassandra安装使用教程

    1、cassandra的安装、维护使用 2、java操作cassandra实例 3、cql使用详解

    Cassandra技术详解 操作与测试报告

    ### Cassandra技术详解与操作测试报告 #### 一、Cassandra概述 Cassandra是一个开源的分布式数据库管理系统,由Facebook开发,并随后捐赠给Apache基金会。它的设计灵感来源于Amazon的Dynamo和Google的Bigtable,...

    Java连接cassandra实现简单的增删查demo

    这就是使用Java连接Cassandra数据库并执行基本操作的基本流程。在实际项目中,你可能需要处理异常、优化性能、使用预编译语句等更复杂的场景。如果你在`logdemo`文件中找到了日志相关的代码,可能还涉及了日志记录,...

    cassandra-C#应用

    在"CassandraTest"这个项目中,可能包含了一些示例代码,展示了如何在C#中使用Thrift API与Cassandra进行交互,比如添加数据、检索数据等基本操作。通过研究这些代码,开发者可以学习到如何在实际项目中实现...

    Cassandra C Sharp Driver.1.0.0.0

    它允许开发人员使用.NET的LINQ语法直接对Cassandra表进行操作,如筛选、排序、分组和投影,极大地提高了开发效率。通过这个库,你可以将C#的对象映射到Cassandra的键值对或列族,简化了数据存取的复杂性。 ...

    Cassandra使用手册

    Cassandra使用手册详细介绍了数据库的安装、配置、数据模型、命令行操作、Java编程接口Thrift的使用,测试以及具体的系统实例实现。手册的目的是为了让用户能够系统地理解和掌握Cassandra的使用方法,从而在实际的...

Global site tag (gtag.js) - Google Analytics