diff --git a/src/org/redkale/service/DataSourceService.java b/src/org/redkale/service/DataSourceService.java
index 3010980f1..e13f43153 100644
--- a/src/org/redkale/service/DataSourceService.java
+++ b/src/org/redkale/service/DataSourceService.java
@@ -33,336 +33,719 @@ public class DataSourceService implements DataSource, Service, AutoCloseable {
         source.insert(values);
     }
 
+    @Override
+    public <T> void insert(final AsyncHandler<Void, T[]> handler, @RpcAttachment @RpcCall(DataCallArrayAttribute.class) final T... values) {
+        source.insert(values);
+        if (handler != null) handler.completed(null, values);
+    }
+
     @Override
     public <T> int delete(T... values) {
         return source.delete(values);
     }
 
+    @Override
+    public <T> void delete(final AsyncHandler<Integer, T[]> handler, @RpcAttachment final T... values) {
+        int rs = source.delete(values);
+        if (handler != null) handler.completed(rs, values);
+    }
+
     @Override
     public <T> int delete(final Class<T> clazz, final Serializable... ids) {
         return source.delete(clazz, ids);
     }
 
+    @Override
+    public <T> void delete(final AsyncHandler<Integer, Serializable[]> handler, final Class<T> clazz, @RpcAttachment final Serializable... ids) {
+        int rs = source.delete(clazz, ids);
+        if (handler != null) handler.completed(rs, ids);
+    }
+
     @Override
     public <T> int delete(final Class<T> clazz, FilterNode node) {
         return source.delete(clazz, node);
     }
 
