diff --git a/src/org/redkale/source/DataJdbcOldSource.java b/src/org/redkale/source/DataJdbcOldSource.java
deleted file mode 100644
index 746f8dbbd..000000000
--- a/src/org/redkale/source/DataJdbcOldSource.java
+++ /dev/null
@@ -1,2469 +0,0 @@
-/*
- * To change this license header, choose License Headers in Project Properties.
- * To change this template file, choose Tools | Templates
- * and open the template in the editor.
- */
-package org.redkale.source;
-
-import java.io.*;
-import java.net.URL;
-import java.sql.*;
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.concurrent.atomic.*;
-import java.util.function.*;
-import java.util.logging.*;
-import java.util.stream.Stream;
-import javax.annotation.Resource;
-import org.redkale.service.*;
-import static org.redkale.source.DataSources.*;
-import org.redkale.util.*;
-
-/**
- * DataSource的JDBC实现类
- *
- * <p>
- * 详情见: https://redkale.org
- *
- * @author zhangjx
- */
-@Local
-@AutoLoad(false)
-@SuppressWarnings("unchecked")
-@ResourceType(DataSource.class)
-public class DataJdbcOldSource extends AbstractService implements DataSource, DataCacheListener, Function<Class, EntityInfo>, AutoCloseable, Resourcable {
-
-    protected static final Flipper FLIPPER_ONE = new Flipper(1);
-
-    protected final Logger logger = Logger.getLogger(this.getClass().getSimpleName());
-
-    protected String name;
-
-    protected URL persistxml;
-
-    protected int threads;
-
-    protected ExecutorService executor;
-
-    protected boolean cacheForbidden;
-
-    protected PoolJdbcSource readPool;
-
-    protected PoolJdbcSource writePool;
-
-    @Resource(name = "$")
-    protected DataCacheListener cacheListener;
-
-    protected final BiConsumer futureCompleteConsumer = (r, t) -> {
-        if (t != null) logger.log(Level.SEVERE, "CompletableFuture complete error", (Throwable) t);
-    };
-
-    protected final BiFunction<DataSource, Class, List> fullloader = (s, t) -> querySheet(false, false, t, null, null, (FilterNode) null).list(true);
-
-    public DataJdbcOldSource(String unitName, URL persistxml, Properties readprop, Properties writeprop) {
-        this.persistxml = persistxml;
-        this.preConstruct(unitName, readprop, writeprop);
-        this.initByProperties(unitName, readprop, writeprop);
-    }
-
-    public DataJdbcOldSource() {
-    }
-
-    @Override
-    public void init(AnyValue config) { //通过空构造函数创建的对象需要调用init方法进行初始化
-        String unitName = config.getValue("name");
-        Properties readprop = new Properties();
-        Properties writeprop = new Properties();
-
-        for (AnyValue confs : config.getAnyValues("properties")) {
-            boolean write = confs.getValue("name", "").contains("write");
-            for (AnyValue conf : confs.getAnyValues("property")) {
-                String pn = conf.getValue("name");
-                String pv = conf.getValue("value");
-                if (pn == null || pv == null) continue;
-                (write ? writeprop : readprop).put(pn, pv);
-            }
-        }
-
-        for (AnyValue conf : config.getAnyValues("property")) {
-            String pn = conf.getValue("name");
-            String pv = conf.getValue("value");
-            if (pn == null || pv == null) continue;
-            readprop.put(pn, pv);
-        }
-        if (writeprop.isEmpty()) writeprop = readprop;
-        this.initByProperties(unitName, readprop, writeprop);
-    }
-
-    @Override
-    protected ExecutorService getExecutor() {
-        return executor;
-    }
-
-    @Override
-    public void destroy(AnyValue config) {
-        if (this.executor != null) this.executor.shutdownNow();
-    }
-
-    //构造前调用
-    protected void preConstruct(String unitName, Properties readprop, Properties writeprop) {
-        final AtomicInteger counter = new AtomicInteger();
-        this.threads = Integer.decode(readprop.getProperty(JDBC_CONNECTIONSMAX, "" + Runtime.getRuntime().availableProcessors() * 16));
-        final String cname = this.getClass().getSimpleName();
-        final Thread.UncaughtExceptionHandler ueh = (t, e) -> {
-            logger.log(Level.SEVERE, cname + " error", e);
-        };
-        this.executor = Executors.newFixedThreadPool(threads, (Runnable r) -> {
-            Thread t = new Thread(r);
-            t.setDaemon(true);
-            String s = "" + counter.incrementAndGet();
-            if (s.length() == 1) {
-                s = "00" + s;
-            } else if (s.length() == 2) {
-                s = "0" + s;
-            }
-            t.setName(cname + "-Thread-" + s);
-            t.setUncaughtExceptionHandler(ueh);
-            return t;
-        });
-    }
-
-    protected void initByProperties(String unitName, Properties readprop, Properties writeprop) {
-        this.name = unitName;
-        this.cacheForbidden = "NONE".equalsIgnoreCase(readprop.getProperty(JDBC_CACHE_MODE));
-        this.readPool = new PoolJdbcSource(unitName, persistxml, "read", null, readprop, logger);
-        this.writePool = new PoolJdbcSource(unitName, persistxml, "write", null, writeprop, logger);
-    }
-
-    @Local
-    @Override
-    public String getType() {
-        return "jdbc";
-    }
-
-    @Override
-    public final String resourceName() {
-        return name;
-    }
-
-    @Override
-    @Local
-    public void close() throws Exception {
-        readPool.close();
-        writePool.close();
-    }
-
-    @Local
-    public PoolJdbcSource getReadPoolJdbcSource() {
-        return readPool;
-    }
-
-    @Local
-    public PoolJdbcSource getWritePoolJdbcSource() {
-        return writePool;
-    }
-
-    @Local
-    public Connection createReadSQLConnection() {
-        return readPool.poll();
-    }
-
-    @Local
-    public <T> Connection createWriteSQLConnection() {
-        return writePool.poll();
-    }
-
-    @Local
-    public void closeSQLConnection(final Connection sqlconn) {
-        if (sqlconn == null) return;
-        try {
-            sqlconn.close();
-        } catch (Exception e) {
-            logger.log(Level.WARNING, "closeSQLConnection abort", e);
-        }
-    }
-
-    @Override
-    @Local
-    public EntityInfo apply(Class t) {
-        return loadEntityInfo(t);
-    }
-
-    protected <T> EntityInfo<T> loadEntityInfo(Class<T> clazz) {
-        return EntityInfo.load(clazz, this.cacheForbidden, this.readPool.props, this, fullloader);
-    }
-
-    /**
-     * 将entity的对象全部加载到Cache中去，如果clazz没有被@javax.persistence.Cacheable注解则不做任何事
-     *
-     * @param <T>   Entity类泛型
-     * @param clazz Entity类
-     */
-    public <T> void refreshCache(Class<T> clazz) {
-        EntityInfo<T> info = loadEntityInfo(clazz);
-        EntityCache<T> cache = info.getCache();
-        if (cache == null) return;
-        cache.fullLoad();
-    }
-
-    //----------------------insertCache-----------------------------
-    /**
-     * 新增对象， 必须是Entity对象
-     *
-     * @param <T>    Entity类泛型
-     * @param values Entity对象
-     *
-     * @return 影响的记录条数
-     */
-    @Override
-    public <T> int insert(@RpcCall(DataCallArrayAttribute.class) T... values) {
-        if (values.length == 0) return 0;
-        if (values.length > 1) { //检查对象是否都是同一个Entity类
-            Class clazz = null;
-            for (T val : values) {
-                if (clazz == null) {
-                    clazz = val.getClass();
-                    continue;
-                }
-                if (clazz != val.getClass()) {
-                    throw new RuntimeException("DataSource.insert must the same Class Entity, but diff is " + clazz + " and " + val.getClass());
-                }
-            }
-        }
-        final EntityInfo<T> info = loadEntityInfo((Class<T>) values[0].getClass());
-        if (info.isVirtualEntity()) {
-            return insert(null, info, values);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return insert(conn, info, values);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> insertAsync(@RpcCall(DataCallArrayAttribute.class) T... values) {
-        return CompletableFuture.supplyAsync(() -> insert(values), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int insert(final Connection conn, final EntityInfo<T> info, T... values) {
-        if (values.length == 0) return 0;
-        int c = -1;
-        try {
-            if (!info.isVirtualEntity()) {
-                final String sql = info.getInsertPrepareSQL(values[0]);
-                final Class primaryType = info.getPrimary().type();
-                final Attribute primary = info.getPrimary();
-                Attribute<T, Serializable>[] attrs = info.insertAttributes;
-                conn.setReadOnly(false);
-                PreparedStatement prestmt = createInsertPreparedStatement(conn, sql, info, values);
-                try {
-                    prestmt.executeBatch();
-                } catch (SQLException se) {
-                    if (info.tableStrategy == null || !info.isTableNotExist(se)) throw se;
-                    synchronized (info.tables) {
-                        final String oldTable = info.table;
-                        final String newTable = info.getTable(values[0]);
-                        if (!info.tables.contains(newTable)) {
-                            try {
-                                Statement st = conn.createStatement();
-                                st.execute(info.tablecopySQL.replace("${newtable}", newTable).replace("${oldtable}", oldTable));
-                                st.close();
-                                info.tables.add(newTable);
-                            } catch (SQLException sqle) { //多进程并发时可能会出现重复建表
-                                if (newTable.indexOf('.') > 0 && info.isTableNotExist(se)) {
-                                    Statement st;
-                                    try {
-                                        st = conn.createStatement();
-                                        st.execute("CREATE DATABASE " + newTable.substring(0, newTable.indexOf('.')));
-                                        st.close();
-                                    } catch (SQLException sqle1) {
-                                        logger.log(Level.SEVERE, "create database(" + newTable.substring(0, newTable.indexOf('.')) + ") error", sqle1);
-                                    }
-                                    try {
-                                        st = conn.createStatement();
-                                        st.execute(info.tablecopySQL.replace("${newtable}", newTable).replace("${oldtable}", oldTable));
-                                        st.close();
-                                        info.tables.add(newTable);
-                                    } catch (SQLException sqle2) {
-                                        logger.log(Level.SEVERE, "create table2(" + info.tablecopySQL.replace("${newtable}", newTable).replace("${oldtable}", oldTable) + ") error", sqle2);
-                                    }
-                                } else {
-                                    logger.log(Level.SEVERE, "create table(" + info.tablecopySQL.replace("${newtable}", newTable).replace("${oldtable}", oldTable) + ") error", sqle);
-                                }
-                            }
-                        }
-                    }
-                    prestmt.close();
-                    prestmt = createInsertPreparedStatement(conn, sql, info, values);
-                    int[] cs = prestmt.executeBatch();
-                    int c1 = 0;
-                    for (int cc : cs) {
-                        c1 += cc;
-                    }
-                    c = c1;
-                }
-                if (info.autoGenerated) { //由数据库自动生成主键值
-                    ResultSet set = prestmt.getGeneratedKeys();
-                    int i = -1;
-                    while (set.next()) {
-                        if (primaryType == int.class) {
-                            primary.set(values[++i], set.getInt(1));
-                        } else if (primaryType == long.class) {
-                            primary.set(values[++i], set.getLong(1));
-                        } else {
-                            primary.set(values[++i], set.getObject(1));
-                        }
-                    }
-                    set.close();
-                }
-                prestmt.close();
-                //------------------------------------------------------------
-                if (info.isLoggable(logger, Level.FINEST)) {  //打印调试信息
-                    char[] sqlchars = sql.toCharArray();
-                    for (final T value : values) {
-                        //-----------------------------
-                        StringBuilder sb = new StringBuilder(128);
-                        int i = 0;
-                        for (char ch : sqlchars) {
-                            if (ch == '?') {
-                                Object obj = attrs[i++].get(value);
-                                if (obj != null && obj.getClass().isArray()) {
-                                    sb.append("'[length=").append(java.lang.reflect.Array.getLength(obj)).append("]'");
-                                } else {
-                                    sb.append(FilterNode.formatToString(obj));
-                                }
-                            } else {
-                                sb.append(ch);
-                            }
-                        }
-                        logger.finest(info.getType().getSimpleName() + " insert sql=" + sb.toString().replaceAll("(\r|\n)", "\\n"));
-                    }
-                } //打印结束
-            }
-            final EntityCache<T> cache = info.getCache();
-            int c2 = 0;
-            if (cache != null) { //更新缓存
-                for (final T value : values) {
-                    c2 += cache.insert(value);
-                }
-                if (cacheListener != null) cacheListener.insertCache(info.getType(), values);
-            }
-            return c >= 0 ? c : c2;
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    protected <T> PreparedStatement createInsertPreparedStatement(final Connection conn, final String sql,
-        final EntityInfo<T> info, T... values) throws SQLException {
-        Attribute<T, Serializable>[] attrs = info.insertAttributes;
-        final PreparedStatement prestmt = info.autoGenerated ? conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS) : conn.prepareStatement(sql);
-
-        for (final T value : values) {
-            int i = 0;
-            if (info.autouuid) info.createPrimaryValue(value);
-            for (Attribute<T, Serializable> attr : attrs) {
-                Serializable val = attr.get(value);
-                if (val instanceof byte[]) {
-                    Blob blob = conn.createBlob();
-                    blob.setBytes(1, (byte[]) val);
-                    prestmt.setObject(++i, blob);
-                } else if (val instanceof AtomicInteger) {
-                    prestmt.setObject(++i, ((AtomicInteger) val).get());
-                } else if (val instanceof AtomicLong) {
-                    prestmt.setObject(++i, ((AtomicLong) val).get());
-                } else {
-                    prestmt.setObject(++i, val);
-                }
-            }
-            prestmt.addBatch();
-        }
-        return prestmt;
-    }
-
-    @Override
-    public <T> int insertCache(Class<T> clazz, T... values) {
-        if (values.length == 0) return 0;
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache == null) return -1;
-        int c = 0;
-        for (T value : values) {
-            c += cache.insert(value);
-        }
-        return c;
-    }
-
-    //-------------------------deleteCache--------------------------
-    /**
-     * 删除对象， 必须是Entity对象
-     *
-     * @param <T>    Entity类泛型
-     * @param values Entity对象
-     *
-     * @return 删除的数据条数
-     */
-    @Override
-    public <T> int delete(T... values) {
-        if (values.length == 0) return -1;
-        if (values.length > 1) { //检查对象是否都是同一个Entity类
-            Class clazz = null;
-            for (T val : values) {
-                if (clazz == null) {
-                    clazz = val.getClass();
-                    continue;
-                }
-                if (clazz != val.getClass()) {
-                    throw new RuntimeException("DataSource.delete must the same Class Entity, but diff is " + clazz + " and " + val.getClass());
-                }
-            }
-        }
-        final EntityInfo<T> info = loadEntityInfo((Class<T>) values[0].getClass());
-        if (info.isVirtualEntity()) { //虚拟表只更新缓存Cache
-            return delete(null, info, values);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return delete(conn, info, values);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> deleteAsync(final T... values) {
-        return CompletableFuture.supplyAsync(() -> delete(values), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int delete(final Connection conn, final EntityInfo<T> info, T... values) {
-        if (values.length == 0) return -1;
-        final Attribute primary = info.getPrimary();
-        Serializable[] ids = new Serializable[values.length];
-        int i = 0;
-        for (final T value : values) {
-            ids[i++] = (Serializable) primary.get(value);
-        }
-        return delete(conn, info, ids);
-    }
-
-    @Override
-    public <T> int delete(Class<T> clazz, Serializable... ids) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        if (info.isVirtualEntity()) { //虚拟表只更新缓存Cache
-            return delete(null, info, ids);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return delete(conn, info, ids);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> deleteAsync(final Class<T> clazz, final Serializable... ids) {
-        return CompletableFuture.supplyAsync(() -> delete(clazz, ids), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int delete(final Connection conn, final EntityInfo<T> info, Serializable... keys) {
-        if (keys.length == 0) return -1;
-        int c = -1;
-        int c2 = 0;
-        try {
-            if (!info.isVirtualEntity()) {
-                conn.setReadOnly(false);
-                final Statement stmt = conn.createStatement();
-                for (Serializable key : keys) {
-                    String sql = "DELETE FROM " + info.getTable(key) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(key);
-                    if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql);
-                    stmt.addBatch(sql);
-                }
-                int[] pc = stmt.executeBatch();
-                c = 0;
-                for (int p : pc) {
-                    if (p >= 0) c += p;
-                }
-                stmt.close();
-            }
-            //------------------------------------
-            final EntityCache<T> cache = info.getCache();
-            if (cache == null) return c;
-            for (Serializable key : keys) {
-                c2 += cache.delete(key);
-            }
-            if (cacheListener != null) cacheListener.deleteCache(info.getType(), keys);
-            return c >= 0 ? c : c2;
-        } catch (SQLException e) {
-            if (info.tableStrategy != null && info.isTableNotExist(e)) return c >= 0 ? c : c2;
-            throw new RuntimeException(e);
-        }
-    }
-
-    @Override
-    public <T> int delete(Class<T> clazz, FilterNode node) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        if (info.isVirtualEntity()) {
-            return delete(null, info, null, node);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return delete(conn, info, null, node);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> deleteAsync(final Class<T> clazz, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> delete(clazz, node), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    @Override
-    public <T> int delete(Class<T> clazz, final Flipper flipper, FilterNode node) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        if (info.isVirtualEntity()) {
-            return delete(null, info, flipper, node);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return delete(conn, info, flipper, node);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> deleteAsync(final Class<T> clazz, final Flipper flipper, FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> delete(clazz, flipper, node), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int delete(final Connection conn, final EntityInfo<T> info, final Flipper flipper, final FilterNode node) {
-        int c = -1;
-        try {
-            if (!info.isVirtualEntity()) {
-                Map<Class, String> joinTabalis = node.getJoinTabalis();
-                CharSequence join = node.createSQLJoin(this, true, joinTabalis, new HashSet<>(), info);
-                CharSequence where = node.createSQLExpress(info, joinTabalis);
-
-                StringBuilder join1 = null;
-                StringBuilder join2 = null;
-                if (join != null) {
-                    String joinstr = join.toString();
-                    join1 = multisplit('[', ']', ",", new StringBuilder(), joinstr, 0);
-                    join2 = multisplit('{', '}', " AND ", new StringBuilder(), joinstr, 0);
-                }
-                String sql = "DELETE " + ("mysql".equals(this.readPool.getDbtype()) ? "a" : "") + " FROM " + info.getTable(node) + " a" + (join1 == null ? "" : (", " + join1))
-                    + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                    : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2)))) + info.createSQLOrderby(flipper)
-                    + ((flipper == null || flipper.getLimit() < 1) ? "" : (" LIMIT " + flipper.getLimit()));
-                if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql);
-                conn.setReadOnly(false);
-                final Statement stmt = conn.createStatement();
-                c = stmt.executeUpdate(sql);
-                stmt.close();
-            }
-            //------------------------------------
-            final EntityCache<T> cache = info.getCache();
-            if (cache == null) return c;
-            Serializable[] ids = cache.delete(flipper, node);
-            if (cacheListener != null) cacheListener.deleteCache(info.getType(), ids);
-            return c >= 0 ? c : (ids == null ? 0 : ids.length);
-        } catch (SQLException e) {
-            if (info.tableStrategy != null && info.isTableNotExist(e)) return c;
-            throw new RuntimeException(e);
-        }
-    }
-
-    @Override
-    public <T> int deleteCache(Class<T> clazz, Serializable... ids) {
-        if (ids.length == 0) return 0;
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache == null) return -1;
-        int c = 0;
-        for (Serializable id : ids) {
-            c += cache.delete(id);
-        }
-        return c;
-    }
-
-    //------------------------updateAsync---------------------------
-    /**
-     * 更新对象， 必须是Entity对象
-     *
-     * @param <T>    Entity类泛型
-     * @param values Entity对象
-     *
-     * @return 更新的数据条数
-     */
-    @Override
-    public <T> int update(T... values) {
-        if (values.length == 0) return 0;
-        if (values.length > 1) { //检查对象是否都是同一个Entity类
-            Class clazz = null;
-            for (T val : values) {
-                if (clazz == null) {
-                    clazz = val.getClass();
-                    continue;
-                }
-                if (clazz != val.getClass()) {
-                    throw new RuntimeException("DataSource.update must the same Class Entity, but diff is " + clazz + " and " + val.getClass());
-                }
-            }
-        }
-        final EntityInfo<T> info = loadEntityInfo((Class<T>) values[0].getClass());
-        if (info.isVirtualEntity()) {
-            return update(null, info, values);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return update(conn, info, values);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateAsync(final T... values) {
-        return CompletableFuture.supplyAsync(() -> update(values), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int update(final Connection conn, final EntityInfo<T> info, T... values) {
-        try {
-            Class clazz = info.getType();
-            int c = -1;
-            if (!info.isVirtualEntity()) {
-                final String updateSQL = info.getUpdatePrepareSQL(values[0]);
-                final Attribute<T, Serializable> primary = info.getPrimary();
-                conn.setReadOnly(false);
-                final PreparedStatement prestmt = conn.prepareStatement(updateSQL);
-                Attribute<T, Serializable>[] attrs = info.updateAttributes;
-                final boolean debugfinest = info.isLoggable(logger, Level.FINEST);
-                char[] sqlchars = debugfinest ? updateSQL.toCharArray() : null;
-                for (final T value : values) {
-                    int k = 0;
-                    for (Attribute<T, Serializable> attr : attrs) {
-                        Serializable val = attr.get(value);
-                        if (val instanceof byte[]) {
-                            Blob blob = conn.createBlob();
-                            blob.setBytes(1, (byte[]) val);
-                            prestmt.setObject(++k, blob);
-                        } else if (val instanceof AtomicInteger) {
-                            prestmt.setObject(++k, ((AtomicInteger) val).get());
-                        } else if (val instanceof AtomicLong) {
-                            prestmt.setObject(++k, ((AtomicLong) val).get());
-                        } else {
-                            prestmt.setObject(++k, val);
-                        }
-                    }
-                    prestmt.setObject(++k, primary.get(value));
-                    prestmt.addBatch();//------------------------------------------------------------
-                    if (debugfinest) {  //打印调试信息
-                        //-----------------------------
-                        int i = 0;
-                        StringBuilder sb = new StringBuilder(128);
-                        for (char ch : sqlchars) {
-                            if (ch == '?') {
-                                Object obj = i == attrs.length ? primary.get(value) : attrs[i++].get(value);
-                                if (obj != null && obj.getClass().isArray()) {
-                                    sb.append("'[length=").append(java.lang.reflect.Array.getLength(obj)).append("]'");
-                                } else {
-                                    sb.append(FilterNode.formatToString(obj));
-                                }
-                            } else {
-                                sb.append(ch);
-                            }
-                        }
-                        logger.finest(info.getType().getSimpleName() + " update sql=" + sb.toString().replaceAll("(\r|\n)", "\\n"));
-                    } //打印结束
-                }
-                int[] pc = prestmt.executeBatch();
-                c = 0;
-                for (int p : pc) {
-                    if (p >= 0) c += p;
-                }
-                prestmt.close();
-            }
-            //---------------------------------------------------
-            final EntityCache<T> cache = info.getCache();
-            if (cache == null) return c;
-            int c2 = 0;
-            for (final T value : values) {
-                c2 += cache.update(value);
-            }
-            if (cacheListener != null) cacheListener.updateCache(clazz, values);
-            return c >= 0 ? c : c2;
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    /**
-     * 根据主键值更新对象的column对应的值， 必须是Entity Class
-     *
-     * @param <T>    Entity类的泛型
-     * @param clazz  Entity类
-     * @param id     主键值
-     * @param column 过滤字段名
-     * @param value  过滤字段值
-     *
-     * @return 更新的数据条数
-     */
-    @Override
-    public <T> int updateColumn(Class<T> clazz, Serializable id, String column, Serializable value) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        if (info.isVirtualEntity()) {
-            return updateColumn(null, info, id, column, value);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return updateColumn(conn, info, id, column, value);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final Serializable id, final String column, final Serializable value) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, id, column, value), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int updateColumn(Connection conn, final EntityInfo<T> info, Serializable id, String column, final Serializable value) {
-        try {
-            int c = -1;
-            if (!info.isVirtualEntity()) {
-                if (value instanceof byte[]) {
-                    String sql = "UPDATE " + info.getTable(id) + " SET " + info.getSQLColumn(null, column) + " = ? WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(id);
-                    if (info.isLoggable(logger, 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 (info.isLoggable(logger, 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();
-            if (cache == null) return c;
-            T rs = cache.update(id, info.getAttribute(column), value);
-            if (cacheListener != null) cacheListener.updateCache(info.getType(), rs);
-            return c >= 0 ? c : (rs == null ? 0 : 1);
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        } finally {
-            if (conn != null) closeSQLConnection(conn);
-        }
-    }
-
-    /**
-     * 根据主键值更新对象的column对应的值， 必须是Entity Class
-     *
-     * @param <T>    Entity类的泛型
-     * @param clazz  Entity类
-     * @param column 过滤字段名
-     * @param value  过滤字段值
-     * @param node   过滤node 不能为null
-     *
-     * @return 更新的数据条数
-     */
-    @Override
-    public <T> int updateColumn(Class<T> clazz, String column, Serializable value, FilterNode node) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        if (info.isVirtualEntity()) {
-            return updateColumn(null, info, column, value, node);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return updateColumn(conn, info, column, value, node);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final String column, final Serializable value, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, column, value, node), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int updateColumn(Connection conn, final EntityInfo<T> info, String column, final Serializable value, FilterNode node) {
-        try {
-            int c = -1;
-            if (!info.isVirtualEntity()) {
-                Map<Class, String> joinTabalis = node.getJoinTabalis();
-                CharSequence join = node.createSQLJoin(this, true, joinTabalis, new HashSet<>(), info);
-                CharSequence where = node.createSQLExpress(info, joinTabalis);
-
-                StringBuilder join1 = null;
-                StringBuilder join2 = null;
-                if (join != null) {
-                    String joinstr = join.toString();
-                    join1 = multisplit('[', ']', ",", new StringBuilder(), joinstr, 0);
-                    join2 = multisplit('{', '}', " AND ", new StringBuilder(), joinstr, 0);
-                }
-                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 (info.isLoggable(logger, 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 (info.isLoggable(logger, 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();
-            if (cache == null) return c;
-            T[] rs = cache.update(info.getAttribute(column), value, node);
-            if (cacheListener != null) cacheListener.updateCache(info.getType(), rs);
-            return c >= 0 ? c : (rs == null ? 0 : rs.length);
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        } finally {
-            if (conn != null) closeSQLConnection(conn);
-        }
-    }
-
-    /**
-     * 根据主键值更新对象的多个column对应的值， 必须是Entity Class
-     *
-     * @param <T>    Entity类的泛型
-     * @param clazz  Entity类
-     * @param id     主键值
-     * @param values 字段值
-     *
-     * @return 更新的数据条数
-     */
-    @Override
-    public <T> int updateColumn(final Class<T> clazz, final Serializable id, final ColumnValue... values) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        if (info.isVirtualEntity()) {
-            return updateColumn(null, info, id, values);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return updateColumn(conn, info, id, values);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final Serializable id, final ColumnValue... values) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, id, values), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int updateColumn(final Connection conn, final EntityInfo<T> info, final Serializable id, final ColumnValue... values) {
-        if (values == null || values.length < 1) return -1;
-        try {
-            StringBuilder setsql = new StringBuilder();
-            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) throw new RuntimeException(info.getType() + " cannot found column " + col.getColumn());
-                attrs.add(attr);
-                cols.add(col);
-                if (!virtual) {
-                    if (setsql.length() > 0) setsql.append(", ");
-                    String c = info.getSQLColumn(null, col.getColumn());
-                    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;
-            if (!virtual) {
-                String sql = "UPDATE " + info.getTable(id) + " SET " + setsql + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(id);
-                if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + ": " + sql);
-                conn.setReadOnly(false);
-                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();
-            if (cache == null) return c;
-            T rs = cache.updateColumn(id, attrs, cols);
-            if (cacheListener != null) cacheListener.updateCache(info.getType(), rs);
-            return c >= 0 ? c : (rs == null ? 0 : 1);
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    /**
-     * 根据主键值更新对象的多个column对应的值， 必须是Entity Class
-     *
-     * @param <T>    Entity类的泛型
-     * @param clazz  Entity类
-     * @param node   过滤条件
-     * @param values 字段值
-     *
-     * @return 更新的数据条数
-     */
-    @Override
-    public <T> int updateColumn(final Class<T> clazz, final FilterNode node, final ColumnValue... values) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        if (info.isVirtualEntity()) {
-            return updateColumn(null, info, node, null, values);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return updateColumn(conn, info, node, null, values);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final FilterNode node, final ColumnValue... values) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, node, values), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    /**
-     * 根据主键值更新对象的多个column对应的值， 必须是Entity Class
-     *
-     * @param <T>     Entity类的泛型
-     * @param clazz   Entity类
-     * @param node    过滤条件
-     * @param flipper 翻页对象
-     * @param values  字段值
-     *
-     * @return 更新的数据条数
-     */
-    @Override
-    public <T> int updateColumn(final Class<T> clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        if (info.isVirtualEntity()) {
-            return updateColumn(null, info, node, flipper, values);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return updateColumn(conn, info, node, flipper, values);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, node, flipper, values), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <T> int updateColumn(final Connection conn, final EntityInfo<T> info, final FilterNode node, final Flipper flipper, final ColumnValue... values) {
-        if (values == null || values.length < 1) return -1;
-        try {
-            StringBuilder setsql = new StringBuilder();
-            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;
-                attrs.add(attr);
-                cols.add(col);
-                if (!virtual) {
-                    if (setsql.length() > 0) setsql.append(", ");
-                    String c = info.getSQLColumn("a", col.getColumn());
-                    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;
-            if (!virtual) {
-                Map<Class, String> joinTabalis = node.getJoinTabalis();
-                CharSequence join = node.createSQLJoin(this, true, joinTabalis, new HashSet<>(), info);
-                CharSequence where = node.createSQLExpress(info, joinTabalis);
-                StringBuilder join1 = null;
-                StringBuilder join2 = null;
-                if (join != null) {
-                    String joinstr = join.toString();
-                    join1 = multisplit('[', ']', ",", new StringBuilder(), joinstr, 0);
-                    join2 = multisplit('{', '}', " AND ", new StringBuilder(), joinstr, 0);
-                }
-                String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1)) + " SET " + setsql
-                    + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                    : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))))
-                    + info.createSQLOrderby(flipper);
-                if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
-                conn.setReadOnly(false);
-                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();
-            if (cache == null) return c;
-            T[] rs = cache.updateColumn(node, flipper, attrs, cols);
-            if (cacheListener != null) cacheListener.updateCache(info.getType(), rs);
-            return c >= 0 ? c : (rs == null ? 0 : rs.length);
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    @Override
-    public <T> int updateColumn(final T bean, final String... columns) {
-        return updateColumn(bean, SelectColumn.createIncludes(columns));
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final String... columns) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(bean, columns), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    @Override
-    public <T> int updateColumn(final T bean, final FilterNode node, final String... columns) {
-        return updateColumn(bean, node, SelectColumn.createIncludes(columns));
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final FilterNode node, final String... columns) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(bean, node, columns), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    @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, selects);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return updateColumns(conn, info, bean, selects);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final SelectColumn selects) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(bean, selects), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <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 (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, 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;
-            if (!virtual) {
-                String sql = "UPDATE " + info.getTable(id) + " SET " + setsql + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(id);
-                if (info.isLoggable(logger, Level.FINEST)) logger.finest(bean.getClass().getSimpleName() + ": " + sql);
-                conn.setReadOnly(false);
-                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();
-            if (cache == null) return c;
-            T rs = cache.update(bean, attrs);
-            if (cacheListener != null) cacheListener.updateCache(clazz, rs);
-            return c >= 0 ? c : (rs == null ? 0 : 1);
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    @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, selects);
-        }
-        Connection conn = createWriteSQLConnection();
-        try {
-            return updateColumns(conn, info, bean, node, selects);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final FilterNode node, final SelectColumn selects) {
-        return CompletableFuture.supplyAsync(() -> updateColumn(bean, node, selects), getExecutor()).whenComplete(futureCompleteConsumer);
-    }
-
-    protected <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 (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", 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;
-            if (!virtual) {
-                Map<Class, String> joinTabalis = node.getJoinTabalis();
-                CharSequence join = node.createSQLJoin(this, true, joinTabalis, new HashSet<>(), info);
-                CharSequence where = node.createSQLExpress(info, joinTabalis);
-                StringBuilder join1 = null;
-                StringBuilder join2 = null;
-                if (join != null) {
-                    String joinstr = join.toString();
-                    join1 = multisplit('[', ']', ",", new StringBuilder(), joinstr, 0);
-                    join2 = multisplit('{', '}', " AND ", new StringBuilder(), joinstr, 0);
-                }
-                String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1)) + " SET " + setsql
-                    + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                    : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
-                if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
-                conn.setReadOnly(false);
-                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();
-            if (cache == null) return c;
-            T[] rs = cache.update(bean, attrs, node);
-            if (cacheListener != null) cacheListener.updateCache(clazz, rs);
-            return c >= 0 ? c : (rs == null ? 0 : rs.length);
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    @Override
-    public <T> int updateCache(Class<T> clazz, T... values) {
-        if (values.length == 0) return 0;
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache == null) return -1;
-        int c = 0;
-        for (T value : values) {
-            c += cache.update(value);
-        }
-        return c;
-    }
-
-    public <T> int reloadCache(Class<T> clazz, Serializable... ids) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache == null) return -1;
-        String column = info.getPrimary().field();
-        int c = 0;
-        for (Serializable id : ids) {
-            Sheet<T> sheet = querySheet(false, true, clazz, null, FLIPPER_ONE, FilterNode.create(column, id));
-            T value = sheet.isEmpty() ? null : sheet.list().get(0);
-            if (value != null) c += cache.update(value);
-        }
-        return c;
-    }
-
-    //-----------------------getNumberResultAsync-----------------------------
-    @Override
-    public Number getNumberResult(final Class entityClass, final FilterFunc func, final String column) {
-        return getNumberResult(entityClass, func, null, column, (FilterNode) null);
-    }
-
-    @Override
-    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final String column) {
-        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, column), getExecutor());
-    }
-
-    @Override
-    public Number getNumberResult(final Class entityClass, final FilterFunc func, final String column, FilterBean bean) {
-        return getNumberResult(entityClass, func, null, column, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final String column, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, column, bean), getExecutor());
-    }
-
-    @Override
-    public Number getNumberResult(final Class entityClass, final FilterFunc func, final String column, final FilterNode node) {
-        return getNumberResult(entityClass, func, null, column, node);
-    }
-
-    @Override
-    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final String column, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, column, node), getExecutor());
-    }
-
-    @Override
-    public Number getNumberResult(final Class entityClass, final FilterFunc func, final Number defVal, final String column) {
-        return getNumberResult(entityClass, func, defVal, column, (FilterNode) null);
-    }
-
-    @Override
-    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final Number defVal, final String column) {
-        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, defVal, column), getExecutor());
-    }
-
-    @Override
-    public Number getNumberResult(final Class entityClass, final FilterFunc func, final Number defVal, final String column, FilterBean bean) {
-        return getNumberResult(entityClass, func, defVal, column, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, defVal, column, bean), getExecutor());
-    }
-
-    @Override
-    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, defVal, column, node), getExecutor());
-    }
-
-    @Override
-    public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterFuncColumn... columns) {
-        return getNumberMap(entityClass, (FilterNode) null, columns);
-    }
-
-    @Override
-    public <N extends Number> CompletableFuture<Map<String, N>> getNumberMapAsync(final Class entityClass, final FilterFuncColumn... columns) {
-        return CompletableFuture.supplyAsync(() -> getNumberMap(entityClass, columns), getExecutor());
-    }
-
-    @Override
-    public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterBean bean, final FilterFuncColumn... columns) {
-        return getNumberMap(entityClass, FilterNodeBean.createFilterNode(bean), columns);
-    }
-
-    @Override
-    public <N extends Number> CompletableFuture<Map<String, N>> getNumberMapAsync(final Class entityClass, final FilterBean bean, final FilterFuncColumn... columns) {
-        return CompletableFuture.supplyAsync(() -> getNumberMap(entityClass, bean, columns), getExecutor());
-    }
-
-    @Override
-    public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterNode node, final FilterFuncColumn... columns) {
-        if (columns == null || columns.length == 0) return new HashMap<>();
-        final EntityInfo info = loadEntityInfo(entityClass);
-        final Connection conn = createReadSQLConnection();
-        final Map map = new HashMap<>();
-        try {
-            final EntityCache cache = info.getCache();
-            if (cache != null && (info.isVirtualEntity() || cache.isFullLoaded())) {
-                if (node == null || node.isCacheUseable(this)) {
-                    for (FilterFuncColumn ffc : columns) {
-                        for (String col : ffc.cols()) {
-                            map.put(ffc.col(col), cache.getNumberResult(ffc.func, ffc.defvalue, col, node));
-                        }
-                    }
-                    return map;
-                }
-            }
-            final Map<Class, String> joinTabalis = node == null ? null : node.getJoinTabalis();
-            final Set<String> haset = new HashSet<>();
-            final CharSequence join = node == null ? null : node.createSQLJoin(this, false, joinTabalis, haset, info);
-            final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
-            StringBuilder sb = new StringBuilder();
-            for (FilterFuncColumn ffc : columns) {
-                for (String col : ffc.cols()) {
-                    if (sb.length() > 0) sb.append(", ");
-                    sb.append(ffc.func.getColumn((col == null || col.isEmpty() ? "*" : info.getSQLColumn("a", col))));
-                }
-            }
-            final String sql = "SELECT " + sb + " FROM " + info.getTable(node) + " a"
-                + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-            if (info.isLoggable(logger, Level.FINEST)) logger.finest(entityClass.getSimpleName() + " single sql=" + sql);
-            conn.setReadOnly(true);
-            final PreparedStatement prestmt = conn.prepareStatement(sql);
-
-            ResultSet set = prestmt.executeQuery();
-            if (set.next()) {
-                int index = 0;
-                for (FilterFuncColumn ffc : columns) {
-                    for (String col : ffc.cols()) {
-                        Object o = set.getObject(++index);
-                        Number rs = ffc.defvalue;
-                        if (o != null) rs = (Number) o;
-                        map.put(ffc.col(col), rs);
-                    }
-                }
-            }
-            set.close();
-            prestmt.close();
-            return map;
-        } catch (SQLException e) {
-            if (info.tableStrategy != null && info.isTableNotExist(e)) {
-                for (FilterFuncColumn ffc : columns) {
-                    for (String col : ffc.cols()) {
-                        map.put(ffc.col(col), ffc.defvalue);
-                    }
-                }
-                return map;
-            }
-            throw new RuntimeException(e);
-        } finally {
-            if (conn != null) closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <N extends Number> CompletableFuture<Map<String, N>> getNumberMapAsync(final Class entityClass, final FilterNode node, final FilterFuncColumn... columns) {
-        return CompletableFuture.supplyAsync(() -> getNumberMap(entityClass, node, columns), getExecutor());
-    }
-
-    @Override
-    public Number getNumberResult(final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node) {
-        final EntityInfo info = loadEntityInfo(entityClass);
-        final Connection conn = createReadSQLConnection();
-        try {
-            final EntityCache cache = info.getCache();
-            if (cache != null && (info.isVirtualEntity() || cache.isFullLoaded())) {
-                if (node == null || node.isCacheUseable(this)) {
-                    return cache.getNumberResult(func, defVal, column, node);
-                }
-            }
-            final Map<Class, String> joinTabalis = node == null ? null : node.getJoinTabalis();
-            final Set<String> haset = new HashSet<>();
-            final CharSequence join = node == null ? null : node.createSQLJoin(this, false, joinTabalis, haset, info);
-            final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
-            final String sql = "SELECT " + func.getColumn((column == null || column.isEmpty() ? "*" : info.getSQLColumn("a", column))) + " FROM " + info.getTable(node) + " a"
-                + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-            if (info.isLoggable(logger, Level.FINEST)) logger.finest(entityClass.getSimpleName() + " single sql=" + sql);
-            conn.setReadOnly(true);
-            final PreparedStatement prestmt = conn.prepareStatement(sql);
-            Number rs = defVal;
-            ResultSet set = prestmt.executeQuery();
-            if (set.next()) {
-                Object o = set.getObject(1);
-                if (o != null) rs = (Number) o;
-            }
-            set.close();
-            prestmt.close();
-            return rs;
-        } catch (SQLException e) {
-            if (info.tableStrategy != null && info.isTableNotExist(e)) return defVal;
-            throw new RuntimeException(e);
-        } finally {
-            if (conn != null) closeSQLConnection(conn);
-        }
-    }
-
-    //-----------------------queryColumnMapAsync-----------------------------
-    @Override
-    public <T, K extends Serializable, N extends Number> Map<K, N> queryColumnMap(final Class<T> entityClass, final String keyColumn, FilterFunc func, final String funcColumn) {
-        return queryColumnMap(entityClass, keyColumn, func, funcColumn, (FilterNode) null);
-    }
-
-    @Override
-    public <T, K extends Serializable, N extends Number> CompletableFuture<Map<K, N>> queryColumnMapAsync(final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn) {
-        return CompletableFuture.supplyAsync(() -> queryColumnMap(entityClass, keyColumn, func, funcColumn), getExecutor());
-    }
-
-    @Override
-    public <T, K extends Serializable, N extends Number> Map<K, N> queryColumnMap(final Class<T> entityClass, final String keyColumn, FilterFunc func, final String funcColumn, FilterBean bean) {
-        return queryColumnMap(entityClass, keyColumn, func, funcColumn, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T, K extends Serializable, N extends Number> CompletableFuture<Map<K, N>> queryColumnMapAsync(final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryColumnMap(entityClass, keyColumn, func, funcColumn, bean), getExecutor());
-    }
-
-    @Override
-    public <T, K extends Serializable, N extends Number> Map<K, N> queryColumnMap(final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, FilterNode node) {
-        final EntityInfo info = loadEntityInfo(entityClass);
-        final Connection conn = createReadSQLConnection();
-        try {
-            final EntityCache cache = info.getCache();
-            if (cache != null && (info.isVirtualEntity() || cache.isFullLoaded())) {
-                if (node == null || node.isCacheUseable(this)) {
-                    return cache.queryColumnMap(keyColumn, func, funcColumn, node);
-                }
-            }
-            final String sqlkey = info.getSQLColumn(null, keyColumn);
-            final Map<Class, String> joinTabalis = node == null ? null : node.getJoinTabalis();
-            final Set<String> haset = new HashSet<>();
-            final CharSequence join = node == null ? null : node.createSQLJoin(this, false, joinTabalis, haset, info);
-            final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
-            final String sql = "SELECT a." + sqlkey + ", " + func.getColumn((funcColumn == null || funcColumn.isEmpty() ? "*" : info.getSQLColumn("a", funcColumn)))
-                + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where)) + " GROUP BY a." + sqlkey;
-            if (info.isLoggable(logger, Level.FINEST)) logger.finest(entityClass.getSimpleName() + " single sql=" + sql);
-            conn.setReadOnly(true);
-            final PreparedStatement prestmt = conn.prepareStatement(sql);
-            Map<K, N> rs = new LinkedHashMap<>();
-            ResultSet set = prestmt.executeQuery();
-            ResultSetMetaData rsd = set.getMetaData();
-            boolean smallint = rsd.getColumnType(1) == Types.SMALLINT;
-            while (set.next()) {
-                rs.put((K) (smallint ? set.getShort(1) : set.getObject(1)), (N) set.getObject(2));
-            }
-            set.close();
-            prestmt.close();
-            return rs;
-        } catch (SQLException e) {
-            if (info.tableStrategy != null && info.isTableNotExist(e)) return new LinkedHashMap<>();
-            throw new RuntimeException(e);
-        } finally {
-            if (conn != null) closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T, K extends Serializable, N extends Number> CompletableFuture<Map<K, N>> queryColumnMapAsync(final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryColumnMap(entityClass, keyColumn, func, funcColumn, node), getExecutor());
-    }
-
-    //-----------------------findAsync----------------------------
-    /**
-     * 根据主键获取对象
-     *
-     * @param <T>   Entity类的泛型
-     * @param clazz Entity类
-     * @param pk    主键值
-     *
-     * @return Entity对象
-     */
-    @Override
-    public <T> T find(Class<T> clazz, Serializable pk) {
-        return find(clazz, (SelectColumn) null, pk);
-    }
-
-    @Override
-    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final Serializable pk) {
-        return CompletableFuture.supplyAsync(() -> find(clazz, pk), getExecutor());
-    }
-
-    @Override
-    public <T> T find(Class<T> clazz, final SelectColumn selects, Serializable pk) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache != null) {
-            T rs = cache.find(selects, pk);
-            if (cache.isFullLoaded() || rs != null) return rs;
-        }
-
-        final Connection conn = createReadSQLConnection();
-        try {
-            final SelectColumn sels = selects;
-            final String sql = "SELECT " + info.getQueryColumns(null, selects) + " FROM " + info.getTable(pk) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(pk);
-            if (info.isLoggable(logger, Level.FINEST)) logger.finest(clazz.getSimpleName() + " find sql=" + sql);
-            conn.setReadOnly(true);
-            final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            ps.setFetchSize(1);
-            final ResultSet set = ps.executeQuery();
-            T rs = set.next() ? info.getValue(sels, set) : null;
-            set.close();
-            ps.close();
-            return rs;
-        } catch (SQLException sex) {
-            if (info.tableStrategy != null && info.isTableNotExist(sex)) return null;
-            throw new RuntimeException(sex);
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final SelectColumn selects, final Serializable pk) {
-        return CompletableFuture.supplyAsync(() -> find(clazz, selects, pk), getExecutor());
-    }
-
-    @Override
-    public <T> T find(final Class<T> clazz, final String column, final Serializable key) {
-        return find(clazz, null, FilterNode.create(column, key));
-    }
-
-    @Override
-    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final String column, final Serializable key) {
-        return CompletableFuture.supplyAsync(() -> find(clazz, column, key), getExecutor());
-    }
-
-    @Override
-    public <T> T find(final Class<T> clazz, final FilterBean bean) {
-        return find(clazz, null, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> find(clazz, bean), getExecutor());
-    }
-
-    @Override
-    public <T> T find(final Class<T> clazz, final FilterNode node) {
-        return find(clazz, null, node);
-    }
-
-    @Override
-    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> find(clazz, node), getExecutor());
-    }
-
-    @Override
-    public <T> T find(final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
-        return find(clazz, selects, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> find(clazz, selects, bean), getExecutor());
-    }
-
-    @Override
-    public <T> T find(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache != null && cache.isFullLoaded() && (node == null || node.isCacheUseable(this))) return cache.find(selects, node);
-
-        final Connection conn = createReadSQLConnection();
-        try {
-            final SelectColumn sels = selects;
-            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);
-            final String sql = "SELECT " + info.getQueryColumns("a", selects) + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-            if (info.isLoggable(logger, Level.FINEST)) logger.finest(clazz.getSimpleName() + " find sql=" + sql);
-            conn.setReadOnly(true);
-            final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            ps.setFetchSize(1);
-            final ResultSet set = ps.executeQuery();
-            T rs = set.next() ? info.getValue(sels, set) : null;
-            set.close();
-            ps.close();
-            return rs;
-        } catch (SQLException se) {
-            if (info.tableStrategy != null && info.isTableNotExist(se)) return null;
-            throw new RuntimeException(se);
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> find(clazz, selects, node), getExecutor());
-    }
-
-    @Override
-    public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable pk) {
-        return findColumn(clazz, column, null, pk);
-    }
-
-    @Override
-    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final Serializable pk) {
-        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, pk), getExecutor());
-    }
-
-    @Override
-    public <T> Serializable findColumn(final Class<T> clazz, final String column, final FilterBean bean) {
-        return findColumn(clazz, column, null, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, bean), getExecutor());
-    }
-
-    @Override
-    public <T> Serializable findColumn(final Class<T> clazz, final String column, final FilterNode node) {
-        return findColumn(clazz, column, null, node);
-    }
-
-    @Override
-    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, node), getExecutor());
-    }
-
-    @Override
-    public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final Serializable pk) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache != null) {
-            Serializable val = cache.findColumn(column, defValue, pk);
-            if (cache.isFullLoaded() || val != null) return val;
-        }
-
-        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 (info.isLoggable(logger, Level.FINEST)) logger.finest(clazz.getSimpleName() + " find sql=" + sql);
-            conn.setReadOnly(true);
-            final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            ps.setFetchSize(1);
-            final ResultSet set = ps.executeQuery();
-            Serializable val = defValue;
-            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;
-        } catch (SQLException sex) {
-            if (info.tableStrategy != null && info.isTableNotExist(sex)) return defValue;
-            throw new RuntimeException(sex);
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final Serializable defValue, final Serializable pk) {
-        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, defValue, pk), getExecutor());
-    }
-
-    @Override
-    public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final FilterBean bean) {
-        return findColumn(clazz, column, defValue, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final Serializable defValue, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, defValue, bean), getExecutor());
-    }
-
-    @Override
-    public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final FilterNode node) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache != null && cache.isFullLoaded() && (node == null || node.isCacheUseable(this))) return cache.findColumn(column, defValue, node);
-
-        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);
-            final String sql = "SELECT " + info.getSQLColumn("a", column) + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-            if (info.isLoggable(logger, Level.FINEST)) logger.finest(clazz.getSimpleName() + " find sql=" + sql);
-            conn.setReadOnly(true);
-            final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            ps.setFetchSize(1);
-            final ResultSet set = ps.executeQuery();
-            Serializable val = defValue;
-            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;
-        } catch (SQLException se) {
-            if (info.tableStrategy != null && info.isTableNotExist(se)) return defValue;
-            throw new RuntimeException(se);
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final Serializable defValue, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, defValue, node), getExecutor());
-    }
-
-    @Override
-    public <T> boolean exists(Class<T> clazz, Serializable pk) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache != null) {
-            boolean rs = cache.exists(pk);
-            if (rs || cache.isFullLoaded()) return rs;
-        }
-
-        final Connection conn = createReadSQLConnection();
-        final boolean log = info.isLoggable(logger, Level.FINEST);
-        String logstr = null;
-        try {
-            final String sql = "SELECT COUNT(*) FROM " + info.getTable(pk) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(pk);
-            if (log) logstr = clazz.getSimpleName() + " exists sql=" + sql;
-            conn.setReadOnly(true);
-            final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            final ResultSet set = ps.executeQuery();
-            boolean rs = set.next() ? (set.getInt(1) > 0) : false;
-            set.close();
-            ps.close();
-            if (log) logstr = clazz.getSimpleName() + " exists (" + rs + ") sql=" + sql;
-            return rs;
-        } catch (SQLException se) {
-            if (info.tableStrategy != null && info.isTableNotExist(se)) return false;
-            throw new RuntimeException(se);
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        } finally {
-            if (logstr != null) logger.finest(logstr);
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Boolean> existsAsync(final Class<T> clazz, final Serializable pk) {
-        return CompletableFuture.supplyAsync(() -> exists(clazz, pk), getExecutor());
-    }
-
-    @Override
-    public <T> boolean exists(final Class<T> clazz, final FilterBean bean) {
-        return exists(clazz, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T> CompletableFuture<Boolean> existsAsync(final Class<T> clazz, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> exists(clazz, bean), getExecutor());
-    }
-
-    @Override
-    public <T> boolean exists(final Class<T> clazz, final FilterNode node) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (cache != null && cache.isFullLoaded() && (node == null || node.isCacheUseable(this))) return cache.exists(node);
-
-        final Connection conn = createReadSQLConnection();
-        final boolean log = info.isLoggable(logger, Level.FINEST);
-        String logstr = null;
-        try {
-            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);
-            final String sql = "SELECT COUNT(" + info.getPrimarySQLColumn("a") + ") FROM " + info.getTable(node) + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-            if (log) logstr = clazz.getSimpleName() + " exists sql=" + sql;
-            conn.setReadOnly(true);
-            final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            final ResultSet set = ps.executeQuery();
-            boolean rs = set.next() ? (set.getInt(1) > 0) : false;
-            set.close();
-            ps.close();
-            if (log) logstr = clazz.getSimpleName() + " exists (" + rs + ") sql=" + sql;
-            return rs;
-        } catch (SQLException se) {
-            if (info.tableStrategy != null && info.isTableNotExist(se)) return false;
-            throw new RuntimeException(se);
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        } finally {
-            if (logstr != null) logger.finest(logstr);
-            closeSQLConnection(conn);
-        }
-    }
-
-    @Override
-    public <T> CompletableFuture<Boolean> existsAsync(final Class<T> clazz, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> exists(clazz, node), getExecutor());
-    }
-
-    //-----------------------list set----------------------------
-    @Override
-    public <T, V extends Serializable> HashSet<V> queryColumnSet(final String selectedColumn, Class<T> clazz, String column, Serializable key) {
-        return queryColumnSet(selectedColumn, clazz, FilterNode.create(column, key));
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<HashSet<V>> queryColumnSetAsync(final String selectedColumn, Class<T> clazz, String column, Serializable key) {
-        return CompletableFuture.supplyAsync(() -> queryColumnSet(selectedColumn, clazz, column, key), getExecutor());
-    }
-
-    @Override
-    public <T, V extends Serializable> HashSet<V> queryColumnSet(final String selectedColumn, final Class<T> clazz, final FilterBean bean) {
-        return new LinkedHashSet<>(queryColumnList(selectedColumn, clazz, bean));
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<HashSet<V>> queryColumnSetAsync(final String selectedColumn, final Class<T> clazz, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryColumnSet(selectedColumn, clazz, bean), getExecutor());
-    }
-
-    @Override
-    public <T, V extends Serializable> HashSet<V> queryColumnSet(String selectedColumn, Class<T> clazz, FilterNode node) {
-        return new LinkedHashSet<>(queryColumnList(selectedColumn, clazz, node));
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<HashSet<V>> queryColumnSetAsync(final String selectedColumn, final Class<T> clazz, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryColumnSet(selectedColumn, clazz, node), getExecutor());
-    }
-
-    @Override
-    public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key) {
-        return queryColumnList(selectedColumn, clazz, FilterNode.create(column, key));
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key) {
-        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, column, key), getExecutor());
-    }
-
-    @Override
-    public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final FilterBean bean) {
-        return queryColumnList(selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, bean), getExecutor());
-    }
-
-    @Override
-    public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final FilterNode node) {
-        return (List<V>) queryColumnSheet(false, selectedColumn, clazz, null, node).list(true);
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, node), getExecutor());
-    }
-
-    @Override
-    public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
-        return queryColumnList(selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, flipper, bean), getExecutor());
-    }
-
-    @Override
-    public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        return (List<V>) queryColumnSheet(false, selectedColumn, clazz, flipper, node).list(true);
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, flipper, node), getExecutor());
-    }
-
-    /**
-     * 根据指定参数查询对象某个字段的集合
-     * <p>
-     * @param <T>            Entity类的泛型
-     * @param <V>            字段值的类型
-     * @param selectedColumn 字段名
-     * @param clazz          Entity类
-     * @param flipper        翻页对象
-     * @param bean           过滤Bean
-     *
-     * @return 字段集合
-     */
-    @Override
-    public <T, V extends Serializable> Sheet<V> queryColumnSheet(final String selectedColumn, Class<T> clazz, final Flipper flipper, final FilterBean bean) {
-        return queryColumnSheet(selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<Sheet<V>> queryColumnSheetAsync(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryColumnSheet(selectedColumn, clazz, flipper, bean), getExecutor());
-    }
-
-    @Override
-    public <T, V extends Serializable> Sheet<V> queryColumnSheet(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        return queryColumnSheet(true, selectedColumn, clazz, flipper, node);
-    }
-
-    @Override
-    public <T, V extends Serializable> CompletableFuture<Sheet<V>> queryColumnSheetAsync(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryColumnSheet(selectedColumn, clazz, flipper, node), getExecutor());
-    }
-
-    protected <T, V extends Serializable> Sheet<V> queryColumnSheet(final boolean needtotal, final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        Sheet<T> sheet = querySheet(true, needtotal, clazz, SelectColumn.createIncludes(selectedColumn), flipper, node);
-        final Sheet<V> rs = new Sheet<>();
-        if (sheet.isEmpty()) return rs;
-        rs.setTotal(sheet.getTotal());
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final Attribute<T, V> selected = (Attribute<T, V>) info.getAttribute(selectedColumn);
-        final List<V> list = new ArrayList<>();
-        for (T t : sheet.getRows()) {
-            list.add(selected.get(t));
-        }
-        rs.setRows(list);
-        return rs;
-    }
-
-    /**
-     * 查询符合过滤条件记录的Map集合, 主键值为key   <br>
-     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
-     *
-     * @param <K>       主键泛型
-     * @param <T>       Entity泛型
-     * @param clazz     Entity类
-     * @param keyStream 主键Stream
-     *
-     * @return Entity的集合
-     */
-    @Override
-    public <K extends Serializable, T> Map<K, T> queryMap(final Class<T> clazz, final Stream<K> keyStream) {
-        return queryMap(clazz, null, keyStream);
-    }
-
-    @Override
-    public <K extends Serializable, T> CompletableFuture<Map<K, T>> queryMapAsync(final Class<T> clazz, final Stream<K> keyStream) {
-        return CompletableFuture.supplyAsync(() -> queryMap(clazz, null, keyStream), getExecutor());
-    }
-
-    /**
-     * 查询符合过滤条件记录的Map集合, 主键值为key   <br>
-     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
-     *
-     * @param <K>   主键泛型
-     * @param <T>   Entity泛型
-     * @param clazz Entity类
-     * @param bean  FilterBean
-     *
-     * @return Entity的集合
-     */
-    @Override
-    public <K extends Serializable, T> Map<K, T> queryMap(final Class<T> clazz, final FilterBean bean) {
-        return queryMap(clazz, null, bean);
-    }
-
-    @Override
-    public <K extends Serializable, T> CompletableFuture<Map<K, T>> queryMapAsync(final Class<T> clazz, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryMap(clazz, null, bean), getExecutor());
-    }
-
-    /**
-     * 查询符合过滤条件记录的Map集合, 主键值为key   <br>
-     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
-     *
-     * @param <K>   主键泛型
-     * @param <T>   Entity泛型
-     * @param clazz Entity类
-     * @param node  FilterNode
-     *
-     * @return Entity的集合
-     */
-    @Override
-    public <K extends Serializable, T> Map<K, T> queryMap(final Class<T> clazz, final FilterNode node) {
-        return queryMap(clazz, null, node);
-    }
-
-    @Override
-    public <K extends Serializable, T> CompletableFuture<Map<K, T>> queryMapAsync(final Class<T> clazz, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryMap(clazz, null, node), getExecutor());
-    }
-
-    /**
-     * 查询符合过滤条件记录的Map集合, 主键值为key   <br>
-     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
-     *
-     * @param <K>       主键泛型
-     * @param <T>       Entity泛型
-     * @param clazz     Entity类
-     * @param selects   指定字段
-     * @param keyStream 主键Stream
-     *
-     * @return Entity的集合
-     */
-    @Override
-    public <K extends Serializable, T> Map<K, T> queryMap(final Class<T> clazz, final SelectColumn selects, final Stream<K> keyStream) {
-        if (keyStream == null) return new LinkedHashMap<>();
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final ArrayList<K> ids = new ArrayList<>();
-        keyStream.forEach(k -> ids.add(k));
-        final Attribute<T, Serializable> primary = info.primary;
-        List<T> rs = queryList(clazz, FilterNode.create(primary.field(), ids));
-        Map<K, T> map = new LinkedHashMap<>();
-        if (rs.isEmpty()) return new LinkedHashMap<>();
-        for (T item : rs) {
-            map.put((K) primary.get(item), item);
-        }
-        return map;
-    }
-
-    @Override
-    public <K extends Serializable, T> CompletableFuture<Map<K, T>> queryMapAsync(final Class<T> clazz, final SelectColumn selects, final Stream<K> keyStream) {
-        return CompletableFuture.supplyAsync(() -> queryMap(clazz, selects, keyStream), getExecutor());
-    }
-
-    /**
-     * 查询符合过滤条件记录的Map集合, 主键值为key   <br>
-     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
-     *
-     * @param <K>     主键泛型
-     * @param <T>     Entity泛型
-     * @param clazz   Entity类
-     * @param selects 指定字段
-     * @param bean    FilterBean
-     *
-     * @return Entity的集合
-     */
-    @Override
-    public <K extends Serializable, T> Map<K, T> queryMap(final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
-        return queryMap(clazz, selects, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <K extends Serializable, T> CompletableFuture<Map<K, T>> queryMapAsync(final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryMap(clazz, selects, FilterNodeBean.createFilterNode(bean)), getExecutor());
-    }
-
-    /**
-     * 查询符合过滤条件记录的Map集合, 主键值为key   <br>
-     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
-     *
-     * @param <K>     主键泛型
-     * @param <T>     Entity泛型
-     * @param clazz   Entity类
-     * @param selects 指定字段
-     * @param node    FilterNode
-     *
-     * @return Entity的集合
-     */
-    @Override
-    public <K extends Serializable, T> Map<K, T> queryMap(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final Attribute<T, Serializable> primary = info.primary;
-        List<T> rs = queryList(clazz, selects, node);
-        Map<K, T> map = new LinkedHashMap<>();
-        if (rs.isEmpty()) return new LinkedHashMap<>();
-        for (T item : rs) {
-            map.put((K) primary.get(item), item);
-        }
-        return map;
-    }
-
-    @Override
-    public <K extends Serializable, T> CompletableFuture<Map<K, T>> queryMapAsync(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryMap(clazz, selects, node), getExecutor());
-    }
-
-    /**
-     * 根据指定字段值查询对象集合
-     *
-     * @param <T>    Entity类的泛型
-     * @param clazz  Entity类
-     * @param column 过滤字段名
-     * @param key    过滤字段值
-     *
-     * @return Entity对象的集合
-     */
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final String column, final Serializable key) {
-        return queryList(clazz, FilterNode.create(column, key));
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final String column, final Serializable key) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, column, key), getExecutor());
-    }
-
-    /**
-     * 根据过滤对象FilterBean查询对象集合
-     *
-     * @param <T>   Entity类的泛型
-     * @param clazz Entity类
-     * @param bean  过滤Bean
-     *
-     * @return Entity对象集合
-     */
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final FilterBean bean) {
-        return queryList(clazz, (SelectColumn) null, bean);
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, bean), getExecutor());
-    }
-
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final FilterNode node) {
-        return queryList(clazz, (SelectColumn) null, node);
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, node), getExecutor());
-    }
-
-    /**
-     * 根据过滤对象FilterBean查询对象集合， 对象只填充或排除SelectField指定的字段
-     *
-     * @param <T>     Entity类的泛型
-     * @param clazz   Entity类
-     * @param selects 收集的字段
-     * @param bean    过滤Bean
-     *
-     * @return Entity对象的集合
-     */
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
-        return queryList(clazz, selects, (Flipper) null, bean);
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, SelectColumn selects, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, selects, bean), getExecutor());
-    }
-
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
-        return queryList(clazz, selects, (Flipper) null, node);
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, SelectColumn selects, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, selects, node), getExecutor());
-    }
-
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final String column, final Serializable key) {
-        return queryList(clazz, flipper, FilterNode.create(column, key));
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final Flipper flipper, final String column, final Serializable key) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, flipper, column, key), getExecutor());
-    }
-
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
-        return queryList(clazz, null, flipper, bean);
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, flipper, bean), getExecutor());
-    }
-
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        return queryList(clazz, null, flipper, node);
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, flipper, node), getExecutor());
-    }
-
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
-        return querySheet(true, false, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean)).list(true);
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, selects, flipper, bean), getExecutor());
-    }
-
-    @Override
-    public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
-        return querySheet(true, false, clazz, selects, flipper, node).list(true);
-    }
-
-    @Override
-    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> queryList(clazz, selects, flipper, node), getExecutor());
-    }
-
-    //-----------------------sheet----------------------------
-    /**
-     * 根据过滤对象FilterBean和翻页对象Flipper查询一页的数据
-     *
-     * @param <T>     Entity类的泛型
-     * @param clazz   Entity类
-     * @param flipper 翻页对象
-     * @param bean    过滤Bean
-     *
-     * @return Entity对象的集合
-     */
-    @Override
-    public <T> Sheet<T> querySheet(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
-        return querySheet(clazz, null, flipper, bean);
-    }
-
-    @Override
-    public <T> CompletableFuture<Sheet<T>> querySheetAsync(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> querySheet(clazz, flipper, bean), getExecutor());
-    }
-
-    @Override
-    public <T> Sheet<T> querySheet(final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        return querySheet(clazz, null, flipper, node);
-    }
-
-    @Override
-    public <T> CompletableFuture<Sheet<T>> querySheetAsync(final Class<T> clazz, final Flipper flipper, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> querySheet(clazz, flipper, node), getExecutor());
-    }
-
-    /**
-     * 根据过滤对象FilterBean和翻页对象Flipper查询一页的数据， 对象只填充或排除SelectField指定的字段
-     *
-     * @param <T>     Entity类的泛型
-     * @param clazz   Entity类
-     * @param selects 收集的字段集合
-     * @param flipper 翻页对象
-     * @param bean    过滤Bean
-     *
-     * @return Entity对象的集合
-     */
-    @Override
-    public <T> Sheet<T> querySheet(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
-        return querySheet(true, true, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
-    }
-
-    @Override
-    public <T> CompletableFuture<Sheet<T>> querySheetAsync(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
-        return CompletableFuture.supplyAsync(() -> querySheet(clazz, selects, flipper, bean), getExecutor());
-    }
-
-    @Override
-    public <T> Sheet<T> querySheet(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
-        return querySheet(true, true, clazz, selects, flipper, node);
-    }
-
-    @Override
-    public <T> CompletableFuture<Sheet<T>> querySheetAsync(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
-        return CompletableFuture.supplyAsync(() -> querySheet(clazz, selects, flipper, node), getExecutor());
-    }
-
-    protected <T> Sheet<T> querySheet(final boolean readcache, final boolean needtotal, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
-        final EntityInfo<T> info = loadEntityInfo(clazz);
-        final EntityCache<T> cache = info.getCache();
-        if (readcache && cache != null && cache.isFullLoaded()) {
-            if (node == null || node.isCacheUseable(this)) {
-                if (info.isLoggable(logger, Level.FINEST)) logger.finest(clazz.getSimpleName() + " cache query predicate = " + (node == null ? null : node.createPredicate(cache)));
-                return cache.querySheet(needtotal, selects, flipper, node);
-            }
-        }
-        final Connection conn = createReadSQLConnection();
-        try {
-            final SelectColumn sels = selects;
-            final List<T> list = new ArrayList();
-            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);
-            final String sql = "SELECT " + info.getQueryColumns("a", selects) + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join)
-                + ((where == null || where.length() == 0) ? "" : (" WHERE " + where)) + info.createSQLOrderby(flipper);
-            if (info.isLoggable(logger, Level.FINEST)) {
-                logger.finest(clazz.getSimpleName() + " query sql=" + sql + (flipper == null || flipper.getLimit() < 1 ? "" : (" LIMIT " + flipper.getOffset() + "," + flipper.getLimit())));
-            }
-            conn.setReadOnly(true);
-            final PreparedStatement ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            if (flipper != null && flipper.getLimit() > 0) ps.setFetchSize(flipper.getLimit());
-            final ResultSet set = ps.executeQuery();
-            if (flipper != null && flipper.getOffset() > 0) set.absolute(flipper.getOffset());
-            final int limit = flipper == null || flipper.getLimit() < 1 ? Integer.MAX_VALUE : flipper.getLimit();
-            int i = 0;
-            while (set.next()) {
-                i++;
-                list.add(info.getValue(sels, set));
-                if (limit <= i) break;
-            }
-            long total = list.size();
-            if (needtotal && flipper != null) {
-                set.last();
-                total = set.getRow();
-            }
-            set.close();
-            ps.close();
-            return new Sheet<>(total, list);
-        } catch (SQLException se) {
-            if (info.tableStrategy != null && info.isTableNotExist(se)) return new Sheet<>();
-            throw new RuntimeException(se);
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    protected static StringBuilder multisplit(char ch1, char ch2, String split, StringBuilder sb, String str, int from) {
-        if (str == null) return sb;
-        int pos1 = str.indexOf(ch1, from);
-        if (pos1 < 0) return sb;
-        int pos2 = str.indexOf(ch2, from);
-        if (pos2 < 0) return sb;
-        if (sb.length() > 0) sb.append(split);
-        sb.append(str.substring(pos1 + 1, pos2));
-        return multisplit(ch1, ch2, split, sb, str, pos2 + 1);
-    }
-
-    protected int[] directExecute(final Connection conn, String... sqls) {
-        if (sqls.length == 0) return new int[0];
-        try {
-            conn.setReadOnly(false);
-            final Statement stmt = conn.createStatement();
-            final int[] rs = new int[sqls.length];
-            int i = -1;
-            for (String sql : sqls) {
-                rs[++i] = stmt.execute(sql) ? 1 : 0;
-            }
-            stmt.close();
-            return rs;
-        } catch (SQLException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    /**
-     * 直接本地执行SQL语句进行增删改操作，远程模式不可用   <br>
-     * 通常用于复杂的更新操作   <br>
-     *
-     * @param sqls SQL语句
-     *
-     * @return 结果数组
-     */
-    @Local
-    public int[] directExecute(String... sqls) {
-        Connection conn = createWriteSQLConnection();
-        try {
-            return directExecute(conn, sqls);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-    /**
-     * 直接本地执行SQL语句进行查询，远程模式不可用   <br>
-     * 通常用于复杂的关联查询   <br>
-     *
-     * @param sql      SQL语句
-     * @param consumer 回调函数
-     */
-    @Local
-    public void directQuery(String sql, Consumer<ResultSet> consumer) {
-        final Connection conn = createReadSQLConnection();
-        try {
-            if (logger.isLoggable(Level.FINEST)) logger.finest("direct query sql=" + sql);
-            conn.setReadOnly(true);
-            final Statement statement = conn.createStatement();
-            //final PreparedStatement statement = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
-            final ResultSet set = statement.executeQuery(sql);// ps.executeQuery();
-            consumer.accept(set);
-            set.close();
-            statement.close();
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        } finally {
-            closeSQLConnection(conn);
-        }
-    }
-
-}
diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java
index c6551cc93..6057ca182 100644
--- a/src/org/redkale/source/DataJdbcSource.java
+++ b/src/org/redkale/source/DataJdbcSource.java
@@ -142,7 +142,8 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
                             sb.append(ch);
                         }
                     }
-                    logger.finest(info.getType().getSimpleName() + " insert sql=" + sb.toString().replaceAll("(\r|\n)", "\\n"));
+                    String debugsql = sb.toString();
+                    if (info.isLoggable(logger, Level.FINEST, debugsql)) logger.finest(info.getType().getSimpleName() + " insert sql=" + debugsql.replaceAll("(\r|\n)", "\\n"));
                 }
             } //打印结束
             return CompletableFuture.completedFuture(c);
