转载

Spring Data Cassandra简介

我们将从基础开始，完成配置和编码，最后构建一个完整的Spring Data Cassandra模块。

1.概述

本文使用Spring Data访问与Cassandra的实用介绍。Cassandra是一个支持快速写入的NoSQL数据库，可以用作事件溯源的事件存储等。

2. Maven依赖

让我们首先使用Maven 定义pom.xml中的依赖项：

<dependency>
    <groupId>com.datastax.cassandra</groupId>
    <artifactId>cassandra-driver-core</artifactId>
    <version>2.1.9</version>
</dependency>

3. Cassandra的配置

我们将在整个过程中使用Java风格的配置来配置Cassandra集成。

3.1。主配置

让我们从主配置类开始 - 当然是通过类级别@Configuration注释驱动的：

@Configuration
<b>public</b> <b>class</b> CassandraConfig <b>extends</b> AbstractCassandraConfiguration {
 
    @Override
    <b>protected</b> String getKeyspaceName() {
        <b>return</b> <font>"testKeySpace"</font><font>;
    }
 
    @Bean
    <b>public</b> CassandraClusterFactoryBean cluster() {
        CassandraClusterFactoryBean cluster = 
          <b>new</b> CassandraClusterFactoryBean();
        cluster.setContactPoints(</font><font>"127.0.0.1"</font><font>);
        cluster.setPort(9142);
        <b>return</b> cluster;
    }
 
    @Bean
    <b>public</b> CassandraMappingContext cassandraMapping() 
      throws ClassNotFoundException {
        <b>return</b> <b>new</b> BasicCassandraMappingContext();
    }
}
</font>

注意新的bean - BasicCassandraMappingContext - 带有默认实现。这是在对象和持久格式之间映射持久性实体所必需的。

由于默认实现足够，我们可以直接使用它。

3.2。Cassandra连接属性

我们必须配置三个必需的设置来设置Cassandra客户端的连接。

我们必须设置Cassandra服务器作为contactPoints运行的主机名。端口只是服务器中请求的侦听端口。KeyspaceName是定义节点上数据复制的命名空间，它基于Cassandra相关概念。

4. Cassandra存储库

我们将使用CassandraRepository作为数据访问层。这遵循Spring Data存储库抽象，该抽象集中于抽象出跨不同持久性机制实现数据访问层所需的代码。

4.1。创建CassandraRepository

让我们创建要在配置中使用的CassandraRepository：

@Repository
<b>public</b> <b>interface</b> BookRepository <b>extends</b> CassandraRepository<Book> {
    <font><i>//</i></font><font>
}
</font>

4.2。CassandraRepository的配置

现在，我们可以扩展第3.1节中的配置，添加@EnableCassandraRepositories类级别注释来标记我们在CassandraConfig的 4.1节中创建的Cassandra存储库：

@Configuration
@EnableCassandraRepositories(
  basePackages = <font>"org.baeldung.spring.data.cassandra.repository"</font><font>)
<b>public</b> <b>class</b> CassandraConfig <b>extends</b> AbstractCassandraConfiguration {
    </font><font><i>//</i></font><font>
}
</font>

5.实体

让我们快速浏览一下实体 - 我们将要使用的模型类。该类已注释，并为嵌入模式下的元数据Cassandra数据表创建定义了其他参数。

使用@Table注释，bean直接映射到Cassandra数据表。此外，每个属性都定义为一种主键或一个简单列：

@Table
<b>public</b> <b>class</b> Book {
    @PrimaryKeyColumn(
      name = <font>"isbn"</font><font>, 
      ordinal = 2, 
      type = PrimaryKeyType.CLUSTERED, 
      ordering = Ordering.DESCENDING)
    <b>private</b> UUID id;
    @PrimaryKeyColumn(
      name = </font><font>"title"</font><font>, ordinal = 0, type = PrimaryKeyType.PARTITIONED)
    <b>private</b> String title;
    @PrimaryKeyColumn(
      name = </font><font>"publisher"</font><font>, ordinal = 1, type = PrimaryKeyType.PARTITIONED)
    <b>private</b> String publisher;
    @Column
    <b>private</b> Set<String> tags = <b>new</b> HashSet<>();
    </font><font><i>// standard getters and setters</i></font><font>
}
</font>

6.使用嵌入式服务器进行测试

6.1。Maven依赖

如果要在嵌入模式下运行Cassandra（无需手动安装单独的Cassandra服务器），则需要将与cassandra-unit相关的依赖项添加到pom.xml：

