链接到第一部分：REST API 和下一个测试任务 好吧，我们的应用程序正在运行，我们可以从中获得某种响应，但这给我们带来了什么？它没有做任何有用的工作。说到做到，让我们实现一些有用的东西。首先，让我们在 build.gradle 中添加一些新的依赖项，它们对我们很有用：
![Java-университет]()
![REST API 和数据验证 - 1]()
已修改的类以蓝色突出显示，新的类以绿色突出显示，如果你工作可以获得这样的指示使用 git 存储库，但 git 不是我们文章的主题，因此我们不会详细讨论它。因此，目前我们有一个端点支持 GET 和 POST 两种方法。顺便说一句，关于端点的一些有趣的信息。例如，为什么我们不为 GET 和 POST 分配单独的端点，例如 getAllEmployees 或 createEmployees？一切都非常简单——用一个点来处理所有请求会更加方便。路由基于 HTTP 方法进行，并且很直观，无需记住 getAllEmployees、getEmployeeByName、get...update...create...delete... 的所有变体，让我们测试一下我们得到了什么。我已经在上一篇文章中写道，我们需要 Postman，现在是时候安装它了。在程序界面中，我们创建一个新的POST请求 ![REST API 和数据验证 - 2]()
并尝试发送它。如果一切顺利，我们将在屏幕右侧看到 Status 201。但例如，发送了相同的内容但没有唯一的号码（我们对此进行了验证），我得到了不同的答案： ![REST API 和数据验证 - 3]()
好吧，让我们检查一下我们的完整选择是如何工作的 - 我们为同一端点创建一个 GET 方法并发送它。 ![REST API 和数据验证 - 4]()
我真诚地希望您一切顺利，就像我一样，我们下一篇文章再见。
implementation 'org.apache.commons:commons-lang3:3.12.0'
implementation 'org.apache.commons:commons-collections4:4.4'
implementation 'org.springframework.boot:spring-boot-starter-validation'{
"firstName": String,
"lastName": String,
"department": String,
"salary": String
"hired": String //"yyyy-mm-dd"
"tasks": [
]
}@Entity
@Data
@Accessors(chain = true)
public class Employee {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@JsonIgnore
Long id;
@NotBlank
@Column(unique = true)
private String uniqueNumber;
private String firstName;
private String lastName;
private String department;
private Double salary;
private LocalDate hired;
@OneToMany
@JoinColumn(name = "employee_id")
List<Task> tasks = new ArrayList<>();
}@Entity
@Data
@Accessors(chain = true)
public class Task {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long taskId;
}
public List<Employee> getAllEmployees() {
return employeeRepository.findAll();
}@PostMapping("${application.endpoint.employee}")
public ResponseEntity<?> createOrUpdateEmployee(@RequestBody final Employee employee) {
try {
employeeService.save(employee);
} catch (ValidationException e) {
return ResponseEntity.badRequest().body(e.getViolations());
}
return ResponseEntity.status(HttpStatus.CREATED).build();
}application:
endpoint:
root: api/v1
employee: ${application.endpoint.root}/employees
task: ${application.endpoint.root}/tasks@RestController
@RequestMapping("${application.endpoint.employee}")
@RequiredArgsConstructor
public class EmployeeController {
private final EmployeeService employeeService;
@GetMapping
public ResponseEntity<List<Employee>> getEmployees() {
return ResponseEntity.ok().body(employeeService.getAllEmployees());
}
@PostMapping
public ResponseEntity<?> createOrUpdateEmployee(@RequestBody final Employee employee) {
try {
employeeService.save(employee);
} catch (ValidationException e) {
return ResponseEntity.badRequest().body(e.getViolations());
}
return ResponseEntity.status(HttpStatus.CREATED).build();
}
}import com.example.demo.exception.ValidationException;
import com.example.demo.persistence.entity.Employee;
import lombok.RequiredArgsConstructor;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Set;
import javax.validation.ConstraintViolation;
import javax.validation.Validator;
@Service
@RequiredArgsConstructor
public class ValidationService {
private final Validator validator;
public boolean isValidEmployee(Employee employee) throws ValidationException {
Set<Constraintviolation<Employee>> constraintViolations = validator.validate(employee);
if (CollectionUtils.isNotEmpty(constraintViolations)) {
throw new ValidationException(buildViolationsList(constraintViolations));
}
return true;
}
private <T> List<Violation> buildViolationsList(Set<Constraintviolation<T>> constraintViolations) {
return constraintViolations.stream()
.map(violation -> new Violation(
violation.getPropertyPath().toString(),
violation.getMessage()
)
)
.toList();
}
}public record Violation(String property, String message) {}@RequiredArgsConstructor
public class ValidationException extends Exception {
@Getter
private final List<Violation> violations;
}@Service
@RequiredArgsConstructor
public class EmployeeService {
private final EmployeeRepository employeeRepository;
private final ValidationService validationService;
public List<Employee> getAllEmployees() {
return employeeRepository.findAll();
}
@Transactional
public void save(Employee employee) throws ValidationException {
if (validationService.isValidEmployee(employee)) {
Employee existingEmployee = employeeRepository.findByUniqueNumber(employee.getUniqueNumber());
if (existingEmployee == null) {
employeeRepository.save(employee);
} else {
existingEmployee = updateFields(existingEmployee, employee);
employeeRepository.save(existingEmployee);
}
}
}
private Employee updateFields(Employee existingEmployee, Employee updatedEmployee) {
return existingEmployee.setDepartment(updatedEmployee.getDepartment())
.setSalary(updatedEmployee.getSalary())
//TODO implement tasks merging instead of replacement
.setTasks(updatedEmployee.getTasks());
}
}public interface EmployeeRepository extends JpaRepository<Employee, Long> {
Employee findByUniqueNumber(String uniqueNumber);
}
已修改的类以蓝色突出显示，新的类以绿色突出显示，如果你工作可以获得这样的指示使用 git 存储库，但 git 不是我们文章的主题，因此我们不会详细讨论它。因此，目前我们有一个端点支持 GET 和 POST 两种方法。顺便说一句，关于端点的一些有趣的信息。例如，为什么我们不为 GET 和 POST 分配单独的端点，例如 getAllEmployees 或 createEmployees？一切都非常简单——用一个点来处理所有请求会更加方便。路由基于 HTTP 方法进行，并且很直观，无需记住 getAllEmployees、getEmployeeByName、get...update...create...delete... 的所有变体，让我们测试一下我们得到了什么。我已经在上一篇文章中写道，我们需要 Postman，现在是时候安装它了。在程序界面中，我们创建一个新的POST请求 
并尝试发送它。如果一切顺利，我们将在屏幕右侧看到 Status 201。但例如，发送了相同的内容但没有唯一的号码（我们对此进行了验证），我得到了不同的答案： 
好吧，让我们检查一下我们的完整选择是如何工作的 - 我们为同一端点创建一个 GET 方法并发送它。 
我真诚地希望您一切顺利，就像我一样，我们下一篇文章再见。
GO TO FULL VERSION