+    @Override
+    public <T> void delete(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node) {
+        int rs = source.delete(clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int delete(final Class<T> clazz, final Flipper flipper, FilterNode node) {
         return source.delete(clazz, flipper, node);
     }
 
+    @Override
+    public <T> void delete(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final Flipper flipper, @RpcAttachment FilterNode node) {
+        int rs = source.delete(clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int update(T... values) {
         return source.update(values);
     }
 
+    @Override
+    public <T> void update(final AsyncHandler<Integer, T[]> handler, @RpcAttachment final T... values) {
+        int rs = source.update(values);
+        if (handler != null) handler.completed(rs, values);
+    }
+
     @Override
     public <T> int updateColumn(final Class<T> clazz, final Serializable id, final String column, final Serializable value) {
         return source.updateColumn(clazz, id, column, value);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, Serializable> handler, final Class<T> clazz, @RpcAttachment final Serializable id, final String column, final Serializable value) {
+        int rs = source.updateColumn(clazz, id, column, value);
+        if (handler != null) handler.completed(rs, id);
+    }
+
     @Override
     public <T> int updateColumn(final Class<T> clazz, final String column, final Serializable value, final FilterNode node) {
         return source.updateColumn(clazz, column, value, node);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final String column, final Serializable value, @RpcAttachment final FilterNode node) {
+        int rs = source.updateColumn(clazz, column, value, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int updateColumn(final Class<T> clazz, final Serializable id, final ColumnValue... values) {
         return source.updateColumn(clazz, id, values);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, Serializable> handler, final Class<T> clazz, @RpcAttachment final Serializable id, final ColumnValue... values) {
+        int rs = source.updateColumn(clazz, id, values);
+        if (handler != null) handler.completed(rs, id);
+    }
+
     @Override
     public <T> int updateColumn(final Class<T> clazz, final FilterNode node, final ColumnValue... values) {
         return source.updateColumn(clazz, node, values);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node, final ColumnValue... values) {
+        int rs = source.updateColumn(clazz, node, values);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int updateColumn(final Class<T> clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values) {
         return source.updateColumn(clazz, node, flipper, values);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node, final Flipper flipper, final ColumnValue... values) {
+        int rs = source.updateColumn(clazz, node, flipper, values);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int updateColumn(T bean, final String... columns) {
         return source.updateColumn(bean, columns);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, T> handler, @RpcAttachment final T bean, final String... columns) {
+        int rs = source.updateColumn(bean, columns);
+        if (handler != null) handler.completed(rs, bean);
+    }
+
     @Override
     public <T> int updateColumn(T bean, final FilterNode node, final String... columns) {
         return source.updateColumn(bean, node, columns);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final T bean, @RpcAttachment final FilterNode node, final String... columns) {
+        int rs = source.updateColumn(bean, node, columns);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int updateColumn(T bean, final SelectColumn selects) {
         return source.updateColumn(bean, selects);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, T> handler, @RpcAttachment final T bean, final SelectColumn selects) {
+        int rs = source.updateColumn(bean, selects);
+        if (handler != null) handler.completed(rs, bean);
+    }
+
     @Override
     public <T> int updateColumn(T bean, final FilterNode node, final SelectColumn selects) {
         return source.updateColumn(bean, node, selects);
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final T bean, @RpcAttachment final FilterNode node, final SelectColumn selects) {
+        int rs = source.updateColumn(bean, node, selects);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public Number getNumberResult(final Class entityClass, FilterFunc func, final String column) {
         return source.getNumberResult(entityClass, func, column);
     }
 
+    @Override
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, @RpcAttachment final String column) {
+        Number rs = source.getNumberResult(entityClass, func, column);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     @Override
     public final Number getNumberResult(final Class entityClass, FilterFunc func, final String column, FilterBean bean) {
         return getNumberResult(entityClass, func, column, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final void getNumberResult(final AsyncHandler<Number, FilterNode> handler, final Class entityClass, final FilterFunc func, final String column, final FilterBean bean) {
+        getNumberResult(handler, entityClass, func, column, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public Number getNumberResult(final Class entityClass, FilterFunc func, final String column, FilterNode node) {
         return source.getNumberResult(entityClass, func, column, node);
     }
 
+    @Override
+    public void getNumberResult(final AsyncHandler<Number, FilterNode> handler, final Class entityClass, final FilterFunc func, final String column, @RpcAttachment final FilterNode node) {
+        Number rs = source.getNumberResult(entityClass, func, column, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public Number getNumberResult(final Class entityClass, FilterFunc func, final Number defVal, final String column) {
         return source.getNumberResult(entityClass, func, defVal, column);
     }
 
+    @Override
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column) {
+        Number rs = source.getNumberResult(entityClass, func, defVal, column);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     @Override
     public final Number getNumberResult(final Class entityClass, FilterFunc func, final Number defVal, final String column, FilterBean bean) {
         return getNumberResult(entityClass, func, defVal, column, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column, final FilterBean bean) {
+        getNumberResult(handler, entityClass, func, defVal, column, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public Number getNumberResult(final Class entityClass, FilterFunc func, final Number defVal, final String column, FilterNode node) {
         return source.getNumberResult(entityClass, func, defVal, column, node);
     }
 
+    @Override
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column, final FilterNode node) {
+        Number rs = source.getNumberResult(entityClass, func, defVal, column, node);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     @Override
     public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterFuncColumn... columns) {
         return source.getNumberMap(entityClass, columns);
     }
 
+    @Override
+    public <N extends Number> void getNumberMap(final AsyncHandler<Map<String, N>, FilterFuncColumn[]> handler, final Class entityClass, @RpcAttachment final FilterFuncColumn... columns) {
+        Map<String, N> rs = source.getNumberMap(entityClass, columns);
+        if (handler != null) handler.completed(rs, columns);
+    }
+
     @Override
     public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterBean bean, final FilterFuncColumn... columns) {
         return source.getNumberMap(entityClass, bean, columns);
     }
 
+    @Override
+    public final <N extends Number> void getNumberMap(final AsyncHandler<Map<String, N>, FilterNode> handler, final Class entityClass, @RpcAttachment final FilterBean bean, final FilterFuncColumn... columns) {
+        getNumberMap(handler, entityClass, FilterNodeBean.createFilterNode(bean), columns);
+    }
+
     @Override
     public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterNode node, final FilterFuncColumn... columns) {
         return source.getNumberMap(entityClass, node, columns);
     }
 
+    @Override
+    public <N extends Number> void getNumberMap(final AsyncHandler<Map<String, N>, FilterNode> handler, final Class entityClass, @RpcAttachment final FilterNode node, final FilterFuncColumn... columns) {
+        Map<String, N> rs = source.getNumberMap(entityClass, node, columns);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @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 source.queryColumnMap(entityClass, keyColumn, func, funcColumn);
     }
 
+    @Override
+    public <T, K extends Serializable, N extends Number> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn) {
+        Map<K, N> rs = source.queryColumnMap(entityClass, keyColumn, func, funcColumn);
+        if (handler != null) handler.completed(rs, keyColumn);
+    }
+
     @Override
     public final <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 final <T, K extends Serializable, N extends Number> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean) {
+        queryColumnMap(handler, entityClass, keyColumn, func, funcColumn, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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, FilterNode node) {
         return source.queryColumnMap(entityClass, keyColumn, func, funcColumn, node);
     }
 
+    @Override
+    public <T, K extends Serializable, N extends Number> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node) {
+        Map<K, N> rs = source.queryColumnMap(entityClass, keyColumn, func, funcColumn, node);
+        if (handler != null) handler.completed(rs, keyColumn);
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, final Serializable pk) {
         return source.find(clazz, pk);
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, @RpcAttachment final Serializable pk) {
+        T rs = source.find(clazz, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, SelectColumn selects, final Serializable pk) {
         return source.find(clazz, selects, pk);
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, SelectColumn selects, @RpcAttachment final Serializable pk) {
+        T rs = source.find(clazz, selects, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, final String column, final Serializable key) {
         return source.find(clazz, column, key);
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, final String column, @RpcAttachment final Serializable key) {
+        T rs = source.find(clazz, column, key);
+        if (handler != null) handler.completed(rs, key);
+    }
+
     @Override
     public final <T> T find(final Class<T> clazz, FilterBean bean) {
         return find(clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final FilterBean bean) {
+        find(handler, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, FilterNode node) {
         return source.find(clazz, node);
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node) {
+        T rs = source.find(clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public final <T> T find(final Class<T> clazz, final SelectColumn selects, FilterBean bean) {
         return find(clazz, selects, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
+        find(handler, clazz, selects, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
         return source.find(clazz, selects, node);
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, @RpcAttachment final FilterNode node) {
+        T rs = source.find(clazz, selects, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable pk) {
         return source.findColumn(clazz, column, pk);
     }
 
+    @Override
+    public <T> void findColumn(final AsyncHandler<Serializable, Serializable> handler, final Class<T> clazz, final String column, @RpcAttachment final Serializable pk) {
+        Serializable rs = source.findColumn(clazz, column, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final FilterBean bean) {
         return source.findColumn(clazz, column, bean);
     }
 
+    @Override
+    public final <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final FilterBean bean) {
+        findColumn(handler, clazz, column, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final FilterNode node) {
         return source.findColumn(clazz, column, node);
     }
 
+    @Override
+    public <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, @RpcAttachment final FilterNode node) {
+        Serializable rs = source.findColumn(clazz, column, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final Serializable pk) {
         return source.findColumn(clazz, column, defValue, pk);
     }
 
+    @Override
+    public <T> void findColumn(final AsyncHandler<Serializable, Serializable> handler, final Class<T> clazz, final String column, final Serializable defValue, @RpcAttachment final Serializable pk) {
+        Serializable rs = source.findColumn(clazz, column, defValue, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final FilterBean bean) {
         return source.findColumn(clazz, column, defValue, bean);
     }
 
+    @Override
+    public final <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final Serializable defValue, final FilterBean bean) {
+        findColumn(handler, clazz, column, defValue, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final FilterNode node) {
         return source.findColumn(clazz, column, defValue, node);
     }
 
+    @Override
+    public <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final Serializable defValue, @RpcAttachment final FilterNode node) {
+        Serializable rs = source.findColumn(clazz, column, defValue, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> boolean exists(final Class<T> clazz, final Serializable pk) {
         return source.exists(clazz, pk);
     }
 
+    @Override
+    public <T> void exists(final AsyncHandler<Boolean, Serializable> handler, final Class<T> clazz, @RpcAttachment final Serializable pk) {
+        boolean rs = source.exists(clazz, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @Override
     public final <T> boolean exists(final Class<T> clazz, FilterBean bean) {
         return exists(clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void exists(final AsyncHandler<Boolean, FilterNode> handler, final Class<T> clazz, final FilterBean bean) {
+        exists(handler, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> boolean exists(final Class<T> clazz, FilterNode node) {
         return source.exists(clazz, node);
     }
 
+    @Override
+    public <T> void exists(final AsyncHandler<Boolean, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node) {
+        boolean rs = source.exists(clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T, V extends Serializable> HashSet<V> queryColumnSet(String selectedColumn, Class<T> clazz, final String column, final Serializable key) {
         return source.queryColumnSet(selectedColumn, clazz, column, key);
     }
 
+    @Override
+    public <T, V extends Serializable> void queryColumnSet(final AsyncHandler<HashSet<V>, String> handler, final String selectedColumn, final Class<T> clazz, @RpcAttachment final String column, final Serializable key) {
+        HashSet<V> rs = source.queryColumnSet(selectedColumn, clazz, column, key);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     @Override
     public final <T, V extends Serializable> HashSet<V> queryColumnSet(String selectedColumn, Class<T> clazz, FilterBean bean) {
         return queryColumnSet(selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T, V extends Serializable> void queryColumnSet(final AsyncHandler<HashSet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final FilterBean bean) {
+        queryColumnSet(handler, selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T, V extends Serializable> HashSet<V> queryColumnSet(String selectedColumn, Class<T> clazz, FilterNode node) {
         return source.queryColumnSet(selectedColumn, clazz, node);
     }
 
+    @Override
+    public <T, V extends Serializable> void queryColumnSet(final AsyncHandler<HashSet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, @RpcAttachment final FilterNode node) {
+        HashSet<V> rs = source.queryColumnSet(selectedColumn, clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T, V extends Serializable> List<V> queryColumnList(String selectedColumn, Class<T> clazz, final String column, final Serializable key) {
         return source.queryColumnList(selectedColumn, clazz, column, key);
     }
 
+    @Override
+    public <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, Serializable> handler, final String selectedColumn, final Class<T> clazz, final String column, @RpcAttachment final Serializable key) {
+        List<V> rs = source.queryColumnList(selectedColumn, clazz, column, key);
+        if (handler != null) handler.completed(rs, key);
+    }
+
     @Override
     public final <T, V extends Serializable> List<V> queryColumnList(String selectedColumn, Class<T> clazz, FilterBean bean) {
         return queryColumnList(selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, String selectedColumn, Class<T> clazz, FilterBean bean) {
+        queryColumnList(handler, selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T, V extends Serializable> List<V> queryColumnList(String selectedColumn, Class<T> clazz, FilterNode node) {
         return source.queryColumnList(selectedColumn, clazz, node);
     }
 
+    @Override
+    public <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, @RpcAttachment final FilterNode node) {
+        List<V> rs = source.queryColumnList(selectedColumn, clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public final <T, V extends Serializable> List<V> queryColumnList(String selectedColumn, Class<T> clazz, Flipper flipper, FilterBean bean) {
         return queryColumnList(selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, String selectedColumn, Class<T> clazz, Flipper flipper, FilterBean bean) {
+        queryColumnList(handler, selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T, V extends Serializable> List<V> queryColumnList(String selectedColumn, Class<T> clazz, Flipper flipper, FilterNode node) {
         return source.queryColumnList(selectedColumn, clazz, flipper, node);
     }
 
+    @Override
+    public <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, Flipper flipper, @RpcAttachment final FilterNode node) {
+        List<V> rs = source.queryColumnList(selectedColumn, clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public final <T, V extends Serializable> Sheet<V> queryColumnSheet(String selectedColumn, Class<T> clazz, Flipper flipper, FilterBean bean) {
         return queryColumnSheet(selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T, V extends Serializable> void queryColumnSheet(final AsyncHandler<Sheet<V>, FilterNode> handler, String selectedColumn, Class<T> clazz, Flipper flipper, FilterBean bean) {
+        queryColumnSheet(handler, selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T, V extends Serializable> Sheet<V> queryColumnSheet(String selectedColumn, Class<T> clazz, Flipper flipper, FilterNode node) {
         return source.queryColumnSheet(selectedColumn, clazz, flipper, node);
     }
 
+    @Override
+    public <T, V extends Serializable> void queryColumnSheet(final AsyncHandler<Sheet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final Flipper flipper, @RpcAttachment final FilterNode node) {
+        Sheet<V> rs = source.queryColumnSheet(selectedColumn, clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> List<T> queryList(final Class<T> clazz, final String column, final Serializable key) {
         return source.queryList(clazz, column, key);
     }
 
+    @Override
+    public <T> void queryList(final AsyncHandler<List<T>, Serializable> handler, final Class<T> clazz, final String column, @RpcAttachment final Serializable key) {
+        List<T> rs = source.queryList(clazz, column, key);
+        if (handler != null) handler.completed(rs, key);
+    }
+
     @Override
     public final <T> List<T> queryList(final Class<T> clazz, final FilterBean bean) {
         return queryList(clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final FilterBean bean) {
+        queryList(handler, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> List<T> queryList(final Class<T> clazz, final FilterNode node) {
         return source.queryList(clazz, node);
     }
 
+    @Override
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node) {
+        List<T> rs = source.queryList(clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public final <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
         return queryList(clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
+        queryList(handler, clazz, selects, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
         return source.queryList(clazz, selects, node);
     }
 
+    @Override
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, @RpcAttachment final FilterNode node) {
+        List<T> rs = source.queryList(clazz, selects, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final String column, final Serializable key) {
         return source.queryList(clazz, flipper, column, key);
     }
 
+    @Override
+    public <T> void queryList(final AsyncHandler<List<T>, Serializable> handler, final Class<T> clazz, final Flipper flipper, final String column, @RpcAttachment final Serializable key) {
+        List<T> rs = source.queryList(clazz, flipper, column, key);
+        if (handler != null) handler.completed(rs, key);
+    }
+
     @Override
     public final <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
         return queryList(clazz, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
+        queryList(handler, clazz, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final FilterNode node) {
         return source.queryList(clazz, flipper, node);
     }
 
+    @Override
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, @RpcAttachment final FilterNode node) {
+        List<T> rs = source.queryList(clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public final <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
         return queryList(clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
+        queryList(handler, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
         return source.queryList(clazz, selects, flipper, node);
     }
 
+    @Override
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final FilterNode node) {
+        List<T> rs = source.queryList(clazz, selects, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public final <T> Sheet<T> querySheet(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
         return querySheet(clazz, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
+        querySheet(handler, clazz, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> Sheet<T> querySheet(final Class<T> clazz, final Flipper flipper, final FilterNode node) {
         return source.querySheet(clazz, flipper, node);
     }
 
+    @Override
+    public <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, @RpcAttachment final FilterNode node) {
+        Sheet<T> rs = source.querySheet(clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public final <T> Sheet<T> querySheet(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
         return querySheet(clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
+        querySheet(handler, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> Sheet<T> querySheet(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
         return source.querySheet(clazz, selects, flipper, node);
     }
 
+    @Override
+    public <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final FilterNode node) {
+        Sheet<T> rs = source.querySheet(clazz, selects, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public void close() throws Exception {
         source.getClass().getMethod("close").invoke(source);
diff --git a/src/org/redkale/source/DataDefaultSource.java b/src/org/redkale/source/DataDefaultSource.java
index 96daad3f0..1dbed05cf 100644
--- a/src/org/redkale/source/DataDefaultSource.java
+++ b/src/org/redkale/source/DataDefaultSource.java
@@ -246,6 +246,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void insert(final AsyncHandler<Void, T[]> handler, final T... values) {
+        insert(values);
+        if (handler != null) handler.completed(null, values);
+    }
+
     private <T> void insert(final Connection conn, final EntityInfo<T> info, T... values) {
         if (values.length == 0) return;
         try {
@@ -416,6 +422,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void delete(final AsyncHandler<Integer, T[]> handler, final T... values) {
+        int rs = delete(values);
+        if (handler != null) handler.completed(rs, values);
+    }
+
     private <T> int delete(final Connection conn, final EntityInfo<T> info, T... values) {
         if (values.length == 0) return -1;
         final Attribute primary = info.getPrimary();
@@ -441,6 +453,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void delete(final AsyncHandler<Integer, Serializable[]> handler, final Class<T> clazz, final Serializable... ids) {
+        int rs = delete(clazz, ids);
+        if (handler != null) handler.completed(rs, ids);
+    }
+
     private <T> int delete(final Connection conn, final EntityInfo<T> info, Serializable... keys) {
         if (keys.length == 0) return -1;
         int c = -1;
@@ -489,6 +507,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void delete(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final FilterNode node) {
+        int rs = delete(clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int delete(Class<T> clazz, final Flipper flipper, FilterNode node) {
         final EntityInfo<T> info = loadEntityInfo(clazz);
@@ -503,6 +527,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void delete(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final Flipper flipper, FilterNode node) {
+        int rs = delete(clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     private <T> int delete(final Connection conn, final EntityInfo<T> info, final Flipper flipper, final FilterNode node) {
         int c = -1;
         try {
@@ -588,6 +618,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void update(final AsyncHandler<Integer, T[]> handler, final T... values) {
+        int rs = update(values);
+        if (handler != null) handler.completed(rs, values);
+    }
+
     private <T> int update(final Connection conn, final EntityInfo<T> info, T... values) {
         try {
             Class clazz = info.getType();
@@ -679,6 +715,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, Serializable> handler, final Class<T> clazz, final Serializable id, final String column, final Serializable value) {
+        int rs = updateColumn(clazz, id, column, value);
+        if (handler != null) handler.completed(rs, id);
+    }
+
     private <T> int updateColumn(Connection conn, final EntityInfo<T> info, Serializable id, String column, final Serializable value) {
         try {
             int c = -1;
@@ -741,6 +783,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final String column, final Serializable value, final FilterNode node) {
+        int rs = updateColumn(clazz, column, value, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     private <T> int updateColumn(Connection conn, final EntityInfo<T> info, String column, final Serializable value, FilterNode node) {
         try {
             int c = -1;
@@ -818,6 +866,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, Serializable> handler, final Class<T> clazz, final Serializable id, final ColumnValue... values) {
+        int rs = updateColumn(clazz, id, values);
+        if (handler != null) handler.completed(rs, id);
+    }
+
     private <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 {
@@ -899,6 +953,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final FilterNode node, final ColumnValue... values) {
+        int rs = updateColumn(clazz, node, values);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     /**
      * 根据主键值更新对象的多个column对应的值， 必须是Entity Class
      *
@@ -924,6 +984,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values) {
+        int rs = updateColumn(clazz, node, flipper, values);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     private <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 {
@@ -1000,6 +1066,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return updateColumn(bean, SelectColumn.createIncludes(columns));
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, T> handler, final T bean, final String... columns) {
+        int rs = updateColumn(bean, columns);
+        if (handler != null) handler.completed(rs, bean);
+    }
+
     @Override
     public <T> int updateColumn(final T bean, final SelectColumn selects) {
         final EntityInfo<T> info = loadEntityInfo((Class<T>) bean.getClass());
@@ -1014,6 +1086,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, T> handler, final T bean, final SelectColumn selects) {
+        int rs = updateColumn(bean, selects);
+        if (handler != null) handler.completed(rs, bean);
+    }
+
     private <T> int updateColumns(final Connection conn, final EntityInfo<T> info, final T bean, final SelectColumn selects) {
         if (bean == null || selects == null) return -1;
         try {
@@ -1076,6 +1154,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return updateColumn(bean, node, SelectColumn.createIncludes(columns));
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final T bean, final FilterNode node, final String... columns) {
+        int rs = updateColumn(bean, node, columns);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int updateColumn(final T bean, final FilterNode node, final SelectColumn selects) {
         final EntityInfo<T> info = loadEntityInfo((Class<T>) bean.getClass());
@@ -1090,6 +1174,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final T bean, final FilterNode node, final SelectColumn selects) {
+        int rs = updateColumn(bean, node, selects);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     private <T> int updateColumns(final Connection conn, final EntityInfo<T> info, final T bean, final FilterNode node, final SelectColumn selects) {
         if (bean == null || node == null || selects == null) return -1;
         try {
@@ -1191,36 +1281,75 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return getNumberResult(entityClass, func, null, column, (FilterNode) null);
     }
 
+    @Override
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final String column) {
+        Number rs = getNumberResult(entityClass, func, column);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     @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 final void getNumberResult(final AsyncHandler<Number, FilterNode> handler, final Class entityClass, final FilterFunc func, final String column, final FilterBean bean) {
+        getNumberResult(handler, entityClass, func, column, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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 void getNumberResult(final AsyncHandler<Number, FilterNode> handler, final Class entityClass, final FilterFunc func, final String column, final FilterNode node) {
+        Number rs = getNumberResult(entityClass, func, column, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @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 void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column) {
+        Number rs = getNumberResult(entityClass, func, defVal, column);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     @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 final void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterBean bean) {
+        getNumberResult(handler, entityClass, func, defVal, column, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void getNumberMap(final AsyncHandler<Map<String, N>, FilterFuncColumn[]> handler, final Class entityClass, final FilterFuncColumn... columns) {
+        Map<String, N> rs = getNumberMap(entityClass, columns);
+        if (handler != null) handler.completed(rs, columns);
+    }
+
     @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 final <N extends Number> void getNumberMap(final AsyncHandler<Map<String, N>, FilterNode> handler, final Class entityClass, final FilterBean bean, final FilterFuncColumn... columns) {
+        getNumberMap(handler, entityClass, FilterNodeBean.createFilterNode(bean), columns);
+    }
+
     @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<>();
@@ -1285,6 +1414,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <N extends Number> void getNumberMap(final AsyncHandler<Map<String, N>, FilterNode> handler, final Class entityClass, final FilterNode node, final FilterFuncColumn... columns) {
+        Map<String, N> rs = getNumberMap(entityClass, node, columns);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public Number getNumberResult(final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node) {
         final EntityInfo info = loadEntityInfo(entityClass);
@@ -1321,17 +1456,34 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node) {
+        Number rs = getNumberResult(entityClass, func, defVal, column, node);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     //-----------------------queryColumnMap-----------------------------
     @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> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn) {
+        Map<K, N> rs = queryColumnMap(entityClass, keyColumn, func, funcColumn);
+        if (handler != null) handler.completed(rs, keyColumn);
+    }
+
     @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 final <T, K extends Serializable, N extends Number> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean) {
+        queryColumnMap(handler, entityClass, keyColumn, func, funcColumn, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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);
@@ -1370,6 +1522,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T, K extends Serializable, N extends Number> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node) {
+        Map<K, N> rs = queryColumnMap(entityClass, keyColumn, func, funcColumn, node);
+        if (handler != null) handler.completed(rs, keyColumn);
+    }
+
     //-----------------------find----------------------------
     /**
      * 根据主键获取对象
@@ -1385,6 +1543,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return find(clazz, (SelectColumn) null, pk);
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, final Serializable pk) {
+        T rs = find(clazz, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @Override
     public <T> T find(Class<T> clazz, final SelectColumn selects, Serializable pk) {
         final EntityInfo<T> info = loadEntityInfo(clazz);
@@ -1417,26 +1581,54 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, SelectColumn selects, final Serializable pk) {
+        T rs = find(clazz, selects, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @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> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, final String column, final Serializable key) {
+        T rs = find(clazz, column, key);
+        if (handler != null) handler.completed(rs, key);
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, final FilterBean bean) {
         return find(clazz, null, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final FilterBean bean) {
+        find(handler, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, final FilterNode node) {
         return find(clazz, null, node);
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final FilterNode node) {
+        T rs = find(clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
         return find(clazz, selects, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
+        find(handler, clazz, selects, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> T find(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
         final EntityInfo<T> info = loadEntityInfo(clazz);
@@ -1469,21 +1661,44 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
+        T rs = find(clazz, selects, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable pk) {
         return findColumn(clazz, column, null, pk);
     }
 
+    @Override
+    public <T> void findColumn(final AsyncHandler<Serializable, Serializable> handler, final Class<T> clazz, final String column, final Serializable pk) {
+        Serializable rs = findColumn(clazz, column, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @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 final <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final FilterBean bean) {
+        findColumn(handler, clazz, column, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final FilterNode node) {
         return findColumn(clazz, column, null, node);
     }
 
+    @Override
+    public <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final FilterNode node) {
+        Serializable rs = findColumn(clazz, column, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final Serializable pk) {
         final EntityInfo<T> info = loadEntityInfo(clazz);
@@ -1524,11 +1739,22 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void findColumn(final AsyncHandler<Serializable, Serializable> handler, final Class<T> clazz, final String column, final Serializable defValue, final Serializable pk) {
+        Serializable rs = findColumn(clazz, column, defValue, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @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 final <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final Serializable defValue, final FilterBean bean) {
+        findColumn(handler, clazz, column, defValue, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final FilterNode node) {
         final EntityInfo<T> info = loadEntityInfo(clazz);
@@ -1569,6 +1795,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final Serializable defValue, final FilterNode node) {
+        Serializable rs = findColumn(clazz, column, defValue, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> boolean exists(Class<T> clazz, Serializable pk) {
         final EntityInfo<T> info = loadEntityInfo(clazz);
@@ -1603,11 +1835,22 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void exists(final AsyncHandler<Boolean, Serializable> handler, final Class<T> clazz, final Serializable pk) {
+        boolean rs = exists(clazz, pk);
+        if (handler != null) handler.completed(rs, pk);
+    }
+
     @Override
     public <T> boolean exists(final Class<T> clazz, final FilterBean bean) {
         return exists(clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void exists(final AsyncHandler<Boolean, FilterNode> handler, final Class<T> clazz, final FilterBean bean) {
+        exists(handler, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> boolean exists(final Class<T> clazz, final FilterNode node) {
         final EntityInfo<T> info = loadEntityInfo(clazz);
@@ -1642,47 +1885,98 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
     }
 
+    @Override
+    public <T> void exists(final AsyncHandler<Boolean, FilterNode> handler, final Class<T> clazz, final FilterNode node) {
+        boolean rs = exists(clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     //-----------------------list set----------------------------
     @Override
     public <T, V extends Serializable> HashSet<V> queryColumnSet(String selectedColumn, Class<T> clazz, String column, Serializable key) {
         return queryColumnSet(selectedColumn, clazz, FilterNode.create(column, key));
     }
 
+    @Override
+    public <T, V extends Serializable> void queryColumnSet(final AsyncHandler<HashSet<V>, String> handler, final String selectedColumn, final Class<T> clazz, final String column, final Serializable key) {
+        HashSet<V> rs = queryColumnSet(selectedColumn, clazz, column, key);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     @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 final <T, V extends Serializable> void queryColumnSet(final AsyncHandler<HashSet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final FilterBean bean) {
+        queryColumnSet(handler, selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void queryColumnSet(final AsyncHandler<HashSet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final FilterNode node) {
+        HashSet<V> rs = queryColumnSet(selectedColumn, clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @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> void queryColumnList(final AsyncHandler<List<V>, Serializable> handler, final String selectedColumn, final Class<T> clazz, final String column, final Serializable key) {
+        List<V> rs = queryColumnList(selectedColumn, clazz, column, key);
+        if (handler != null) handler.completed(rs, key);
+    }
+
     @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 final <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, String selectedColumn, Class<T> clazz, FilterBean bean) {
+        queryColumnList(handler, selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final FilterNode node) {
+        List<V> rs = queryColumnList(selectedColumn, clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @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 final <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, String selectedColumn, Class<T> clazz, Flipper flipper, FilterBean bean) {
+        queryColumnList(handler, selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, Flipper flipper, final FilterNode node) {
+        List<V> rs = queryColumnList(selectedColumn, clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     /**
      * 根据指定参数查询对象某个字段的集合
      * <p>
@@ -1700,11 +1994,22 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return queryColumnSheet(selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T, V extends Serializable> void queryColumnSheet(final AsyncHandler<Sheet<V>, FilterNode> handler, String selectedColumn, Class<T> clazz, Flipper flipper, FilterBean bean) {
+        queryColumnSheet(handler, selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void queryColumnSheet(final AsyncHandler<Sheet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
+        Sheet<V> rs = queryColumnSheet(selectedColumn, clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     private <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<>();
@@ -1735,6 +2040,12 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return queryList(clazz, FilterNode.create(column, key));
     }
 
+    @Override
+    public <T> void queryList(final AsyncHandler<List<T>, Serializable> handler, final Class<T> clazz, final String column, final Serializable key) {
+        List<T> rs = queryList(clazz, column, key);
+        if (handler != null) handler.completed(rs, key);
+    }
+
     /**
      * 根据过滤对象FilterBean查询对象集合
      *
@@ -1749,11 +2060,22 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return queryList(clazz, (SelectColumn) null, bean);
     }
 
+    @Override
+    public final <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final FilterBean bean) {
+        queryList(handler, clazz, FilterNodeBean.createFilterNode(bean));
+    }
+
     @Override
     public <T> List<T> queryList(final Class<T> clazz, final FilterNode node) {
         return queryList(clazz, (SelectColumn) null, node);
     }
 
+    @Override
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final FilterNode node) {
+        List<T> rs = queryList(clazz, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     /**
      * 根据过滤对象FilterBean查询对象集合， 对象只填充或排除SelectField指定的字段
      *
@@ -1769,36 +2091,75 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return queryList(clazz, selects, (Flipper) null, bean);
     }
 
+    @Override
+    public final <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
+        queryList(handler, clazz, selects, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
+        List<T> rs = queryList(clazz, selects, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @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> void queryList(final AsyncHandler<List<T>, Serializable> handler, final Class<T> clazz, final Flipper flipper, final String column, final Serializable key) {
+        List<T> rs = queryList(clazz, flipper, column, key);
+        if (handler != null) handler.completed(rs, key);
+    }
+
     @Override
     public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
         return queryList(clazz, null, flipper, bean);
     }
 
+    @Override
+    public final <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
+        queryList(handler, clazz, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
+        List<T> rs = queryList(clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @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 final <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
+        queryList(handler, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
+        List<T> rs = queryList(clazz, selects, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     //-----------------------sheet----------------------------
     /**
      * 根据过滤对象FilterBean和翻页对象Flipper查询一页的数据
@@ -1815,11 +2176,22 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return querySheet(clazz, null, flipper, bean);
     }
 
+    @Override
+    public final <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
+        querySheet(handler, clazz, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
+        Sheet<T> rs = querySheet(clazz, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     /**
      * 根据过滤对象FilterBean和翻页对象Flipper查询一页的数据， 对象只填充或排除SelectField指定的字段
      *
@@ -1836,11 +2208,22 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         return querySheet(true, true, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public final <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
+        querySheet(handler, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
+    }
+
     @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> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
+        Sheet<T> rs = querySheet(clazz, selects, flipper, node);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     private <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();
diff --git a/src/org/redkale/source/DataSource.java b/src/org/redkale/source/DataSource.java
index e852c9af5..9e20dbca7 100644
--- a/src/org/redkale/source/DataSource.java
+++ b/src/org/redkale/source/DataSource.java
@@ -32,6 +32,15 @@ public interface DataSource {
      */
     public <T> void insert(final T... values);
 
+    /**
+     * 新增记录， 多对象必须是同一个Entity类  <br>
+     *
+     * @param <T>     泛型
+     * @param handler 回调函数
+     * @param values  Entity对象
+     */
+    public <T> void insert(final AsyncHandler<Void, T[]> handler, final T... values);
+
     //-------------------------delete--------------------------
     /**
      * 删除指定主键值的记录， 多对象必须是同一个Entity类  <br>
@@ -44,6 +53,17 @@ public interface DataSource {
      */
     public <T> int delete(final T... values);
 
+    /**
+     * 删除指定主键值的记录， 多对象必须是同一个Entity类  <br>
+     * 等价SQL: DELETE FROM {table} WHERE {primary} IN {values.id}  <br>
+     *
+     * @param <T>     泛型
+     * @param handler 回调函数
+     * @param values  Entity对象
+     *
+     */
+    public <T> void delete(final AsyncHandler<Integer, T[]> handler, final T... values);
+
     /**
      * 删除指定主键值的记录  <br>
      * 等价SQL: DELETE FROM {table} WHERE {primary} IN {ids}  <br>
@@ -56,6 +76,18 @@ public interface DataSource {
      */
     public <T> int delete(final Class<T> clazz, final Serializable... ids);
 
+    /**
+     * 删除指定主键值的记录  <br>
+     * 等价SQL: DELETE FROM {table} WHERE {primary} IN {ids}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param ids     主键值
+     *
+     */
+    public <T> void delete(final AsyncHandler<Integer, Serializable[]> handler, final Class<T> clazz, final Serializable... ids);
+
     /**
      * 删除符合过滤条件的记录  <br>
      * 等价SQL: DELETE FROM {table} WHERE {filter node}  <br>
@@ -68,6 +100,18 @@ public interface DataSource {
      */
     public <T> int delete(final Class<T> clazz, final FilterNode node);
 
+    /**
+     * 删除符合过滤条件的记录  <br>
+     * 等价SQL: DELETE FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param node    过滤条件
+     *
+     */
+    public <T> void delete(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final FilterNode node);
+
     /**
      * 删除符合过滤条件且指定最大影响条数的记录  <br>
      * Flipper中offset字段将被忽略  <br>
@@ -82,6 +126,20 @@ public interface DataSource {
      */
     public <T> int delete(final Class<T> clazz, final Flipper flipper, final FilterNode node);
 
+    /**
+     * 删除符合过滤条件且指定最大影响条数的记录  <br>
+     * Flipper中offset字段将被忽略  <br>
+     * 等价SQL: DELETE FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param flipper 翻页对象
+     * @param node    过滤条件
+     *
+     */
+    public <T> void delete(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterNode node);
+
     //------------------------update---------------------------
     /**
      * 更新记录， 多对象必须是同一个Entity类  <br>
@@ -97,6 +155,20 @@ public interface DataSource {
      */
     public <T> int update(final T... values);
 
+    /**
+     * 更新记录， 多对象必须是同一个Entity类  <br>
+     * 等价SQL:  <br>
+     * UPDATE {table} SET column1 = value1, column2 = value2, &#183;&#183;&#183; WHERE {primary} = {id1}  <br>
+     * UPDATE {table} SET column1 = value1, column2 = value2, &#183;&#183;&#183; WHERE {primary} = {id2}  <br>
+     * &#183;&#183;&#183;  <br>
+     *
+     * @param <T>     泛型
+     * @param handler 回调函数
+     * @param values  Entity对象
+     *
+     */
+    public <T> void update(final AsyncHandler<Integer, T[]> handler, final T... values);
+
     /**
      * 更新单个记录的单个字段  <br>
      * <b>注意</b>：即使字段标记为&#064;Column(updatable=false)也会被更新   <br>
@@ -112,6 +184,21 @@ public interface DataSource {
      */
     public <T> int updateColumn(final Class<T> clazz, final Serializable id, final String column, final Serializable value);
 
+    /**
+     * 更新单个记录的单个字段  <br>
+     * <b>注意</b>：即使字段标记为&#064;Column(updatable=false)也会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column} = {value} WHERE {primary} = {id}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param id      主键
+     * @param column  待更新的字段名
+     * @param value   更新值
+     *
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, Serializable> handler, final Class<T> clazz, final Serializable id, final String column, final Serializable value);
+
     /**
      * 更新符合过滤条件记录的单个字段   <br>
      * <b>注意</b>：即使字段标记为&#064;Column(updatable=false)也会被更新   <br>
@@ -127,6 +214,21 @@ public interface DataSource {
      */
     public <T> int updateColumn(final Class<T> clazz, final String column, final Serializable value, final FilterNode node);
 
+    /**
+     * 更新符合过滤条件记录的单个字段   <br>
+     * <b>注意</b>：即使字段标记为&#064;Column(updatable=false)也会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column} = {value} WHERE {filter node}   <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param column  待更新的字段名
+     * @param value   更新值
+     * @param node    过滤条件
+     *
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final String column, final Serializable value, final FilterNode node);
+
     /**
      * 更新指定主键值记录的部分字段   <br>
      * 字段赋值操作选项见 ColumnExpress   <br>
@@ -141,6 +243,20 @@ public interface DataSource {
      */
     public <T> int updateColumn(final Class<T> clazz, final Serializable id, final ColumnValue... values);
 
+    /**
+     * 更新指定主键值记录的部分字段   <br>
+     * 字段赋值操作选项见 ColumnExpress   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, &#183;&#183;&#183; WHERE {filter node}   <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param id      主键
+     * @param values  更新字段
+     *
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, Serializable> handler, final Class<T> clazz, final Serializable id, final ColumnValue... values);
+
     /**
      * 更新符合过滤条件记录的部分字段   <br>
      * 字段赋值操作选项见 ColumnExpress   <br>
@@ -156,6 +272,21 @@ public interface DataSource {
      */
     public <T> int updateColumn(final Class<T> clazz, final FilterNode node, final ColumnValue... values);
 
+    /**
+     * 更新符合过滤条件记录的部分字段   <br>
+     * 字段赋值操作选项见 ColumnExpress   <br>
+     * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, &#183;&#183;&#183; WHERE {filter node}   <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param node    过滤条件
+     * @param values  更新字段
+     *
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final FilterNode node, final ColumnValue... values);
+
     /**
      * 更新符合过滤条件的记录的指定字段   <br>
      * Flipper中offset字段将被忽略   <br>
@@ -172,6 +303,22 @@ public interface DataSource {
      */
     public <T> int updateColumn(final Class<T> clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values);
 
+    /**
+     * 更新符合过滤条件的记录的指定字段   <br>
+     * Flipper中offset字段将被忽略   <br>
+     * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, &#183;&#183;&#183; WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param node    过滤条件
+     * @param flipper 翻页对象
+     * @param values  更新字段
+     *
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values);
+
     /**
      * 更新单个记录的指定字段   <br>
      * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
@@ -185,6 +332,18 @@ public interface DataSource {
      */
     public <T> int updateColumn(final T bean, final String... columns);
 
+    /**
+     * 更新单个记录的指定字段   <br>
+     * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param bean    待更新的Entity对象
+     * @param columns 需更新的字段名
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, T> handler, final T bean, final String... columns);
+
     /**
      * 更新符合过滤条件记录的指定字段   <br>
      * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
@@ -199,6 +358,20 @@ public interface DataSource {
      */
     public <T> int updateColumn(final T bean, final FilterNode node, final String... columns);
 
+    /**
+     * 更新符合过滤条件记录的指定字段   <br>
+     * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param bean    待更新的Entity对象
+     * @param node    过滤条件
+     * @param columns 需更新的字段名
+     *
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final T bean, final FilterNode node, final String... columns);
+
     /**
      * 更新单个记录的指定字段   <br>
      * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
@@ -212,6 +385,19 @@ public interface DataSource {
      */
     public <T> int updateColumn(final T bean, final SelectColumn selects);
 
+    /**
+     * 更新单个记录的指定字段   <br>
+     * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param bean    待更新的Entity对象
+     * @param selects 指定字段
+     *
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, T> handler, final T bean, final SelectColumn selects);
+
     /**
      * 更新符合过滤条件记录的指定字段   <br>
      * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
@@ -226,6 +412,20 @@ public interface DataSource {
      */
     public <T> int updateColumn(final T bean, final FilterNode node, final SelectColumn selects);
 
+    /**
+     * 更新符合过滤条件记录的指定字段   <br>
+     * <b>注意</b>：Entity类中标记为&#064;Column(updatable=false)不会被更新   <br>
+     * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param bean    待更新的Entity对象
+     * @param node    过滤条件
+     * @param selects 指定字段
+     *
+     */
+    public <T> void updateColumn(final AsyncHandler<Integer, FilterNode> handler, final T bean, final FilterNode node, final SelectColumn selects);
+
     //############################################# 查询接口 #############################################
     //-----------------------getXXXXResult-----------------------------
     /**
@@ -241,6 +441,19 @@ public interface DataSource {
      */
     public Number getNumberResult(final Class entityClass, final FilterFunc func, final String column);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果, 无结果返回null   <br>
+     * 等价SQL: SELECT FUNC{column} FROM {table}  <br>
+     * 如 getNumberResult(Record.class, FilterFunc.COUNT, null) 等价于: SELECT COUNT(*) FROM {table} <br>
+     *
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param func        聚合函数
+     * @param column      指定字段
+     *
+     */
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final String column);
+
     /**
      * 获取符合过滤条件记录的聚合结果, 无结果返回null   <br>
      * 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean}  <br>
@@ -255,6 +468,20 @@ public interface DataSource {
      */
     public Number getNumberResult(final Class entityClass, final FilterFunc func, final String column, final FilterBean bean);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果, 无结果返回null   <br>
+     * 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean}  <br>
+     * 如 getNumberResult(Record.class, FilterFunc.COUNT, null, (FilterBean)null) 等价于: SELECT COUNT(*) FROM {table} <br>
+     *
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param func        聚合函数
+     * @param column      指定字段
+     * @param bean        过滤条件
+     *
+     */
+    public void getNumberResult(final AsyncHandler<Number, FilterNode> handler, final Class entityClass, final FilterFunc func, final String column, final FilterBean bean);
+
     /**
      * 获取符合过滤条件记录的聚合结果, 无结果返回null   <br>
      * 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}  <br>
@@ -269,6 +496,20 @@ public interface DataSource {
      */
     public Number getNumberResult(final Class entityClass, final FilterFunc func, final String column, final FilterNode node);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果, 无结果返回null   <br>
+     * 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}  <br>
+     * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} <br>
+     *
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param func        聚合函数
+     * @param column      指定字段
+     * @param node        过滤条件
+     *
+     */
+    public void getNumberResult(final AsyncHandler<Number, FilterNode> handler, final Class entityClass, final FilterFunc func, final String column, final FilterNode node);
+
     /**
      * 获取符合过滤条件记录的聚合结果, 无结果返回默认值   <br>
      * 等价SQL: SELECT FUNC{column} FROM {table}  <br>
@@ -283,6 +524,19 @@ public interface DataSource {
      */
     public Number getNumberResult(final Class entityClass, final FilterFunc func, final Number defVal, final String column);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果, 无结果返回默认值   <br>
+     * 等价SQL: SELECT FUNC{column} FROM {table}  <br>
+     * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime") 等价于: SELECT MAX(createtime) FROM {table} <br>
+     *
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param func        聚合函数
+     * @param defVal      默认值
+     * @param column      指定字段
+     */
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column);
+
     /**
      * 获取符合过滤条件记录的聚合结果, 无结果返回默认值   <br>
      * 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean}  <br>
@@ -298,6 +552,20 @@ public interface DataSource {
      */
     public Number getNumberResult(final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterBean bean);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果, 无结果返回默认值   <br>
+     * 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean}  <br>
+     * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} <br>
+     *
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param func        聚合函数
+     * @param defVal      默认值
+     * @param column      指定字段
+     * @param bean        过滤条件
+     */
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterBean bean);
+
     /**
      * 获取符合过滤条件记录的聚合结果, 无结果返回默认值   <br>
      * 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}  <br>
@@ -313,6 +581,21 @@ public interface DataSource {
      */
     public Number getNumberResult(final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果, 无结果返回默认值   <br>
+     * 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}  <br>
+     * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} <br>
+     *
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param func        聚合函数
+     * @param defVal      默认值
+     * @param column      指定字段
+     * @param node        过滤条件
+     *
+     */
+    public void getNumberResult(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node);
+
     /**
      * 获取符合过滤条件记录的聚合结果Map   <br>
      * 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, &#183;&#183;&#183; FROM {table}  <br>
@@ -326,6 +609,18 @@ public interface DataSource {
      */
     public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterFuncColumn... columns);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果Map   <br>
+     * 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, &#183;&#183;&#183; FROM {table}  <br>
+     * 如 getNumberMap(Record.class, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} <br>
+     *
+     * @param <N>         Number
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param columns     聚合字段
+     */
+    public <N extends Number> void getNumberMap(final AsyncHandler<Map<String, N>, FilterFuncColumn[]> handler, final Class entityClass, final FilterFuncColumn... columns);
+
     /**
      * 获取符合过滤条件记录的聚合结果Map   <br>
      * 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean}  <br>
@@ -340,6 +635,19 @@ public interface DataSource {
      */
     public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterBean bean, final FilterFuncColumn... columns);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果Map   <br>
+     * 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean}  <br>
+     * 如 getNumberMap(Record.class, (FilterBean)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} <br>
+     *
+     * @param <N>         Number
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param bean        过滤条件
+     * @param columns     聚合字段
+     */
+    public <N extends Number> void getNumberMap(final AsyncHandler<Map<String, N>, FilterNode> handler, final Class entityClass, final FilterBean bean, final FilterFuncColumn... columns);
+
     /**
      * 获取符合过滤条件记录的聚合结果Map   <br>
      * 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node}  <br>
@@ -354,6 +662,19 @@ public interface DataSource {
      */
     public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterNode node, final FilterFuncColumn... columns);
 
+    /**
+     * 获取符合过滤条件记录的聚合结果Map   <br>
+     * 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node}  <br>
+     * 如 getNumberMap(Record.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} <br>
+     *
+     * @param <N>         Number
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param node        过滤条件
+     * @param columns     聚合字段
+     */
+    public <N extends Number> void getNumberMap(final AsyncHandler<Map<String, N>, FilterNode> handler, final Class entityClass, final FilterNode node, final FilterFuncColumn... columns);
+
     /**
      * 查询符合过滤条件记录的GROUP BY聚合结果Map   <br>
      * 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} GROUP BY {keyColumn}  <br>
@@ -371,6 +692,22 @@ public interface DataSource {
      */
     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);
 
+    /**
+     * 查询符合过滤条件记录的GROUP BY聚合结果Map   <br>
+     * 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} GROUP BY {keyColumn}  <br>
+     * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime") 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name<br>
+     *
+     * @param <T>         Entity泛型
+     * @param <K>         Key字段的数据类型
+     * @param <N>         Number
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param keyColumn   Key字段
+     * @param func        聚合函数
+     * @param funcColumn  聚合字段
+     */
+    public <T, K extends Serializable, N extends Number> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn);
+
     /**
      * 查询符合过滤条件记录的GROUP BY聚合结果Map   <br>
      * 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter bean} GROUP BY {keyColumn}  <br>
@@ -389,6 +726,23 @@ public interface DataSource {
      */
     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, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的GROUP BY聚合结果Map   <br>
+     * 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter bean} GROUP BY {keyColumn}  <br>
+     * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime", (FilterBean)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name<br>
+     *
+     * @param <T>         Entity泛型
+     * @param <K>         Key字段的数据类型
+     * @param <N>         Number
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param keyColumn   Key字段
+     * @param func        聚合函数
+     * @param funcColumn  聚合字段
+     * @param bean        过滤条件
+     */
+    public <T, K extends Serializable, N extends Number> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的GROUP BY聚合结果Map   <br>
      * 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter node} GROUP BY {keyColumn}  <br>
@@ -407,6 +761,23 @@ public interface DataSource {
      */
     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, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的GROUP BY聚合结果Map   <br>
+     * 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter node} GROUP BY {keyColumn}  <br>
+     * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name<br>
+     *
+     * @param <T>         Entity泛型
+     * @param <K>         Key字段的数据类型
+     * @param <N>         Number
+     * @param handler     回调函数
+     * @param entityClass Entity类
+     * @param keyColumn   Key字段
+     * @param func        聚合函数
+     * @param funcColumn  聚合字段
+     * @param node        过滤条件
+     */
+    public <T, K extends Serializable, N extends Number> void queryColumnMap(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node);
+
     //-----------------------find----------------------------
     /**
      * 获取指定主键值的单个记录, 返回null表示不存在值   <br>
@@ -420,6 +791,17 @@ public interface DataSource {
      */
     public <T> T find(final Class<T> clazz, final Serializable pk);
 
+    /**
+     * 获取指定主键值的单个记录, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {primary} = {id}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param pk      主键值
+     */
+    public <T> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, final Serializable pk);
+
     /**
      * 获取指定主键值的单个记录, 返回null表示不存在值   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {primary} = {id}  <br>
@@ -433,6 +815,18 @@ public interface DataSource {
      */
     public <T> T find(final Class<T> clazz, final SelectColumn selects, final Serializable pk);
 
+    /**
+     * 获取指定主键值的单个记录, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {primary} = {id}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param pk      主键值
+     */
+    public <T> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, final SelectColumn selects, final Serializable pk);
+
     /**
      * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {column} = {key}  <br>
@@ -446,6 +840,18 @@ public interface DataSource {
      */
     public <T> T find(final Class<T> clazz, final String column, final Serializable key);
 
+    /**
+     * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param column  过滤字段名
+     * @param key     过滤字段值
+     */
+    public <T> void find(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, final String column, final Serializable key);
+
     /**
      * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {filter bean}  <br>
@@ -458,6 +864,17 @@ public interface DataSource {
      */
     public <T> T find(final Class<T> clazz, final FilterBean bean);
 
+    /**
+     * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param bean    过滤条件
+     */
+    public <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final FilterBean bean);
+
     /**
      * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {filter node}  <br>
@@ -470,6 +887,17 @@ public interface DataSource {
      */
     public <T> T find(final Class<T> clazz, final FilterNode node);
 
+    /**
+     * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param node    过滤条件
+     */
+    public <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final FilterNode node);
+
     /**
      * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean}  <br>
@@ -483,6 +911,18 @@ public interface DataSource {
      */
     public <T> T find(final Class<T> clazz, final SelectColumn selects, final FilterBean bean);
 
+    /**
+     * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param bean    过滤条件
+     */
+    public <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterBean bean);
+
     /**
      * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node}  <br>
@@ -496,6 +936,18 @@ public interface DataSource {
      */
     public <T> T find(final Class<T> clazz, final SelectColumn selects, final FilterNode node);
 
+    /**
+     * 获取符合过滤条件单个记录, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param node    过滤条件
+     */
+    public <T> void find(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterNode node);
+
     /**
      * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值   <br>
      * 等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id}  <br>
@@ -509,6 +961,18 @@ public interface DataSource {
      */
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable pk);
 
+    /**
+     * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param column  字段名
+     * @param pk      主键值
+     */
+    public <T> void findColumn(final AsyncHandler<Serializable, Serializable> handler, final Class<T> clazz, final String column, final Serializable pk);
+
     /**
      * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值   <br>
      * 等价SQL: SELECT {column} FROM {table} WHERE {filter bean}  <br>
@@ -522,6 +986,18 @@ public interface DataSource {
      */
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final FilterBean bean);
 
+    /**
+     * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT {column} FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param column  字段名
+     * @param bean    过滤条件
+     */
+    public <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final FilterBean bean);
+
     /**
      * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值   <br>
      * 等价SQL: SELECT {column} FROM {table} WHERE {filter node}  <br>
@@ -535,6 +1011,18 @@ public interface DataSource {
      */
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final FilterNode node);
 
+    /**
+     * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值   <br>
+     * 等价SQL: SELECT {column} FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param column  字段名
+     * @param node    过滤条件
+     */
+    public <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final FilterNode node);
+
     /**
      * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值   <br>
      * 等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id}  <br>
@@ -549,6 +1037,19 @@ public interface DataSource {
      */
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final Serializable pk);
 
+    /**
+     * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值   <br>
+     * 等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id}  <br>
+     *
+     * @param <T>      Entity泛型
+     * @param handler  回调函数
+     * @param clazz    Entity类
+     * @param column   字段名
+     * @param defValue 默认值
+     * @param pk       主键值
+     */
+    public <T> void findColumn(final AsyncHandler<Serializable, Serializable> handler, final Class<T> clazz, final String column, final Serializable defValue, final Serializable pk);
+
     /**
      * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值   <br>
      * 等价SQL: SELECT {column} FROM {table} WHERE {filter bean}  <br>
@@ -563,6 +1064,19 @@ public interface DataSource {
      */
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final FilterBean bean);
 
+    /**
+     * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值   <br>
+     * 等价SQL: SELECT {column} FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>      Entity泛型
+     * @param handler  回调函数
+     * @param clazz    Entity类
+     * @param column   字段名
+     * @param defValue 默认值
+     * @param bean     过滤条件
+     */
+    public <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final Serializable defValue, final FilterBean bean);
+
     /**
      * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值   <br>
      * 等价SQL: SELECT {column} FROM {table} WHERE {filter node}  <br>
@@ -577,6 +1091,19 @@ public interface DataSource {
      */
     public <T> Serializable findColumn(final Class<T> clazz, final String column, final Serializable defValue, final FilterNode node);
 
+    /**
+     * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值   <br>
+     * 等价SQL: SELECT {column} FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>      Entity泛型
+     * @param handler  回调函数
+     * @param clazz    Entity类
+     * @param column   字段名
+     * @param defValue 默认值
+     * @param node     过滤条件
+     */
+    public <T> void findColumn(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final Serializable defValue, final FilterNode node);
+
     /**
      * 判断是否存在主键值的记录   <br>
      * 等价SQL: SELECT COUNT(*) FROM {table} WHERE {primary} = {id}  <br>
@@ -589,6 +1116,17 @@ public interface DataSource {
      */
     public <T> boolean exists(final Class<T> clazz, final Serializable pk);
 
+    /**
+     * 判断是否存在主键值的记录   <br>
+     * 等价SQL: SELECT COUNT(*) FROM {table} WHERE {primary} = {id}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param pk      主键值
+     */
+    public <T> void exists(final AsyncHandler<Boolean, Serializable> handler, final Class<T> clazz, final Serializable pk);
+
     /**
      * 判断是否存在符合过滤条件的记录   <br>
      * 等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter bean}  <br>
@@ -601,6 +1139,17 @@ public interface DataSource {
      */
     public <T> boolean exists(final Class<T> clazz, final FilterBean bean);
 
+    /**
+     * 判断是否存在符合过滤条件的记录   <br>
+     * 等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param bean    过滤条件
+     */
+    public <T> void exists(final AsyncHandler<Boolean, FilterNode> handler, final Class<T> clazz, final FilterBean bean);
+
     /**
      * 判断是否存在符合过滤条件的记录   <br>
      * 等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter node}  <br>
@@ -613,6 +1162,17 @@ public interface DataSource {
      */
     public <T> boolean exists(final Class<T> clazz, final FilterNode node);
 
+    /**
+     * 判断是否存在符合过滤条件的记录   <br>
+     * 等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param node    过滤条件
+     */
+    public <T> void exists(final AsyncHandler<Boolean, FilterNode> handler, final Class<T> clazz, final FilterNode node);
+
     //-----------------------list set----------------------------
     /**
      * 查询符合过滤条件记录的某个字段Set集合   <br>
@@ -629,6 +1189,20 @@ public interface DataSource {
      */
     public <T, V extends Serializable> HashSet<V> queryColumnSet(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key);
 
+    /**
+     * 查询符合过滤条件记录的某个字段Set集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {column} = {key}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param column         过滤字段名
+     * @param key            过滤字段值
+     */
+    public <T, V extends Serializable> void queryColumnSet(final AsyncHandler<HashSet<V>, String> handler, final String selectedColumn, final Class<T> clazz, final String column, final Serializable key);
+
     /**
      * 查询符合过滤条件记录的某个字段Set集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean}  <br>
@@ -643,6 +1217,19 @@ public interface DataSource {
      */
     public <T, V extends Serializable> HashSet<V> queryColumnSet(final String selectedColumn, final Class<T> clazz, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的某个字段Set集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param bean           过滤条件
+     */
+    public <T, V extends Serializable> void queryColumnSet(final AsyncHandler<HashSet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的某个字段Set集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node}  <br>
@@ -657,6 +1244,19 @@ public interface DataSource {
      */
     public <T, V extends Serializable> HashSet<V> queryColumnSet(final String selectedColumn, final Class<T> clazz, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的某个字段Set集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param node           过滤条件
+     */
+    public <T, V extends Serializable> void queryColumnSet(final AsyncHandler<HashSet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final FilterNode node);
+
     /**
      * 查询符合过滤条件记录的某个字段List集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {column} = {key}  <br>
@@ -672,6 +1272,20 @@ public interface DataSource {
      */
     public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key);
 
+    /**
+     * 查询符合过滤条件记录的某个字段List集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {column} = {key}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param column         过滤字段名
+     * @param key            过滤字段值
+     */
+    public <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, Serializable> handler, final String selectedColumn, final Class<T> clazz, final String column, final Serializable key);
+
     /**
      * 查询符合过滤条件记录的某个字段List集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean}  <br>
@@ -686,6 +1300,19 @@ public interface DataSource {
      */
     public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的某个字段List集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param bean           过滤条件
+     */
+    public <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的某个字段List集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node}  <br>
@@ -700,6 +1327,19 @@ public interface DataSource {
      */
     public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的某个字段List集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param node           过滤条件
+     */
+    public <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final FilterNode node);
+
     /**
      * 查询符合过滤条件记录的某个字段List集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -715,6 +1355,20 @@ public interface DataSource {
      */
     public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的某个字段List集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param flipper        翻页对象
+     * @param bean           过滤条件
+     */
+    public <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的某个字段List集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -730,6 +1384,20 @@ public interface DataSource {
      */
     public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的某个字段List集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param flipper        翻页对象
+     * @param node           过滤条件
+     */
+    public <T, V extends Serializable> void queryColumnList(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node);
+
     /**
      * 查询符合过滤条件记录的某个字段Sheet集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -745,6 +1413,20 @@ public interface DataSource {
      */
     public <T, V extends Serializable> Sheet<V> queryColumnSheet(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的某个字段Sheet集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param flipper        翻页对象
+     * @param bean           过滤条件
+     */
+    public <T, V extends Serializable> void queryColumnSheet(final AsyncHandler<Sheet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的某个字段Sheet集合   <br>
      * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -760,6 +1442,20 @@ public interface DataSource {
      */
     public <T, V extends Serializable> Sheet<V> queryColumnSheet(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的某个字段Sheet集合   <br>
+     * 等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>            Entity泛型
+     * @param <V>            字段类型
+     * @param handler        回调函数
+     * @param selectedColumn 指定字段
+     * @param clazz          Entity类
+     * @param flipper        翻页对象
+     * @param node           过滤条件
+     */
+    public <T, V extends Serializable> void queryColumnSheet(final AsyncHandler<Sheet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -773,6 +1469,18 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final String column, final Serializable key);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param column  过滤字段名
+     * @param key     过滤字段值
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, Serializable> handler, final Class<T> clazz, final String column, final Serializable key);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {filter bean}  <br>
@@ -785,6 +1493,17 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param bean    过滤条件
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {filter node}  <br>
@@ -797,6 +1516,17 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param node    过滤条件
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final FilterNode node);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean}  <br>
@@ -810,6 +1540,18 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param bean    过滤条件
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node}  <br>
@@ -823,6 +1565,18 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param node    过滤条件
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final FilterNode node);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -837,6 +1591,19 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final String column, final Serializable key);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param flipper 翻页对象
+     * @param column  过滤字段名
+     * @param key     过滤字段值
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, Serializable> handler, final Class<T> clazz, final Flipper flipper, final String column, final Serializable key);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -850,6 +1617,18 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param flipper 翻页对象
+     * @param bean    过滤条件
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -863,6 +1642,18 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param flipper 翻页对象
+     * @param node    过滤条件
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterNode node);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -877,6 +1668,19 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param flipper 翻页对象
+     * @param bean    过滤条件
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的List集合   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -891,6 +1695,19 @@ public interface DataSource {
      */
     public <T> List<T> queryList(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的List集合   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param flipper 翻页对象
+     * @param node    过滤条件
+     */
+    public <T> void queryList(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node);
+
     //-----------------------sheet----------------------------
     /**
      * 查询符合过滤条件记录的Sheet集合   <br>
@@ -905,6 +1722,18 @@ public interface DataSource {
      */
     public <T> Sheet<T> querySheet(final Class<T> clazz, final Flipper flipper, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的Sheet集合   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param flipper 翻页对象
+     * @param bean    过滤条件
+     */
+    public <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的Sheet集合   <br>
      * 等价SQL: SELECT * FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -918,6 +1747,18 @@ public interface DataSource {
      */
     public <T> Sheet<T> querySheet(final Class<T> clazz, final Flipper flipper, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的Sheet集合   <br>
+     * 等价SQL: SELECT * FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param flipper 翻页对象
+     * @param node    过滤条件
+     */
+    public <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, final FilterNode node);
+
     /**
      * 查询符合过滤条件记录的Sheet集合   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -932,6 +1773,19 @@ public interface DataSource {
      */
     public <T> Sheet<T> querySheet(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean);
 
+    /**
+     * 查询符合过滤条件记录的Sheet集合   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param flipper 翻页对象
+     * @param bean    过滤条件
+     */
+    public <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean);
+
     /**
      * 查询符合过滤条件记录的Sheet集合   <br>
      * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
@@ -946,6 +1800,19 @@ public interface DataSource {
      */
     public <T> Sheet<T> querySheet(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node);
 
+    /**
+     * 查询符合过滤条件记录的Sheet集合   <br>
+     * 等价SQL: SELECT {column1},{column2}, &#183;&#183;&#183; FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}  <br>
+     *
+     * @param <T>     Entity泛型
+     * @param handler 回调函数
+     * @param clazz   Entity类
+     * @param selects 指定字段
+     * @param flipper 翻页对象
+     * @param node    过滤条件
+     */
+    public <T> void querySheet(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node);
+
     //-----------------------direct----------------------------
     /**
      * 直接本地执行SQL语句进行查询，远程模式不可用   <br>
diff --git a/src/org/redkale/util/AsyncHandler.java b/src/org/redkale/util/AsyncHandler.java
index 417061220..bc45a5e40 100644
--- a/src/org/redkale/util/AsyncHandler.java
+++ b/src/org/redkale/util/AsyncHandler.java
@@ -10,7 +10,7 @@ import java.nio.channels.CompletionHandler;
 import java.util.function.*;
 
 /**
- * 异步接口
+ * 异步回调函数
  *
  *
  * <p>