@@ -190,7 +191,7 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
             conn.setReadOnly(false);
             conn.setAutoCommit(true);
             sql += ((flipper == null || flipper.getLimit() < 1) ? "" : (" LIMIT " + flipper.getLimit()));
-            if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql);
+            if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql);
             final Statement stmt = conn.createStatement();
             int c = stmt.executeUpdate(sql);
             stmt.close();
@@ -251,7 +252,8 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
                             sb.append(ch);
                         }
                     }
-                    logger.finest(info.getType().getSimpleName() + " update sql=" + sb.toString().replaceAll("(\r|\n)", "\\n"));
+                    String debugsql = sb.toString();
+                    if (info.isLoggable(logger, Level.FINEST, debugsql)) logger.finest(info.getType().getSimpleName() + " update sql=" + debugsql.replaceAll("(\r|\n)", "\\n"));
                 } //打印结束
             }
             int[] pc = prestmt.executeBatch();
@@ -289,7 +291,7 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
                 prestmt.close();
                 return CompletableFuture.completedFuture(c);
             } else {
-                if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
+                if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
                 final Statement stmt = conn.createStatement();
                 int c = stmt.executeUpdate(sql);
                 stmt.close();
@@ -453,7 +455,7 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
             boolean rs = set.next() ? (set.getInt(1) > 0) : false;
             set.close();
             ps.close();
-            if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " exists (" + rs + ") sql=" + sql);
+            if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " exists (" + rs + ") sql=" + sql);
             return CompletableFuture.completedFuture(rs);
         } catch (SQLException e) {
             if (info.tableStrategy != null && info.isTableNotExist(e)) return CompletableFuture.completedFuture(false);
@@ -479,7 +481,7 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
             if ("mysql".equals(this.readPool.getDbtype()) || "postgresql".equals(this.readPool.getDbtype())) {
                 final String listsql = "SELECT " + info.getQueryColumns("a", selects) + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join)
                     + ((where == null || where.length() == 0) ? "" : (" WHERE " + where)) + createSQLOrderby(info, flipper) + (flipper == null || flipper.getLimit() < 1 ? "" : (" LIMIT " + flipper.getLimit() + " OFFSET " + flipper.getOffset()));
-                if (info.isLoggable(logger, Level.FINEST)) {
+                if (info.isLoggable(logger, Level.FINEST, listsql)) {
                     logger.finest(info.getType().getSimpleName() + " query sql=" + listsql);
                 }
                 PreparedStatement ps = conn.prepareStatement(listsql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
@@ -501,7 +503,7 @@ public class DataJdbcSource extends DataSqlSource<Connection> {
             }
             final String sql = "SELECT " + info.getQueryColumns("a", selects) + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join)
                 + ((where == null || where.length() == 0) ? "" : (" WHERE " + where)) + info.createSQLOrderby(flipper);
-            if (info.isLoggable(logger, Level.FINEST)) {
+            if (info.isLoggable(logger, Level.FINEST, sql)) {
                 logger.finest(info.getType().getSimpleName() + " query sql=" + sql + (flipper == null || flipper.getLimit() < 1 ? "" : (" LIMIT " + flipper.getLimit() + " OFFSET " + flipper.getOffset())));
             }
             conn.setReadOnly(true);
diff --git a/src/org/redkale/source/DataSqlSource.java b/src/org/redkale/source/DataSqlSource.java
index 0fea738ec..61b3c0ebd 100644
--- a/src/org/redkale/source/DataSqlSource.java
+++ b/src/org/redkale/source/DataSqlSource.java
@@ -479,7 +479,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
             sql += FilterNode.formatToString(ids[i]);
         }
         sql += ")";
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql);
         return deleteDB(info, null, sql);
     }
 
