projects
/
demos
/
kafka
/
outbox
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Wiredly enforcing uniqe-users with an exception
[demos/kafka/outbox]
/
src
/
main
/
java
/
de
/
juplo
/
boot
/
data
/
jdbc
/
UserController.java
diff --git
a/src/main/java/de/juplo/boot/data/jdbc/UserController.java
b/src/main/java/de/juplo/boot/data/jdbc/UserController.java
index
4eb1094
..
0aaefd5
100644
(file)
--- a/
src/main/java/de/juplo/boot/data/jdbc/UserController.java
+++ b/
src/main/java/de/juplo/boot/data/jdbc/UserController.java
@@
-2,6
+2,8
@@
package de.juplo.boot.data.jdbc;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.dao.IncorrectResultSizeDataAccessException;
import org.springframework.http.ResponseEntity;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import org.springframework.http.ResponseEntity;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
@@
-10,6
+12,9
@@
import org.springframework.web.util.UriComponents;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
+import static de.juplo.boot.data.jdbc.UserEvent.Type.CREATED;
+import static de.juplo.boot.data.jdbc.UserEvent.Type.DELETED;
+
@RestController
@Transactional
@RequestMapping("/users")
@RestController
@Transactional
@RequestMapping("/users")
@@
-19,10
+24,15
@@
public class UserController {
private final UserRepository repository;
private final UserRepository repository;
+ private final ApplicationEventPublisher publisher;
- public UserController(UserRepository repository) {
+ public UserController(
+ UserRepository repository,
+ ApplicationEventPublisher publisher)
+ {
this.repository = repository;
this.repository = repository;
+ this.publisher = publisher;
}
}
@@
-32,7
+42,12
@@
public class UserController {
@RequestBody String username) {
String sanitizedUsername = UserController.sanitize(username);
User user = new User(sanitizedUsername, LocalDateTime.now(), false);
@RequestBody String username) {
String sanitizedUsername = UserController.sanitize(username);
User user = new User(sanitizedUsername, LocalDateTime.now(), false);
+
+ // Triggering a unique-error for username prevents persistence
repository.save(user);
repository.save(user);
+ publisher.publishEvent(new UserEvent(this, CREATED, sanitizedUsername));
+ user = repository.findByUsername(sanitizedUsername);
+
UriComponents uri =
builder
.fromCurrentRequest()
UriComponents uri =
builder
.fromCurrentRequest()
@@
-59,6
+74,7
@@
public class UserController {
return ResponseEntity.notFound().build();
repository.delete(user);
return ResponseEntity.notFound().build();
repository.delete(user);
+ publisher.publishEvent(new UserEvent(this, DELETED, username));
return ResponseEntity.ok(user);
}
return ResponseEntity.ok(user);
}
@@
-75,4
+91,13
@@
public class UserController {
return string.trim().toLowerCase();
}
return string.trim().toLowerCase();
}
+
+ @ExceptionHandler
+ public ResponseEntity<?> incorrectResultSizeDataAccessException(
+ IncorrectResultSizeDataAccessException e
+ )
+ {
+ LOG.info("User already exists!");
+ return ResponseEntity.badRequest().build();
+ }
}
}