From e31c4a30418614672ae8fe309b371f2d6b008d88 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Tue, 28 Feb 2017 13:37:38 +0800
Subject: [PATCH] =?UTF-8?q?DataSource=E5=A2=9E=E5=8A=A0=E6=94=AF=E6=8C=81B?=
 =?UTF-8?q?lob=EF=BC=88byte[]=EF=BC=89=E7=B1=BB=E5=9E=8B=E5=AD=97=E6=AE=B5?=
 =?UTF-8?q?=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../redkale/service/DataSourceService.java    |  12 +
 src/org/redkale/source/DataDefaultSource.java | 269 +++++++++++++-----
 src/org/redkale/source/DataSource.java        |  33 ++-
 src/org/redkale/source/EntityInfo.java        |  64 +++--
 4 files changed, 278 insertions(+), 100 deletions(-)

diff --git a/src/org/redkale/service/DataSourceService.java b/src/org/redkale/service/DataSourceService.java
index fbd92f654..2670f9a39 100644
--- a/src/org/redkale/service/DataSourceService.java
+++ b/src/org/redkale/service/DataSourceService.java
@@ -93,11 +93,23 @@ public class DataSourceService implements DataSource, Service, AutoCloseable {
         return source.updateColumn(bean, node, columns);
     }
 
+    @Override
+    public <T> int updateColumn(T bean, final SelectColumn selects) {
+        return source.updateColumn(bean, selects);
+    }
+
+    @Override
+    public <T> int updateColumn(T bean, final FilterNode node, final SelectColumn selects) {
+        return source.updateColumn(bean, node, selects);
+    }
+
+    @Deprecated
     @Override
     public <T> int updateColumns(T bean, final String... columns) {
         return source.updateColumn(bean, columns);
     }
 
+    @Deprecated
     @Override
     public <T> int updateColumns(T bean, final FilterNode node, final String... columns) {
         return source.updateColumn(bean, node, columns);
diff --git a/src/org/redkale/source/DataDefaultSource.java b/src/org/redkale/source/DataDefaultSource.java
index 7f3dc0abe..f9e7d830b 100644
--- a/src/org/redkale/source/DataDefaultSource.java
+++ b/src/org/redkale/source/DataDefaultSource.java
@@ -448,7 +448,14 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
             int i = 0;
             if (info.autouuid) info.createPrimaryValue(value);
             for (Attribute<T, Serializable> attr : attrs) {
-                prestmt.setObject(++i, attr.get(value));
+                Serializable val = attr.get(value);
+                if (val instanceof byte[]) {
+                    Blob blob = conn.createBlob();
+                    blob.setBytes(1, (byte[]) val);
+                    prestmt.setObject(++i, blob);
+                } else {
+                    prestmt.setObject(++i, val);
+                }
             }
             prestmt.addBatch();
         }
