Remove BigDecimal default value 0 while insert (#42)

x-ream · Dec 21, 2021 · 8f0c69c · 8f0c69c
1 parent 9a5d0cc
commit 8f0c69c
Show file tree

Hide file tree

Showing 9 changed files with 28 additions and 19 deletions.
diff --git a/sqli-builder/src/main/java/io/xream/sqli/builder/DialectSupport.java b/sqli-builder/src/main/java/io/xream/sqli/builder/DialectSupport.java
@@ -27,7 +27,6 @@
 import io.xream.sqli.util.SqliJsonUtil;
 
 import java.lang.reflect.Field;
-import java.math.BigDecimal;
 import java.util.List;
 
 /**
@@ -63,11 +62,11 @@ default void objectToListForCreate(List<Object> list, Object obj, List<BeanEleme
                     if (EnumUtil.isEnum(clz))
                         throw new PersistenceException(
                                 "ENUM CAN NOT NULL, property:" + obj.getClass().getName() + "." + ele.getProperty());
-                    if (clz == Boolean.class || clz == Integer.class || clz == Long.class
-                            || clz == Double.class || clz == Float.class || clz == BigDecimal.class
-                            || clz == Byte.class || clz == Short.class)
-                        list.add(0);
-                    else
+//                    if (clz == Boolean.class || clz == Integer.class || clz == Long.class
+//                            || clz == Double.class || clz == Float.class || clz == BigDecimal.class
+//                            || clz == Byte.class || clz == Short.class)
+//                        list.add(0);
+//                    else
                         list.add(null);
                 } else {
                     if (ele.isJson()) {
@@ -84,7 +83,7 @@ default void objectToListForCreate(List<Object> list, Object obj, List<BeanEleme
             }
         } catch (Exception e) {
             SqliExceptionUtil.throwRuntimeExceptionFirst(e);
-            throw new ParsingException(SqliExceptionUtil.getMessage(e));
+            throw new ParsingException(e);
         }
 
 

diff --git a/sqli-builder/src/main/java/io/xream/sqli/exception/ExceptionTranslator.java b/sqli-builder/src/main/java/io/xream/sqli/exception/ExceptionTranslator.java
@@ -32,20 +32,14 @@ public static  PersistenceException onRollback(Object obj, Exception e, Logger l
         Throwable t = SqliExceptionUtil.unwrapThrowable(e);
         if (t instanceof RuntimeException)
             throw (RuntimeException)t;
-        String msg = SqliExceptionUtil.getMessage(t);
-        String objStr = obj == null ? "": obj.toString();
-        String logStr =  objStr + ", Exception: " + msg;
-        String eStr =  objStr + ", \nException: " + msg;
-        logger.error(logStr);
-        return new PersistenceException(eStr);
+        return new PersistenceException(e);
     }
 
     public static QueryException onQuery(Exception e, Logger logger) {
         Throwable t = SqliExceptionUtil.unwrapThrowable(e);
         if (t instanceof RuntimeException)
             throw (RuntimeException)t;
-        String msg = SqliExceptionUtil.getMessage(t);
-        logger.error(msg);
-        return new QueryException(msg);
+        logger.error(SqliExceptionUtil.getMessage(t));
+        return new QueryException(e);
     }
 }
diff --git a/sqli-builder/src/main/java/io/xream/sqli/exception/ParsingException.java b/sqli-builder/src/main/java/io/xream/sqli/exception/ParsingException.java
@@ -28,4 +28,8 @@ public class ParsingException extends RuntimeException implements Serializable {
     public ParsingException(String message){
         super(message);
     }
+
+    public ParsingException(Throwable t) {
+        super(t);
+    }
 }
diff --git a/sqli-builder/src/main/java/io/xream/sqli/exception/PersistenceException.java b/sqli-builder/src/main/java/io/xream/sqli/exception/PersistenceException.java
@@ -29,4 +29,8 @@ public PersistenceException(String message){
 		super(message);
 	}
 
+	public PersistenceException(Throwable t) {
+		super(t);
+	}
+
 }
diff --git a/sqli-builder/src/main/java/io/xream/sqli/exception/ProxyException.java b/sqli-builder/src/main/java/io/xream/sqli/exception/ProxyException.java
@@ -26,4 +26,8 @@ public class ProxyException extends RuntimeException {
     public ProxyException(String message){
         super(message);
     }
+
+    public ProxyException(Throwable t) {
+        super(t);
+    }
 }
diff --git a/sqli-builder/src/main/java/io/xream/sqli/exception/QueryException.java b/sqli-builder/src/main/java/io/xream/sqli/exception/QueryException.java
@@ -29,4 +29,8 @@ public QueryException(String message){
 		super(message);
 	}
 
+	public QueryException(Throwable t) {
+		super(t);
+	}
+
 }
diff --git a/sqli-dialect/src/main/java/io/xream/sqli/dialect/OracleDialect.java b/sqli-dialect/src/main/java/io/xream/sqli/dialect/OracleDialect.java
@@ -85,7 +85,7 @@ private Object toNCLOBString(Object obj) {
                 return new String(charArr);//FIXME UIF-8 ?
             } catch (Exception e) {
                 SqliExceptionUtil.throwRuntimeExceptionFirst(e);
-                throw new PersistenceException(SqliExceptionUtil.getMessage(e));
+                throw new PersistenceException(e);
             }finally{
                 if (reader !=null) {
                     try {

diff --git a/sqli-repo/src/main/java/io/xream/sqli/repository/internal/DefaultNativeRepository.java b/sqli-repo/src/main/java/io/xream/sqli/repository/internal/DefaultNativeRepository.java
@@ -59,7 +59,7 @@ public boolean execute(String sql, Object...objs){
 			return nativeSupport.execute(sql, objs);
 		}catch (Exception e) {
 			SqliExceptionUtil.throwRuntimeExceptionFirst(e);
-			throw new PersistenceException(SqliExceptionUtil.getMessage(e));
+			throw new PersistenceException(e);
 		}finally {
 			removeDialectKey();
 		}

diff --git a/sqli-repo/src/main/java/io/xream/sqli/repository/internal/DefaultTemporaryRepository.java b/sqli-repo/src/main/java/io/xream/sqli/repository/internal/DefaultTemporaryRepository.java
@@ -81,7 +81,7 @@ private boolean doProxy(String logTag, Callable<Boolean> callable) {
         }catch (Exception e){
             logger.warn("{} exception: {}" , logTag, SqliExceptionUtil.getMessage(e));
             SqliExceptionUtil.throwRuntimeExceptionFirst(e);
-            throw new ProxyException(SqliExceptionUtil.getMessage(e));
+            throw new ProxyException(e);
         }finally {
             removeDialectKey();
             long endTime = System.currentTimeMillis();