No commit message

redkale · Jan 30, 2020 · 85582ee · 85582ee
1 parent 02b9548
commit 85582ee
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/org/redkalex/source/mysql/MysqlDataSource.java b/src/org/redkalex/source/mysql/MysqlDataSource.java
@@ -463,6 +463,7 @@ protected <T> CompletableFuture<Integer> exceptionallyUpdateTableNotExist(Comple
     }
 
     protected static <T> byte[] formatPrepareParam(EntityInfo<T> info, Attribute<T, Serializable> attr, Object param) {
+        if (param == null && info.isNotNullJson(attr)) return new byte[0];
         if (param == null) return null;
         if (param instanceof CharSequence) {
             return param.toString().getBytes(StandardCharsets.UTF_8);

diff --git a/src/org/redkalex/source/pgsql/PgsqlLDataSource.java b/src/org/redkalex/source/pgsql/PgsqlLDataSource.java
@@ -278,7 +278,7 @@ protected <T, K extends Serializable, N extends Number> CompletableFuture<Map<K[
             return rs;
         }));
     }
-    
+
     @Override
     protected <T> CompletableFuture<T> findDB(EntityInfo<T> info, String sql, boolean onlypk, SelectColumn selects) {
         return readPool.pollAsync().thenCompose((conn) -> executeQuery(info, conn, sql).thenApply((ResultSet set) -> {
@@ -365,6 +365,7 @@ protected static int fetchSize(Flipper flipper) {
     }
 
     protected static <T> byte[] formatPrepareParam(EntityInfo<T> info, Attribute<T, Serializable> attr, Object param) {
+        if (param == null && info.isNotNullJson(attr)) return new byte[0];
         if (param == null) return null;
         if (param instanceof byte[]) return (byte[]) param;
         if (param instanceof Boolean) return (Boolean) param ? TRUE : FALSE;