projects
/
demos
/
spring
/
data-jdbc
/ 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/spring/data-jdbc]
/
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
177b120
..
ac5ddbc
100644
(file)
--- a/
src/main/java/de/juplo/boot/data/jdbc/UserController.java
+++ b/
src/main/java/de/juplo/boot/data/jdbc/UserController.java
@@
-3,6
+3,7
@@
package de.juplo.boot.data.jdbc;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationEventPublisher;
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.*;
@@
-46,6
+47,9
@@
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);
+
+ LOG.info("Request to create user: {}", user);
+
repository.save(user);
publisher.publishEvent(
new UserEvent(
repository.save(user);
publisher.publishEvent(
new UserEvent(
@@
-53,6
+57,10
@@
public class UserController {
sanitizedUsername,
CREATED,
ZonedDateTime.now(clock)));
sanitizedUsername,
CREATED,
ZonedDateTime.now(clock)));
+
+ // Triggers an IncorrectResultSizeDataAccessException, if the user already existed!
+ user = repository.findByUsername(sanitizedUsername);
+
UriComponents uri =
builder
.fromCurrentRequest()
UriComponents uri =
builder
.fromCurrentRequest()
@@
-101,4
+109,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();
+ }
}
}