@@ -498,7 +498,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
         String sql = "DELETE " + ("mysql".equals(this.readPool.getDbtype()) ? "a" : "") + " FROM " + info.getTable(node) + " a" + (join1 == null ? "" : (", " + join1))
             + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
             : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2)))) + info.createSQLOrderby(flipper);
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " delete sql="
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " delete sql="
                 + (sql + ((flipper == null || flipper.getLimit() < 1) ? "" : (" LIMIT " + flipper.getLimit()))));
         return deleteDB(info, flipper, sql);
     }
@@ -1205,7 +1205,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
         }
         final String sql = "SELECT " + sb + " FROM " + info.getTable(node) + " a"
             + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " getnumbermap sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " getnumbermap sql=" + sql);
         return getNumberMapDB(info, sql, columns);
     }
 
@@ -1292,7 +1292,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
         final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
         final String sql = "SELECT " + func.getColumn((column == null || column.isEmpty() ? "*" : info.getSQLColumn("a", column))) + " FROM " + info.getTable(node) + " a"
             + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(entityClass.getSimpleName() + " getnumberresult sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(entityClass.getSimpleName() + " getnumberresult sql=" + sql);
         return getNumberResultDB(info, sql, defVal, column);
     }
 
@@ -1350,7 +1350,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
         final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
         final String sql = "SELECT a." + sqlkey + ", " + func.getColumn((funcColumn == null || funcColumn.isEmpty() ? "*" : info.getSQLColumn("a", funcColumn)))
             + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where)) + " GROUP BY a." + sqlkey;
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " querycolumnmap sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " querycolumnmap sql=" + sql);
         return queryColumnMapDB(info, sql, keyColumn);
     }
 
