DBChannel
- 数据库连接@Local @AutoLoad(value=false) @ResourceType(value=DataSource.class) public abstract class DataSqlSource<DBChannel> extends AbstractService implements DataSource, DataCacheListener, java.util.function.Function<java.lang.Class,EntityInfo>, java.lang.AutoCloseable, Resourcable
详情见: https://redkale.org
限定符和类型 | 字段和说明 |
---|---|
protected ObjectPool<java.nio.ByteBuffer> |
bufferPool |
protected boolean |
cacheForbidden |
protected DataCacheListener |
cacheListener |
protected java.util.concurrent.ThreadPoolExecutor |
executor |
protected static Flipper |
FLIPPER_ONE |
protected java.util.function.BiFunction<DataSource,java.lang.Class,java.util.List> |
fullloader |
protected java.util.function.BiConsumer |
futureCompleteConsumer |
protected java.util.logging.Logger |
logger |
protected java.lang.String |
name |
protected java.net.URL |
persistxml |
protected PoolSource<DBChannel> |
readPool |
protected int |
threads |
protected PoolSource<DBChannel> |
writePool |
构造器和说明 |
---|
DataSqlSource(java.lang.String unitName,
java.net.URL persistxml,
java.util.Properties readprop,
java.util.Properties writeprop) |
限定符和类型 | 方法和说明 |
---|---|
EntityInfo |
apply(java.lang.Class t) |
protected <T> java.util.concurrent.CompletableFuture |
checkEntity(java.lang.String action,
boolean async,
T... entitys) |
<T> int |
clearTable(java.lang.Class<T> clazz)
清空表
等价SQL: TRUNCATE TABLE {table} |
<T> int |
clearTable(java.lang.Class<T> clazz,
FilterNode node)
清空表
等价SQL: TRUNCATE TABLE {table} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
clearTableAsync(java.lang.Class<T> clazz)
清空表
等价SQL: TRUNCATE TABLE {table} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
clearTableAsync(java.lang.Class<T> clazz,
FilterNode node)
清空表
等价SQL: TRUNCATE TABLE {table} |
protected <T> int |
clearTableCache(EntityInfo<T> info,
FilterNode node) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
clearTableCompose(EntityInfo<T> info,
FilterNode node) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
clearTableDB(EntityInfo<T> info,
java.lang.String sql) |
void |
close() |
protected abstract PoolSource<DBChannel> |
createPoolSource(DataSource source,
java.lang.String rwtype,
java.util.concurrent.ArrayBlockingQueue queue,
java.util.concurrent.Semaphore semaphore,
java.util.Properties prop) |
protected <T> java.lang.CharSequence |
createSQLExpress(FilterNode node,
EntityInfo<T> info,
java.util.Map<java.lang.Class,java.lang.String> joinTabalis) |
protected <T> java.lang.CharSequence |
createSQLJoin(FilterNode node,
java.util.function.Function<java.lang.Class,EntityInfo> func,
boolean update,
java.util.Map<java.lang.Class,java.lang.String> joinTabalis,
java.util.Set<java.lang.String> haset,
EntityInfo<T> info) |
protected <T> java.lang.String |
createSQLOrderby(EntityInfo<T> info,
Flipper flipper) |
<T> int |
delete(java.lang.Class<T> clazz,
FilterNode node)
删除符合过滤条件的记录
等价SQL: DELETE FROM {table} WHERE {filter node} |
<T> int |
delete(java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
删除符合过滤条件且指定最大影响条数的记录
Flipper中offset字段将被忽略 等价SQL: DELETE FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> int |
delete(java.lang.Class<T> clazz,
java.io.Serializable... pks)
删除指定主键值的记录,多主键值必须在同一张表中
等价SQL: DELETE FROM {table} WHERE {primary} IN {ids} |
<T> int |
delete(T... entitys)
删除对象, 必须是Entity对象
|
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
deleteAsync(java.lang.Class<T> clazz,
FilterNode node)
删除符合过滤条件的记录
等价SQL: DELETE FROM {table} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
deleteAsync(java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
删除符合过滤条件且指定最大影响条数的记录
Flipper中offset字段将被忽略 等价SQL: DELETE FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
deleteAsync(java.lang.Class<T> clazz,
java.io.Serializable... pks)
删除指定主键值的记录,多主键值必须在同一张表中
等价SQL: DELETE FROM {table} WHERE {primary} IN {ids} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
deleteAsync(T... entitys)
删除指定主键值的记录, 多对象必须是同一个Entity类且必须在同一张表中
等价SQL: DELETE FROM {table} WHERE {primary} IN {values.id} |
<T> int |
deleteCache(java.lang.Class<T> clazz,
java.io.Serializable... pks) |
protected <T> int |
deleteCache(EntityInfo<T> info,
int count,
Flipper flipper,
FilterNode node) |
protected <T> int |
deleteCache(EntityInfo<T> info,
int count,
java.io.Serializable... pks) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
deleteCompose(EntityInfo<T> info,
Flipper flipper,
FilterNode node) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
deleteCompose(EntityInfo<T> info,
java.io.Serializable... pks) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
deleteDB(EntityInfo<T> info,
Flipper flipper,
java.lang.String sql) |
void |
destroy(AnyValue config)
进程退出时,调用Service销毁
远程模式下该方法会重载成空方法
|
abstract int[] |
directExecute(java.lang.String... sqls) |
abstract int |
directExecute(java.lang.String sql) |
abstract <V> V |
directQuery(java.lang.String sql,
java.util.function.Function<java.sql.ResultSet,V> handler) |
<T> int |
dropTable(java.lang.Class<T> clazz)
删除表
等价SQL: DROP TABLE {table} |
<T> int |
dropTable(java.lang.Class<T> clazz,
FilterNode node)
删除表
等价SQL: DROP TABLE {table} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
dropTableAsync(java.lang.Class<T> clazz)
删除表
等价SQL: DROP TABLE {table} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
dropTableAsync(java.lang.Class<T> clazz,
FilterNode node)
删除表
等价SQL: DROP TABLE {table} |
protected <T> int |
dropTableCache(EntityInfo<T> info,
FilterNode node) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
dropTableCompose(EntityInfo<T> info,
FilterNode node) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
dropTableDB(EntityInfo<T> info,
java.lang.String sql) |
<T> boolean |
exists(java.lang.Class<T> clazz,
FilterBean bean)
判断是否存在符合过滤条件的记录
等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter bean} |
<T> boolean |
exists(java.lang.Class<T> clazz,
FilterNode node)
判断是否存在符合过滤条件的记录
等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter node} |
<T> boolean |
exists(java.lang.Class<T> clazz,
java.io.Serializable pk)
判断是否存在主键值的记录
等价SQL: SELECT COUNT(*) FROM {table} WHERE {primary} = {id} |
<T> java.util.concurrent.CompletableFuture<java.lang.Boolean> |
existsAsync(java.lang.Class<T> clazz,
FilterBean bean)
判断是否存在符合过滤条件的记录
等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter bean} |
<T> java.util.concurrent.CompletableFuture<java.lang.Boolean> |
existsAsync(java.lang.Class<T> clazz,
FilterNode node)
判断是否存在符合过滤条件的记录
等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.lang.Boolean> |
existsAsync(java.lang.Class<T> clazz,
java.io.Serializable pk)
判断是否存在主键值的记录
等价SQL: SELECT COUNT(*) FROM {table} WHERE {primary} = {id} |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> |
existsCompose(EntityInfo<T> info,
FilterNode node) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> |
existsCompose(EntityInfo<T> info,
java.io.Serializable pk) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> |
existsDB(EntityInfo<T> info,
java.lang.String sql,
boolean onlypk) |
<T> T |
find(java.lang.Class<T> clazz,
FilterBean bean)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT * FROM {table} WHERE {filter bean} |
<T> T |
find(java.lang.Class<T> clazz,
FilterNode node)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT * FROM {table} WHERE {filter node} |
<T> T |
find(java.lang.Class<T> clazz,
SelectColumn selects,
FilterBean bean)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter bean} |
<T> T |
find(java.lang.Class<T> clazz,
SelectColumn selects,
FilterNode node)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} |
<T> T |
find(java.lang.Class<T> clazz,
SelectColumn selects,
java.io.Serializable pk)
获取指定主键值的单个记录, 返回null表示不存在值
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id} |
<T> T |
find(java.lang.Class<T> clazz,
java.io.Serializable pk)
根据主键获取对象
|
<T> T |
find(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT * FROM {table} WHERE {column} = {key} |
<T> java.util.concurrent.CompletableFuture<T> |
findAsync(java.lang.Class<T> clazz,
FilterBean bean)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT * FROM {table} WHERE {filter bean} |
<T> java.util.concurrent.CompletableFuture<T> |
findAsync(java.lang.Class<T> clazz,
FilterNode node)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT * FROM {table} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<T> |
findAsync(java.lang.Class<T> clazz,
SelectColumn selects,
FilterBean bean)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter bean} |
<T> java.util.concurrent.CompletableFuture<T> |
findAsync(java.lang.Class<T> clazz,
SelectColumn selects,
FilterNode node)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<T> |
findAsync(java.lang.Class<T> clazz,
SelectColumn selects,
java.io.Serializable pk)
获取指定主键值的单个记录, 返回null表示不存在值
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id} |
<T> java.util.concurrent.CompletableFuture<T> |
findAsync(java.lang.Class<T> clazz,
java.io.Serializable pk)
获取指定主键值的单个记录, 返回null表示不存在值
等价SQL: SELECT * FROM {table} WHERE {primary} = {id} |
<T> java.util.concurrent.CompletableFuture<T> |
findAsync(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval)
获取符合过滤条件单个记录, 返回null表示不存在值
等价SQL: SELECT * FROM {table} WHERE {column} = {key} |
<T> java.io.Serializable |
findColumn(java.lang.Class<T> clazz,
java.lang.String column,
FilterBean bean)
获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
等价SQL: SELECT {column} FROM {table} WHERE {filter bean} |
<T> java.io.Serializable |
findColumn(java.lang.Class<T> clazz,
java.lang.String column,
FilterNode node)
获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
等价SQL: SELECT {column} FROM {table} WHERE {filter node} |
<T> java.io.Serializable |
findColumn(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable pk)
获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id} |
<T> java.io.Serializable |
findColumn(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable defValue,
FilterBean bean)
获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
等价SQL: SELECT {column} FROM {table} WHERE {filter bean} |
<T> java.io.Serializable |
findColumn(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable defValue,
FilterNode node)
获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
等价SQL: SELECT {column} FROM {table} WHERE {filter node} |
<T> java.io.Serializable |
findColumn(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable defValue,
java.io.Serializable pk)
获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id} |
<T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnAsync(java.lang.Class<T> clazz,
java.lang.String column,
FilterBean bean)
获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
等价SQL: SELECT {column} FROM {table} WHERE {filter bean} |
<T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnAsync(java.lang.Class<T> clazz,
java.lang.String column,
FilterNode node)
获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
等价SQL: SELECT {column} FROM {table} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnAsync(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable pk)
获取符合过滤条件单个记录的单个字段值, 返回null表示不存在值
等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id} |
<T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnAsync(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable defValue,
FilterBean bean)
获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
等价SQL: SELECT {column} FROM {table} WHERE {filter bean} |
<T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnAsync(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable defValue,
FilterNode node)
获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
等价SQL: SELECT {column} FROM {table} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnAsync(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable defValue,
java.io.Serializable pk)
获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id} |
protected <T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnCompose(EntityInfo<T> info,
java.lang.String column,
java.io.Serializable defValue,
FilterNode node) |
protected <T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnCompose(EntityInfo<T> info,
java.lang.String column,
java.io.Serializable defValue,
java.io.Serializable pk) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnDB(EntityInfo<T> info,
java.lang.String sql,
boolean onlypk,
java.lang.String column,
java.io.Serializable defValue) |
protected <T> java.util.concurrent.CompletableFuture<T> |
findCompose(EntityInfo<T> info,
SelectColumn selects,
FilterNode node) |
protected <T> java.util.concurrent.CompletableFuture<T> |
findCompose(EntityInfo<T> info,
SelectColumn selects,
java.io.Serializable pk) |
protected abstract <T> java.util.concurrent.CompletableFuture<T> |
findDB(EntityInfo<T> info,
java.lang.String sql,
boolean onlypk,
SelectColumn selects) |
protected <T> T |
getEntityValue(EntityInfo<T> info,
SelectColumn sels,
java.sql.ResultSet set) |
protected java.util.concurrent.ExecutorService |
getExecutor() |
protected <T> java.io.Serializable |
getFieldValue(EntityInfo<T> info,
Attribute<T,java.io.Serializable> attr,
java.sql.ResultSet set) |
protected <T> java.io.Serializable |
getFieldValue(EntityInfo<T> info,
Attribute<T,java.io.Serializable> attr,
java.sql.ResultSet set,
int index) |
protected java.util.Map<java.lang.Class,java.lang.String> |
getJoinTabalis(FilterNode node) |
<N extends java.lang.Number> |
getNumberMap(java.lang.Class entityClass,
FilterBean bean,
FilterFuncColumn... columns)
获取符合过滤条件记录的聚合结果Map
等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter bean} 如 getNumberMapAsync(Record.class, (FilterBean)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} |
<N extends java.lang.Number> |
getNumberMap(java.lang.Class entityClass,
FilterFuncColumn... columns)
获取符合过滤条件记录的聚合结果Map
等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} 如 getNumberMapAsync(Record.class, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} |
<N extends java.lang.Number> |
getNumberMap(java.lang.Class entityClass,
FilterNode node,
FilterFuncColumn... columns)
获取符合过滤条件记录的聚合结果Map
等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter node} 如 getNumberMapAsync(Record.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} |
<N extends java.lang.Number> |
getNumberMapAsync(java.lang.Class entityClass,
FilterBean bean,
FilterFuncColumn... columns)
获取符合过滤条件记录的聚合结果Map
等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter bean} 如 getNumberMapAsync(Record.class, (FilterBean)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} |
<N extends java.lang.Number> |
getNumberMapAsync(java.lang.Class entityClass,
FilterFuncColumn... columns)
获取符合过滤条件记录的聚合结果Map
等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} 如 getNumberMapAsync(Record.class, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} |
<N extends java.lang.Number> |
getNumberMapAsync(java.lang.Class entityClass,
FilterNode node,
FilterFuncColumn... columns)
获取符合过滤条件记录的聚合结果Map
等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter node} 如 getNumberMapAsync(Record.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table} |
protected <N extends java.lang.Number> |
getNumberMapCompose(EntityInfo info,
FilterNode node,
FilterFuncColumn... columns) |
protected abstract <T,N extends java.lang.Number> |
getNumberMapDB(EntityInfo<T> info,
java.lang.String sql,
FilterFuncColumn... columns) |
java.lang.Number |
getNumberResult(java.lang.Class entityClass,
FilterFunc func,
java.lang.Number defVal,
java.lang.String column)
获取符合过滤条件记录的聚合结果, 无结果返回默认值
等价SQL: SELECT FUNC{column} FROM {table} 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime") 等价于: SELECT MAX(createtime) FROM {table} |
java.lang.Number |
getNumberResult(java.lang.Class entityClass,
FilterFunc func,
java.lang.Number defVal,
java.lang.String column,
FilterBean bean)
获取符合过滤条件记录的聚合结果, 无结果返回默认值
等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean} 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} |
java.lang.Number |
getNumberResult(java.lang.Class entityClass,
FilterFunc func,
java.lang.Number defVal,
java.lang.String column,
FilterNode node)
获取符合过滤条件记录的聚合结果, 无结果返回默认值
等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node} 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} |
java.lang.Number |
getNumberResult(java.lang.Class entityClass,
FilterFunc func,
java.lang.String column)
获取符合过滤条件记录的聚合结果, 无结果返回null
等价SQL: SELECT FUNC{column} FROM {table} 如 getNumberResultAsync(Record.class, FilterFunc.COUNT, null) 等价于: SELECT COUNT(*) FROM {table} |
java.lang.Number |
getNumberResult(java.lang.Class entityClass,
FilterFunc func,
java.lang.String column,
FilterBean bean)
获取符合过滤条件记录的聚合结果, 无结果返回null
等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean} 如 getNumberResultAsync(Record.class, FilterFunc.COUNT, null, (FilterBean)null) 等价于: SELECT COUNT(*) FROM {table} |
java.lang.Number |
getNumberResult(java.lang.Class entityClass,
FilterFunc func,
java.lang.String column,
FilterNode node)
获取符合过滤条件记录的聚合结果, 无结果返回null
等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node} 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} |
java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultAsync(java.lang.Class entityClass,
FilterFunc func,
java.lang.Number defVal,
java.lang.String column)
获取符合过滤条件记录的聚合结果, 无结果返回默认值
等价SQL: SELECT FUNC{column} FROM {table} 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime") 等价于: SELECT MAX(createtime) FROM {table} |
java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultAsync(java.lang.Class entityClass,
FilterFunc func,
java.lang.Number defVal,
java.lang.String column,
FilterBean bean)
获取符合过滤条件记录的聚合结果, 无结果返回默认值
等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean} 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} |
java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultAsync(java.lang.Class entityClass,
FilterFunc func,
java.lang.Number defVal,
java.lang.String column,
FilterNode node)
获取符合过滤条件记录的聚合结果, 无结果返回默认值
等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node} 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} |
java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultAsync(java.lang.Class entityClass,
FilterFunc func,
java.lang.String column)
获取符合过滤条件记录的聚合结果, 无结果返回null
等价SQL: SELECT FUNC{column} FROM {table} 如 getNumberResultAsync(Record.class, FilterFunc.COUNT, null) 等价于: SELECT COUNT(*) FROM {table} |
java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultAsync(java.lang.Class entityClass,
FilterFunc func,
java.lang.String column,
FilterBean bean)
获取符合过滤条件记录的聚合结果, 无结果返回null
等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter bean} 如 getNumberResultAsync(Record.class, FilterFunc.COUNT, null, (FilterBean)null) 等价于: SELECT COUNT(*) FROM {table} |
java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultAsync(java.lang.Class entityClass,
FilterFunc func,
java.lang.String column,
FilterNode node)
获取符合过滤条件记录的聚合结果, 无结果返回null
等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node} 如 getNumberResultAsync(Record.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table} |
protected java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultCompose(EntityInfo info,
java.lang.Class entityClass,
FilterFunc func,
java.lang.Number defVal,
java.lang.String column,
FilterNode node) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultDB(EntityInfo<T> info,
java.lang.String sql,
java.lang.Number defVal,
java.lang.String column) |
PoolSource<DBChannel> |
getReadPoolSource() |
java.lang.String |
getType()
获取数据源类型
|
PoolSource<DBChannel> |
getWritePoolSource() |
void |
init(AnyValue config)
该方法必须是可以重复调用, 当reload时需要重复调用init方法
远程模式下该方法会重载成空方法
|
<T> int |
insert(T... entitys)
新增对象, 必须是Entity对象
|
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
insertAsync(T... entitys)
新增记录, 多对象必须是同一个Entity类且必须在同一张表中
|
<T> int |
insertCache(java.lang.Class<T> clazz,
T... entitys) |
protected <T> int |
insertCache(EntityInfo<T> info,
T... entitys) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
insertDB(EntityInfo<T> info,
T... entitys) |
protected abstract boolean |
isAsync() |
protected boolean |
isOnlyCache(EntityInfo info) |
protected <T> EntityInfo<T> |
loadEntityInfo(java.lang.Class<T> clazz) |
protected static java.lang.StringBuilder |
multisplit(char ch1,
char ch2,
java.lang.String split,
java.lang.StringBuilder sb,
java.lang.String str,
int from) |
protected abstract java.lang.String |
prepareParamSign(int index) |
<T,V extends java.io.Serializable> |
queryColumnList(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
FilterBean bean)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} |
<T,V extends java.io.Serializable> |
queryColumnList(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
FilterNode node)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} |
<T,V extends java.io.Serializable> |
queryColumnList(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T,V extends java.io.Serializable> |
queryColumnList(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T,V extends java.io.Serializable> |
queryColumnList(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {column} = {key} |
<T,V extends java.io.Serializable> |
queryColumnListAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
FilterBean bean)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} |
<T,V extends java.io.Serializable> |
queryColumnListAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
FilterNode node)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} |
<T,V extends java.io.Serializable> |
queryColumnListAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T,V extends java.io.Serializable> |
queryColumnListAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T,V extends java.io.Serializable> |
queryColumnListAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval)
查询符合过滤条件记录的某个字段List集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {column} = {key} |
<T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMap(java.lang.Class<T> entityClass,
java.lang.String keyColumn,
FilterFunc func,
java.lang.String funcColumn)
查询符合过滤条件记录的GROUP BY聚合结果Map
等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} GROUP BY {keyColumn} 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime") 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name |
<T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMap(java.lang.Class<T> entityClass,
java.lang.String keyColumn,
FilterFunc func,
java.lang.String funcColumn,
FilterBean bean)
查询符合过滤条件记录的GROUP BY聚合结果Map
等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter bean} GROUP BY {keyColumn} 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime", (FilterBean)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name |
<T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMap(java.lang.Class<T> entityClass,
java.lang.String keyColumn,
FilterFunc func,
java.lang.String funcColumn,
FilterNode node)
查询符合过滤条件记录的GROUP BY聚合结果Map
等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter node} GROUP BY {keyColumn} 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name |
<T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMapAsync(java.lang.Class<T> entityClass,
java.lang.String keyColumn,
FilterFunc func,
java.lang.String funcColumn)
查询符合过滤条件记录的GROUP BY聚合结果Map
等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} GROUP BY {keyColumn} 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime") 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name |
<T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMapAsync(java.lang.Class<T> entityClass,
java.lang.String keyColumn,
FilterFunc func,
java.lang.String funcColumn,
FilterBean bean)
查询符合过滤条件记录的GROUP BY聚合结果Map
等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter bean} GROUP BY {keyColumn} 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime", (FilterBean)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name |
<T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMapAsync(java.lang.Class<T> entityClass,
java.lang.String keyColumn,
FilterFunc func,
java.lang.String funcColumn,
FilterNode node)
查询符合过滤条件记录的GROUP BY聚合结果Map
等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter node} GROUP BY {keyColumn} 如 queryColumnMapAsync(Record.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM record GROUP BY name |
protected <T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMapCompose(EntityInfo<T> info,
java.lang.String keyColumn,
FilterFunc func,
java.lang.String funcColumn,
FilterNode node) |
protected abstract <T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMapDB(EntityInfo<T> info,
java.lang.String sql,
java.lang.String keyColumn) |
<T,V extends java.io.Serializable> |
queryColumnSet(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
FilterBean bean)
查询符合过滤条件记录的某个字段Set集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} |
<T,V extends java.io.Serializable> |
queryColumnSet(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
FilterNode node)
查询符合过滤条件记录的某个字段Set集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} |
<T,V extends java.io.Serializable> |
queryColumnSet(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval)
查询符合过滤条件记录的某个字段Set集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {column} = {key} |
<T,V extends java.io.Serializable> |
queryColumnSetAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
FilterBean bean)
查询符合过滤条件记录的某个字段Set集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} |
<T,V extends java.io.Serializable> |
queryColumnSetAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
FilterNode node)
查询符合过滤条件记录的某个字段Set集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} |
<T,V extends java.io.Serializable> |
queryColumnSetAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval)
查询符合过滤条件记录的某个字段Set集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {column} = {key} |
<T,V extends java.io.Serializable> |
queryColumnSheet(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
Flipper flipper,
FilterBean bean)
根据指定参数查询对象某个字段的集合
|
<T,V extends java.io.Serializable> |
queryColumnSheet(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的某个字段Sheet集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T,V extends java.io.Serializable> |
queryColumnSheetAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的某个字段Sheet集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T,V extends java.io.Serializable> |
queryColumnSheetAsync(java.lang.String selectedColumn,
java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的某个字段Sheet集合
等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz)
查询记录的List集合
等价SQL: SELECT * FROM {table} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
FilterBean bean)
根据过滤对象FilterBean查询对象集合
|
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {filter node} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
Flipper flipper,
java.lang.String column,
java.io.Serializable colval)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
SelectColumn selects,
FilterBean bean)
根据过滤对象FilterBean查询对象集合, 对象只填充或排除SelectField指定的字段
|
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
SelectColumn selects,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的List集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.List<T> |
queryList(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval)
根据指定字段值查询对象集合
|
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz)
查询记录的List集合
等价SQL: SELECT * FROM {table} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
FilterBean bean)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {filter bean} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
Flipper flipper,
java.lang.String column,
java.io.Serializable colval)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
SelectColumn selects,
FilterBean bean)
查询符合过滤条件记录的List集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter bean} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
SelectColumn selects,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的List集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<java.util.List<T>> |
queryListAsync(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMap(java.lang.Class<T> clazz,
FilterBean bean)
查询符合过滤条件记录的Map集合, 主键值为key
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMap(java.lang.Class<T> clazz,
FilterNode node)
查询符合过滤条件记录的Map集合, 主键值为key
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMap(java.lang.Class<T> clazz,
SelectColumn selects,
FilterBean bean)
查询符合过滤条件记录的Map集合, 主键值为key
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMap(java.lang.Class<T> clazz,
SelectColumn selects,
FilterNode node)
查询符合过滤条件记录的Map集合, 主键值为key
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMap(java.lang.Class<T> clazz,
SelectColumn selects,
java.util.stream.Stream<K> keyStream)
查询符合过滤条件记录的Map集合, 主键值为key
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMap(java.lang.Class<T> clazz,
java.util.stream.Stream<K> keyStream)
查询符合过滤条件记录的Map集合, 主键值为key
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMapAsync(java.lang.Class<T> clazz,
FilterBean bean)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMapAsync(java.lang.Class<T> clazz,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMapAsync(java.lang.Class<T> clazz,
SelectColumn selects,
FilterBean bean)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMapAsync(java.lang.Class<T> clazz,
SelectColumn selects,
FilterNode node)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMapAsync(java.lang.Class<T> clazz,
SelectColumn selects,
java.util.stream.Stream<K> keyStream)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<K extends java.io.Serializable,T> |
queryMapAsync(java.lang.Class<T> clazz,
java.util.stream.Stream<K> keyStream)
查询符合过滤条件记录的List集合
等价SQL: SELECT * FROM {table} WHERE {column} = {key} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> Sheet<T> |
querySheet(java.lang.Class<T> clazz,
Flipper flipper,
FilterBean bean)
根据过滤对象FilterBean和翻页对象Flipper查询一页的数据
|
<T> Sheet<T> |
querySheet(java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的Sheet集合
等价SQL: SELECT * FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> Sheet<T> |
querySheet(java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterBean bean)
根据过滤对象FilterBean和翻页对象Flipper查询一页的数据, 对象只填充或排除SelectField指定的字段
|
<T> Sheet<T> |
querySheet(java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的Sheet集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<Sheet<T>> |
querySheetAsync(java.lang.Class<T> clazz,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的Sheet集合
等价SQL: SELECT * FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<Sheet<T>> |
querySheetAsync(java.lang.Class<T> clazz,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的Sheet集合
等价SQL: SELECT * FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<Sheet<T>> |
querySheetAsync(java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterBean bean)
查询符合过滤条件记录的Sheet集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
<T> java.util.concurrent.CompletableFuture<Sheet<T>> |
querySheetAsync(java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterNode node)
查询符合过滤条件记录的Sheet集合
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit} |
protected <T> java.util.concurrent.CompletableFuture<Sheet<T>> |
querySheetCompose(boolean readcache,
boolean needtotal,
java.lang.Class<T> clazz,
SelectColumn selects,
Flipper flipper,
FilterNode node) |
protected abstract <T> java.util.concurrent.CompletableFuture<Sheet<T>> |
querySheetDB(EntityInfo<T> info,
boolean needtotal,
SelectColumn selects,
Flipper flipper,
FilterNode node) |
<T> void |
refreshCache(java.lang.Class<T> clazz)
将entity的对象全部加载到Cache中去,如果clazz没有被@javax.persistence.Cacheable注解则不做任何事
|
<T> int |
reloadCache(java.lang.Class<T> clazz,
java.io.Serializable... pks) |
java.lang.String |
resourceName() |
<T> int |
update(T... entitys)
更新对象, 必须是Entity对象
|
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateAsync(T... entitys)
更新记录, 多对象必须是同一个Entity类且必须在同一张表中
等价SQL: UPDATE {table} SET column1 = value1, column2 = value2, ··· WHERE {primary} = {id1} UPDATE {table} SET column1 = value1, column2 = value2, ··· WHERE {primary} = {id2} ··· |
<T> int |
updateCache(java.lang.Class<T> clazz,
T... entitys) |
protected <T> int |
updateCache(EntityInfo<T> info,
int count,
boolean neednode,
T entity,
FilterNode node,
SelectColumn selects) |
protected <T> int |
updateCache(EntityInfo<T> info,
int count,
FilterNode node,
Flipper flipper,
ColumnValue... values) |
protected <T> int |
updateCache(EntityInfo<T> info,
int count,
java.io.Serializable pk,
ColumnValue... values) |
protected <T> int |
updateCache(EntityInfo<T> info,
int count,
java.io.Serializable pk,
java.lang.String column,
java.io.Serializable colval) |
protected <T> int |
updateCache(EntityInfo<T> info,
int count,
java.lang.String column,
java.io.Serializable colval,
FilterNode node) |
protected <T> int |
updateCache(EntityInfo<T> info,
int count,
T... entitys) |
<T> int |
updateColumn(java.lang.Class<T> clazz,
FilterNode node,
ColumnValue... values)
根据主键值更新对象的多个column对应的值, 必须是Entity Class
|
<T> int |
updateColumn(java.lang.Class<T> clazz,
FilterNode node,
Flipper flipper,
ColumnValue... values)
更新符合过滤条件的记录的指定字段
Flipper中offset字段将被忽略 注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, ··· WHERE {filter node} ORDER BY {flipper.sort} |
<T> int |
updateColumn(java.lang.Class<T> clazz,
java.io.Serializable pk,
ColumnValue... values)
根据主键值更新对象的多个column对应的值, 必须是Entity Class
|
<T> int |
updateColumn(java.lang.Class<T> clazz,
java.io.Serializable pk,
java.lang.String column,
java.io.Serializable colval)
根据主键值更新对象的column对应的值, 必须是Entity Class
|
<T> int |
updateColumn(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval,
FilterNode node)
根据主键值更新对象的column对应的值, 必须是Entity Class
|
<T> int |
updateColumn(T entity,
FilterNode node,
SelectColumn selects)
更新符合过滤条件记录的指定字段
注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {filter node} |
<T> int |
updateColumn(T entity,
FilterNode node,
java.lang.String... columns)
更新符合过滤条件记录的指定字段
注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {filter node} |
<T> int |
updateColumn(T entity,
SelectColumn selects)
更新单个记录的指定字段
注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {primary} = {bean.id} |
<T> int |
updateColumn(T entity,
java.lang.String... columns)
更新单个记录的指定字段
注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {primary} = {bean.id} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(java.lang.Class<T> clazz,
FilterNode node,
ColumnValue... values)
更新符合过滤条件记录的部分字段
字段赋值操作选项见 ColumnExpress 注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, ··· WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(java.lang.Class<T> clazz,
FilterNode node,
Flipper flipper,
ColumnValue... values)
更新符合过滤条件的记录的指定字段
Flipper中offset字段将被忽略 注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, ··· WHERE {filter node} ORDER BY {flipper.sort} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(java.lang.Class<T> clazz,
java.io.Serializable pk,
ColumnValue... values)
更新指定主键值记录的部分字段
字段赋值操作选项见 ColumnExpress 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, ··· WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(java.lang.Class<T> clazz,
java.io.Serializable pk,
java.lang.String column,
java.io.Serializable colval)
更新单个记录的单个字段
注意:即使字段标记为@Column(updatable=false)也会被更新 等价SQL: UPDATE {table} SET {column} = {value} WHERE {primary} = {id} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(java.lang.Class<T> clazz,
java.lang.String column,
java.io.Serializable colval,
FilterNode node)
更新符合过滤条件记录的单个字段
注意:即使字段标记为@Column(updatable=false)也会被更新 等价SQL: UPDATE {table} SET {column} = {value} WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(T entity,
FilterNode node,
SelectColumn selects)
更新符合过滤条件记录的指定字段
注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(T entity,
FilterNode node,
java.lang.String... columns)
更新符合过滤条件记录的指定字段
注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {filter node} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(T entity,
SelectColumn selects)
更新单个记录的指定字段
注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {primary} = {bean.id} |
<T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnAsync(T entity,
java.lang.String... columns)
更新单个记录的指定字段
注意:Entity类中标记为@Column(updatable=false)不会被更新 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {primary} = {bean.id} |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnCompose(EntityInfo<T> info,
boolean neednode,
T entity,
FilterNode node,
SelectColumn selects) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnCompose(EntityInfo<T> info,
FilterNode node,
Flipper flipper,
ColumnValue... values) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnCompose(EntityInfo<T> info,
java.io.Serializable pk,
ColumnValue... values) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnCompose(EntityInfo<T> info,
java.io.Serializable pk,
java.lang.String column,
java.io.Serializable colval) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateColumnCompose(EntityInfo<T> info,
java.lang.String column,
java.io.Serializable colval,
FilterNode node) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateDB(EntityInfo<T> info,
Flipper flipper,
java.lang.String sql,
boolean prepared,
java.lang.Object... params) |
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateDB(EntityInfo<T> info,
T... entitys) |
runAsync
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
delete, delete, deleteAsync, deleteAsync, update, update, updateAsync, updateAsync
protected static final Flipper FLIPPER_ONE
protected final java.util.logging.Logger logger
protected java.lang.String name
protected java.net.URL persistxml
protected int threads
protected ObjectPool<java.nio.ByteBuffer> bufferPool
protected java.util.concurrent.ThreadPoolExecutor executor
protected boolean cacheForbidden
protected PoolSource<DBChannel> readPool
protected PoolSource<DBChannel> writePool
protected DataCacheListener cacheListener
protected final java.util.function.BiConsumer futureCompleteConsumer
protected final java.util.function.BiFunction<DataSource,java.lang.Class,java.util.List> fullloader
public DataSqlSource(java.lang.String unitName, java.net.URL persistxml, java.util.Properties readprop, java.util.Properties writeprop)
@Local public abstract int directExecute(java.lang.String sql)
@Local public abstract int[] directExecute(java.lang.String... sqls)
@Local public abstract <V> V directQuery(java.lang.String sql, java.util.function.Function<java.sql.ResultSet,V> handler)
protected abstract boolean isAsync()
protected abstract java.lang.String prepareParamSign(int index)
protected abstract PoolSource<DBChannel> createPoolSource(DataSource source, java.lang.String rwtype, java.util.concurrent.ArrayBlockingQueue queue, java.util.concurrent.Semaphore semaphore, java.util.Properties prop)
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> insertDB(EntityInfo<T> info, T... entitys)
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteDB(EntityInfo<T> info, Flipper flipper, java.lang.String sql)
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> clearTableDB(EntityInfo<T> info, java.lang.String sql)
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> dropTableDB(EntityInfo<T> info, java.lang.String sql)
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateDB(EntityInfo<T> info, T... entitys)
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateDB(EntityInfo<T> info, Flipper flipper, java.lang.String sql, boolean prepared, java.lang.Object... params)
protected abstract <T,N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,N>> getNumberMapDB(EntityInfo<T> info, java.lang.String sql, FilterFuncColumn... columns)
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultDB(EntityInfo<T> info, java.lang.String sql, java.lang.Number defVal, java.lang.String column)
protected abstract <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<K,N>> queryColumnMapDB(EntityInfo<T> info, java.lang.String sql, java.lang.String keyColumn)
protected abstract <T> java.util.concurrent.CompletableFuture<T> findDB(EntityInfo<T> info, java.lang.String sql, boolean onlypk, SelectColumn selects)
protected abstract <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnDB(EntityInfo<T> info, java.lang.String sql, boolean onlypk, java.lang.String column, java.io.Serializable defValue)
protected abstract <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsDB(EntityInfo<T> info, java.lang.String sql, boolean onlypk)
protected abstract <T> java.util.concurrent.CompletableFuture<Sheet<T>> querySheetDB(EntityInfo<T> info, boolean needtotal, SelectColumn selects, Flipper flipper, FilterNode node)
protected <T> T getEntityValue(EntityInfo<T> info, SelectColumn sels, java.sql.ResultSet set) throws java.sql.SQLException
java.sql.SQLException
protected <T> java.io.Serializable getFieldValue(EntityInfo<T> info, Attribute<T,java.io.Serializable> attr, java.sql.ResultSet set, int index) throws java.sql.SQLException
java.sql.SQLException
protected <T> java.io.Serializable getFieldValue(EntityInfo<T> info, Attribute<T,java.io.Serializable> attr, java.sql.ResultSet set) throws java.sql.SQLException
java.sql.SQLException
protected <T> java.lang.String createSQLOrderby(EntityInfo<T> info, Flipper flipper)
protected java.util.Map<java.lang.Class,java.lang.String> getJoinTabalis(FilterNode node)
protected <T> java.lang.CharSequence createSQLJoin(FilterNode node, java.util.function.Function<java.lang.Class,EntityInfo> func, boolean update, java.util.Map<java.lang.Class,java.lang.String> joinTabalis, java.util.Set<java.lang.String> haset, EntityInfo<T> info)
protected <T> java.lang.CharSequence createSQLExpress(FilterNode node, EntityInfo<T> info, java.util.Map<java.lang.Class,java.lang.String> joinTabalis)
protected java.util.concurrent.ExecutorService getExecutor()
getExecutor
在类中 AbstractService
public void init(AnyValue config)
Service
@Local public java.lang.String getType()
DataSource
getType
在接口中 DataSource
public final java.lang.String resourceName()
resourceName
在接口中 Resourcable
@Local public void close() throws java.lang.Exception
close
在接口中 java.lang.AutoCloseable
java.lang.Exception
@Local public PoolSource<DBChannel> getReadPoolSource()
@Local public PoolSource<DBChannel> getWritePoolSource()
@Local public EntityInfo apply(java.lang.Class t)
apply
在接口中 java.util.function.Function<java.lang.Class,EntityInfo>
protected <T> EntityInfo<T> loadEntityInfo(java.lang.Class<T> clazz)
protected boolean isOnlyCache(EntityInfo info)
public <T> void refreshCache(java.lang.Class<T> clazz)
T
- Entity类泛型clazz
- Entity类protected <T> java.util.concurrent.CompletableFuture checkEntity(java.lang.String action, boolean async, T... entitys)
public <T> int insert(@RpcCall(value=DataCallArrayAttribute.class) T... entitys)
insert
在接口中 DataSource
T
- Entity类泛型entitys
- Entity对象public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> insertAsync(@RpcCall(value=DataCallArrayAttribute.class) T... entitys)
DataSource
insertAsync
在接口中 DataSource
T
- 泛型entitys
- Entity对象protected <T> int insertCache(EntityInfo<T> info, T... entitys)
public <T> int insertCache(java.lang.Class<T> clazz, T... entitys)
insertCache
在接口中 DataCacheListener
public <T> int delete(T... entitys)
delete
在接口中 DataSource
T
- Entity类泛型entitys
- Entity对象public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteAsync(T... entitys)
DataSource
deleteAsync
在接口中 DataSource
T
- 泛型entitys
- Entity对象public <T> int delete(java.lang.Class<T> clazz, java.io.Serializable... pks)
DataSource
delete
在接口中 DataSource
T
- Entity泛型clazz
- Entity类pks
- 主键值public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteAsync(java.lang.Class<T> clazz, java.io.Serializable... pks)
DataSource
deleteAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类pks
- 主键值public <T> int delete(java.lang.Class<T> clazz, FilterNode node)
DataSource
delete
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteAsync(java.lang.Class<T> clazz, FilterNode node)
DataSource
deleteAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> int delete(java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
delete
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteAsync(java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
deleteAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象node
- 过滤条件protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteCompose(EntityInfo<T> info, java.io.Serializable... pks)
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteCompose(EntityInfo<T> info, Flipper flipper, FilterNode node)
public <T> int clearTable(java.lang.Class<T> clazz)
DataSource
clearTable
在接口中 DataSource
T
- Entity泛型clazz
- Entity类public <T> int clearTable(java.lang.Class<T> clazz, FilterNode node)
DataSource
clearTable
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> clearTableAsync(java.lang.Class<T> clazz)
DataSource
clearTableAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> clearTableAsync(java.lang.Class<T> clazz, FilterNode node)
DataSource
clearTableAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> clearTableCompose(EntityInfo<T> info, FilterNode node)
public <T> int dropTable(java.lang.Class<T> clazz)
DataSource
dropTable
在接口中 DataSource
T
- Entity泛型clazz
- Entity类public <T> int dropTable(java.lang.Class<T> clazz, FilterNode node)
DataSource
dropTable
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> dropTableAsync(java.lang.Class<T> clazz)
DataSource
dropTableAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> dropTableAsync(java.lang.Class<T> clazz, FilterNode node)
DataSource
dropTableAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> dropTableCompose(EntityInfo<T> info, FilterNode node)
protected <T> int clearTableCache(EntityInfo<T> info, FilterNode node)
protected <T> int dropTableCache(EntityInfo<T> info, FilterNode node)
protected <T> int deleteCache(EntityInfo<T> info, int count, Flipper flipper, FilterNode node)
protected <T> int deleteCache(EntityInfo<T> info, int count, java.io.Serializable... pks)
public <T> int deleteCache(java.lang.Class<T> clazz, java.io.Serializable... pks)
deleteCache
在接口中 DataCacheListener
protected static java.lang.StringBuilder multisplit(char ch1, char ch2, java.lang.String split, java.lang.StringBuilder sb, java.lang.String str, int from)
public <T> int update(T... entitys)
update
在接口中 DataSource
T
- Entity类泛型entitys
- Entity对象public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateAsync(T... entitys)
DataSource
updateAsync
在接口中 DataSource
T
- 泛型entitys
- Entity对象public <T> int updateColumn(java.lang.Class<T> clazz, java.io.Serializable pk, java.lang.String column, java.io.Serializable colval)
updateColumn
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类pk
- 主键值column
- 过滤字段名colval
- 过滤字段值public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(java.lang.Class<T> clazz, java.io.Serializable pk, java.lang.String column, java.io.Serializable colval)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类pk
- 主键column
- 待更新的字段名colval
- 更新值protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnCompose(EntityInfo<T> info, java.io.Serializable pk, java.lang.String column, java.io.Serializable colval)
public <T> int updateColumn(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval, FilterNode node)
updateColumn
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值node
- 过滤node 不能为nullpublic <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval, FilterNode node)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 待更新的字段名colval
- 更新值node
- 过滤条件protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnCompose(EntityInfo<T> info, java.lang.String column, java.io.Serializable colval, FilterNode node)
public <T> int updateColumn(java.lang.Class<T> clazz, java.io.Serializable pk, ColumnValue... values)
updateColumn
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类pk
- 主键值values
- 字段值public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(java.lang.Class<T> clazz, java.io.Serializable pk, ColumnValue... values)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类pk
- 主键values
- 更新字段protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnCompose(EntityInfo<T> info, java.io.Serializable pk, ColumnValue... values)
public <T> int updateColumn(java.lang.Class<T> clazz, FilterNode node, ColumnValue... values)
updateColumn
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类node
- 过滤条件values
- 字段值public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(java.lang.Class<T> clazz, FilterNode node, ColumnValue... values)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件values
- 更新字段public <T> int updateColumn(java.lang.Class<T> clazz, FilterNode node, Flipper flipper, ColumnValue... values)
DataSource
updateColumn
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件flipper
- 翻页对象values
- 更新字段public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(java.lang.Class<T> clazz, FilterNode node, Flipper flipper, ColumnValue... values)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件flipper
- 翻页对象values
- 更新字段protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnCompose(EntityInfo<T> info, FilterNode node, Flipper flipper, ColumnValue... values)
public <T> int updateColumn(T entity, java.lang.String... columns)
DataSource
updateColumn
在接口中 DataSource
T
- Entity泛型entity
- 待更新的Entity对象columns
- 需更新的字段名public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(T entity, java.lang.String... columns)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型entity
- 待更新的Entity对象columns
- 需更新的字段名public <T> int updateColumn(T entity, FilterNode node, java.lang.String... columns)
DataSource
updateColumn
在接口中 DataSource
T
- Entity泛型entity
- 待更新的Entity对象node
- 过滤条件columns
- 需更新的字段名public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(T entity, FilterNode node, java.lang.String... columns)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型entity
- 待更新的Entity对象node
- 过滤条件columns
- 需更新的字段名public <T> int updateColumn(T entity, SelectColumn selects)
DataSource
updateColumn
在接口中 DataSource
T
- Entity泛型entity
- 待更新的Entity对象selects
- 指定字段public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(T entity, SelectColumn selects)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型entity
- 待更新的Entity对象selects
- 指定字段public <T> int updateColumn(T entity, FilterNode node, SelectColumn selects)
DataSource
updateColumn
在接口中 DataSource
T
- Entity泛型entity
- 待更新的Entity对象node
- 过滤条件selects
- 指定字段public <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnAsync(T entity, FilterNode node, SelectColumn selects)
DataSource
updateColumnAsync
在接口中 DataSource
T
- Entity泛型entity
- 待更新的Entity对象node
- 过滤条件selects
- 指定字段protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateColumnCompose(EntityInfo<T> info, boolean neednode, T entity, FilterNode node, SelectColumn selects)
protected <T> int updateCache(EntityInfo<T> info, int count, boolean neednode, T entity, FilterNode node, SelectColumn selects)
protected <T> int updateCache(EntityInfo<T> info, int count, FilterNode node, Flipper flipper, ColumnValue... values)
protected <T> int updateCache(EntityInfo<T> info, int count, java.io.Serializable pk, ColumnValue... values)
protected <T> int updateCache(EntityInfo<T> info, int count, java.lang.String column, java.io.Serializable colval, FilterNode node)
protected <T> int updateCache(EntityInfo<T> info, int count, java.io.Serializable pk, java.lang.String column, java.io.Serializable colval)
protected <T> int updateCache(EntityInfo<T> info, int count, T... entitys)
public <T> int updateCache(java.lang.Class<T> clazz, T... entitys)
updateCache
在接口中 DataCacheListener
public <T> int reloadCache(java.lang.Class<T> clazz, java.io.Serializable... pks)
public <N extends java.lang.Number> java.util.Map<java.lang.String,N> getNumberMap(java.lang.Class entityClass, FilterFuncColumn... columns)
DataSource
getNumberMap
在接口中 DataSource
N
- NumberentityClass
- Entity类columns
- 聚合字段public <N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,N>> getNumberMapAsync(java.lang.Class entityClass, FilterFuncColumn... columns)
DataSource
getNumberMapAsync
在接口中 DataSource
N
- NumberentityClass
- Entity类columns
- 聚合字段public <N extends java.lang.Number> java.util.Map<java.lang.String,N> getNumberMap(java.lang.Class entityClass, FilterBean bean, FilterFuncColumn... columns)
DataSource
getNumberMap
在接口中 DataSource
N
- NumberentityClass
- Entity类bean
- 过滤条件columns
- 聚合字段public <N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,N>> getNumberMapAsync(java.lang.Class entityClass, FilterBean bean, FilterFuncColumn... columns)
DataSource
getNumberMapAsync
在接口中 DataSource
N
- NumberentityClass
- Entity类bean
- 过滤条件columns
- 聚合字段public <N extends java.lang.Number> java.util.Map<java.lang.String,N> getNumberMap(java.lang.Class entityClass, FilterNode node, FilterFuncColumn... columns)
DataSource
getNumberMap
在接口中 DataSource
N
- NumberentityClass
- Entity类node
- 过滤条件columns
- 聚合字段public <N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,N>> getNumberMapAsync(java.lang.Class entityClass, FilterNode node, FilterFuncColumn... columns)
DataSource
getNumberMapAsync
在接口中 DataSource
N
- NumberentityClass
- Entity类node
- 过滤条件columns
- 聚合字段protected <N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,N>> getNumberMapCompose(EntityInfo info, FilterNode node, FilterFuncColumn... columns)
public java.lang.Number getNumberResult(java.lang.Class entityClass, FilterFunc func, java.lang.String column)
DataSource
getNumberResult
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数column
- 指定字段public java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultAsync(java.lang.Class entityClass, FilterFunc func, java.lang.String column)
DataSource
getNumberResultAsync
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数column
- 指定字段public java.lang.Number getNumberResult(java.lang.Class entityClass, FilterFunc func, java.lang.String column, FilterBean bean)
DataSource
getNumberResult
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数column
- 指定字段bean
- 过滤条件public java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultAsync(java.lang.Class entityClass, FilterFunc func, java.lang.String column, FilterBean bean)
DataSource
getNumberResultAsync
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数column
- 指定字段bean
- 过滤条件public java.lang.Number getNumberResult(java.lang.Class entityClass, FilterFunc func, java.lang.String column, FilterNode node)
DataSource
getNumberResult
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数column
- 指定字段node
- 过滤条件public java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultAsync(java.lang.Class entityClass, FilterFunc func, java.lang.String column, FilterNode node)
DataSource
getNumberResultAsync
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数column
- 指定字段node
- 过滤条件public java.lang.Number getNumberResult(java.lang.Class entityClass, FilterFunc func, java.lang.Number defVal, java.lang.String column)
DataSource
getNumberResult
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数defVal
- 默认值column
- 指定字段public java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultAsync(java.lang.Class entityClass, FilterFunc func, java.lang.Number defVal, java.lang.String column)
DataSource
getNumberResultAsync
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数defVal
- 默认值column
- 指定字段public java.lang.Number getNumberResult(java.lang.Class entityClass, FilterFunc func, java.lang.Number defVal, java.lang.String column, FilterBean bean)
DataSource
getNumberResult
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数defVal
- 默认值column
- 指定字段bean
- 过滤条件public java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultAsync(java.lang.Class entityClass, FilterFunc func, java.lang.Number defVal, java.lang.String column, FilterBean bean)
DataSource
getNumberResultAsync
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数defVal
- 默认值column
- 指定字段bean
- 过滤条件public java.lang.Number getNumberResult(java.lang.Class entityClass, FilterFunc func, java.lang.Number defVal, java.lang.String column, FilterNode node)
DataSource
getNumberResult
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数defVal
- 默认值column
- 指定字段node
- 过滤条件public java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultAsync(java.lang.Class entityClass, FilterFunc func, java.lang.Number defVal, java.lang.String column, FilterNode node)
DataSource
getNumberResultAsync
在接口中 DataSource
entityClass
- Entity类func
- 聚合函数defVal
- 默认值column
- 指定字段node
- 过滤条件protected java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultCompose(EntityInfo info, java.lang.Class entityClass, FilterFunc func, java.lang.Number defVal, java.lang.String column, FilterNode node)
public <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.Map<K,N> queryColumnMap(java.lang.Class<T> entityClass, java.lang.String keyColumn, FilterFunc func, java.lang.String funcColumn)
DataSource
queryColumnMap
在接口中 DataSource
T
- Entity泛型K
- Key字段的数据类型N
- NumberentityClass
- Entity类keyColumn
- Key字段func
- 聚合函数funcColumn
- 聚合字段public <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<K,N>> queryColumnMapAsync(java.lang.Class<T> entityClass, java.lang.String keyColumn, FilterFunc func, java.lang.String funcColumn)
DataSource
queryColumnMapAsync
在接口中 DataSource
T
- Entity泛型K
- Key字段的数据类型N
- NumberentityClass
- Entity类keyColumn
- Key字段func
- 聚合函数funcColumn
- 聚合字段public <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.Map<K,N> queryColumnMap(java.lang.Class<T> entityClass, java.lang.String keyColumn, FilterFunc func, java.lang.String funcColumn, FilterBean bean)
DataSource
queryColumnMap
在接口中 DataSource
T
- Entity泛型K
- Key字段的数据类型N
- NumberentityClass
- Entity类keyColumn
- Key字段func
- 聚合函数funcColumn
- 聚合字段bean
- 过滤条件public <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<K,N>> queryColumnMapAsync(java.lang.Class<T> entityClass, java.lang.String keyColumn, FilterFunc func, java.lang.String funcColumn, FilterBean bean)
DataSource
queryColumnMapAsync
在接口中 DataSource
T
- Entity泛型K
- Key字段的数据类型N
- NumberentityClass
- Entity类keyColumn
- Key字段func
- 聚合函数funcColumn
- 聚合字段bean
- 过滤条件public <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.Map<K,N> queryColumnMap(java.lang.Class<T> entityClass, java.lang.String keyColumn, FilterFunc func, java.lang.String funcColumn, FilterNode node)
DataSource
queryColumnMap
在接口中 DataSource
T
- Entity泛型K
- Key字段的数据类型N
- NumberentityClass
- Entity类keyColumn
- Key字段func
- 聚合函数funcColumn
- 聚合字段node
- 过滤条件public <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<K,N>> queryColumnMapAsync(java.lang.Class<T> entityClass, java.lang.String keyColumn, FilterFunc func, java.lang.String funcColumn, FilterNode node)
DataSource
queryColumnMapAsync
在接口中 DataSource
T
- Entity泛型K
- Key字段的数据类型N
- NumberentityClass
- Entity类keyColumn
- Key字段func
- 聚合函数funcColumn
- 聚合字段node
- 过滤条件protected <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<K,N>> queryColumnMapCompose(EntityInfo<T> info, java.lang.String keyColumn, FilterFunc func, java.lang.String funcColumn, FilterNode node)
public <T> T find(java.lang.Class<T> clazz, java.io.Serializable pk)
find
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类pk
- 主键值public <T> java.util.concurrent.CompletableFuture<T> findAsync(java.lang.Class<T> clazz, java.io.Serializable pk)
DataSource
findAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类pk
- 主键值public <T> T find(java.lang.Class<T> clazz, SelectColumn selects, java.io.Serializable pk)
DataSource
find
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段pk
- 主键值public <T> java.util.concurrent.CompletableFuture<T> findAsync(java.lang.Class<T> clazz, SelectColumn selects, java.io.Serializable pk)
DataSource
findAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段pk
- 主键值protected <T> java.util.concurrent.CompletableFuture<T> findCompose(EntityInfo<T> info, SelectColumn selects, java.io.Serializable pk)
public <T> T find(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval)
DataSource
find
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值public <T> java.util.concurrent.CompletableFuture<T> findAsync(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval)
DataSource
findAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值public <T> T find(java.lang.Class<T> clazz, FilterBean bean)
DataSource
find
在接口中 DataSource
T
- Entity泛型clazz
- Entity类bean
- 过滤条件public <T> java.util.concurrent.CompletableFuture<T> findAsync(java.lang.Class<T> clazz, FilterBean bean)
DataSource
findAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类bean
- 过滤条件public <T> T find(java.lang.Class<T> clazz, FilterNode node)
DataSource
find
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<T> findAsync(java.lang.Class<T> clazz, FilterNode node)
DataSource
findAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> T find(java.lang.Class<T> clazz, SelectColumn selects, FilterBean bean)
DataSource
find
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段bean
- 过滤条件public <T> java.util.concurrent.CompletableFuture<T> findAsync(java.lang.Class<T> clazz, SelectColumn selects, FilterBean bean)
DataSource
findAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段bean
- 过滤条件public <T> T find(java.lang.Class<T> clazz, SelectColumn selects, FilterNode node)
DataSource
find
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<T> findAsync(java.lang.Class<T> clazz, SelectColumn selects, FilterNode node)
DataSource
findAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段node
- 过滤条件protected <T> java.util.concurrent.CompletableFuture<T> findCompose(EntityInfo<T> info, SelectColumn selects, FilterNode node)
public <T> java.io.Serializable findColumn(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable pk)
DataSource
findColumn
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名pk
- 主键值public <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnAsync(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable pk)
DataSource
findColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名pk
- 主键值public <T> java.io.Serializable findColumn(java.lang.Class<T> clazz, java.lang.String column, FilterBean bean)
DataSource
findColumn
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名bean
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnAsync(java.lang.Class<T> clazz, java.lang.String column, FilterBean bean)
DataSource
findColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名bean
- 过滤条件public <T> java.io.Serializable findColumn(java.lang.Class<T> clazz, java.lang.String column, FilterNode node)
DataSource
findColumn
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnAsync(java.lang.Class<T> clazz, java.lang.String column, FilterNode node)
DataSource
findColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名node
- 过滤条件public <T> java.io.Serializable findColumn(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable defValue, FilterBean bean)
DataSource
findColumn
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名defValue
- 默认值bean
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnAsync(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable defValue, FilterBean bean)
DataSource
findColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名defValue
- 默认值bean
- 过滤条件public <T> java.io.Serializable findColumn(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable defValue, java.io.Serializable pk)
DataSource
findColumn
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名defValue
- 默认值pk
- 主键值public <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnAsync(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable defValue, java.io.Serializable pk)
DataSource
findColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名defValue
- 默认值pk
- 主键值protected <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnCompose(EntityInfo<T> info, java.lang.String column, java.io.Serializable defValue, java.io.Serializable pk)
public <T> java.io.Serializable findColumn(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable defValue, FilterNode node)
DataSource
findColumn
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名defValue
- 默认值node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnAsync(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable defValue, FilterNode node)
DataSource
findColumnAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 字段名defValue
- 默认值node
- 过滤条件protected <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnCompose(EntityInfo<T> info, java.lang.String column, java.io.Serializable defValue, FilterNode node)
public <T> boolean exists(java.lang.Class<T> clazz, java.io.Serializable pk)
DataSource
exists
在接口中 DataSource
T
- Entity泛型clazz
- Entity类pk
- 主键值public <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsAsync(java.lang.Class<T> clazz, java.io.Serializable pk)
DataSource
existsAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类pk
- 主键值protected <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsCompose(EntityInfo<T> info, java.io.Serializable pk)
public <T> boolean exists(java.lang.Class<T> clazz, FilterBean bean)
DataSource
exists
在接口中 DataSource
T
- Entity泛型clazz
- Entity类bean
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsAsync(java.lang.Class<T> clazz, FilterBean bean)
DataSource
existsAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类bean
- 过滤条件public <T> boolean exists(java.lang.Class<T> clazz, FilterNode node)
DataSource
exists
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsAsync(java.lang.Class<T> clazz, FilterNode node)
DataSource
existsAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件protected <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsCompose(EntityInfo<T> info, FilterNode node)
public <T,V extends java.io.Serializable> java.util.HashSet<V> queryColumnSet(java.lang.String selectedColumn, java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval)
DataSource
queryColumnSet
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<java.util.HashSet<V>> queryColumnSetAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval)
DataSource
queryColumnSetAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值public <T,V extends java.io.Serializable> java.util.HashSet<V> queryColumnSet(java.lang.String selectedColumn, java.lang.Class<T> clazz, FilterBean bean)
DataSource
queryColumnSet
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类bean
- 过滤条件public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<java.util.HashSet<V>> queryColumnSetAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, FilterBean bean)
DataSource
queryColumnSetAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类bean
- 过滤条件public <T,V extends java.io.Serializable> java.util.HashSet<V> queryColumnSet(java.lang.String selectedColumn, java.lang.Class<T> clazz, FilterNode node)
DataSource
queryColumnSet
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类node
- 过滤条件public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<java.util.HashSet<V>> queryColumnSetAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, FilterNode node)
DataSource
queryColumnSetAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类node
- 过滤条件public <T,V extends java.io.Serializable> java.util.List<V> queryColumnList(java.lang.String selectedColumn, java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval)
DataSource
queryColumnList
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<java.util.List<V>> queryColumnListAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval)
DataSource
queryColumnListAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值public <T,V extends java.io.Serializable> java.util.List<V> queryColumnList(java.lang.String selectedColumn, java.lang.Class<T> clazz, FilterBean bean)
DataSource
queryColumnList
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类bean
- 过滤条件public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<java.util.List<V>> queryColumnListAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, FilterBean bean)
DataSource
queryColumnListAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类bean
- 过滤条件public <T,V extends java.io.Serializable> java.util.List<V> queryColumnList(java.lang.String selectedColumn, java.lang.Class<T> clazz, FilterNode node)
DataSource
queryColumnList
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类node
- 过滤条件public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<java.util.List<V>> queryColumnListAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, FilterNode node)
DataSource
queryColumnListAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类node
- 过滤条件public <T,V extends java.io.Serializable> java.util.List<V> queryColumnList(java.lang.String selectedColumn, java.lang.Class<T> clazz, Flipper flipper, FilterBean bean)
DataSource
queryColumnList
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类flipper
- 翻页对象bean
- 过滤条件public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<java.util.List<V>> queryColumnListAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, Flipper flipper, FilterBean bean)
DataSource
queryColumnListAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类flipper
- 翻页对象bean
- 过滤条件public <T,V extends java.io.Serializable> java.util.List<V> queryColumnList(java.lang.String selectedColumn, java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
queryColumnList
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<java.util.List<V>> queryColumnListAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
queryColumnListAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <T,V extends java.io.Serializable> Sheet<V> queryColumnSheet(java.lang.String selectedColumn, java.lang.Class<T> clazz, Flipper flipper, FilterBean bean)
queryColumnSheet
在接口中 DataSource
T
- Entity类的泛型V
- 字段值的类型selectedColumn
- 字段名clazz
- Entity类flipper
- 翻页对象bean
- 过滤Beanpublic <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<Sheet<V>> queryColumnSheetAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, Flipper flipper, FilterBean bean)
DataSource
queryColumnSheetAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类flipper
- 翻页对象bean
- 过滤条件public <T,V extends java.io.Serializable> Sheet<V> queryColumnSheet(java.lang.String selectedColumn, java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
queryColumnSheet
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <T,V extends java.io.Serializable> java.util.concurrent.CompletableFuture<Sheet<V>> queryColumnSheetAsync(java.lang.String selectedColumn, java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
queryColumnSheetAsync
在接口中 DataSource
T
- Entity泛型V
- 字段类型selectedColumn
- 指定字段clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <K extends java.io.Serializable,T> java.util.Map<K,T> queryMap(java.lang.Class<T> clazz, java.util.stream.Stream<K> keyStream)
queryMap
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类keyStream
- 主键Streampublic <K extends java.io.Serializable,T> java.util.concurrent.CompletableFuture<java.util.Map<K,T>> queryMapAsync(java.lang.Class<T> clazz, java.util.stream.Stream<K> keyStream)
DataSource
queryMapAsync
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类keyStream
- 主键Streampublic <K extends java.io.Serializable,T> java.util.Map<K,T> queryMap(java.lang.Class<T> clazz, FilterBean bean)
queryMap
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类bean
- FilterBeanpublic <K extends java.io.Serializable,T> java.util.concurrent.CompletableFuture<java.util.Map<K,T>> queryMapAsync(java.lang.Class<T> clazz, FilterBean bean)
DataSource
queryMapAsync
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类bean
- FilterBeanpublic <K extends java.io.Serializable,T> java.util.Map<K,T> queryMap(java.lang.Class<T> clazz, FilterNode node)
queryMap
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类node
- FilterNodepublic <K extends java.io.Serializable,T> java.util.concurrent.CompletableFuture<java.util.Map<K,T>> queryMapAsync(java.lang.Class<T> clazz, FilterNode node)
DataSource
queryMapAsync
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类node
- FilterNodepublic <K extends java.io.Serializable,T> java.util.Map<K,T> queryMap(java.lang.Class<T> clazz, SelectColumn selects, java.util.stream.Stream<K> keyStream)
queryMap
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类selects
- 指定字段keyStream
- 主键Streampublic <K extends java.io.Serializable,T> java.util.concurrent.CompletableFuture<java.util.Map<K,T>> queryMapAsync(java.lang.Class<T> clazz, SelectColumn selects, java.util.stream.Stream<K> keyStream)
DataSource
queryMapAsync
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类selects
- 指定字段keyStream
- 主键Streampublic <K extends java.io.Serializable,T> java.util.Map<K,T> queryMap(java.lang.Class<T> clazz, SelectColumn selects, FilterBean bean)
queryMap
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类selects
- 指定字段bean
- FilterBeanpublic <K extends java.io.Serializable,T> java.util.concurrent.CompletableFuture<java.util.Map<K,T>> queryMapAsync(java.lang.Class<T> clazz, SelectColumn selects, FilterBean bean)
DataSource
queryMapAsync
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类selects
- 指定字段bean
- FilterBeanpublic <K extends java.io.Serializable,T> java.util.Map<K,T> queryMap(java.lang.Class<T> clazz, SelectColumn selects, FilterNode node)
queryMap
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类selects
- 指定字段node
- FilterNodepublic <K extends java.io.Serializable,T> java.util.concurrent.CompletableFuture<java.util.Map<K,T>> queryMapAsync(java.lang.Class<T> clazz, SelectColumn selects, FilterNode node)
DataSource
queryMapAsync
在接口中 DataSource
K
- 主键泛型T
- Entity泛型clazz
- Entity类selects
- 指定字段node
- FilterNodepublic <T> java.util.List<T> queryList(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval)
queryList
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, java.lang.String column, java.io.Serializable colval)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类column
- 过滤字段名colval
- 过滤字段值public <T> java.util.List<T> queryList(java.lang.Class<T> clazz)
DataSource
queryList
在接口中 DataSource
T
- Entity泛型clazz
- Entity类public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, FilterBean bean)
queryList
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类bean
- 过滤Beanpublic <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, FilterBean bean)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类bean
- 过滤条件public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, FilterNode node)
DataSource
queryList
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, FilterNode node)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类node
- 过滤条件public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, SelectColumn selects, FilterBean bean)
queryList
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类selects
- 收集的字段bean
- 过滤Beanpublic <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, SelectColumn selects, FilterBean bean)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段bean
- 过滤条件public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, SelectColumn selects, FilterNode node)
DataSource
queryList
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, SelectColumn selects, FilterNode node)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段node
- 过滤条件public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, Flipper flipper, java.lang.String column, java.io.Serializable colval)
DataSource
queryList
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象column
- 过滤字段名colval
- 过滤字段值public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, Flipper flipper, java.lang.String column, java.io.Serializable colval)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象column
- 过滤字段名colval
- 过滤字段值public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, Flipper flipper, FilterBean bean)
DataSource
queryList
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象bean
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, Flipper flipper, FilterBean bean)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象bean
- 过滤条件public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
queryList
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterBean bean)
DataSource
queryList
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段flipper
- 翻页对象bean
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterBean bean)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段flipper
- 翻页对象bean
- 过滤条件public <T> java.util.List<T> queryList(java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterNode node)
DataSource
queryList
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段flipper
- 翻页对象node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<java.util.List<T>> queryListAsync(java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterNode node)
DataSource
queryListAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段flipper
- 翻页对象node
- 过滤条件public <T> Sheet<T> querySheet(java.lang.Class<T> clazz, Flipper flipper, FilterBean bean)
querySheet
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类flipper
- 翻页对象bean
- 过滤Beanpublic <T> java.util.concurrent.CompletableFuture<Sheet<T>> querySheetAsync(java.lang.Class<T> clazz, Flipper flipper, FilterBean bean)
DataSource
querySheetAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象bean
- 过滤条件public <T> Sheet<T> querySheet(java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
querySheet
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<Sheet<T>> querySheetAsync(java.lang.Class<T> clazz, Flipper flipper, FilterNode node)
DataSource
querySheetAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类flipper
- 翻页对象node
- 过滤条件public <T> Sheet<T> querySheet(java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterBean bean)
querySheet
在接口中 DataSource
T
- Entity类的泛型clazz
- Entity类selects
- 收集的字段集合flipper
- 翻页对象bean
- 过滤Beanpublic <T> java.util.concurrent.CompletableFuture<Sheet<T>> querySheetAsync(java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterBean bean)
DataSource
querySheetAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段flipper
- 翻页对象bean
- 过滤条件public <T> Sheet<T> querySheet(java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterNode node)
DataSource
querySheet
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段flipper
- 翻页对象node
- 过滤条件public <T> java.util.concurrent.CompletableFuture<Sheet<T>> querySheetAsync(java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterNode node)
DataSource
querySheetAsync
在接口中 DataSource
T
- Entity泛型clazz
- Entity类selects
- 指定字段flipper
- 翻页对象node
- 过滤条件protected <T> java.util.concurrent.CompletableFuture<Sheet<T>> querySheetCompose(boolean readcache, boolean needtotal, java.lang.Class<T> clazz, SelectColumn selects, Flipper flipper, FilterNode node)