@@ -688,7 +695,14 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                 for (final T value : values) {
                     int k = 0;
                     for (Attribute<T, Serializable> attr : attrs) {
-                        prestmt.setObject(++k, attr.get(value));
+                        Serializable val = attr.get(value);
+                        if (val instanceof byte[]) {
+                            Blob blob = conn.createBlob();
+                            blob.setBytes(1, (byte[]) val);
+                            prestmt.setObject(++k, blob);
+                        } else {
+                            prestmt.setObject(++k, val);
+                        }
                     }
                     prestmt.setObject(++k, primary.get(value));
                     prestmt.addBatch();//------------------------------------------------------------
@@ -757,17 +771,29 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
-    private <T> int updateColumn(Connection conn, final EntityInfo<T> info, Serializable id, String column, Serializable value) {
+    private <T> int updateColumn(Connection conn, final EntityInfo<T> info, Serializable id, String column, final Serializable value) {
         try {
             int c = -1;
             if (!info.isVirtualEntity()) {
-                String sql = "UPDATE " + info.getTable(id) + " SET " + info.getSQLColumn(null, column) + " = "
-                    + info.formatToString(value) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(id);
-                if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
-                conn.setReadOnly(false);
-                final Statement stmt = conn.createStatement();
-                c = stmt.executeUpdate(sql);
-                stmt.close();
+                if (value instanceof byte[]) {
+                    String sql = "UPDATE " + info.getTable(id) + " SET " + info.getSQLColumn(null, column) + " = ? WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(id);
+                    if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
+                    conn.setReadOnly(false);
+                    final PreparedStatement stmt = conn.prepareStatement(sql);
+                    Blob blob = conn.createBlob();
+                    blob.setBytes(1, (byte[]) value);
+                    stmt.setBlob(1, blob);
+                    c = stmt.executeUpdate(sql);
+                    stmt.close();
+                } else {
+                    String sql = "UPDATE " + info.getTable(id) + " SET " + info.getSQLColumn(null, column) + " = "
+                        + info.formatToString(value) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(id);
+                    if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
+                    conn.setReadOnly(false);
+                    final Statement stmt = conn.createStatement();
+                    c = stmt.executeUpdate(sql);
+                    stmt.close();
+                }
             }
             //---------------------------------------------------
             final EntityCache<T> cache = info.getCache();
@@ -807,7 +833,7 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
-    private <T> int updateColumn(Connection conn, final EntityInfo<T> info, String column, Serializable value, FilterNode node) {
+    private <T> int updateColumn(Connection conn, final EntityInfo<T> info, String column, final Serializable value, FilterNode node) {
         try {
             int c = -1;
             if (!info.isVirtualEntity()) {
@@ -822,15 +848,30 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                     join1 = multisplit('[', ']', ",", new StringBuilder(), joinstr, 0);
                     join2 = multisplit('{', '}', " AND ", new StringBuilder(), joinstr, 0);
                 }
-                String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1))
-                    + " SET " + info.getSQLColumn("a", column) + " = " + info.formatToString(value)
-                    + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                        : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
-                if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
-                conn.setReadOnly(false);
-                final Statement stmt = conn.createStatement();
-                c = stmt.executeUpdate(sql);
-                stmt.close();
+                if (value instanceof byte[]) {
+                    String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1))
+                        + " SET " + info.getSQLColumn("a", column) + " = ?"
+                        + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
+                            : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
+                    if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
+                    conn.setReadOnly(false);
+                    Blob blob = conn.createBlob();
+                    blob.setBytes(1, (byte[]) value);
+                    final PreparedStatement stmt = conn.prepareStatement(sql);
+                    stmt.setBlob(1, blob);
+                    c = stmt.executeUpdate(sql);
+                    stmt.close();
+                } else {
+                    String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1))
+                        + " SET " + info.getSQLColumn("a", column) + " = " + info.formatToString(value)
+                        + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
+                            : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
+                    if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
+                    conn.setReadOnly(false);
+                    final Statement stmt = conn.createStatement();
+                    c = stmt.executeUpdate(sql);
+                    stmt.close();
+                }
             }
             //---------------------------------------------------
             final EntityCache<T> cache = info.getCache();
@@ -876,6 +917,7 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
             final List<Attribute<T, Serializable>> attrs = new ArrayList<>();
             final List<ColumnValue> cols = new ArrayList<>();
             final boolean virtual = info.isVirtualEntity();
+            List<byte[]> blobs = null;
             for (ColumnValue col : values) {
                 Attribute<T, Serializable> attr = info.getUpdateAttribute(col.getColumn());
                 if (attr == null) continue;
@@ -884,7 +926,14 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                 if (!virtual) {
                     if (setsql.length() > 0) setsql.append(", ");
                     String c = info.getSQLColumn(null, col.getColumn());
-                    setsql.append(c).append(" = ").append(info.formatSQLValue(c, col));
+                    setsql.append(c).append(" = ");
+                    if (col.getValue() instanceof byte[]) {
+                        if (blobs == null) blobs = new ArrayList<>();
+                        blobs.add((byte[]) col.getValue());
+                        setsql.append(c).append(" = ?");
+                    } else {
+                        setsql.append(c).append(" = ").append(info.formatSQLValue(c, col));
+                    }
                 }
             }
             int c = -1;
@@ -892,9 +941,21 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                 String sql = "UPDATE " + info.getTable(id) + " SET " + setsql + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(id);
                 if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + ": " + sql);
                 conn.setReadOnly(false);
-                final Statement stmt = conn.createStatement();
-                c = stmt.executeUpdate(sql);
-                stmt.close();
+                if (blobs != null) {
+                    final PreparedStatement stmt = conn.prepareStatement(sql);
+                    int idx = 0;
+                    for (byte[] bs : blobs) {
+                        Blob blob = conn.createBlob();
+                        blob.setBytes(1, bs);
+                        stmt.setBlob(++idx, blob);
+                    }
+                    c = stmt.executeUpdate();
+                    stmt.close();
+                } else {
+                    final Statement stmt = conn.createStatement();
+                    c = stmt.executeUpdate(sql);
+                    stmt.close();
+                }
             }
             //---------------------------------------------------
             final EntityCache<T> cache = info.getCache();