@@ -1399,7 +1399,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
 
     protected <T> CompletableFuture<T> findCompose(final EntityInfo<T> info, final SelectColumn selects, Serializable pk) {
         final String sql = "SELECT " + info.getQueryColumns(null, selects) + " FROM " + info.getTable(pk) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(pk);
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " find sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " find sql=" + sql);
         return findDB(info, sql, true, selects);
     }
 
@@ -1467,7 +1467,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
         final CharSequence join = node == null ? null : node.createSQLJoin(this, false, joinTabalis, new HashSet<>(), info);
         final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
         final String sql = "SELECT " + info.getQueryColumns("a", selects) + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " find sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " find sql=" + sql);
         return findDB(info, sql, false, selects);
     }
 
@@ -1536,7 +1536,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
 
     protected <T> CompletableFuture<Serializable> findColumnCompose(final EntityInfo<T> info, String column, final Serializable defValue, final Serializable pk) {
         final String sql = "SELECT " + info.getSQLColumn(null, column) + " FROM " + info.getTable(pk) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(pk);
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " find sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " find sql=" + sql);
         return findColumnDB(info, sql, true, column, defValue);
     }
 
@@ -1568,7 +1568,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
         final CharSequence join = node == null ? null : node.createSQLJoin(this, false, joinTabalis, new HashSet<>(), info);
         final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
         final String sql = "SELECT " + info.getSQLColumn("a", column) + " FROM " + info.getTable(node) + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " find sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " find sql=" + sql);
         return findColumnDB(info, sql, false, column, defValue);
     }
 
