X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fboot%2Fdata%2Fjdbc%2FUserController.java;h=0a4a62ffa6f04f224e7632c187f86ae656ac4043;hb=a20df3da57291f107122e0fbf57e0a44a8ee15a9;hp=30872904f8a3a3f2c4b2caad6b4091d0b6debaa8;hpb=0d30fafa6f618d5b4f9818cdc0405214bc19cfc8;p=demos%2Fkafka%2Foutbox

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 3087290..0a4a62f 100644
--- a/src/main/java/de/juplo/boot/data/jdbc/UserController.java
+++ b/src/main/java/de/juplo/boot/data/jdbc/UserController.java
@@ -3,12 +3,17 @@ package de.juplo.boot.data.jdbc;
 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.util.StreamUtils;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.servlet.support.ServletUriComponentsBuilder;
 import org.springframework.web.util.UriComponents;
 
+import javax.servlet.http.HttpServletRequest;
+import java.io.IOException;
+import java.nio.charset.Charset;
 import java.time.LocalDateTime;
 
 import static de.juplo.boot.data.jdbc.UserEvent.Type.CREATED;
@@ -41,8 +46,12 @@ public class UserController {
             @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);
         publisher.publishEvent(new UserEvent(this, CREATED, sanitizedUsername));
+        user = repository.findByUsername(sanitizedUsername);
+
         UriComponents uri =
             builder
                 .fromCurrentRequest()
@@ -86,4 +95,22 @@ public class UserController {
 
         return string.trim().toLowerCase();
     }
+
+    @ExceptionHandler
+    public ResponseEntity<?> incorrectResultSizeDataAccessException(
+        HttpServletRequest request,
+        IncorrectResultSizeDataAccessException e
+        )
+    {
+      String username;
+      try {
+          username = StreamUtils.copyToString(request.getInputStream(), Charset.defaultCharset());
+      }
+      catch (IOException ioe)
+      {
+        username = e.getMessage() + " -> " + ioe.getMessage();
+      }
+      LOG.info("User {} already exists!", username);
+      return ResponseEntity.badRequest().build();
+    }
 }