Springboot3.3 整合Cassandra 4.1.5的詳細過程
更新時間：2024年06月21日 11:10:15 作者：zhua.er
這篇文章主要介紹了Springboot3.3 整合Cassandra 4.1.5的詳細過程,本文通過實例代碼給大家介紹的非常詳細,感興趣的朋友跟隨小編一起看看吧
一、數(shù)據(jù)庫搭建
-- 創(chuàng)建Keyspace
CREATE KEYSPACE school WITH replication = {'class':'SimpleStrategy', 'replication_factor' : 1};
-- 創(chuàng)建表
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是下面多線程導入數(shù)據(jù)引入 --> <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，可執(zhí)行下面命令：
[root@localhost apache-cassandra]# bin/nodetool status
四、創(chuàng)建一個實體類：
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;
}五、創(chuàng)建一個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位整數(shù)的最大值
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 本身不適合用來做數(shù)據(jù)分析統(tǒng)計，比如 count，是需要去遍歷數(shù)據(jù)庫的，分布式數(shù)據(jù)庫，那么就要通通遍歷一次。小數(shù)據(jù)還可以，數(shù)據(jù)量大會報查詢超時錯誤。
六、編寫service查詢數(shù)據(jù)
service接口省略
1、JPA方式查詢
service實現(xiàn)
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:
如果你的查詢條件里，有一個是根據(jù)索引查詢，那其它非索引非主鍵字段，可以通過加一個ALLOW FILTERING來過濾實現(xiàn)；
雖然查詢非索引非主鍵字段，但是只要加了ALLOW FILTERING條件，它會先根據(jù)索引查出來的值，再對結果進行過濾；
（如果不加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內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要為大家詳細介紹了Java獲取精確到秒的時間戳方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-12-12
這篇文章主要介紹了java中的冒泡排序，本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-08-08
這篇文章主要給大家介紹了關于java中volatile關鍵字的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-04-04
這篇文章給大家介紹Java中的排序并不是指插入排序、希爾排序、歸并排序等具體的排序算法。而是自然排序和比較器排序，文中通過實例代碼介紹的很詳細，有需要的朋友們可以參考借鑒。2016-09-09
在本篇文章里我們給大家整理了一篇關于Java前端Layer.open.btn驗證無效解決方法以及實例代碼，需要的朋友們可以參考學習下。2019-09-09
Java中使用MongoDB數(shù)據(jù)庫實例Demo
MongoDB是由C++語言編寫的,基于分布式文件存儲的數(shù)據(jù)庫,是一個介于關系數(shù)據(jù)庫和非關系數(shù)據(jù)庫之間的產品,是最接近于關系型數(shù)據(jù)庫的NoSQL數(shù)據(jù)庫,下面這篇文章主要給大家介紹了關于Java中使用MongoDB數(shù)據(jù)庫的相關資料,需要的朋友可以參考下2023-12-12
這篇文章為大家介紹了java基礎開發(fā)中泛型類的詳解，包括泛型的概念以及應用實例有需要的朋友可以借鑒參考下，希望能夠有所幫助2021-10-10
這篇文章主要介紹了Java?IPage分頁加自定義sql,主要包括引入依賴，impl常規(guī)操作，本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-06-06
mybatisplus如何在xml的連表查詢中使用queryWrapper
這篇文章主要介紹了mybatisplus如何在xml的連表查詢中使用queryWrapper，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-01-01
java中Hashtable和HashMap的區(qū)別分析
java中Hashtable和HashMap的區(qū)別分析，需要的朋友可以參考一下2013-04-04