@@ -1598,7 +1598,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
 
     protected <T> CompletableFuture<Boolean> existsCompose(final EntityInfo<T> info, Serializable pk) {
         final String sql = "SELECT COUNT(*) FROM " + info.getTable(pk) + " WHERE " + info.getPrimarySQLColumn() + " = " + FilterNode.formatToString(pk);
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " exists sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " exists sql=" + sql);
         return existsDB(info, sql, true);
     }
 
@@ -1640,7 +1640,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
         final CharSequence join = node == null ? null : node.createSQLJoin(this, false, joinTabalis, new HashSet<>(), info);
         final CharSequence where = node == null ? null : node.createSQLExpress(info, joinTabalis);
         final String sql = "SELECT COUNT(" + info.getPrimarySQLColumn("a") + ") FROM " + info.getTable(node) + " a" + (join == null ? "" : join) + ((where == null || where.length() == 0) ? "" : (" WHERE " + where));
-        if (info.isLoggable(logger, Level.FINEST)) logger.finest(info.getType().getSimpleName() + " exists sql=" + sql);
+        if (info.isLoggable(logger, Level.FINEST, sql)) logger.finest(info.getType().getSimpleName() + " exists sql=" + sql);
         return existsDB(info, sql, false);
     }
 
@@ -2173,7 +2173,7 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
         final EntityCache<T> cache = info.getCache();
         if (readcache && cache != null && cache.isFullLoaded()) {
             if (node == null || node.isCacheUseable(this)) {
-                if (info.isLoggable(logger, Level.FINEST)) logger.finest(clazz.getSimpleName() + " cache query predicate = " + (node == null ? null : node.createPredicate(cache)));
+                if (info.isLoggable(logger, Level.FINEST, " cache query predicate = ")) logger.finest(clazz.getSimpleName() + " cache query predicate = " + (node == null ? null : node.createPredicate(cache)));
                 return CompletableFuture.completedFuture(cache.querySheet(needtotal, selects, flipper, node));
             }
         }
