springboot集成cassandra數據庫demo

配置文件
server:
  port: 8080
  tomcat:
    uri-encoding: UTF-8
  servlet:
    context-path: /cassandra
#  compression:
#    enabled: true
#    mime-types: text/html,text/xml,text/plain,text/css,text/javascript,application/javascript

spring:
  data:
    cassandra:
      keyspace-name: ***
      contact-points: ***.***.***.***
      port: 9042
      username: cassandra
      password: cassandra
      session-name: Test Cluster
      local-datacenter: datacenter1 #默認的數據中心
domain類

package com.csf.cassandra.entity;

import lombok.Data;
import lombok.Getter;
import lombok.Setter;
import org.springframework.data.cassandra.core.mapping.PrimaryKey;
import org.springframework.data.cassandra.core.mapping.Table;



@Getter
@Setter
@Data
@Table("users")//Cassandra的表注解，value指定表名
public class UserEntity {


        @PrimaryKey
        private int userid;

        private String fname;

        private String lname;


}

dao我沒有寫service 根據自己的結構自行調整

package com.csf.cassandra.dao;

import com.csf.cassandra.entity.UserEntity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.cassandra.core.CassandraTemplate;
import org.springframework.stereotype.Repository;

import java.util.List;

@Repository
public class UserDao {


    @Autowired
    private CassandraTemplate template;

    public List getAll() {

        List<UserEntity> list = template.select("select * from users", UserEntity.class);
        return list;
    }

    public UserEntity insert(UserEntity user){

        return template.insert(user);

    }
}

package com.csf.cassandra.web;

import com.csf.cassandra.dao.UserDao;
import com.csf.cassandra.entity.UserEntity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
public class UserController {

    @Autowired
    private UserDao userDao;
    @RequestMapping("/users")
    public  List<UserEntity>  getAll() {
            List<UserEntity> list =userDao.getAll();
            return list;
    }

    @RequestMapping("/add")
    public UserEntity save() {
        UserEntity user= new  UserEntity();
        user.setUserid(4);
        user.setFname("鯨魚");
        user.setLname("吳");
        return userDao.insert(user);

    }

}

pom依賴

<dependencies>
    <dependency>
　　　　　<!--這是主要依賴  詳細點進去看源碼-->
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-cassandra</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
        <exclusions>
            <exclusion>
                <groupId>org.junit.vintage</groupId>
                <artifactId>junit-vintage-engine</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
</dependencies>
轉載請注明來源