Springboot3.3 整合Cassandra 4.1.5的详细过程

更新时间：2024年06月21日 11:10:15 作者：zhua.er

这篇文章主要介绍了Springboot3.3 整合Cassandra 4.1.5的详细过程,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧

一、数据库搭建

-- 创建Keyspace
CREATE KEYSPACE school WITH replication = {'class':'SimpleStrategy', 'replication_factor' : 1};
-- 创建表
CREATE TABLE student(
   id int PRIMARY KEY,  
   name text,  
   age int,  
   genders int,  
   address text ,
   interest set<text>,
   phone list<text>,
   education map<text, text>
);

二、引入依赖

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-data-cassandra</artifactId>
</dependency>
<!-- hutool是下面多线程导入数据引入 -->
<dependency>
	<groupId>cn.hutool</groupId>
	<artifactId>hutool-all</artifactId>
	<version>5.8.26</version>
</dependency>

三、配置文件

spring:
  application:
    name: Spring-Cassandra
  cassandra:
    keyspace-name: school
    contact-points:
      - 192.168.204.131:9042
    port: 9042
    username: ***
    password: ******
    local-datacenter: datacenter1
    request:
      timeout: 60s

检查Cassandra的local-datacenter，可执行下面命令：

[root@localhost apache-cassandra]# bin/nodetool status

四、创建一个实体类：

import lombok.Data;
import org.springframework.data.cassandra.core.mapping.Column;
import org.springframework.data.cassandra.core.mapping.PrimaryKey;
import org.springframework.data.cassandra.core.mapping.Table;
import java.io.Serializable;
import java.util.List;
import java.util.Map;
import java.util.Set;
@Data
@Table(value="student")
public class Student implements Serializable {
    @PrimaryKey
    private Integer id;
    @Column("name")
    private String name;
    @Column("age")
    private Integer age;
    @Column("genders")
    private Integer genders;
    @Column("address")
    private String address;
    @Column("interest")
    private Set<String> interest;
    @Column("phone")
    private List<String> phone;
    @Column("education")
    private Map<String, String> education;
}

五、创建一个Controller

private final StudentService studentService;
@GetMapping("student")
public List<Student> getStudentByName(String name) {
	return studentService.getStudentByName(name);
}
@GetMapping("count")
public Long count() {
	return studentService.count();
}
@GetMapping("list")
public List<Student> list(String name) {
	Student student = new Student();
	student.setName(name);
	return studentService.list(student);
}
@GetMapping("save")
public String sava() {
	for(int i = 0; i<100; i++) {
		try {
			Thread.sleep(200);
		} catch (InterruptedException e) {
			throw new RuntimeException(e);
		}
		int finalI = i;
		ThreadUtil.execute(() -> {
			System.out.println("线程"+ finalI +"运行");
			List<Student> list = Lists.newArrayList();
			for(int j=0; j<100; j++) {
				UUID uuid = UUID.randomUUID();
				int hash = uuid.toString().hashCode();
				int maxTenDigit = (int) Math.pow(10, 10) - 1; // 10位整数的最大值
				int modHash = Math.abs(hash % maxTenDigit);
				Student student = new Student();
				student.setId(modHash);
				int random = (int) (Math.random() * 100);
				student.setName("GG"+ random);
				student.setAge(random);
				student.setGenders(1);
				student.setAddress("China");
				list.add(student);
//                    studentService.save(student);
			}
			System.out.println("线程"+ finalI +"开始批量插入");
			studentService.batchSave(list);
			System.out.println("线程"+ finalI +"结束批量插入");
		});
	}
	System.out.println("线程结束");
//        ThreadUtil.waitForDie();
	return "success";
}

注意：Cassandra 本身不适合用来做数据分析统计，比如 count，是需要去遍历数据库的，分布式数据库，那么就要通通遍历一次。小数据还可以，数据量大会报查询超时错误。

六、编写service查询数据

service接口省略

1、JPA方式查询

service实现

private final StudentMapper studentMapper;
@Override
public List<Student> getStudentByName(String name) {
	return studentMapper.getStudentByName(name);
}

mapper接口