@@ -963,6 +1024,7 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
             final List<Attribute<T, Serializable>> attrs = new ArrayList<>();
             final List<ColumnValue> cols = new ArrayList<>();
             final boolean virtual = info.isVirtualEntity();
+            List<byte[]> blobs = null;
             for (ColumnValue col : values) {
                 Attribute<T, Serializable> attr = info.getUpdateAttribute(col.getColumn());
                 if (attr == null) continue;
@@ -971,7 +1033,13 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                 if (!virtual) {
                     if (setsql.length() > 0) setsql.append(", ");
                     String c = info.getSQLColumn("a", col.getColumn());
-                    setsql.append(c).append(" = ").append(info.formatSQLValue(c, col));
+                    if (col.getValue() instanceof byte[]) {
+                        if (blobs == null) blobs = new ArrayList<>();
+                        blobs.add((byte[]) col.getValue());
+                        setsql.append(c).append(" = ?");
+                    } else {
+                        setsql.append(c).append(" = ").append(info.formatSQLValue(c, col));
+                    }
                 }
             }
             int c = -1;
@@ -993,9 +1061,21 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                 sql += info.createSQLOrderby(flipper) + ((flipper == null || flipper.getLimit() < 1) ? "" : (" LIMIT " + flipper.getLimit()));
                 if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
                 conn.setReadOnly(false);
-                final Statement stmt = conn.createStatement();
-                c = stmt.executeUpdate(sql);
-                stmt.close();
+                if (blobs != null) {
+                    final PreparedStatement stmt = conn.prepareStatement(sql);
+                    int idx = 0;
+                    for (byte[] bs : blobs) {
+                        Blob blob = conn.createBlob();
+                        blob.setBytes(1, bs);
+                        stmt.setBlob(++idx, blob);
+                    }
+                    c = stmt.executeUpdate();
+                    stmt.close();
+                } else {
+                    final Statement stmt = conn.createStatement();
+                    c = stmt.executeUpdate(sql);
+                    stmt.close();
+                }
             }
             //---------------------------------------------------
             final EntityCache<T> cache = info.getCache();
@@ -1013,44 +1093,48 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return updateColumn(bean, columns);
     }
 
-    /**
-     * 更新对象指定的一些字段， 必须是Entity对象
-     *
-     * @param <T>     Entity类的泛型
-     * @param bean    Entity对象
-     * @param columns 需要更新的字段
-     *
-     * @return 更新的数据条数
-     */
     @Override
     public <T> int updateColumn(final T bean, final String... columns) {
+        return updateColumn(bean, SelectColumn.createIncludes(columns));
+    }
+
+    @Override
+    public <T> int updateColumn(final T bean, final SelectColumn selects) {
         final EntityInfo<T> info = loadEntityInfo((Class<T>) bean.getClass());
         if (info.isVirtualEntity()) {
-            return updateColumns(null, info, bean, columns);
+            return updateColumns(null, info, bean, selects);
         }
         Connection conn = createWriteSQLConnection();
         try {
-            return updateColumns(conn, info, bean, columns);
+            return updateColumns(conn, info, bean, selects);
         } finally {
             closeSQLConnection(conn);
         }
     }
 
