jpa dao exception 处理

src/main/java/ltass/staudy/spring/data/jpa/constant/Constants.java

+package ltass.staudy.spring.data.jpa.constant;
+
+public class Constants {
+
+    public final static Integer DEL_FLAG_FALSE    = 0;
+    public final static Integer DEL_FLAG_TRUE     = 1;
+
+}

src/main/java/ltass/staudy/spring/data/jpa/controller/TestController.java

 import com.alibaba.fastjson.JSON;
 import ltass.staudy.spring.data.jpa.dao.UserJpaDao;
 import ltass.staudy.spring.data.jpa.entity.User;
+import ltass.staudy.spring.data.jpa.exception.JpaDaoException;
 import ltass.staudy.spring.data.jpa.repo.UserRepository;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
         try{
             userJpaDao.insert(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.insert(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         user.setUpdateProcess("web");
         try{
             userJpaDao.insert(user);
+        }catch (JpaDaoException ex){
+            return "jpadaoException";
+            //return JSON.toJSONString(ex);
         }catch (Exception ex){
-            return dealException(ex);
+            return "exception";
+            //return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.insert(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.insert(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.update(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.update(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.update(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.update(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.update(user);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
+        }
+        return "OK.";
+    }
+
+    //{"causeBy":"org.hibernate.exception.ConstraintViolationException","message":"could not execute statement"}
+    @GetMapping("/user/update/error/version_null")
+    public String updateErrorVersionNull() {
+        User user = new User();
+        user.setId(1L);
+        user.setNickName("12345");
+        user.setName("myName");
+        user.setEmail("email");
+        user.setRegisterDatetime("2019/01/01 01:01:00");
+        user.setRegisterUserId(1L);
+        user.setRegisterProcess("web");
+        user.setUpdateDatetime("2019/01/01 01:01:00");
+        user.setUpdateUserId(1L);
+        user.setUpdateProcess("web");
+
+        try{
+            userJpaDao.update(user);
+        }catch (Exception ex){
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.deleteById(8L);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
         try{
             userJpaDao.deleteById(1L);
         }catch (Exception ex){
-            return dealException(ex);
+            return JSON.toJSONString(ex);
         }
         return "OK.";
     }
 
-    private String dealException(Exception ex){
-        Map<String,Map<String,Object>> retMap = new LinkedHashMap<>();
-
-        Map<String,Object> retValue1 = new LinkedHashMap<>();
-        retValue1.put("exClass",ex.getClass());
-        retValue1.put("message",ex.getMessage());
-
-        retMap.put("ex",retValue1);
-
-        Map<String,Object> retValue2 = new LinkedHashMap<>();
-        retValue2.put("causeBy",ex.getCause().getClass());
-        retValue2.put("message",ex.getCause().getMessage());
-
-        retMap.put("exCause",retValue2);
-
-        return JSON.toJSONString(retMap);
-    }
-
 }

src/main/java/ltass/staudy/spring/data/jpa/dao/impl/UserJpaDaoImpl.java

 package ltass.staudy.spring.data.jpa.dao.impl;
 
+import cn.hutool.core.date.DateUtil;
+import ltass.staudy.spring.data.jpa.constant.Constants;
 import ltass.staudy.spring.data.jpa.dao.UserJpaDao;
 import ltass.staudy.spring.data.jpa.entity.User;
+import ltass.staudy.spring.data.jpa.exception.ExceptionHelper;
+import ltass.staudy.spring.data.jpa.exception.JpaDaoNoPrimaryException;
+import ltass.staudy.spring.data.jpa.exception.JpaDaoNoVerionInfoException;
 import ltass.staudy.spring.data.jpa.repo.UserRepository;
+import ltass.staudy.spring.data.jpa.utils.IdUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 @Service
-public class UserJpaDaoImpl implements UserJpaDao {
+public class UserJpaDaoImpl implements UserJpaDao{
     @Autowired
     UserRepository repository;
 
     @Override
     public User insert(User entity) {
-        return repository.save(entity);
+        if(entity.getId()==null)entity.setId(IdUtils.id());
+
+        entity.setDelFlag(Constants.DEL_FLAG_FALSE);
+
+        String now = DateUtil.now();
+        entity.setRegisterDatetime(now);
+        entity.setUpdateDatetime(now);
+
+        if(entity.getRegisterProcess()==null){
+            entity.setRegisterProcess("web");
+            entity.setUpdateProcess("web");
+        }
+
+        try{
+            repository.save(entity);
+        }catch (Exception e){
+            ExceptionHelper.insertExceptionProcess(e,"user","insert");
+        }
+
+        return entity;
     }
 
     @Override
     public User update(User entity) {
-        return repository.save(entity);
+        if(entity.getId()==null) throw new JpaDaoNoPrimaryException("user","update");
+        if(entity.getVerNo()==null) throw new JpaDaoNoVerionInfoException("user","update");
+
+        String now = DateUtil.now();
+        entity.setUpdateDatetime(now);
+
+        if(entity.getUpdateProcess()==null)entity.setUpdateProcess("web");
+
+       try{
+            repository.save(entity);
+        }catch (Exception e){
+           ExceptionHelper.updateExceptionProcess(e,"user","update");
+        }
+
+       return entity;
     }
 
     @Override

src/main/java/ltass/staudy/spring/data/jpa/exception/ExceptionHelper.java

+package ltass.staudy.spring.data.jpa.exception;
+
+import org.hibernate.exception.DataException;
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.orm.ObjectOptimisticLockingFailureException;
+
+public class ExceptionHelper {
+
+    public static void insertExceptionProcess(Exception e,String table,String action){
+
+        StringBuilder sb = new StringBuilder();
+        sb.append("class:").append(e.getClass().getName());
+        sb.append("message:").append(e.getMessage());
+        sb.append("causeBy:").append(e.getCause().getClass().getName());
+        sb.append("causeByMessage:").append(e.getCause().getMessage());
+
+        if(e instanceof DataIntegrityViolationException){
+            if(e.getCause() instanceof DataException) {
+                throw new JpaDaoDataException(sb.toString(), table, action);
+            }else{
+                String constraintField = getConstraintField(e.getMessage());
+                if("PRIMARY".equalsIgnoreCase(constraintField)){
+                    throw new JpaDaoConflictIdException(sb.toString(),table,action);
+                }if("null".equalsIgnoreCase(constraintField)){
+                    throw new JpaDaoConflictNullException(sb.toString(),table,action);
+                }else{
+                    throw new JpaDaoConflictUniqueException(sb.toString(),table,action);
+                }
+            }
+        }
+        throw new JpaDaoException(sb.toString(),table,action);
+    }
+
+    public static void updateExceptionProcess(Exception e,String table,String action){
+
+        StringBuilder sb = new StringBuilder();
+        sb.append("class:").append(e.getClass().getName());
+        sb.append("message:").append(e.getMessage());
+        sb.append("causeBy:").append(e.getCause().getClass().getName());
+        sb.append("causeByMessage:").append(e.getCause().getMessage());
+
+        if(e instanceof DataIntegrityViolationException){
+            if(e.getCause() instanceof DataException) {
+                throw new JpaDaoDataException(sb.toString(), table, action);
+            }else{
+                String constraintField = getConstraintField(e.getMessage());
+                if("PRIMARY".equalsIgnoreCase(constraintField)){
+                    throw new JpaDaoConflictIdException(sb.toString(),table,action);
+                }if("null".equalsIgnoreCase(constraintField)){
+                    throw new JpaDaoConflictNullException(sb.toString(),table,action);
+                }else{
+                    throw new JpaDaoConflictUniqueException(sb.toString(),table,action);
+                }
+            }
+        }else if(e instanceof ObjectOptimisticLockingFailureException){
+            throw new JpaDaoOptimisticLockingFailureException(sb.toString(),table,action);
+        }
+        throw new JpaDaoException(sb.toString(),table,action);
+    }
+
+    private static String getConstraintField(String str){
+        int c_start = str.indexOf("constraint");
+        int start = str.indexOf("[",c_start);
+        int end = str.indexOf("]",c_start);
+
+        return str.substring(start+1,end);
+    }
+}

src/main/java/ltass/staudy/spring/data/jpa/exception/JpaDaoConflictIdException.java

+package ltass.staudy.spring.data.jpa.exception;
+
+public class JpaDaoConflictIdException extends RuntimeException{
+    private String rawMessage;
+    private String table;
+    private String action;
+
+    public JpaDaoConflictIdException(String rawMessage, String table, String action) {
+        super();
+        this.rawMessage = rawMessage;
+        this.table = table;
+        this.action = action;
+    }
+
+}

src/main/java/ltass/staudy/spring/data/jpa/exception/JpaDaoConflictNullException.java

+package ltass.staudy.spring.data.jpa.exception;
+
+public class JpaDaoConflictNullException extends RuntimeException{
+    private String rawMessage;
+    private String table;
+    private String action;
+
+    public JpaDaoConflictNullException(String rawMessage, String table, String action) {
+        super();
+        this.rawMessage = rawMessage;
+        this.table = table;
+        this.action = action;
+    }
+
+}

src/main/java/ltass/staudy/spring/data/jpa/exception/JpaDaoConflictUniqueException.java

+package ltass.staudy.spring.data.jpa.exception;
+
+public class JpaDaoConflictUniqueException extends RuntimeException{
+    private String rawMessage;
+    private String table;
+    private String action;
+
+    public JpaDaoConflictUniqueException(String rawMessage, String table, String action) {
+        super();
+        this.rawMessage = rawMessage;
+        this.table = table;
+        this.action = action;
+    }
+
+}

src/main/java/ltass/staudy/spring/data/jpa/exception/JpaDaoDataException.java

+package ltass.staudy.spring.data.jpa.exception;
+
+import lombok.Getter;
+
+@Getter
+public class JpaDaoDataException extends RuntimeException {
+
+    private String rawMessage;
+    private String table;
+    private String action;
+
+    public JpaDaoDataException(String rawMessage, String table, String action) {
+        super();
+        this.rawMessage = rawMessage;
+        this.table = table;
+        this.action = action;
+    }
+
+}

src/main/java/ltass/staudy/spring/data/jpa/exception/JpaDaoException.java

+package ltass.staudy.spring.data.jpa.exception;
+
+import lombok.Getter;
+
+@Getter
+public class JpaDaoException extends RuntimeException {
+
+    private String rawMessage;
+    private String table;
+    private String action;
+
+    public JpaDaoException(String rawMessage,String table,String action) {
+        super();
+        this.rawMessage = rawMessage;
+        this.table = table;
+        this.action = action;
+    }
+
+}

src/main/java/ltass/staudy/spring/data/jpa/exception/JpaDaoNoPrimaryException.java

+package ltass.staudy.spring.data.jpa.exception;
+
+public class JpaDaoNoPrimaryException extends RuntimeException{
+
+    private String table;
+    private String action;
+
+    public JpaDaoNoPrimaryException(String table, String action) {
+        super();
+        this.table = table;
+        this.action = action;
+    }
+
+}

src/main/java/ltass/staudy/spring/data/jpa/exception/JpaDaoNoVerionInfoException.java

+package ltass.staudy.spring.data.jpa.exception;
+
+public class JpaDaoNoVerionInfoException extends RuntimeException{
+
+    private String table;
+    private String action;
+
+    public JpaDaoNoVerionInfoException(String table, String action) {
+        super();
+        this.table = table;
+        this.action = action;
+    }
+
+}

src/main/java/ltass/staudy/spring/data/jpa/exception/JpaDaoOptimisticLockingFailureException.java

+package ltass.staudy.spring.data.jpa.exception;
+
+public class JpaDaoOptimisticLockingFailureException extends RuntimeException{
+    private String rawMessage;
+    private String table;
+    private String action;
+
+    public JpaDaoOptimisticLockingFailureException(String rawMessage, String table, String action) {
+        super();
+        this.rawMessage = rawMessage;
+        this.table = table;
+        this.action = action;
+    }
+
+}