@Query(value = "select id, address, age, genders, name, interest, phone, education from student where name = ?0 ALLOW filtering")
List<Student> getStudentByName(String name);

Allow filtering:

如果你的查询条件里，有一个是根据索引查询，那其它非索引非主键字段，可以通过加一个ALLOW FILTERING来过滤实现；

　　虽然查询非索引非主键字段，但是只要加了ALLOW FILTERING条件，它会先根据索引查出来的值，再对结果进行过滤；

（如果不加ALLOW FILTERING，而又有非索引列，这样是不允许的；加上ALLOW FILTERING，相当于在结果后再进行过滤。）

2、CassandraTemplate方式查询

private final CassandraTemplate cassandraTemplate;
@Override
public List<Student> list(Student queryInfo) {
	Query query = Query
			.query(where("name").is(queryInfo.getName()));
	query = query.withAllowFiltering();
	query = query.columns(Columns.from("id", "name", "age", "address", "genders", "interest", "phone", "education"));
	System.out.println(query);
	return this.cassandraTemplate.select(query, Student.class);
}
@Override
public void save(Student student) {
	this.cassandraTemplate.insert(student);
}
/**
* 批量插入
*/
@Override
public void batchSave(List<Student> list) {
	CassandraBatchOperations batchOps = cassandraTemplate.batchOps();
	batchOps.insert(list);
	batchOps.execute();
}
@Override
public Long count() {
	return cassandraTemplate.count(Student.class);
}

到此这篇关于Springboot3.3 整合Cassandra 4.1.5的文章就介绍到这了,更多相关Springboot整合Cassandra内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

使用Stargate访问K8ssandra的过程之Springboot整合Cassandra

@AutoConfigurationPackage与@ComponentScan注解区别
这篇文章主要介绍了@AutoConfigurationPackage与@ComponentScan注解区别，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-06-06
Java使用Flyway实现数据库版本控制的技术指南
在现代应用开发中,数据库结构经常随着业务需求不断演变,使用手动SQL脚本管理数据库版本,不仅容易出现错误,还难以跟踪和回滚,Flyway是一个强大的数据库迁移工具,能够帮助开发者高效管理和自动化数据库的版本控制,本文将介绍Flyway的基本功能及其在SpringBoot项目中的实践
2025-02-02
java利用SMB读取远程文件的方法
这篇文章主要为大家详细介绍了java利用SMB读取远程文件的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-05-05
如何解决线程太多导致java socket连接池出现的问题
这篇文章主要介绍了如何解决线程太多导致socket连接池出现的问题,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-12-12
SpringBoot整合JWT框架,解决Token跨域验证问题
Json web token (JWT), 是为了在网络应用环境间传递声明而执行的一种基于JSON的开放标准（(RFC 7519).定义了一种简洁的，自包含的方法用于通信双方之间以JSON对象的形式安全的传递信息。
2021-06-06
Spring中BeanFactory接口的作用小结
BeanFactory是Spring IOC核心接口,负责管理Bean的实例化、配置与生命周期,通过配置类构建BeanDefinition,注册并解析注解,实现依赖注入,确保Bean正确加载与管理,本文就来详细介绍一下,感兴趣的可以了解一下
2025-09-09
源码解析JDK 1.8 中的 Map.merge()
这篇文章主要介绍了JDK 1.8 之 Map.merge()的相关知识，本文给大家介绍的非常详细，具有一定的参考借鉴价值,需要的朋友可以参考下
2019-10-10
SpringBoot集成Sa-Token实现权限认证流程入门教程
本文详解SpringBoot集成Sa-Token框架的入门步骤,涵盖依赖添加、配置设置、拦截器注册、权限角色逻辑定义、设备工具类创建及登录/注销功能改造,通过注解实现鉴权,解决权限认证问题,感兴趣的朋友跟随小编一起看看吧
2025-09-09
springboot多模块中的共用配置文件详解
这篇文章主要介绍了springboot多模块中的共用配置文件详解，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-12-12
Java双向链表倒置功能实现过程解析
这篇文章主要介绍了Java双向链表倒置功能实现过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-09-09