-    private <T> int updateColumns(final Connection conn, final EntityInfo<T> info, final T bean, final String... columns) {
-        if (bean == null || columns.length < 1) return -1;
+    private <T> int updateColumns(final Connection conn, final EntityInfo<T> info, final T bean, final SelectColumn selects) {
+        if (bean == null || selects == null) return -1;
         try {
             final Class<T> clazz = (Class<T>) bean.getClass();
             StringBuilder setsql = new StringBuilder();
             final Serializable id = info.getPrimary().get(bean);
             final List<Attribute<T, Serializable>> attrs = new ArrayList<>();
+            List<byte[]> blobs = null;
             final boolean virtual = info.isVirtualEntity();
-            for (String col : columns) {
-                Attribute<T, Serializable> attr = info.getUpdateAttribute(col);
-                if (attr == null) continue;
+            for (Attribute<T, Serializable> attr : info.updateAttributes) {
+                if (!selects.test(attr.field())) continue;
                 attrs.add(attr);
                 if (!virtual) {
                     if (setsql.length() > 0) setsql.append(", ");
-                    setsql.append(info.getSQLColumn(null, col)).append(" = ").append(info.formatToString(attr.get(bean)));
+                    setsql.append(info.getSQLColumn(null, attr.field()));
+                    Serializable val = attr.get(bean);
+                    if (val instanceof byte[]) {
+                        if (blobs == null) blobs = new ArrayList<>();
+                        blobs.add((byte[]) val);
+                        setsql.append(" = ?");
+                    } else {
+                        setsql.append(" = ").append(info.formatToString(val));
+                    }
                 }
             }
             int c = -1;
@@ -1058,9 +1142,21 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                 String sql = "UPDATE " + info.getTable(id) + " SET " + setsql + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(id);
                 if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(bean.getClass().getSimpleName() + ": " + sql);
                 conn.setReadOnly(false);
-                final Statement stmt = conn.createStatement();
-                c = stmt.executeUpdate(sql);
-                stmt.close();
+                if (blobs != null) {
+                    final PreparedStatement stmt = conn.prepareStatement(sql);
+                    int idx = 0;
+                    for (byte[] bs : blobs) {
+                        Blob blob = conn.createBlob();
+                        blob.setBytes(1, bs);
+                        stmt.setBlob(++idx, blob);
+                    }
+                    c = stmt.executeUpdate();
+                    stmt.close();
+                } else {
+                    final Statement stmt = conn.createStatement();
+                    c = stmt.executeUpdate(sql);
+                    stmt.close();
+                }
             }
             //---------------------------------------------------
             final EntityCache<T> cache = info.getCache();
@@ -1078,45 +1174,48 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return updateColumn(bean, node, columns);
     }
 
-    /**
-     * 更新对象指定的一些字段， 必须是Entity对象
-     *
-     * @param <T>     Entity类的泛型
-     * @param bean    Entity对象
-     * @param node    过滤node 不能为null
-     * @param columns 需要更新的字段
-     *
-     * @return 更新的数据条数
-     */
     @Override
     public <T> int updateColumn(final T bean, final FilterNode node, final String... columns) {
+        return updateColumn(bean, node, SelectColumn.createIncludes(columns));
+    }
+
+    @Override
+    public <T> int updateColumn(final T bean, final FilterNode node, final SelectColumn selects) {
         final EntityInfo<T> info = loadEntityInfo((Class<T>) bean.getClass());
         if (info.isVirtualEntity()) {
-            return updateColumns(null, info, bean, node, columns);
+            return updateColumns(null, info, bean, node, selects);
         }
         Connection conn = createWriteSQLConnection();
         try {
-            return updateColumns(conn, info, bean, node, columns);
+            return updateColumns(conn, info, bean, node, selects);
         } finally {
             closeSQLConnection(conn);
         }
     }
 
-    private <T> int updateColumns(final Connection conn, final EntityInfo<T> info, final T bean, final FilterNode node, final String... columns) {
-        if (bean == null || node == null || columns.length < 1) return -1;
+    private <T> int updateColumns(final Connection conn, final EntityInfo<T> info, final T bean, final FilterNode node, final SelectColumn selects) {
+        if (bean == null || node == null || selects == null) return -1;
         try {
             final Class<T> clazz = (Class<T>) bean.getClass();
             StringBuilder setsql = new StringBuilder();
             final Serializable id = info.getPrimary().get(bean);
             final List<Attribute<T, Serializable>> attrs = new ArrayList<>();
+            List<byte[]> blobs = null;
             final boolean virtual = info.isVirtualEntity();
-            for (String col : columns) {
-                Attribute<T, Serializable> attr = info.getUpdateAttribute(col);
-                if (attr == null) continue;
+            for (Attribute<T, Serializable> attr : info.updateAttributes) {
+                if (!selects.test(attr.field())) continue;
                 attrs.add(attr);
                 if (!virtual) {
                     if (setsql.length() > 0) setsql.append(", ");
-                    setsql.append(info.getSQLColumn("a", col)).append(" = ").append(info.formatToString(attr.get(bean)));
+                    setsql.append(info.getSQLColumn("a", attr.field()));
+                    Serializable val = attr.get(bean);
+                    if (val instanceof byte[]) {
+                        if (blobs == null) blobs = new ArrayList<>();
+                        blobs.add((byte[]) val);
+                        setsql.append(" = ?");
+                    } else {
+                        setsql.append(" = ").append(info.formatToString(val));
+                    }
                 }
             }
             int c = -1;
@@ -1136,9 +1235,21 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
                         : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
                 if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
                 conn.setReadOnly(false);
-                final Statement stmt = conn.createStatement();
-                c = stmt.executeUpdate(sql);
-                stmt.close();
+                if (blobs != null) {
+                    final PreparedStatement stmt = conn.prepareStatement(sql);
+                    int idx = 0;
+                    for (byte[] bs : blobs) {
+                        Blob blob = conn.createBlob();
+                        blob.setBytes(1, bs);
+                        stmt.setBlob(++idx, blob);
+                    }
+                    c = stmt.executeUpdate();
+                    stmt.close();
+                } else {
+                    final Statement stmt = conn.createStatement();
+                    c = stmt.executeUpdate(sql);
+                    stmt.close();
+                }
             }
             //---------------------------------------------------
             final EntityCache<T> cache = info.getCache();
@@ -1487,6 +1598,7 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
 
         final Connection conn = createReadSQLConnection();
         try {
+            final Attribute<T, Serializable> attr = info.getAttribute(column);
             final String sql = "SELECT " + info.getSQLColumn(null, column) + " FROM " + info.getTable(pk) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(pk);
             if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(clazz.getSimpleName() + " find sql=" + sql);
             conn.setReadOnly(true);
@@ -1494,7 +1606,14 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
             ps.setFetchSize(1);
             final ResultSet set = ps.executeQuery();
             Serializable val = defValue;
-            if (set.next()) val = (Serializable) set.getObject(1);
+            if (set.next()) {
+                if (attr.type() == byte[].class) {
+                    Blob blob = set.getBlob(1);
+                    if (blob != null) val = blob.getBytes(1, (int) blob.length());
+                } else {
+                    val = (Serializable) set.getObject(1);
+                }
+            }
             set.close();
             ps.close();
             return val == null ? defValue : val;
@@ -1521,6 +1640,7 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
 
         final Connection conn = createReadSQLConnection();
         try {
+            final Attribute<T, Serializable> attr = info.getAttribute(column);
             final Map<Class, String> joinTabalis = node == null ? null : node.getJoinTabalis();
             final CharSequence join = node == null ? null : node.createSQLJoin(this, false, joinTabalis, new HashSet<>(), info);
             final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
@@ -1531,7 +1651,14 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
             ps.setFetchSize(1);
             final ResultSet set = ps.executeQuery();
             Serializable val = defValue;
-            if (set.next()) val = (Serializable) set.getObject(1);
+            if (set.next()) {
+                if (attr.type() == byte[].class) {
+                    Blob blob = set.getBlob(1);
+                    if (blob != null) val = blob.getBytes(1, (int) blob.length());
+                } else {
+                    val = (Serializable) set.getObject(1);
+                }
+            }
             set.close();
             ps.close();
             return val == null ? defValue : val;
diff --git a/src/org/redkale/source/DataSource.java b/src/org/redkale/source/DataSource.java
index 510d9ee2b..3ff226dc6 100644
--- a/src/org/redkale/source/DataSource.java
+++ b/src/org/redkale/source/DataSource.java
@@ -99,6 +99,7 @@ public interface DataSource {
 
     /**
      * 更新单个记录的单个字段  <br>
+     * <b>注意</b>：即使字段标记为&#064;Column(updatable=false)也会被更新   <br>
      * 等价SQL: UPDATE {table} SET {column} = {value} WHERE {primary} = {id}  <br>
      *
      * @param <T>    Entity泛型
@@ -113,6 +114,7 @@ public interface DataSource {
 
     /**
      * 更新符合过滤条件记录的单个字段   <br>
+     * <b>注意</b>：即使字段标记为&#064;Column(updatable=false)也会被更新   <br>
      * 等价SQL: UPDATE {table} SET {column} = {value} WHERE {filter node}   <br>
      *
      * @param <T>    Entity泛型
@@ -173,7 +175,7 @@ public interface DataSource {
     /**
      * 更新单个记录的指定字段   <br>
      * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
-     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id}  <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id}  <br>
      *
      * @param <T>     Entity泛型
      * @param bean    待更新的Entity对象
@@ -186,7 +188,7 @@ public interface DataSource {
     /**
      * 更新符合过滤条件记录的指定字段   <br>
      * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
-     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, &#183;&#183;&#183; WHERE {filter node}  <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node}  <br>
      *
      * @param <T>     Entity泛型
      * @param bean    待更新的Entity对象
@@ -197,6 +199,33 @@ public interface DataSource {
      */
     public <T> int updateColumn(final T bean, final FilterNode node, final String... columns);
 
+    /**
+     * 更新单个记录的指定字段   <br>
+     * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param bean    待更新的Entity对象
+     * @param selects 指定字段
+     *
+     * @return 影响的记录条数
+     */
+    public <T> int updateColumn(final T bean, final SelectColumn selects);
+
+    /**
+     * 更新符合过滤条件记录的指定字段   <br>
+     * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param bean    待更新的Entity对象
+     * @param node    过滤条件
+     * @param selects 指定字段
+     *
+     * @return 影响的记录条数
+     */
+    public <T> int updateColumn(final T bean, final FilterNode node, final SelectColumn selects);
+
     /**
      * 由 public int updateColumn(final T bean, final String... columns); 代替
      *
diff --git a/src/org/redkale/source/EntityInfo.java b/src/org/redkale/source/EntityInfo.java
index ba94c728b..f86daa524 100644
--- a/src/org/redkale/source/EntityInfo.java
+++ b/src/org/redkale/source/EntityInfo.java
@@ -425,41 +425,51 @@ public final class EntityInfo<T> {
         T obj = creator.create();
         for (Attribute<T, Serializable> attr : queryAttributes) {
             if (sels == null || sels.test(attr.field())) {
-                Serializable o = (Serializable) set.getObject(this.getSQLColumn(null, attr.field()));
                 final Class t = attr.type();
-                if (t.isPrimitive()) {
-                    if (o != null) {
-                        if (t == int.class) {
-                            o = ((Number) o).intValue();
+                Serializable o;
+                if (t == byte[].class) {
+                    Blob blob = set.getBlob(this.getSQLColumn(null, attr.field()));
+                    if (blob == null) {
+                        o = null;
+                    } else { //不支持超过2G的数据
+                        o = blob.getBytes(1, (int) blob.length());
+                    }
+                } else {
+                    o = (Serializable) set.getObject(this.getSQLColumn(null, attr.field()));
+                    if (t.isPrimitive()) {
+                        if (o != null) {
+                            if (t == int.class) {
+                                o = ((Number) o).intValue();
+                            } else if (t == long.class) {
+                                o = ((Number) o).longValue();
+                            } else if (t == short.class) {
+                                o = ((Number) o).shortValue();
+                            } else if (t == float.class) {
+                                o = ((Number) o).floatValue();
+                            } else if (t == double.class) {
+                                o = ((Number) o).doubleValue();
+                            } else if (t == byte.class) {
+                                o = ((Number) o).byteValue();
+                            } else if (t == char.class) {
+                                o = (char) ((Number) o).intValue();
+                            }
+                        } else if (t == int.class) {
+                            o = 0;
                         } else if (t == long.class) {
-                            o = ((Number) o).longValue();
+                            o = 0L;
                         } else if (t == short.class) {
-                            o = ((Number) o).shortValue();
+                            o = (short) 0;
                         } else if (t == float.class) {
-                            o = ((Number) o).floatValue();
+                            o = 0.0f;
                         } else if (t == double.class) {
-                            o = ((Number) o).doubleValue();
+                            o = 0.0d;
                         } else if (t == byte.class) {
-                            o = ((Number) o).byteValue();
+                            o = (byte) 0;
+                        } else if (t == boolean.class) {
+                            o = false;
                         } else if (t == char.class) {
-                            o = (char) ((Number) o).intValue();
+                            o = (char) 0;
                         }
-                    } else if (t == int.class) {
-                        o = 0;
-                    } else if (t == long.class) {
-                        o = 0L;
-                    } else if (t == short.class) {
-                        o = (short) 0;
-                    } else if (t == float.class) {
-                        o = 0.0f;
-                    } else if (t == double.class) {
-                        o = 0.0d;
-                    } else if (t == byte.class) {
-                        o = (byte) 0;
-                    } else if (t == boolean.class) {
-                        o = false;
-                    } else if (t == char.class) {
-                        o = (char) 0;
                     }
                 }
                 attr.set(obj, o);