diff --git a/src/org/redkale/source/CacheMemorySource.java b/src/org/redkale/source/CacheMemorySource.java index b4f49476a..954eba9ac 100644 --- a/src/org/redkale/source/CacheMemorySource.java +++ b/src/org/redkale/source/CacheMemorySource.java @@ -203,7 +203,7 @@ public class CacheMemorySource extends } @Override - public void exists(final AsyncHandler handler, @RpcAttachment final K key) { + public void existsAsync(final AsyncHandler handler, @RpcAttachment final K key) { boolean rs = exists(key); if (handler != null) handler.completed(rs, key); } @@ -226,7 +226,7 @@ public class CacheMemorySource extends } @Override - public void get(final AsyncHandler handler, @RpcAttachment final K key) { + public void getAsync(final AsyncHandler handler, @RpcAttachment final K key) { V rs = get(key); if (handler != null) handler.completed(rs, key); } @@ -252,7 +252,7 @@ public class CacheMemorySource extends } @Override - public void getAndRefresh(final AsyncHandler handler, @RpcAttachment final K key, final int expireSeconds) { + public void getAndRefreshAsync(final AsyncHandler handler, @RpcAttachment final K key, final int expireSeconds) { V rs = getAndRefresh(key, expireSeconds); if (handler != null) handler.completed(rs, key); } @@ -268,7 +268,7 @@ public class CacheMemorySource extends } @Override - public void refresh(final AsyncHandler handler, @RpcAttachment final K key, final int expireSeconds) { + public void refreshAsync(final AsyncHandler handler, @RpcAttachment final K key, final int expireSeconds) { refresh(key, expireSeconds); if (handler != null) handler.completed(null, key); } @@ -289,7 +289,7 @@ public class CacheMemorySource extends } @Override - public void set(final AsyncHandler handler, @RpcAttachment final K key, final V value) { + public void setAsync(final AsyncHandler handler, @RpcAttachment final K key, final V value) { set(key, value); if (handler != null) handler.completed(null, key); } @@ -310,7 +310,7 @@ public class CacheMemorySource extends } @Override - public void set(final AsyncHandler handler, final int expireSeconds, @RpcAttachment final K key, final V value) { + public void setAsync(final AsyncHandler handler, final int expireSeconds, @RpcAttachment final K key, final V value) { set(expireSeconds, key, value); if (handler != null) handler.completed(null, key); } @@ -325,7 +325,7 @@ public class CacheMemorySource extends } @Override - public void setExpireSeconds(final AsyncHandler handler, @RpcAttachment final K key, final int expireSeconds) { + public void setExpireSecondsAsync(final AsyncHandler handler, @RpcAttachment final K key, final int expireSeconds) { setExpireSeconds(key, expireSeconds); if (handler != null) handler.completed(null, key); } @@ -338,7 +338,7 @@ public class CacheMemorySource extends } @Override - public void remove(final AsyncHandler handler, @RpcAttachment final K key) { + public void removeAsync(final AsyncHandler handler, @RpcAttachment final K key) { remove(key); if (handler != null) handler.completed(null, key); } @@ -349,7 +349,7 @@ public class CacheMemorySource extends } @Override - public void getCollection(final AsyncHandler, K> handler, @RpcAttachment final K key) { + public void getCollectionAsync(final AsyncHandler, K> handler, @RpcAttachment final K key) { Collection rs = getCollection(key); if (handler != null) handler.completed(rs, key); } @@ -360,7 +360,7 @@ public class CacheMemorySource extends } @Override - public void getCollectionAndRefresh(final AsyncHandler, K> handler, @RpcAttachment final K key, final int expireSeconds) { + public void getCollectionAndRefreshAsync(final AsyncHandler, K> handler, @RpcAttachment final K key, final int expireSeconds) { Collection rs = getCollectionAndRefresh(key, expireSeconds); if (handler != null) handler.completed(rs, key); } @@ -382,7 +382,7 @@ public class CacheMemorySource extends } @Override - public void appendListItem(final AsyncHandler handler, @RpcAttachment final K key, final V value) { + public void appendListItemAsync(final AsyncHandler handler, @RpcAttachment final K key, final V value) { appendListItem(key, value); if (handler != null) handler.completed(null, key); } @@ -397,7 +397,7 @@ public class CacheMemorySource extends } @Override - public void removeListItem(final AsyncHandler handler, @RpcAttachment final K key, final V value) { + public void removeListItemAsync(final AsyncHandler handler, @RpcAttachment final K key, final V value) { removeListItem(key, value); if (handler != null) handler.completed(null, key); } @@ -419,7 +419,7 @@ public class CacheMemorySource extends } @Override - public void appendSetItem(final AsyncHandler handler, @RpcAttachment final K key, final V value) { + public void appendSetItemAsync(final AsyncHandler handler, @RpcAttachment final K key, final V value) { appendSetItem(key, value); if (handler != null) handler.completed(null, key); } @@ -434,7 +434,7 @@ public class CacheMemorySource extends } @Override - public void removeSetItem(final AsyncHandler handler, @RpcAttachment final K key, final V value) { + public void removeSetItemAsync(final AsyncHandler handler, @RpcAttachment final K key, final V value) { removeSetItem(key, value); if (handler != null) handler.completed(null, key); } diff --git a/src/org/redkale/source/CacheSource.java b/src/org/redkale/source/CacheSource.java index 80b8702f7..b5401ce38 100644 --- a/src/org/redkale/source/CacheSource.java +++ b/src/org/redkale/source/CacheSource.java @@ -89,35 +89,36 @@ public interface CacheSource { } */ //---------------------- AsyncHandler 异步版 --------------------------------- - public void exists(final AsyncHandler handler, final K key); + + public void existsAsync(final AsyncHandler handler, final K key); - public void get(final AsyncHandler handler, final K key); + public void getAsync(final AsyncHandler handler, final K key); - public void getAndRefresh(final AsyncHandler handler, final K key, final int expireSeconds); + public void getAndRefreshAsync(final AsyncHandler handler, final K key, final int expireSeconds); - public void refresh(final AsyncHandler handler, final K key, final int expireSeconds); + public void refreshAsync(final AsyncHandler handler, final K key, final int expireSeconds); - public void set(final AsyncHandler handler, final K key, final V value); + public void setAsync(final AsyncHandler handler, final K key, final V value); - public void set(final AsyncHandler handler, final int expireSeconds, final K key, final V value); + public void setAsync(final AsyncHandler handler, final int expireSeconds, final K key, final V value); - public void setExpireSeconds(final AsyncHandler handler, final K key, final int expireSeconds); + public void setExpireSecondsAsync(final AsyncHandler handler, final K key, final int expireSeconds); - public void remove(final AsyncHandler handler, final K key); + public void removeAsync(final AsyncHandler handler, final K key); - public void getCollection(final AsyncHandler, K> handler, final K key); + public void getCollectionAsync(final AsyncHandler, K> handler, final K key); - public void getCollectionAndRefresh(final AsyncHandler, K> handler, final K key, final int expireSeconds); + public void getCollectionAndRefreshAsync(final AsyncHandler, K> handler, final K key, final int expireSeconds); - public void appendListItem(final AsyncHandler handler, final K key, final V value); + public void appendListItemAsync(final AsyncHandler handler, final K key, final V value); - public void removeListItem(final AsyncHandler handler, final K key, final V value); + public void removeListItemAsync(final AsyncHandler handler, final K key, final V value); - public void appendSetItem(final AsyncHandler handler, final K key, final V value); + public void appendSetItemAsync(final AsyncHandler handler, final K key, final V value); - public void removeSetItem(final AsyncHandler handler, final K key, final V value); + public void removeSetItemAsync(final AsyncHandler handler, final K key, final V value); - default void isOpen(final AsyncHandler handler) { + default void isOpenAsync(final AsyncHandler handler) { if (handler != null) handler.completed(Boolean.TRUE, null); } } diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java index 82a0a493f..5c93fd469 100644 --- a/src/org/redkale/source/DataJdbcSource.java +++ b/src/org/redkale/source/DataJdbcSource.java @@ -145,7 +145,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void insert(final AsyncHandler handler, @RpcAttachment @RpcCall(DataCallArrayAttribute.class) final T... values) { + public void insertAsync(final AsyncHandler handler, @RpcAttachment @RpcCall(DataCallArrayAttribute.class) final T... values) { insert(values); if (handler != null) handler.completed(null, values); } @@ -324,7 +324,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void delete(final AsyncHandler handler, @RpcAttachment final T... values) { + public void deleteAsync(final AsyncHandler handler, @RpcAttachment final T... values) { int rs = delete(values); if (handler != null) handler.completed(rs, values); } @@ -355,7 +355,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void delete(final AsyncHandler handler, final Class clazz, @RpcAttachment final Serializable... ids) { + public void deleteAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final Serializable... ids) { int rs = delete(clazz, ids); if (handler != null) handler.completed(rs, ids); } @@ -409,7 +409,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void delete(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node) { + public void deleteAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node) { int rs = delete(clazz, node); if (handler != null) handler.completed(rs, node); } @@ -429,7 +429,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void delete(final AsyncHandler handler, final Class clazz, final Flipper flipper, @RpcAttachment FilterNode node) { + public void deleteAsync(final AsyncHandler handler, final Class clazz, final Flipper flipper, @RpcAttachment FilterNode node) { int rs = delete(clazz, flipper, node); if (handler != null) handler.completed(rs, node); } @@ -484,7 +484,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi return c; } - //------------------------update--------------------------- + //------------------------updateAsync--------------------------- /** * 更新对象, 必须是Entity对象 * @@ -521,7 +521,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void update(final AsyncHandler handler, @RpcAttachment final T... values) { + public void updateAsync(final AsyncHandler handler, @RpcAttachment final T... values) { int rs = update(values); if (handler != null) handler.completed(rs, values); } @@ -618,7 +618,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, final Class clazz, final Serializable id, final String column, final Serializable value) { + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, final Serializable id, final String column, final Serializable value) { int rs = updateColumn(clazz, id, column, value); if (handler != null) handler.completed(rs, id); } @@ -686,7 +686,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable value, @RpcAttachment final FilterNode node) { + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable value, @RpcAttachment final FilterNode node) { int rs = updateColumn(clazz, column, value, node); if (handler != null) handler.completed(rs, node); } @@ -769,7 +769,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, final Class clazz, @RpcAttachment final Serializable id, final ColumnValue... values) { + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final Serializable id, final ColumnValue... values) { int rs = updateColumn(clazz, id, values); if (handler != null) handler.completed(rs, id); } @@ -856,7 +856,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node, final ColumnValue... values) { + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node, final ColumnValue... values) { int rs = updateColumn(clazz, node, values); if (handler != null) handler.completed(rs, node); } @@ -887,7 +887,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node, final Flipper flipper, final ColumnValue... values) { + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node, final Flipper flipper, final ColumnValue... values) { int rs = updateColumn(clazz, node, flipper, values); if (handler != null) handler.completed(rs, node); } @@ -969,7 +969,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, @RpcAttachment final T bean, final String... columns) { + public void updateColumnAsync(final AsyncHandler handler, @RpcAttachment final T bean, final String... columns) { int rs = updateColumn(bean, columns); if (handler != null) handler.completed(rs, bean); } @@ -989,7 +989,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, @RpcAttachment final T bean, final SelectColumn selects) { + public void updateColumnAsync(final AsyncHandler handler, @RpcAttachment final T bean, final SelectColumn selects) { int rs = updateColumn(bean, selects); if (handler != null) handler.completed(rs, bean); } @@ -1057,7 +1057,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, final T bean, @RpcAttachment final FilterNode node, final String... columns) { + public void updateColumnAsync(final AsyncHandler handler, final T bean, @RpcAttachment final FilterNode node, final String... columns) { int rs = updateColumn(bean, node, columns); if (handler != null) handler.completed(rs, node); } @@ -1077,7 +1077,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void updateColumn(final AsyncHandler handler, final T bean, @RpcAttachment final FilterNode node, final SelectColumn selects) { + public void updateColumnAsync(final AsyncHandler handler, final T bean, @RpcAttachment final FilterNode node, final SelectColumn selects) { int rs = updateColumn(bean, node, selects); if (handler != null) handler.completed(rs, node); } @@ -1178,14 +1178,14 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi return c; } - //-----------------------getNumberResult----------------------------- + //-----------------------getNumberResultAsync----------------------------- @Override public Number getNumberResult(final Class entityClass, final FilterFunc func, final String column) { return getNumberResult(entityClass, func, null, column, (FilterNode) null); } @Override - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, @RpcAttachment final String column) { + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, @RpcAttachment final String column) { Number rs = getNumberResult(entityClass, func, column); if (handler != null) handler.completed(rs, column); } @@ -1196,7 +1196,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column, @RpcAttachment final B bean) { + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column, @RpcAttachment final B bean) { Number rs = getNumberResult(entityClass, func, column, bean); if (handler != null) handler.completed(rs, bean); } @@ -1207,7 +1207,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column, @RpcAttachment final FilterNode node) { + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column, @RpcAttachment final FilterNode node) { Number rs = getNumberResult(entityClass, func, column, node); if (handler != null) handler.completed(rs, node); } @@ -1218,7 +1218,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column) { + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column) { Number rs = getNumberResult(entityClass, func, defVal, column); if (handler != null) handler.completed(rs, column); } @@ -1229,8 +1229,8 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void getNumberResult(final AsyncHandler 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)); + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column, final FilterBean bean) { + getNumberResultAsync(handler, entityClass, func, defVal, column, FilterNodeBean.createFilterNode(bean)); } @Override @@ -1239,7 +1239,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void getNumberMap(final AsyncHandler, FilterFuncColumn[]> handler, final Class entityClass, @RpcAttachment final FilterFuncColumn... columns) { + public void getNumberMapAsync(final AsyncHandler, FilterFuncColumn[]> handler, final Class entityClass, @RpcAttachment final FilterFuncColumn... columns) { Map rs = getNumberMap(entityClass, columns); if (handler != null) handler.completed(rs, columns); } @@ -1250,7 +1250,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void getNumberMap(final AsyncHandler, B> handler, final Class entityClass, @RpcAttachment final B bean, final FilterFuncColumn... columns) { + public void getNumberMapAsync(final AsyncHandler, B> handler, final Class entityClass, @RpcAttachment final B bean, final FilterFuncColumn... columns) { Map rs = getNumberMap(entityClass, bean, columns); if (handler != null) handler.completed(rs, bean); } @@ -1321,7 +1321,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void getNumberMap(final AsyncHandler, FilterNode> handler, final Class entityClass, @RpcAttachment final FilterNode node, final FilterFuncColumn... columns) { + public void getNumberMapAsync(final AsyncHandler, FilterNode> handler, final Class entityClass, @RpcAttachment final FilterNode node, final FilterFuncColumn... columns) { Map rs = getNumberMap(entityClass, node, columns); if (handler != null) handler.completed(rs, node); } @@ -1364,19 +1364,19 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column, final FilterNode node) { + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column, final FilterNode node) { Number rs = getNumberResult(entityClass, func, defVal, column, node); if (handler != null) handler.completed(rs, column); } - //-----------------------queryColumnMap----------------------------- + //-----------------------queryColumnMapAsync----------------------------- @Override public Map queryColumnMap(final Class entityClass, final String keyColumn, FilterFunc func, final String funcColumn) { return queryColumnMap(entityClass, keyColumn, func, funcColumn, (FilterNode) null); } @Override - public void queryColumnMap(final AsyncHandler, String> handler, final Class entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn) { + public void queryColumnMapAsync(final AsyncHandler, String> handler, final Class entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn) { Map rs = queryColumnMap(entityClass, keyColumn, func, funcColumn); if (handler != null) handler.completed(rs, keyColumn); } @@ -1387,8 +1387,8 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnMap(final AsyncHandler, String> handler, final Class entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean) { - queryColumnMap(handler, entityClass, keyColumn, func, funcColumn, FilterNodeBean.createFilterNode(bean)); + public void queryColumnMapAsync(final AsyncHandler, String> handler, final Class entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean) { + queryColumnMapAsync(handler, entityClass, keyColumn, func, funcColumn, FilterNodeBean.createFilterNode(bean)); } @Override @@ -1431,12 +1431,12 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnMap(final AsyncHandler, String> handler, final Class entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node) { + public void queryColumnMapAsync(final AsyncHandler, String> handler, final Class entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node) { Map rs = queryColumnMap(entityClass, keyColumn, func, funcColumn, node); if (handler != null) handler.completed(rs, keyColumn); } - //-----------------------find---------------------------- + //-----------------------findAsync---------------------------- /** * 根据主键获取对象 * @@ -1452,7 +1452,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void find(final AsyncHandler handler, final Class clazz, @RpcAttachment final Serializable pk) { + public void findAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final Serializable pk) { T rs = find(clazz, pk); if (handler != null) handler.completed(rs, pk); } @@ -1490,7 +1490,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void find(final AsyncHandler handler, final Class clazz, SelectColumn selects, @RpcAttachment final Serializable pk) { + public void findAsync(final AsyncHandler handler, final Class clazz, SelectColumn selects, @RpcAttachment final Serializable pk) { T rs = find(clazz, selects, pk); if (handler != null) handler.completed(rs, pk); } @@ -1501,7 +1501,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void find(final AsyncHandler handler, final Class clazz, final String column, @RpcAttachment final Serializable key) { + public void findAsync(final AsyncHandler handler, final Class clazz, final String column, @RpcAttachment final Serializable key) { T rs = find(clazz, column, key); if (handler != null) handler.completed(rs, key); } @@ -1512,7 +1512,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void find(final AsyncHandler handler, final Class clazz, @RpcAttachment final B bean) { + public void findAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final B bean) { T rs = find(clazz, bean); if (handler != null) handler.completed(rs, bean); } @@ -1523,7 +1523,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void find(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node) { + public void findAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node) { T rs = find(clazz, node); if (handler != null) handler.completed(rs, node); } @@ -1534,7 +1534,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void find(final AsyncHandler handler, final Class clazz, final SelectColumn selects, @RpcAttachment final B bean) { + public void findAsync(final AsyncHandler handler, final Class clazz, final SelectColumn selects, @RpcAttachment final B bean) { T rs = find(clazz, selects, bean); if (handler != null) handler.completed(rs, bean); } @@ -1572,7 +1572,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void find(final AsyncHandler handler, final Class clazz, final SelectColumn selects, @RpcAttachment final FilterNode node) { + public void findAsync(final AsyncHandler handler, final Class clazz, final SelectColumn selects, @RpcAttachment final FilterNode node) { T rs = find(clazz, selects, node); if (handler != null) handler.completed(rs, node); } @@ -1583,7 +1583,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, @RpcAttachment final Serializable pk) { + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, @RpcAttachment final Serializable pk) { Serializable rs = findColumn(clazz, column, pk); if (handler != null) handler.completed(rs, pk); } @@ -1594,7 +1594,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, @RpcAttachment final B bean) { + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, @RpcAttachment final B bean) { Serializable rs = findColumn(clazz, column, bean); if (handler != null) handler.completed(rs, bean); } @@ -1605,7 +1605,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, @RpcAttachment final FilterNode node) { + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, @RpcAttachment final FilterNode node) { Serializable rs = findColumn(clazz, column, node); if (handler != null) handler.completed(rs, node); } @@ -1651,7 +1651,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, @RpcAttachment final Serializable pk) { + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, @RpcAttachment final Serializable pk) { Serializable rs = findColumn(clazz, column, defValue, pk); if (handler != null) handler.completed(rs, pk); } @@ -1662,7 +1662,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, @RpcAttachment final B bean) { + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, @RpcAttachment final B bean) { Serializable rs = findColumn(clazz, column, defValue, bean); if (handler != null) handler.completed(rs, bean); } @@ -1708,7 +1708,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, @RpcAttachment final FilterNode node) { + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, @RpcAttachment final FilterNode node) { Serializable rs = findColumn(clazz, column, defValue, node); if (handler != null) handler.completed(rs, node); } @@ -1748,7 +1748,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void exists(final AsyncHandler handler, final Class clazz, @RpcAttachment final Serializable pk) { + public void existsAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final Serializable pk) { boolean rs = exists(clazz, pk); if (handler != null) handler.completed(rs, pk); } @@ -1759,7 +1759,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void exists(final AsyncHandler handler, final Class clazz, @RpcAttachment final B bean) { + public void existsAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final B bean) { boolean rs = exists(clazz, bean); if (handler != null) handler.completed(rs, bean); } @@ -1799,7 +1799,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void exists(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node) { + public void existsAsync(final AsyncHandler handler, final Class clazz, @RpcAttachment final FilterNode node) { boolean rs = exists(clazz, node); if (handler != null) handler.completed(rs, node); } @@ -1811,7 +1811,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnSet(final AsyncHandler, String> handler, final String selectedColumn, final Class clazz, @RpcAttachment final String column, final Serializable key) { + public void queryColumnSetAsync(final AsyncHandler, String> handler, final String selectedColumn, final Class clazz, @RpcAttachment final String column, final Serializable key) { HashSet rs = queryColumnSet(selectedColumn, clazz, column, key); if (handler != null) handler.completed(rs, column); } @@ -1822,7 +1822,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnSet(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, @RpcAttachment final B bean) { + public void queryColumnSetAsync(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, @RpcAttachment final B bean) { HashSet rs = queryColumnSet(selectedColumn, clazz, bean); if (handler != null) handler.completed(rs, bean); } @@ -1833,7 +1833,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnSet(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, @RpcAttachment final FilterNode node) { + public void queryColumnSetAsync(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, @RpcAttachment final FilterNode node) { HashSet rs = queryColumnSet(selectedColumn, clazz, node); if (handler != null) handler.completed(rs, node); } @@ -1844,7 +1844,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnList(final AsyncHandler, Serializable> handler, final String selectedColumn, final Class clazz, final String column, @RpcAttachment final Serializable key) { + public void queryColumnListAsync(final AsyncHandler, Serializable> handler, final String selectedColumn, final Class clazz, final String column, @RpcAttachment final Serializable key) { List rs = queryColumnList(selectedColumn, clazz, column, key); if (handler != null) handler.completed(rs, key); } @@ -1855,7 +1855,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnList(final AsyncHandler, B> handler, String selectedColumn, Class clazz, @RpcAttachment B bean) { + public void queryColumnListAsync(final AsyncHandler, B> handler, String selectedColumn, Class clazz, @RpcAttachment B bean) { List rs = queryColumnList(selectedColumn, clazz, bean); if (handler != null) handler.completed(rs, bean); } @@ -1866,7 +1866,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnList(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, @RpcAttachment final FilterNode node) { + public void queryColumnListAsync(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, @RpcAttachment final FilterNode node) { List rs = queryColumnList(selectedColumn, clazz, node); if (handler != null) handler.completed(rs, node); } @@ -1877,7 +1877,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnList(final AsyncHandler, B> handler, String selectedColumn, Class clazz, Flipper flipper, @RpcAttachment B bean) { + public void queryColumnListAsync(final AsyncHandler, B> handler, String selectedColumn, Class clazz, Flipper flipper, @RpcAttachment B bean) { List rs = queryColumnList(selectedColumn, clazz, flipper, bean); if (handler != null) handler.completed(rs, bean); } @@ -1888,7 +1888,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnList(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, Flipper flipper, @RpcAttachment final FilterNode node) { + public void queryColumnListAsync(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, Flipper flipper, @RpcAttachment final FilterNode node) { List rs = queryColumnList(selectedColumn, clazz, flipper, node); if (handler != null) handler.completed(rs, node); } @@ -1911,7 +1911,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnSheet(final AsyncHandler, B> handler, String selectedColumn, Class clazz, Flipper flipper, @RpcAttachment B bean) { + public void queryColumnSheetAsync(final AsyncHandler, B> handler, String selectedColumn, Class clazz, Flipper flipper, @RpcAttachment B bean) { Sheet rs = queryColumnSheet(selectedColumn, clazz, flipper, bean); if (handler != null) handler.completed(rs, bean); } @@ -1922,7 +1922,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryColumnSheet(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final Flipper flipper, @RpcAttachment final FilterNode node) { + public void queryColumnSheetAsync(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final Flipper flipper, @RpcAttachment final FilterNode node) { Sheet rs = queryColumnSheet(selectedColumn, clazz, flipper, node); if (handler != null) handler.completed(rs, node); } @@ -1958,7 +1958,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, Serializable> handler, final Class clazz, final String column, @RpcAttachment final Serializable key) { + public void queryListAsync(final AsyncHandler, Serializable> handler, final Class clazz, final String column, @RpcAttachment final Serializable key) { List rs = queryList(clazz, column, key); if (handler != null) handler.completed(rs, key); } @@ -1978,7 +1978,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, B> handler, final Class clazz, @RpcAttachment final B bean) { + public void queryListAsync(final AsyncHandler, B> handler, final Class clazz, @RpcAttachment final B bean) { List rs = queryList(clazz, bean); if (handler != null) handler.completed(rs, bean); } @@ -1989,7 +1989,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, FilterNode> handler, final Class clazz, @RpcAttachment final FilterNode node) { + public void queryListAsync(final AsyncHandler, FilterNode> handler, final Class clazz, @RpcAttachment final FilterNode node) { List rs = queryList(clazz, node); if (handler != null) handler.completed(rs, node); } @@ -2010,7 +2010,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, @RpcAttachment final B bean) { + public void queryListAsync(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, @RpcAttachment final B bean) { List rs = queryList(clazz, selects, bean); if (handler != null) handler.completed(rs, bean); } @@ -2021,7 +2021,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, @RpcAttachment final FilterNode node) { + public void queryListAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, @RpcAttachment final FilterNode node) { List rs = queryList(clazz, selects, node); if (handler != null) handler.completed(rs, node); } @@ -2032,7 +2032,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, Serializable> handler, final Class clazz, final Flipper flipper, final String column, @RpcAttachment final Serializable key) { + public void queryListAsync(final AsyncHandler, Serializable> handler, final Class clazz, final Flipper flipper, final String column, @RpcAttachment final Serializable key) { List rs = queryList(clazz, flipper, column, key); if (handler != null) handler.completed(rs, key); } @@ -2043,7 +2043,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, B> handler, final Class clazz, final Flipper flipper, @RpcAttachment final B bean) { + public void queryListAsync(final AsyncHandler, B> handler, final Class clazz, final Flipper flipper, @RpcAttachment final B bean) { List rs = queryList(clazz, flipper, bean); if (handler != null) handler.completed(rs, bean); } @@ -2054,7 +2054,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, FilterNode> handler, final Class clazz, final Flipper flipper, @RpcAttachment final FilterNode node) { + public void queryListAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final Flipper flipper, @RpcAttachment final FilterNode node) { List rs = queryList(clazz, flipper, node); if (handler != null) handler.completed(rs, node); } @@ -2065,7 +2065,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final B bean) { + public void queryListAsync(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final B bean) { List rs = queryList(clazz, selects, flipper, bean); if (handler != null) handler.completed(rs, bean); } @@ -2076,7 +2076,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void queryList(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final FilterNode node) { + public void queryListAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final FilterNode node) { List rs = queryList(clazz, selects, flipper, node); if (handler != null) handler.completed(rs, node); } @@ -2098,7 +2098,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void querySheet(final AsyncHandler, B> handler, final Class clazz, final Flipper flipper, @RpcAttachment final B bean) { + public void querySheetAsync(final AsyncHandler, B> handler, final Class clazz, final Flipper flipper, @RpcAttachment final B bean) { Sheet rs = querySheet(clazz, flipper, bean); if (handler != null) handler.completed(rs, bean); } @@ -2109,7 +2109,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void querySheet(final AsyncHandler, FilterNode> handler, final Class clazz, final Flipper flipper, @RpcAttachment final FilterNode node) { + public void querySheetAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final Flipper flipper, @RpcAttachment final FilterNode node) { Sheet rs = querySheet(clazz, flipper, node); if (handler != null) handler.completed(rs, node); } @@ -2131,7 +2131,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void querySheet(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final B bean) { + public void querySheetAsync(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final B bean) { Sheet rs = querySheet(clazz, selects, flipper, bean); if (handler != null) handler.completed(rs, bean); } @@ -2142,7 +2142,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi } @Override - public void querySheet(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final FilterNode node) { + public void querySheetAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final FilterNode node) { Sheet rs = querySheet(clazz, selects, flipper, node); if (handler != null) handler.completed(rs, node); } diff --git a/src/org/redkale/source/DataSource.java b/src/org/redkale/source/DataSource.java index 729ba83d8..0c19540c6 100644 --- a/src/org/redkale/source/DataSource.java +++ b/src/org/redkale/source/DataSource.java @@ -24,7 +24,7 @@ import org.redkale.util.*; @SuppressWarnings("unchecked") public interface DataSource { - //----------------------insert----------------------------- + //----------------------insertAsync----------------------------- /** * 新增记录, 多对象必须是同一个Entity类
* @@ -40,9 +40,9 @@ public interface DataSource { * @param handler 回调函数 * @param values Entity对象 */ - public void insert(final AsyncHandler handler, final T... values); + public void insertAsync(final AsyncHandler handler, final T... values); - //-------------------------delete-------------------------- + //-------------------------deleteAsync-------------------------- /** * 删除指定主键值的记录, 多对象必须是同一个Entity类
* 等价SQL: DELETE FROM {table} WHERE {primary} IN {values.id}
@@ -64,7 +64,7 @@ public interface DataSource { * * */ - public void delete(final AsyncHandler handler, final T... values); + public void deleteAsync(final AsyncHandler handler, final T... values); /** * 删除指定主键值的记录
@@ -89,7 +89,7 @@ public interface DataSource { * * */ - public void delete(final AsyncHandler handler, final Class clazz, final Serializable... ids); + public void deleteAsync(final AsyncHandler handler, final Class clazz, final Serializable... ids); /** * 删除符合过滤条件的记录
@@ -114,7 +114,7 @@ public interface DataSource { * * */ - public void delete(final AsyncHandler handler, final Class clazz, final FilterNode node); + public void deleteAsync(final AsyncHandler handler, final Class clazz, final FilterNode node); /** * 删除符合过滤条件且指定最大影响条数的记录
@@ -143,9 +143,9 @@ public interface DataSource { * * */ - public void delete(final AsyncHandler handler, final Class clazz, final Flipper flipper, final FilterNode node); + public void deleteAsync(final AsyncHandler handler, final Class clazz, final Flipper flipper, final FilterNode node); - //------------------------update--------------------------- + //------------------------updateAsync--------------------------- /** * 更新记录, 多对象必须是同一个Entity类
* 等价SQL:
@@ -173,7 +173,7 @@ public interface DataSource { * * */ - public void update(final AsyncHandler handler, final T... values); + public void updateAsync(final AsyncHandler handler, final T... values); /** * 更新单个记录的单个字段
@@ -204,7 +204,7 @@ public interface DataSource { * * */ - public void updateColumn(final AsyncHandler handler, final Class clazz, final Serializable id, final String column, final Serializable value); + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, final Serializable id, final String column, final Serializable value); /** * 更新符合过滤条件记录的单个字段
@@ -235,7 +235,7 @@ public interface DataSource { * * */ - public void updateColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable value, final FilterNode node); + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable value, final FilterNode node); /** * 更新指定主键值记录的部分字段
@@ -264,7 +264,7 @@ public interface DataSource { * * */ - public void updateColumn(final AsyncHandler handler, final Class clazz, final Serializable id, final ColumnValue... values); + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, final Serializable id, final ColumnValue... values); /** * 更新符合过滤条件记录的部分字段
@@ -295,7 +295,7 @@ public interface DataSource { * * */ - public void updateColumn(final AsyncHandler handler, final Class clazz, final FilterNode node, final ColumnValue... values); + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, final FilterNode node, final ColumnValue... values); /** * 更新符合过滤条件的记录的指定字段
@@ -328,7 +328,7 @@ public interface DataSource { * * */ - public void updateColumn(final AsyncHandler handler, final Class clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values); + public void updateColumnAsync(final AsyncHandler handler, final Class clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values); /** * 更新单个记录的指定字段
@@ -354,7 +354,7 @@ public interface DataSource { * @param columns 需更新的字段名 * */ - public void updateColumn(final AsyncHandler handler, final T bean, final String... columns); + public void updateColumnAsync(final AsyncHandler handler, final T bean, final String... columns); /** * 更新符合过滤条件记录的指定字段
@@ -383,7 +383,7 @@ public interface DataSource { * * */ - public void updateColumn(final AsyncHandler handler, final T bean, final FilterNode node, final String... columns); + public void updateColumnAsync(final AsyncHandler handler, final T bean, final FilterNode node, final String... columns); /** * 更新单个记录的指定字段
@@ -410,7 +410,7 @@ public interface DataSource { * * */ - public void updateColumn(final AsyncHandler handler, final T bean, final SelectColumn selects); + public void updateColumnAsync(final AsyncHandler handler, final T bean, final SelectColumn selects); /** * 更新符合过滤条件记录的指定字段
@@ -439,14 +439,14 @@ public interface DataSource { * * */ - public void updateColumn(final AsyncHandler handler, final T bean, final FilterNode node, final SelectColumn selects); + public void updateColumnAsync(final AsyncHandler handler, final T bean, final FilterNode node, final SelectColumn selects); //############################################# 查询接口 ############################################# //-----------------------getXXXXResult----------------------------- /** * 获取符合过滤条件记录的聚合结果, 无结果返回null
* 等价SQL: SELECT FUNC{column} FROM {table}
- * 如 getNumberResult(Record.class, FilterFunc.COUNT, null) 等价于: SELECT COUNT(*) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.COUNT, null) 等价于: SELECT COUNT(*) FROM {table}
* * @param entityClass Entity类 * @param func 聚合函数 @@ -459,7 +459,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果, 无结果返回null
* 等价SQL: SELECT FUNC{column} FROM {table}
- * 如 getNumberResult(Record.class, FilterFunc.COUNT, null) 等价于: SELECT COUNT(*) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.COUNT, null) 等价于: SELECT COUNT(*) FROM {table}
* * @param handler 回调函数 * @param entityClass Entity类 @@ -468,12 +468,12 @@ public interface DataSource { * * */ - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column); + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column); /** * 获取符合过滤条件记录的聚合结果, 无结果返回null
* 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean}
- * 如 getNumberResult(Record.class, FilterFunc.COUNT, null, (FilterBean)null) 等价于: SELECT COUNT(*) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.COUNT, null, (FilterBean)null) 等价于: SELECT COUNT(*) FROM {table}
* * @param entityClass Entity类 * @param func 聚合函数 @@ -487,7 +487,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果, 无结果返回null
* 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean}
- * 如 getNumberResult(Record.class, FilterFunc.COUNT, null, (FilterBean)null) 等价于: SELECT COUNT(*) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.COUNT, null, (FilterBean)null) 等价于: SELECT COUNT(*) FROM {table}
* * @param Filter泛型 * @param handler 回调函数 @@ -498,12 +498,12 @@ public interface DataSource { * * */ - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column, final B bean); + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column, final B bean); /** * 获取符合过滤条件记录的聚合结果, 无结果返回null
* 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}
- * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
* * @param entityClass Entity类 * @param func 聚合函数 @@ -517,7 +517,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果, 无结果返回null
* 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}
- * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
* * @param handler 回调函数 * @param entityClass Entity类 @@ -527,12 +527,12 @@ public interface DataSource { * * */ - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column, final FilterNode node); + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final String column, final FilterNode node); /** * 获取符合过滤条件记录的聚合结果, 无结果返回默认值
* 等价SQL: SELECT FUNC{column} FROM {table}
- * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime") 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime") 等价于: SELECT MAX(createtime) FROM {table}
* * @param entityClass Entity类 * @param func 聚合函数 @@ -546,7 +546,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果, 无结果返回默认值
* 等价SQL: SELECT FUNC{column} FROM {table}
- * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime") 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime") 等价于: SELECT MAX(createtime) FROM {table}
* * @param handler 回调函数 * @param entityClass Entity类 @@ -555,12 +555,12 @@ public interface DataSource { * @param column 指定字段 * */ - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column); + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column); /** * 获取符合过滤条件记录的聚合结果, 无结果返回默认值
* 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean}
- * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
* * @param entityClass Entity类 * @param func 聚合函数 @@ -575,7 +575,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果, 无结果返回默认值
* 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean}
- * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
* * @param handler 回调函数 * @param entityClass Entity类 @@ -585,12 +585,12 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterBean bean); + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterBean bean); /** * 获取符合过滤条件记录的聚合结果, 无结果返回默认值
* 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}
- * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
* * @param entityClass Entity类 * @param func 聚合函数 @@ -605,7 +605,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果, 无结果返回默认值
* 等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}
- * 如 getNumberResult(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
* * @param handler 回调函数 * @param entityClass Entity类 @@ -616,12 +616,12 @@ public interface DataSource { * * */ - public void getNumberResult(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node); + public void getNumberResultAsync(final AsyncHandler handler, final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node); /** * 获取符合过滤条件记录的聚合结果Map
* 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table}
- * 如 getNumberMap(Record.class, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberMapAsync(Record.class, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
* * @param Number * @param entityClass Entity类 @@ -634,7 +634,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果Map
* 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table}
- * 如 getNumberMap(Record.class, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberMapAsync(Record.class, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
* * @param Number * @param handler 回调函数 @@ -642,12 +642,12 @@ public interface DataSource { * @param columns 聚合字段 * */ - public void getNumberMap(final AsyncHandler, FilterFuncColumn[]> handler, final Class entityClass, final FilterFuncColumn... columns); + public void getNumberMapAsync(final AsyncHandler, FilterFuncColumn[]> handler, final Class entityClass, final FilterFuncColumn... columns); /** * 获取符合过滤条件记录的聚合结果Map
* 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter bean}
- * 如 getNumberMap(Record.class, (FilterBean)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberMapAsync(Record.class, (FilterBean)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
* * @param Number * @param entityClass Entity类 @@ -661,7 +661,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果Map
* 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter bean}
- * 如 getNumberMap(Record.class, (FilterBean)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberMapAsync(Record.class, (FilterBean)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
* * @param Number * @param Filter泛型 @@ -671,12 +671,12 @@ public interface DataSource { * @param columns 聚合字段 * */ - public void getNumberMap(final AsyncHandler, B> handler, final Class entityClass, final B bean, final FilterFuncColumn... columns); + public void getNumberMapAsync(final AsyncHandler, B> handler, final Class entityClass, final B bean, final FilterFuncColumn... columns); /** * 获取符合过滤条件记录的聚合结果Map
* 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter node}
- * 如 getNumberMap(Record.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberMapAsync(Record.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
* * @param Number * @param entityClass Entity类 @@ -690,7 +690,7 @@ public interface DataSource { /** * 获取符合过滤条件记录的聚合结果Map
* 等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter node}
- * 如 getNumberMap(Record.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
+ * 如 getNumberMapAsync(Record.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
* * @param Number * @param handler 回调函数 @@ -699,12 +699,12 @@ public interface DataSource { * @param columns 聚合字段 * */ - public void getNumberMap(final AsyncHandler, FilterNode> handler, final Class entityClass, final FilterNode node, final FilterFuncColumn... columns); + public void getNumberMapAsync(final AsyncHandler, FilterNode> handler, final Class entityClass, final FilterNode node, final FilterFuncColumn... columns); /** * 查询符合过滤条件记录的GROUP BY聚合结果Map
* 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} GROUP BY {keyColumn}
- * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime") 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
+ * 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime") 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
* * @param Entity泛型 * @param Key字段的数据类型 @@ -721,7 +721,7 @@ public interface DataSource { /** * 查询符合过滤条件记录的GROUP BY聚合结果Map
* 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} GROUP BY {keyColumn}
- * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime") 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
+ * 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime") 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
* * @param Entity泛型 * @param Key字段的数据类型 @@ -733,12 +733,12 @@ public interface DataSource { * @param funcColumn 聚合字段 * */ - public void queryColumnMap(final AsyncHandler, String> handler, final Class entityClass, final String keyColumn, final FilterFunc func, final String funcColumn); + public void queryColumnMapAsync(final AsyncHandler, String> handler, final Class entityClass, final String keyColumn, final FilterFunc func, final String funcColumn); /** * 查询符合过滤条件记录的GROUP BY聚合结果Map
* 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter bean} GROUP BY {keyColumn}
- * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime", (FilterBean)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
+ * 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime", (FilterBean)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
* * @param Entity泛型 * @param Key字段的数据类型 @@ -756,7 +756,7 @@ public interface DataSource { /** * 查询符合过滤条件记录的GROUP BY聚合结果Map
* 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter bean} GROUP BY {keyColumn}
- * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime", (FilterBean)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
+ * 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime", (FilterBean)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
* * @param Entity泛型 * @param Key字段的数据类型 @@ -769,12 +769,12 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryColumnMap(final AsyncHandler, String> handler, final Class entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean); + public void queryColumnMapAsync(final AsyncHandler, String> handler, final Class entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean); /** * 查询符合过滤条件记录的GROUP BY聚合结果Map
* 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter node} GROUP BY {keyColumn}
- * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
+ * 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
* * @param Entity泛型 * @param Key字段的数据类型 @@ -792,7 +792,7 @@ public interface DataSource { /** * 查询符合过滤条件记录的GROUP BY聚合结果Map
* 等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter node} GROUP BY {keyColumn}
- * 如 queryColumnMap(Record.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
+ * 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name
* * @param Entity泛型 * @param Key字段的数据类型 @@ -805,9 +805,9 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryColumnMap(final AsyncHandler, String> handler, final Class entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node); + public void queryColumnMapAsync(final AsyncHandler, String> handler, final Class entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node); - //-----------------------find---------------------------- + //-----------------------findAsync---------------------------- /** * 获取指定主键值的单个记录, 返回null表示不存在值
* 等价SQL: SELECT * FROM {table} WHERE {primary} = {id}
@@ -830,7 +830,7 @@ public interface DataSource { * @param pk 主键值 * */ - public void find(final AsyncHandler handler, final Class clazz, final Serializable pk); + public void findAsync(final AsyncHandler handler, final Class clazz, final Serializable pk); /** * 获取指定主键值的单个记录, 返回null表示不存在值
@@ -856,7 +856,7 @@ public interface DataSource { * @param pk 主键值 * */ - public void find(final AsyncHandler handler, final Class clazz, final SelectColumn selects, final Serializable pk); + public void findAsync(final AsyncHandler handler, final Class clazz, final SelectColumn selects, final Serializable pk); /** * 获取符合过滤条件单个记录, 返回null表示不存在值
@@ -882,7 +882,7 @@ public interface DataSource { * @param key 过滤字段值 * */ - public void find(final AsyncHandler handler, final Class clazz, final String column, final Serializable key); + public void findAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable key); /** * 获取符合过滤条件单个记录, 返回null表示不存在值
@@ -907,7 +907,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void find(final AsyncHandler handler, final Class clazz, final B bean); + public void findAsync(final AsyncHandler handler, final Class clazz, final B bean); /** * 获取符合过滤条件单个记录, 返回null表示不存在值
@@ -931,7 +931,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void find(final AsyncHandler handler, final Class clazz, final FilterNode node); + public void findAsync(final AsyncHandler handler, final Class clazz, final FilterNode node); /** * 获取符合过滤条件单个记录, 返回null表示不存在值
@@ -958,7 +958,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void find(final AsyncHandler handler, final Class clazz, final SelectColumn selects, final B bean); + public void findAsync(final AsyncHandler handler, final Class clazz, final SelectColumn selects, final B bean); /** * 获取符合过滤条件单个记录, 返回null表示不存在值
@@ -984,7 +984,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void find(final AsyncHandler handler, final Class clazz, final SelectColumn selects, final FilterNode node); + public void findAsync(final AsyncHandler handler, final Class clazz, final SelectColumn selects, final FilterNode node); /** * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
@@ -1010,7 +1010,7 @@ public interface DataSource { * @param pk 主键值 * */ - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable pk); + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable pk); /** * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
@@ -1037,7 +1037,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final B bean); + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final B bean); /** * 获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
@@ -1063,7 +1063,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final FilterNode node); + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final FilterNode node); /** * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
@@ -1091,7 +1091,7 @@ public interface DataSource { * @param pk 主键值 * */ - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, final Serializable pk); + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, final Serializable pk); /** * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
@@ -1120,7 +1120,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, final B bean); + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, final B bean); /** * 获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
@@ -1148,7 +1148,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void findColumn(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, final FilterNode node); + public void findColumnAsync(final AsyncHandler handler, final Class clazz, final String column, final Serializable defValue, final FilterNode node); /** * 判断是否存在主键值的记录
@@ -1172,7 +1172,7 @@ public interface DataSource { * @param pk 主键值 * */ - public void exists(final AsyncHandler handler, final Class clazz, final Serializable pk); + public void existsAsync(final AsyncHandler handler, final Class clazz, final Serializable pk); /** * 判断是否存在符合过滤条件的记录
@@ -1197,7 +1197,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void exists(final AsyncHandler handler, final Class clazz, final B bean); + public void existsAsync(final AsyncHandler handler, final Class clazz, final B bean); /** * 判断是否存在符合过滤条件的记录
@@ -1221,7 +1221,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void exists(final AsyncHandler handler, final Class clazz, final FilterNode node); + public void existsAsync(final AsyncHandler handler, final Class clazz, final FilterNode node); //-----------------------list set---------------------------- /** @@ -1252,7 +1252,7 @@ public interface DataSource { * @param key 过滤字段值 * */ - public void queryColumnSet(final AsyncHandler, String> handler, final String selectedColumn, final Class clazz, final String column, final Serializable key); + public void queryColumnSetAsync(final AsyncHandler, String> handler, final String selectedColumn, final Class clazz, final String column, final Serializable key); /** * 查询符合过滤条件记录的某个字段Set集合
@@ -1281,7 +1281,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryColumnSet(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, final B bean); + public void queryColumnSetAsync(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, final B bean); /** * 查询符合过滤条件记录的某个字段Set集合
@@ -1309,7 +1309,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryColumnSet(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final FilterNode node); + public void queryColumnSetAsync(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final FilterNode node); /** * 查询符合过滤条件记录的某个字段List集合
@@ -1339,7 +1339,7 @@ public interface DataSource { * @param key 过滤字段值 * */ - public void queryColumnList(final AsyncHandler, Serializable> handler, final String selectedColumn, final Class clazz, final String column, final Serializable key); + public void queryColumnListAsync(final AsyncHandler, Serializable> handler, final String selectedColumn, final Class clazz, final String column, final Serializable key); /** * 查询符合过滤条件记录的某个字段List集合
@@ -1368,7 +1368,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryColumnList(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, final B bean); + public void queryColumnListAsync(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, final B bean); /** * 查询符合过滤条件记录的某个字段List集合
@@ -1396,7 +1396,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryColumnList(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final FilterNode node); + public void queryColumnListAsync(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final FilterNode node); /** * 查询符合过滤条件记录的某个字段List集合
@@ -1427,7 +1427,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryColumnList(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, final Flipper flipper, final B bean); + public void queryColumnListAsync(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, final Flipper flipper, final B bean); /** * 查询符合过滤条件记录的某个字段List集合
@@ -1457,7 +1457,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryColumnList(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final Flipper flipper, final FilterNode node); + public void queryColumnListAsync(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final Flipper flipper, final FilterNode node); /** * 查询符合过滤条件记录的某个字段Sheet集合
@@ -1488,7 +1488,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryColumnSheet(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, final Flipper flipper, final B bean); + public void queryColumnSheetAsync(final AsyncHandler, B> handler, final String selectedColumn, final Class clazz, final Flipper flipper, final B bean); /** * 查询符合过滤条件记录的某个字段Sheet集合
@@ -1518,7 +1518,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryColumnSheet(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final Flipper flipper, final FilterNode node); + public void queryColumnSheetAsync(final AsyncHandler, FilterNode> handler, final String selectedColumn, final Class clazz, final Flipper flipper, final FilterNode node); /** * 查询符合过滤条件记录的List集合
@@ -1544,7 +1544,7 @@ public interface DataSource { * @param key 过滤字段值 * */ - public void queryList(final AsyncHandler, Serializable> handler, final Class clazz, final String column, final Serializable key); + public void queryListAsync(final AsyncHandler, Serializable> handler, final Class clazz, final String column, final Serializable key); /** * 查询符合过滤条件记录的List集合
@@ -1569,7 +1569,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryList(final AsyncHandler, B> handler, final Class clazz, final B bean); + public void queryListAsync(final AsyncHandler, B> handler, final Class clazz, final B bean); /** * 查询符合过滤条件记录的List集合
@@ -1593,7 +1593,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryList(final AsyncHandler, FilterNode> handler, final Class clazz, final FilterNode node); + public void queryListAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final FilterNode node); /** * 查询符合过滤条件记录的List集合
@@ -1620,7 +1620,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryList(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final B bean); + public void queryListAsync(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final B bean); /** * 查询符合过滤条件记录的List集合
@@ -1646,7 +1646,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryList(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final FilterNode node); + public void queryListAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final FilterNode node); /** * 查询符合过滤条件记录的List集合
@@ -1674,7 +1674,7 @@ public interface DataSource { * @param key 过滤字段值 * */ - public void queryList(final AsyncHandler, Serializable> handler, final Class clazz, final Flipper flipper, final String column, final Serializable key); + public void queryListAsync(final AsyncHandler, Serializable> handler, final Class clazz, final Flipper flipper, final String column, final Serializable key); /** * 查询符合过滤条件记录的List集合
@@ -1701,7 +1701,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryList(final AsyncHandler, B> handler, final Class clazz, final Flipper flipper, final B bean); + public void queryListAsync(final AsyncHandler, B> handler, final Class clazz, final Flipper flipper, final B bean); /** * 查询符合过滤条件记录的List集合
@@ -1729,7 +1729,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryList(final AsyncHandler, FilterNode> handler, final Class clazz, final Flipper flipper, final FilterNode node); + public void queryListAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final Flipper flipper, final FilterNode node); /** * 查询符合过滤条件记录的List集合
@@ -1758,7 +1758,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void queryList(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, final B bean); + public void queryListAsync(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, final B bean); /** * 查询符合过滤条件记录的List集合
@@ -1786,7 +1786,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void queryList(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node); + public void queryListAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node); //-----------------------sheet---------------------------- /** @@ -1814,7 +1814,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void querySheet(final AsyncHandler, B> handler, final Class clazz, final Flipper flipper, final B bean); + public void querySheetAsync(final AsyncHandler, B> handler, final Class clazz, final Flipper flipper, final B bean); /** * 查询符合过滤条件记录的Sheet集合
@@ -1840,7 +1840,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void querySheet(final AsyncHandler, FilterNode> handler, final Class clazz, final Flipper flipper, final FilterNode node); + public void querySheetAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final Flipper flipper, final FilterNode node); /** * 查询符合过滤条件记录的Sheet集合
@@ -1869,7 +1869,7 @@ public interface DataSource { * @param bean 过滤条件 * */ - public void querySheet(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, final B bean); + public void querySheetAsync(final AsyncHandler, B> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, final B bean); /** * 查询符合过滤条件记录的Sheet集合
@@ -1897,7 +1897,7 @@ public interface DataSource { * @param node 过滤条件 * */ - public void querySheet(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node); + public void querySheetAsync(final AsyncHandler, FilterNode> handler, final Class clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node); //-----------------------direct---------------------------- /** diff --git a/test/org/redkale/test/rest/HelloService.java b/test/org/redkale/test/rest/HelloService.java index 6bbd8ab6f..c0d944f86 100644 --- a/test/org/redkale/test/rest/HelloService.java +++ b/test/org/redkale/test/rest/HelloService.java @@ -87,7 +87,7 @@ public class HelloService implements Service { //异步查询单个 @RestMapping(name = "asyncfind") public void findHello(AsyncHandler handler, @RestParam(name = "#") int id) { //通过 /pipes/hello/find/1234、/pipes/hello/jsfind/1234 查询对象 - if (source != null) source.find(handler, HelloEntity.class, id); + if (source != null) source.findAsync(handler, HelloEntity.class, id); HelloEntity rs = new HelloEntity(); rs.setHelloname("Hello名称"); if (handler != null) handler.completed(rs, null);