<dependency>
    <groupId>org.cassandraunit</groupId>
    <artifactId>cassandra-unit-spring</artifactId>
    <version>2.1.9.2</version>
    <scope>test</scope>
    <exclusions>
        <exclusion>
        <groupId>org.cassandraunit</groupId>
        <artifactId>cassandra-unit</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>org.cassandraunit</groupId>
    <artifactId>cassandra-unit-shaded</artifactId>
    <version>2.1.9.2</version>
    <scope>test</scope>
</dependency>
<dependency>
    <groupId>org.hectorclient</groupId>
    <artifactId>hector-core</artifactId>
    <version>2.0-0</version>
</dependency>

可以使用嵌入式Cassandra服务器来测试此应用程序。主要优点是您不希望显式安装Cassandra。

此嵌入式服务器也与Spring JUnit Tests兼容。在这里，我们可以使用@RunWith注释和嵌入式服务器设置SpringJUnit4ClassRunner。因此，可以在不运行外部Cassandra服务的情况下实现完整的测试套件。

@RunWith(SpringJUnit4ClassRunner.<b>class</b>)
@ContextConfiguration(<b>class</b>es = CassandraConfig.<b>class</b>)
<b>public</b> <b>class</b> BookRepositoryIntegrationTest {
    <font><i>//</i></font><font>
}
</font>

6.2。启动和停止服务器

如果您正在运行外部Cassandra服务器，则可以忽略此部分。

我们必须为整个测试套件启动服务器一次，因此服务器启动方法标有@BeforeClass注释：

@BeforeClass
<b>public</b> <b>static</b> <b>void</b> startCassandraEmbedded() { 
    EmbeddedCassandraServerHelper.startEmbeddedCassandra(); 
    Cluster cluster = Cluster.builder()
      .addContactPoints(<font>"127.0.0.1"</font><font>).withPort(9142).build();
    Session session = cluster.connect(); 
}
</font>

接下来，我们必须确保在完成测试套件执行后服务器停止：

@AfterClass
<b>public</b> <b>static</b> <b>void</b> stopCassandraEmbedded() {
    EmbeddedCassandraServerHelper.cleanEmbeddedCassandra();
}

6.3。清洁数据表

最好在每次测试执行之前删除并创建数据表，以避免由于早期测试执行中的操作数据而导致的意外结果。

现在我们可以在服务器启动时创建数据表：

@Before
<b>public</b> <b>void</b> createTable() {
    adminTemplate.createTable(
      <b>true</b>, CqlIdentifier.cqlId(DATA_TABLE_NAME), 
      Book.<b>class</b>, <b>new</b> HashMap<String, Object>());
}

在每个测试用例执行后删除：

@After
<b>public</b> <b>void</b> dropTable() {
    adminTemplate.dropTable(CqlIdentifier.cqlId(DATA_TABLE_NAME));
}

7.使用CassandraRepository进行数据访问

我们可以直接使用上面创建的BookRepository来持久化，操作和获取Cassandra数据库中的数据。

7.1。保存一本新书

我们可以将新书保存到我们的书店：

Book javaBook = <b>new</b> Book(
  UUIDs.timeBased(), <font>"Head First Java"</font><font>, </font><font>"O'Reilly Media"</font><font>, 
  ImmutableSet.of(</font><font>"Computer"</font><font>, </font><font>"Software"</font><font>));
bookRepository.save(ImmutableSet.of(javaBook));
</font>

然后我们可以检查数据库中插入的书的可用性：

Iterable<Book> books = bookRepository.findByTitleAndPublisher(
  <font>"Head First Java"</font><font>, </font><font>"O'Reilly Media"</font><font>);
assertEquals(javaBook.getId(), books.iterator().next().getId());
</font>

7.2。更新现有图书

Lat首先插入一本新书：

Book javaBook = <b>new</b> Book(
  UUIDs.timeBased(), <font>"Head First Java"</font><font>, </font><font>"O'Reilly Media"</font><font>, 
  ImmutableSet.of(</font><font>"Computer"</font><font>, </font><font>"Software"</font><font>));
bookRepository.save(ImmutableSet.of(javaBook));
</font>

让我们按标题取书：

Iterable<Book> books = bookRepository.findByTitleAndPublisher(
  <font>"Head First Java"</font><font>, </font><font>"O'Reilly Media"</font><font>);
</font>

然后让我们改变这本书的标题：

javaBook.setTitle(<font>"Head First Java Second Edition"</font><font>);
bookRepository.save(ImmutableSet.of(javaBook));
</font>

最后让我们检查标题是否在数据库中更新：

