Complete tutorial of building Spring REST API with Cassandra using Datastax.

<web-app>
    <display-name>Spring REST API with Cassandra using Datastax</display-name>
    <servlet>
        <servlet-name>SpringRESTAPICassandraDatastax</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>/WEB-INF/myApplicationContext.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>SpringRESTAPICassandraDatastax</servlet-name>
        <url-pattern>/*</url-pattern>
    </servlet-mapping>
</web-app>
        

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="
	http://www.springframework.org/schema/beans
	http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/context
	http://www.springframework.org/schema/context/spring-context.xsd
    http://www.springframework.org/schema/mvc
    http://www.springframework.org/schema/mvc/spring-mvc.xsd">
    <context:component-scan base-package="controller,repository"/>
    <mvc:annotation-driven>
        <mvc:message-converters>
            <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter"/>
        </mvc:message-converters>
    </mvc:annotation-driven>
</beans>
            

CREATE TABLE company.customer (
    last_name text,
    first_name text,
    created timestamp,
    phone text,
    PRIMARY KEY (last_name, first_name)
);
        

package controller;

import repository.CassandraRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import model.Customer;

import java.util.List;

@RestController
@RequestMapping("/myapp")
public class MyController {

    @Autowired
    private CassandraRepository cassandraRepository;

    @PutMapping("/customer")
    public void insertCustomer(@RequestBody Customer customer) {

        cassandraRepository.insertCustomer(customer);
    }

    @GetMapping("/customer")
    public List<Customer> getCustomerByLastName(@RequestParam("lastName") String lastName) {

        List<Customer> customerList = cassandraRepository.getCustomerByLastName(lastName);

        return customerList;
    }

    @DeleteMapping("/customer")
    public void deleteCustomerByLastName(@RequestParam("lastName") String lastName) {

        cassandraRepository.deleteCustomerByLastName(lastName);
    }
}
        

package model;

import lombok.Data;

@Data
public class Customer {

    private String lastName;
    private String firstName;
    private String created;
    private String phone;
}
        

package repository;

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.cql.ResultSet;
import com.datastax.oss.driver.api.core.cql.Row;
import com.datastax.oss.driver.api.core.cql.SimpleStatement;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.PreDestroy;
import org.springframework.stereotype.Repository;
import model.Customer;

import java.net.InetSocketAddress;
import java.time.*;
import java.util.*;

@Repository
public class CassandraRepository {

    private CqlSession cqlSession;
    private final String tableName = "company.customer";
    private final String serverIP = "localhost";
    private final int port = 9042;

    @PostConstruct
    private void init() {
        cqlSession = CqlSession.builder()
                .addContactPoint(new InetSocketAddress(serverIP, port))
                .withLocalDatacenter("datacenter1")
                .build();
    }

    @PreDestroy
    private void finish() {
        cqlSession.close();
    }

    public void insertCustomer(Customer customer) {

        String cql = "INSERT INTO " + tableName + " (last_name,first_name,created,phone) VALUES (:last_name,:first_name,:created,:phone);";
        SimpleStatement simpleStatement = SimpleStatement.builder(cql)
                .addNamedValue("last_name", customer.getLastName())
                .addNamedValue("first_name", customer.getFirstName())
                .addNamedValue("created", Instant.now())
                .addNamedValue("phone", customer.getPhone())
                .build();

        cqlSession.execute(simpleStatement);
    }

    public List<Customer> getCustomerByLastName(String lastName) {

        List<Customer> customerList = new ArrayList<>();

        String cql = "SELECT * FROM  " + tableName + " WHERE last_name = :last_name;";
        SimpleStatement simpleStatement = SimpleStatement.builder(cql)
                .addNamedValue("last_name", lastName)
                .build();

        ResultSet resultSet = cqlSession.execute(simpleStatement);
        for (Row row : resultSet) {

            Date created = new Date(row.getInstant("created").toEpochMilli());

            Customer customer = new Customer();
            customer.setLastName(row.getString("last_name"));
            customer.setFirstName(row.getString("first_name"));
            customer.setCreated(created.toString());
            customer.setPhone(row.getString("phone"));

            customerList.add(customer);
        }

        return customerList;
    }

    public void deleteCustomerByLastName(String lastName) {

        String cql = "DELETE FROM  " + tableName + " WHERE last_name = :last_name;";
        SimpleStatement simpleStatement = SimpleStatement.builder(cql)
                .addNamedValue("last_name", lastName)
                .build();

        cqlSession.execute(simpleStatement);
    }
}