diff --git a/src/org/redkale/source/EntityInfo.java b/src/org/redkale/source/EntityInfo.java
index efc270f7f..cb3850c5d 100644
--- a/src/org/redkale/source/EntityInfo.java
+++ b/src/org/redkale/source/EntityInfo.java
@@ -138,6 +138,9 @@ public final class EntityInfo<T> {
     //日志级别，从LogLevel获取
     private final int logLevel;
 
+    //日志控制
+    private final Map<Integer, String[]> excludeLogLevels;
+
     //Flipper.sort转换成以ORDER BY开头SQL的缓存
     private final Map<String, String> sortOrderbySqls = new ConcurrentHashMap<>();
 
@@ -210,6 +213,26 @@ public final class EntityInfo<T> {
 
         LogLevel ll = type.getAnnotation(LogLevel.class);
         this.logLevel = ll == null ? Integer.MIN_VALUE : Level.parse(ll.value()).intValue();
+        Map<Integer, HashSet<String>> logmap = new HashMap<>();
+        for (LogExcludeLevel lel : type.getAnnotationsByType(LogExcludeLevel.class)) {
+            for (String onelevel : lel.levels()) {
+                int level = Level.parse(onelevel).intValue();
+                HashSet<String> set = logmap.get(level);
+                if (set == null) {
+                    set = new HashSet<>();
+                    logmap.put(level, set);
+                }
+                for (String key : lel.keys()) {
+                    set.add(key);
+                }
+            }
+        }
+        if (logmap.isEmpty()) {
+            this.excludeLogLevels = null;
+        } else {
+            this.excludeLogLevels = new HashMap<>();
+            logmap.forEach((l, set) -> excludeLogLevels.put(l, set.toArray(new String[set.size()])));
+        }
         //---------------------------------------------
         Table t = type.getAnnotation(Table.class);
         if (type.getAnnotation(VirtualEntity.class) != null) {
@@ -874,6 +897,26 @@ public final class EntityInfo<T> {
         return logger.isLoggable(l) && l.intValue() >= this.logLevel;
     }
 
+    /**
+     * 判断日志级别
+     *
+     * @param logger Logger
+     * @param l      Level
+     * @param str    String
+     *
+     * @return boolean
+     */
+    public boolean isLoggable(Logger logger, Level l, String str) {
+        boolean rs = logger.isLoggable(l) && l.intValue() >= this.logLevel;
+        if (this.excludeLogLevels == null || !rs || str == null) return rs;
+        String[] keys = this.excludeLogLevels.get(l.intValue());
+        if (keys == null) return rs;
+        for (String key : keys) {
+            if (str.contains(key)) return false;
+        }
+        return rs;
+    }
+
     /**
      * 将字段值序列化为可SQL的字符串
      *
diff --git a/src/org/redkale/util/LogExcludeLevel.java b/src/org/redkale/util/LogExcludeLevel.java
new file mode 100644
index 000000000..25c022932
--- /dev/null
+++ b/src/org/redkale/util/LogExcludeLevel.java
@@ -0,0 +1,46 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package org.redkale.util;
+
+import java.lang.annotation.*;
+import static java.lang.annotation.ElementType.TYPE;
+import static java.lang.annotation.RetentionPolicy.RUNTIME;
+
+/**
+ * 等于level日志级别且包含keys字符串的日志才会被排除 <br>
+ *
+ * <blockquote><pre>
+ * &#64;LogExcludeLevel(levels = {"FINEST"}, keys = {"SET username ="})
+ * public class UserRecord {
+ *      public int userid;
+ *      public String username = "";
+ * }
+ *
+ * 这样当调用DataSource对UserRecord对象进行操作时，拼接的SQL语句含"SET username ="字样的都会在FINEST日志级别过滤掉
+ * </pre></blockquote>
+ * <p>
+ * 详情见: https://redkale.org
+ *
+ * @author zhangjx
+ */
+@Documented
+@Target({TYPE})
+@Retention(RUNTIME)
+@Repeatable(LogExcludeLevel.LogExcludeLevels.class)
+public @interface LogExcludeLevel {
+
+    String[] levels();
+
+    String[] keys();
+
+    @Documented
+    @Target({TYPE})
+    @Retention(RUNTIME)
+    @interface LogExcludeLevels {
+
+        LogExcludeLevel[] value();
+    }
+}