Iterable<Book> books = bookRepository.findByTitleAndPublisher(
  <font>"Head First Java Second Edition"</font><font>, </font><font>"O'Reilly Media"</font><font>);
assertEquals(
  javaBook.getTitle(), updateBooks.iterator().next().getTitle());
</font>

7.3。删除现有图书

插入一本新书：

Book javaBook = <b>new</b> Book(
  UUIDs.timeBased(), <font>"Head First Java"</font><font>, </font><font>"O'Reilly Media"</font><font>,
  ImmutableSet.of(</font><font>"Computer"</font><font>, </font><font>"Software"</font><font>));
bookRepository.save(ImmutableSet.of(javaBook));
</font>

然后删除新输入的书：

bookRepository.delete(javaBook);

现在我们可以检查删除：

Iterable<Book> books = bookRepository.findByTitleAndPublisher(
  <font>"Head First Java"</font><font>, </font><font>"O'Reilly Media"</font><font>);
assertNotEquals(javaBook.getId(), books.iterator().next().getId());
</font>

这将导致从代码中抛出NoSuchElementException，确保删除该书。

7.4。查找所有书籍

首先插入新书：

Book javaBook = <b>new</b> Book(
  UUIDs.timeBased(), <font>"Head First Java"</font><font>, </font><font>"O'Reilly Media"</font><font>, 
  ImmutableSet.of(</font><font>"Computer"</font><font>, </font><font>"Software"</font><font>));
Book dPatternBook = <b>new</b> Book(
  UUIDs.timeBased(), </font><font>"Head Design Patterns"</font><font>,</font><font>"O'Reilly Media"</font><font>,
  ImmutableSet.of(</font><font>"Computer"</font><font>, </font><font>"Software"</font><font>));
bookRepository.save(ImmutableSet.of(javaBook));
bookRepository.save(ImmutableSet.of(dPatternBook));
</font>

查找所有书籍：

Iterable<Book> books = bookRepository.findAll();

然后我们可以查看数据库中可用书籍的数量：

<b>int</b> bookCount = 0;
<b>for</b> (Book book : books) bookCount++;
assertEquals(bookCount, 2);

8.结论

我们使用最常用的CassandraRepository数据访问机制，使用Spring数据对Cassandra进行了基本的动手介绍。

上面的代码片段和示例的实现可以在 我的GitHub项目中 中找到- 这是一个基于Eclipse的项目，因此它应该很容易导入和运行。

原文  https://www.jdon.com/50884
正文到此结束
所属分类： Spring

热门推荐

相关文章

阿里云首购8折
说给你听

本文目录
随机标签
书籍教程
springboot-demo Java入门教程 bootstrap3 CSS Apache基础教程 php ionic 教程 Python mysql教程 eclipse Ubuntu VPS系统配置 AngularJS 教程 MongoDB教程 Struts2教程 Redis教程 Spring教程 Git教程 Jenkins进阶系列 openfire参考指南 Java设计模式 HBase教程 java-demo Maven教程 springcloud-demo hibernate教程 Docker 教程 memcached教程 Quartz指南 Hive教程 ANTLR教程 SpringCloud Ant教程 java实例教程 Hazelcast教程 XStream教程 Elastic-Job-Lite 深入浅出MyBatis ibaties教程 SVN教程 rabittmq教程 Hadoop教程 solr教程 WebService CXF学习 JPA教程 ActiveMQ中文指南 Java内存模型 dubbo教程 python3-demo Linux入门视频教程
近期评论
  1. 1 使用 Docker 打包和运行 Vue 应用
  2. 2 Dependency Check命令行方式扫描jar包的安全漏洞
  3. 3 maven使用Dependency-Check来扫描安全漏洞
  4. 4 使用sonarqube分析代码质量
  5. 5 使用screw来对比数据库表和字段差异
  6. 6 Spring Boot 实现防盗链功能
  7. 7 在Spring Boot中的实现国际化（i18n）
  8. 8 一个用于 SMB/CIFS 网络的 Java 库-JCIFS
  9. 9 Spring Boot 3.x嵌入MongoDB 进行测试
  10. 10 java如何解析和生成yaml文件？
网站信息
  • 文章总数：82,737 篇
  • 文件总数：284,312 个
  • 标签总数：2,416 个
  • 分类总数：85 个
  • 留言数量：2,559 条
  • 在线人数：663 人
  • 运行天数：4,439天
  • 最后更新：2024年12月22日11点
Loading...

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

[HBLOG]公众号 HBLOG HBLOG