In this blog post, we'll explore how to perform Create, Read, Update, and Delete (CRUD) operations using RestClient which was introduced in Spring Framework 6.1 and Spring Boot 3.2.
RestClient Overview
RestClient is designed to offer a more fluent API experience, similar to WebClient, but with a focus on synchronous HTTP calls. It's perfect for applications that need the ease of RestTemplate without the overhead of the reactive stack.
Advantages of Using RestClient
Simplicity: The fluent API makes it straightforward to configure and execute HTTP requests.
Synchronous Operations: Ideal for applications that don’t require the non-blocking nature of WebClient.
Minimal Configuration: Unlike WebClient, it doesn’t require the reactive web stack.
Pre-requisites
The User Entity
- id - primary key
- firstName - user's first name
- lastName - user last name
- email - user email ID
package net.javaguides.springboot.entity;
import jakarta.persistence.*;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
@Entity
@Table(name = "users")
public class User {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;
@Column(nullable = false)
private String firstName;
@Column(nullable = false)
private String lastName;
@Column(nullable = false, unique = true)
private String email;
}
Note that we are using Lombok annotations to reduce the boilerplate code such as getter/setter methods, and constructors.
CRUD Operations with RestClient
Create (POST):
public User createUser(User user) {
return restClient.post()
.uri("/api/users")
.body(user)
.retrieve()
.bodyTo(User.class);
}
- post() - This method initiates a POST request.
- uri("/api/users") - This method specifies the URI of the endpoint.
- body(user) - This method sets the request body with the User object.
- retrieve() - This method fetches the response.
- bodyTo(User.class) - This method converts the response body to a User object.
Read (GET):
public User getUser(Long id) {
return restClient.get()
.uri("/api/users/" + id)
.retrieve()
.bodyTo(User.class);
}
public List<User> getAllUsers() {
return restClient.get()
.uri("/api/users")
.retrieve()
.bodyToList(User.class);
}
Let's understand the above methods:
- get() - This method initiates a GET request.
- For a single user, uri("/api/users/" + id) targets the specific user by ID.
- bodyTo(User.class) and bodyToList(User.class) parse the response into a User object or a list of User objects, respectively.
Update (PUT):
public User updateUser(Long id, User user) {
return restClient.put()
.uri("/api/users/" + id)
.body(user)
.retrieve()
.bodyTo(User.class);
}
- put() - This method starts a PUT request.
- uri() and body() functions are similar to POST, targeting a specific user and sending updated data.
Delete (DELETE):
public void deleteUser(Long id) {
restClient.delete()
.uri("/api/users/" + id)
.retrieve()
.toBodilessEntity();
}
- delete() - This method initiates a DELETE request.
- uri("/api/users/" + id) points to the specific user.
- toBodilessEntity() processes the response without expecting a body (common for DELETE operations).
Complete Code
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.reactive.function.client.RestClient;
import java.util.List;
@Service
public class UserRestClientService {
@Autowired
private RestClient restClient;
// Create
public User createUser(User user) {
return restClient.post()
.uri("/users")
.body(user)
.retrieve()
.bodyTo(User.class);
}
// Read
public User getUser(Long id) {
return restClient.get()
.uri("/users/" + id)
.retrieve()
.bodyTo(User.class);
}
public List<User> getAllUsers() {
return restClient.get()
.uri("/users")
.retrieve()
.bodyToList(User.class);
}
// Update
public User updateUser(Long id, User user) {
return restClient.put()
.uri("/users/" + id)
.body(user)
.retrieve()
.bodyTo(User.class);
}
// Delete
public void deleteUser(Long id) {
restClient.delete()
.uri("/users/" + id)
.retrieve()
.toBodilessEntity();
}
}
Comments
Post a Comment
Leave Comment