模块 org.redkale

类 DataMemorySource

    • 构造器详细资料

      • DataMemorySource

        public DataMemorySource​(String name)
    • 方法详细资料

      • getType

        @Local
        public String getType()
        从接口复制的说明: DataSource
        获取数据源类型
        返回:
        String
      • acceptsConf

        public static boolean acceptsConf​(AnyValue config)
      • compile

        @Local
        public <T> void compile​(Class<T> clazz)
        从接口复制的说明: DataSource
        提取预编译Entity类,主要用于native-image使用
        类型参数:
        T - 泛型
        参数:
        clazz - Entity实体类
      • insert

        public <T> int insert​(T... entitys)
        从接口复制的说明: DataSource
        新增记录, 多对象必须是同一个Entity类且必须在同一张表中
        类型参数:
        T - 泛型
        参数:
        entitys - Entity对象
        返回:
        影响的记录条数
      • insertAsync

        public <T> CompletableFuture<Integer> insertAsync​(T... entitys)
        从接口复制的说明: DataSource
        新增记录, 多对象必须是同一个Entity类且必须在同一张表中
        类型参数:
        T - 泛型
        参数:
        entitys - Entity对象
        返回:
        CompletableFuture
      • delete

        public <T> int delete​(T... entitys)
        从接口复制的说明: DataSource
        删除指定主键值的记录, 多对象必须是同一个Entity类且必须在同一张表中
        等价SQL: DELETE FROM {table} WHERE {primary} IN {getValues.id}
        类型参数:
        T - 泛型
        参数:
        entitys - Entity对象
        返回:
        影响的记录条数
      • deleteAsync

        public <T> CompletableFuture<Integer> deleteAsync​(T... entitys)
        从接口复制的说明: DataSource
        删除指定主键值的记录, 多对象必须是同一个Entity类且必须在同一张表中
        等价SQL: DELETE FROM {table} WHERE {primary} IN {getValues.id}
        类型参数:
        T - 泛型
        参数:
        entitys - Entity对象
        返回:
        影响的记录条数CompletableFuture
      • delete

        public <T> int delete​(Class<T> clazz,
                              Serializable... pks)
        从接口复制的说明: DataSource
        删除指定主键值的记录,多主键值必须在同一张表中
        等价SQL: DELETE FROM {table} WHERE {primary} IN {ids}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pks - 主键值
        返回:
        影响的记录条数
      • deleteAsync

        public <T> CompletableFuture<Integer> deleteAsync​(Class<T> clazz,
                                                          Serializable... pks)
        从接口复制的说明: DataSource
        删除指定主键值的记录,多主键值必须在同一张表中
        等价SQL: DELETE FROM {table} WHERE {primary} IN {ids}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pks - 主键值
        返回:
        影响的记录条数CompletableFuture
      • delete

        public <T> int delete​(Class<T> clazz,
                              Flipper flipper,
                              FilterNode node)
        从接口复制的说明: DataSource
        删除符合过滤条件且指定最大影响条数的记录
        Flipper中offset字段将被忽略
        等价SQL: DELETE FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        flipper - 翻页对象
        node - 过滤条件
        返回:
        影响的记录条数
      • deleteAsync

        public <T> CompletableFuture<Integer> deleteAsync​(Class<T> clazz,
                                                          Flipper flipper,
                                                          FilterNode node)
        从接口复制的说明: DataSource
        删除符合过滤条件且指定最大影响条数的记录
        Flipper中offset字段将被忽略
        等价SQL: DELETE FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        flipper - 翻页对象
        node - 过滤条件
        返回:
        影响的记录条数CompletableFuture
      • clearTable

        public <T> int clearTable​(Class<T> clazz,
                                  FilterNode node)
        从接口复制的说明: DataSource
        清空表
        等价SQL: TRUNCATE TABLE {table}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        node - 分库分表的过滤条件
        返回:
        影响的记录条数 -1表示表不存在
      • clearTableAsync

        public <T> CompletableFuture<Integer> clearTableAsync​(Class<T> clazz,
                                                              FilterNode node)
        从接口复制的说明: DataSource
        清空表
        等价SQL: TRUNCATE TABLE {table}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        node - 分库分表的过滤条件
        返回:
        影响的记录条数CompletableFuture -1表示表不存在
      • createTable

        public <T> int createTable​(Class<T> clazz,
                                   Serializable pk)
        从接口复制的说明: DataSource
        删除表
        等价SQL: DROP TABLE {table}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pk - 主键
        返回:
        建表结果
      • createTableAsync

        public <T> CompletableFuture<Integer> createTableAsync​(Class<T> clazz,
                                                               Serializable pk)
        从接口复制的说明: DataSource
        删除表
        等价SQL: DROP TABLE {table}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pk - 主键
        返回:
        建表结果
      • dropTable

        public <T> int dropTable​(Class<T> clazz,
                                 FilterNode node)
        从接口复制的说明: DataSource
        删除表
        等价SQL: DROP TABLE {table}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        node - 过滤条件
        返回:
        影响的记录条数 -1表示表不存在
      • dropTableAsync

        public <T> CompletableFuture<Integer> dropTableAsync​(Class<T> clazz,
                                                             FilterNode node)
        从接口复制的说明: DataSource
        删除表
        等价SQL: DROP TABLE {table}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        node - 分库分表的过滤条件
        返回:
        影响的记录条数CompletableFuture -1表示表不存在
      • update

        public <T> int update​(T... entitys)
        从接口复制的说明: DataSource
        更新记录, 多对象必须是同一个Entity类且必须在同一张表中
        等价SQL:
        UPDATE {table} SET column1 = value1, column2 = value2, ··· WHERE {primary} = {id1}
        UPDATE {table} SET column1 = value1, column2 = value2, ··· WHERE {primary} = {id2}
        ···
        类型参数:
        T - 泛型
        参数:
        entitys - Entity对象
        返回:
        影响的记录条数
      • updateAsync

        public <T> CompletableFuture<Integer> updateAsync​(T... entitys)
        从接口复制的说明: DataSource
        更新记录, 多对象必须是同一个Entity类且必须在同一张表中
        等价SQL:
        UPDATE {table} SET column1 = value1, column2 = value2, ··· WHERE {primary} = {id1}
        UPDATE {table} SET column1 = value1, column2 = value2, ··· WHERE {primary} = {id2}
        ···
        类型参数:
        T - 泛型
        参数:
        entitys - Entity对象
        返回:
        影响的记录条数CompletableFuture
      • updateColumn

        public <T> int updateColumn​(Class<T> clazz,
                                    Serializable pk,
                                    String column,
                                    Serializable value)
        从接口复制的说明: DataSource
        更新单个记录的单个字段
        注意:即使字段标记为@Column(updatable=false)也会被更新
        等价SQL: UPDATE {table} SET {column} = {value} WHERE {primary} = {id}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pk - 主键
        column - 待更新的字段名
        value - 更新值
        返回:
        影响的记录条数
      • updateColumnAsync

        public <T> CompletableFuture<Integer> updateColumnAsync​(Class<T> clazz,
                                                                Serializable pk,
                                                                String column,
                                                                Serializable value)
        从接口复制的说明: DataSource
        更新单个记录的单个字段
        注意:即使字段标记为@Column(updatable=false)也会被更新
        等价SQL: UPDATE {table} SET {column} = {value} WHERE {primary} = {id}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pk - 主键
        column - 待更新的字段名
        value - 更新值
        返回:
        影响的记录条数CompletableFuture
      • updateColumn

        public <T> int updateColumn​(Class<T> clazz,
                                    String column,
                                    Serializable value,
                                    FilterNode node)
        从接口复制的说明: DataSource
        更新符合过滤条件记录的单个字段
        注意:即使字段标记为@Column(updatable=false)也会被更新
        等价SQL: UPDATE {table} SET {column} = {value} WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        column - 待更新的字段名
        value - 更新值
        node - 过滤条件
        返回:
        影响的记录条数
      • updateColumnAsync

        public <T> CompletableFuture<Integer> updateColumnAsync​(Class<T> clazz,
                                                                String column,
                                                                Serializable value,
                                                                FilterNode node)
        从接口复制的说明: DataSource
        更新符合过滤条件记录的单个字段
        注意:即使字段标记为@Column(updatable=false)也会被更新
        等价SQL: UPDATE {table} SET {column} = {value} WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        column - 待更新的字段名
        value - 更新值
        node - 过滤条件
        返回:
        影响的记录条数CompletableFuture
      • updateColumn

        public <T> int updateColumn​(Class<T> clazz,
                                    Serializable pk,
                                    ColumnValue... values)
        从接口复制的说明: DataSource
        更新指定主键值记录的部分字段
        字段赋值操作选项见 ColumnExpress
        等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, ··· WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pk - 主键
        values - 更新字段
        返回:
        影响的记录条数
      • updateColumnAsync

        public <T> CompletableFuture<Integer> updateColumnAsync​(Class<T> clazz,
                                                                Serializable pk,
                                                                ColumnValue... values)
        从接口复制的说明: DataSource
        更新指定主键值记录的部分字段
        字段赋值操作选项见 ColumnExpress
        等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, ··· WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pk - 主键
        values - 更新字段
        返回:
        影响的记录条数CompletableFuture
      • updateColumn

        public <T> int updateColumn​(Class<T> clazz,
                                    FilterNode node,
                                    Flipper flipper,
                                    ColumnValue... values)
        从接口复制的说明: DataSource
        更新符合过滤条件的记录的指定字段
        Flipper中offset字段将被忽略
        注意:Entity类中标记为@Column(updatable=false)不会被更新
        等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, ··· WHERE {filter node} ORDER BY {flipper.sort}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        node - 过滤条件
        flipper - 翻页对象
        values - 更新字段
        返回:
        影响的记录条数
      • updateColumnAsync

        public <T> CompletableFuture<Integer> updateColumnAsync​(Class<T> clazz,
                                                                FilterNode node,
                                                                Flipper flipper,
                                                                ColumnValue... values)
        从接口复制的说明: DataSource
        更新符合过滤条件的记录的指定字段
        Flipper中offset字段将被忽略
        注意:Entity类中标记为@Column(updatable=false)不会被更新
        等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} += {value2}, {column3} *= {value3}, ··· WHERE {filter node} ORDER BY {flipper.sort}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        node - 过滤条件
        flipper - 翻页对象
        values - 更新字段
        返回:
        影响的记录条数CompletableFuture
      • updateColumn

        public <T> int updateColumn​(T entity,
                                    FilterNode node,
                                    SelectColumn selects)
        从接口复制的说明: DataSource
        更新符合过滤条件记录的指定字段
        注意:Entity类中标记为@Column(updatable=false)不会被更新
        等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        entity - 待更新的Entity对象
        node - 过滤条件
        selects - 指定字段
        返回:
        影响的记录条数
      • updateColumnAsync

        public <T> CompletableFuture<Integer> updateColumnAsync​(T entity,
                                                                FilterNode node,
                                                                SelectColumn selects)
        从接口复制的说明: DataSource
        更新符合过滤条件记录的指定字段
        注意:Entity类中标记为@Column(updatable=false)不会被更新
        等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, ··· WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        entity - 待更新的Entity对象
        node - 过滤条件
        selects - 指定字段
        返回:
        影响的记录条数CompletableFuture
      • getNumberResult

        public Number getNumberResult​(Class entityClass,
                                      FilterFunc func,
                                      Number defVal,
                                      String column,
                                      FilterNode node)
        从接口复制的说明: DataSource
        获取符合过滤条件记录的聚合结果, 无结果返回默认值
        等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}
        如 getNumberResultAsync(User.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
        参数:
        entityClass - Entity类
        func - 聚合函数
        defVal - 默认值
        column - 指定字段
        node - 过滤条件
        返回:
        聚合结果
      • getNumberResultAsync

        public CompletableFuture<Number> getNumberResultAsync​(Class entityClass,
                                                              FilterFunc func,
                                                              Number defVal,
                                                              String column,
                                                              FilterNode node)
        从接口复制的说明: DataSource
        获取符合过滤条件记录的聚合结果, 无结果返回默认值
        等价SQL: SELECT FUNC{column} FROM {table} WHERE {filter node}
        如 getNumberResultAsync(User.class, FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT MAX(createtime) FROM {table}
        参数:
        entityClass - Entity类
        func - 聚合函数
        defVal - 默认值
        column - 指定字段
        node - 过滤条件
        返回:
        聚合结果CompletableFuture
      • getNumberMap

        public <N extends NumberMap<String,​N> getNumberMap​(Class entityClass,
                                                                   FilterNode node,
                                                                   FilterFuncColumn... columns)
        从接口复制的说明: DataSource
        获取符合过滤条件记录的聚合结果Map
        等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter node}
        如 getNumberMapAsync(User.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
        类型参数:
        N - Number
        参数:
        entityClass - Entity类
        node - 过滤条件
        columns - 聚合字段
        返回:
        聚合结果Map
      • getNumberMapAsync

        public <N extends NumberCompletableFuture<Map<String,​N>> getNumberMapAsync​(Class entityClass,
                                                                                           FilterNode node,
                                                                                           FilterFuncColumn... columns)
        从接口复制的说明: DataSource
        获取符合过滤条件记录的聚合结果Map
        等价SQL: SELECT FUNC1{column1}, FUNC2{column2}, ··· FROM {table} WHERE {filter node}
        如 getNumberMapAsync(User.class, (FilterNode)null, new FilterFuncColumn(FilterFunc.MAX, "createtime")) 等价于: SELECT MAX(createtime) FROM {table}
        类型参数:
        N - Number
        参数:
        entityClass - Entity类
        node - 过滤条件
        columns - 聚合字段
        返回:
        聚合结果Map
      • queryColumnMap

        public <T,​K extends Serializable,​N extends NumberMap<K,​N> queryColumnMap​(Class<T> entityClass,
                                                                                                     String keyColumn,
                                                                                                     FilterFunc func,
                                                                                                     String funcColumn,
                                                                                                     FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的GROUP BY聚合结果Map
        等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter node} GROUP BY {keyColumn}
        如 queryColumnMapAsync(User.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM user GROUP BY name
        类型参数:
        T - Entity泛型
        K - Key字段的数据类型
        N - Number
        参数:
        entityClass - Entity类
        keyColumn - Key字段
        func - 聚合函数
        funcColumn - 聚合字段
        node - 过滤条件
        返回:
        聚合结果Map
      • queryColumnMapAsync

        public <T,​K extends Serializable,​N extends NumberCompletableFuture<Map<K,​N>> queryColumnMapAsync​(Class<T> entityClass,
                                                                                                                             String keyColumn,
                                                                                                                             FilterFunc func,
                                                                                                                             String funcColumn,
                                                                                                                             FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的GROUP BY聚合结果Map
        等价SQL: SELECT keyColumn, FUNC{funcColumn} FROM {table} WHERE {filter node} GROUP BY {keyColumn}
        如 queryColumnMapAsync(User.class, "name", FilterFunc.MAX, "createtime", (FilterNode)null) 等价于: SELECT name, MAX(createtime) FROM user GROUP BY name
        类型参数:
        T - Entity泛型
        K - Key字段的数据类型
        N - Number
        参数:
        entityClass - Entity类
        keyColumn - Key字段
        func - 聚合函数
        funcColumn - 聚合字段
        node - 过滤条件
        返回:
        聚合结果Map CompletableFuture
      • queryColumnMap

        public <T,​K extends Serializable,​N extends NumberMap<K,​N[]> queryColumnMap​(Class<T> entityClass,
                                                                                                       ColumnNode[] funcNodes,
                                                                                                       String groupByColumn,
                                                                                                       FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的GROUP BY聚合结果Map
        等价SQL: SELECT col1, FUNC{funcColumn1}, FUNC{funcColumn2} FROM {table} WHERE {filter node} GROUP BY {col1}
        如 queryColumnMapAsync(OrderRecord.class, Utility.ofArray(ColumnExpNode.div(ColumnFuncNode.sum("money"), 100), ColumnFuncNode.avg(ColumnExpNode.dec("money", 20)))), "targetid", (FilterNode)null) 等价于: SELECT targetid, SUM(money) / 100, AVG(money - 20) FROM orderrecord GROUP BY targetid
        类型参数:
        T - Entity泛型
        K - Key字段的数据类型
        N - Number
        参数:
        entityClass - Entity类
        funcNodes - ColumnNode[]
        groupByColumn - GROUP BY字段
        node - 过滤条件
        返回:
        聚合结果Map CompletableFuture
      • queryColumnMapAsync

        public <T,​K extends Serializable,​N extends NumberCompletableFuture<Map<K,​N[]>> queryColumnMapAsync​(Class<T> entityClass,
                                                                                                                               ColumnNode[] funcNodes,
                                                                                                                               String groupByColumn,
                                                                                                                               FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的GROUP BY聚合结果Map
        等价SQL: SELECT col1, FUNC{funcColumn1}, FUNC{funcColumn2} FROM {table} WHERE {filter node} GROUP BY {col1}
        如 queryColumnMapAsync(OrderRecord.class, Utility.ofArray(ColumnExpNode.div(ColumnFuncNode.sum("money"), 100), ColumnFuncNode.avg(ColumnExpNode.dec("money", 20)))), "targetid", (FilterNode)null) 等价于: SELECT targetid, SUM(money) / 100, AVG(money - 20) FROM orderrecord GROUP BY targetid
        类型参数:
        T - Entity泛型
        K - Key字段的数据类型
        N - Number
        参数:
        entityClass - Entity类
        funcNodes - ColumnNode[]
        groupByColumn - GROUP BY字段
        node - 过滤条件
        返回:
        聚合结果Map CompletableFuture
      • queryColumnMap

        public <T,​K extends Serializable,​N extends NumberMap<K[],​N[]> queryColumnMap​(Class<T> entityClass,
                                                                                                         ColumnNode[] funcNodes,
                                                                                                         String[] groupByColumns,
                                                                                                         FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的GROUP BY聚合结果Map
        等价SQL: SELECT col1, col2, FUNC{funcColumn1}, FUNC{funcColumn2} FROM {table} WHERE {filter node} GROUP BY {col1}, {col2}
        如 queryColumnMapAsync(OrderRecord.class, Utility.ofArray(ColumnExpNode.div(ColumnFuncNode.sum("money"), 100), ColumnFuncNode.avg(ColumnExpNode.dec("money", 20)))), Utility.ofArray("fromid", "targetid"), (FilterNode)null) 等价于: SELECT fromid, targetid, SUM(money) / 100, AVG(money - 20) FROM orderrecord GROUP BY fromid, targetid
        类型参数:
        T - Entity泛型
        K - Key字段的数据类型
        N - Number
        参数:
        entityClass - Entity类
        funcNodes - ColumnNode[]
        groupByColumns - GROUP BY字段
        node - 过滤条件
        返回:
        聚合结果Map
      • queryColumnMapAsync

        public <T,​K extends Serializable,​N extends NumberCompletableFuture<Map<K[],​N[]>> queryColumnMapAsync​(Class<T> entityClass,
                                                                                                                                 ColumnNode[] funcNodes,
                                                                                                                                 String[] groupByColumns,
                                                                                                                                 FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的GROUP BY聚合结果Map
        等价SQL: SELECT col1, col2, FUNC{funcColumn1}, FUNC{funcColumn2} FROM {table} WHERE {filter node} GROUP BY {col1}, {col2}
        如 queryColumnMapAsync(OrderRecord.class, Utility.ofArray(ColumnExpNode.div(ColumnFuncNode.sum("money"), 100), ColumnFuncNode.avg(ColumnExpNode.dec("money", 20)))), Utility.ofArray("fromid", "targetid"), (FilterNode)null) 等价于: SELECT fromid, targetid, SUM(money) / 100, AVG(money - 20) FROM orderrecord GROUP BY fromid, targetid
        类型参数:
        T - Entity泛型
        K - Key字段的数据类型
        N - Number
        参数:
        entityClass - Entity类
        funcNodes - ColumnNode[]
        groupByColumns - GROUP BY字段
        node - 过滤条件
        返回:
        聚合结果Map CompletableFuture
      • find

        public <T> T find​(Class<T> clazz,
                          SelectColumn selects,
                          Serializable pk)
        从接口复制的说明: DataSource
        获取指定主键值的单个记录, 返回null表示不存在值
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        pk - 主键值
        返回:
        Entity对象
      • findAsync

        public <T> CompletableFuture<T> findAsync​(Class<T> clazz,
                                                  SelectColumn selects,
                                                  Serializable pk)
        从接口复制的说明: DataSource
        获取指定主键值的单个记录, 返回null表示不存在值
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        pk - 主键值
        返回:
        Entity对象CompletableFuture
      • finds

        public <T> T[] finds​(Class<T> clazz,
                             SelectColumn selects,
                             Serializable... pks)
        从接口复制的说明: DataSource
        获取指定主键值的多个记录, 返回数组,数组长度与pks一样
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id1,id2, ···}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        pks - 主键值集合
        返回:
        Entity对象
      • findsAsync

        public <T> CompletableFuture<T[]> findsAsync​(Class<T> clazz,
                                                     SelectColumn selects,
                                                     Serializable... pks)
        从接口复制的说明: DataSource
        获取指定主键值的多个记录, 返回数组,数组长度与pks一样
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id1,id2, ···}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        pks - 主键值集合
        返回:
        Entity对象CompletableFuture
      • findsList

        public <D extends Serializable,​T> List<T> findsList​(Class<T> clazz,
                                                                  Stream<D> pks)
        从接口复制的说明: DataSource
        获取指定主键值的多个记录, 返回列表
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id1,id2, ···}
        类型参数:
        D - 主键泛型
        T - Entity泛型
        参数:
        clazz - Entity类
        pks - 主键值集合
        返回:
        Entity对象
      • findsListAsync

        public <D extends Serializable,​T> CompletableFuture<List<T>> findsListAsync​(Class<T> clazz,
                                                                                          Stream<D> pks)
        从接口复制的说明: DataSource
        获取指定主键值的多个记录, 返回列表
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id1,id2, ···}
        类型参数:
        D - 主键泛型
        T - Entity泛型
        参数:
        clazz - Entity类
        pks - 主键值集合
        返回:
        Entity对象
      • find

        public <T> T find​(Class<T> clazz,
                          SelectColumn selects,
                          FilterNode node)
        从接口复制的说明: DataSource
        获取符合过滤条件单个记录, 返回null表示不存在值
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        node - 过滤条件
        返回:
        Entity对象
      • findAsync

        public <T> CompletableFuture<T> findAsync​(Class<T> clazz,
                                                  SelectColumn selects,
                                                  FilterNode node)
        从接口复制的说明: DataSource
        获取符合过滤条件单个记录, 返回null表示不存在值
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        node - 过滤条件
        返回:
        Entity对象 CompletableFuture
      • findColumn

        public <T> Serializable findColumn​(Class<T> clazz,
                                           String column,
                                           Serializable defValue,
                                           Serializable pk)
        从接口复制的说明: DataSource
        获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
        等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        column - 字段名
        defValue - 默认值
        pk - 主键值
        返回:
        字段值
      • findColumnAsync

        public <T> CompletableFuture<Serializable> findColumnAsync​(Class<T> clazz,
                                                                   String column,
                                                                   Serializable defValue,
                                                                   Serializable pk)
        从接口复制的说明: DataSource
        获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
        等价SQL: SELECT {column} FROM {table} WHERE {primary} = {id}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        column - 字段名
        defValue - 默认值
        pk - 主键值
        返回:
        字段值 CompletableFuture
      • findColumn

        public <T> Serializable findColumn​(Class<T> clazz,
                                           String column,
                                           Serializable defValue,
                                           FilterNode node)
        从接口复制的说明: DataSource
        获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
        等价SQL: SELECT {column} FROM {table} WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        column - 字段名
        defValue - 默认值
        node - 过滤条件
        返回:
        字段值
      • findColumnAsync

        public <T> CompletableFuture<Serializable> findColumnAsync​(Class<T> clazz,
                                                                   String column,
                                                                   Serializable defValue,
                                                                   FilterNode node)
        从接口复制的说明: DataSource
        获取符合过滤条件单个记录的单个字段值, 不存在值则返回默认值
        等价SQL: SELECT {column} FROM {table} WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        column - 字段名
        defValue - 默认值
        node - 过滤条件
        返回:
        字段值 CompletableFuture
      • exists

        public <T> boolean exists​(Class<T> clazz,
                                  Serializable pk)
        从接口复制的说明: DataSource
        判断是否存在主键值的记录
        等价SQL: SELECT COUNT(*) FROM {table} WHERE {primary} = {id}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pk - 主键值
        返回:
        是否存在
      • existsAsync

        public <T> CompletableFuture<Boolean> existsAsync​(Class<T> clazz,
                                                          Serializable pk)
        从接口复制的说明: DataSource
        判断是否存在主键值的记录
        等价SQL: SELECT COUNT(*) FROM {table} WHERE {primary} = {id}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        pk - 主键值
        返回:
        是否存在CompletableFuture
      • exists

        public <T> boolean exists​(Class<T> clazz,
                                  FilterNode node)
        从接口复制的说明: DataSource
        判断是否存在符合过滤条件的记录
        等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        node - 过滤条件
        返回:
        是否存在
      • existsAsync

        public <T> CompletableFuture<Boolean> existsAsync​(Class<T> clazz,
                                                          FilterNode node)
        从接口复制的说明: DataSource
        判断是否存在符合过滤条件的记录
        等价SQL: SELECT COUNT(*) FROM {table} WHERE {filter node}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        node - 过滤条件
        返回:
        是否存在CompletableFuture
      • queryColumnSet

        public <T,​V extends SerializableSet<V> queryColumnSet​(String selectedColumn,
                                                                      Class<T> clazz,
                                                                      Flipper flipper,
                                                                      FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的某个字段Set集合
        等价SQL: SELECT DISTINCT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        V - 字段类型
        参数:
        selectedColumn - 指定字段
        clazz - Entity类
        flipper - 翻页对象
        node - 过滤条件
        返回:
        字段值的集合
      • queryColumnSetAsync

        public <T,​V extends SerializableCompletableFuture<Set<V>> queryColumnSetAsync​(String selectedColumn,
                                                                                              Class<T> clazz,
                                                                                              Flipper flipper,
                                                                                              FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的某个字段Set集合
        等价SQL: SELECT DISTINCT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        V - 字段类型
        参数:
        selectedColumn - 指定字段
        clazz - Entity类
        flipper - 翻页对象
        node - 过滤条件
        返回:
        字段值的集合CompletableFuture
      • queryColumnList

        public <T,​V extends SerializableList<V> queryColumnList​(String selectedColumn,
                                                                        Class<T> clazz,
                                                                        Flipper flipper,
                                                                        FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的某个字段List集合
        等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        V - 字段类型
        参数:
        selectedColumn - 指定字段
        clazz - Entity类
        flipper - 翻页对象
        node - 过滤条件
        返回:
        字段值的集合
      • queryColumnListAsync

        public <T,​V extends SerializableCompletableFuture<List<V>> queryColumnListAsync​(String selectedColumn,
                                                                                                Class<T> clazz,
                                                                                                Flipper flipper,
                                                                                                FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的某个字段List集合
        等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        V - 字段类型
        参数:
        selectedColumn - 指定字段
        clazz - Entity类
        flipper - 翻页对象
        node - 过滤条件
        返回:
        字段值的集合CompletableFuture
      • queryColumnSheet

        public <T,​V extends SerializableSheet<V> queryColumnSheet​(String selectedColumn,
                                                                          Class<T> clazz,
                                                                          Flipper flipper,
                                                                          FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的某个字段Sheet集合
        等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        V - 字段类型
        参数:
        selectedColumn - 指定字段
        clazz - Entity类
        flipper - 翻页对象
        node - 过滤条件
        返回:
        字段值的集合
      • queryColumnSheetAsync

        public <T,​V extends SerializableCompletableFuture<Sheet<V>> queryColumnSheetAsync​(String selectedColumn,
                                                                                                  Class<T> clazz,
                                                                                                  Flipper flipper,
                                                                                                  FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的某个字段Sheet集合
        等价SQL: SELECT {selectedColumn} FROM {table} WHERE {filter bean} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        V - 字段类型
        参数:
        selectedColumn - 指定字段
        clazz - Entity类
        flipper - 翻页对象
        node - 过滤条件
        返回:
        字段值的集合CompletableFuture
      • queryMap

        public <K extends Serializable,​T> Map<K,​T> queryMap​(Class<T> clazz,
                                                                        SelectColumn selects,
                                                                        Stream<K> keyStream)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的List转Map集合, key=主键值, value=Entity对象
        等价SQL: SELECT * FROM {table} WHERE id IN {ids}
        类型参数:
        K - 主键泛型
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        keyStream - 主键Stream
        返回:
        Entity的集合
      • queryMapAsync

        public <K extends Serializable,​T> CompletableFuture<Map<K,​T>> queryMapAsync​(Class<T> clazz,
                                                                                                SelectColumn selects,
                                                                                                Stream<K> keyStream)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的List转Map集合, key=主键值, value=Entity对象
        等价SQL: SELECT * FROM {table} WHERE id IN {ids}
        类型参数:
        K - 主键泛型
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        keyStream - 主键Stream
        返回:
        Entity的集合CompletableFuture
      • queryMap

        public <K extends Serializable,​T> Map<K,​T> queryMap​(Class<T> clazz,
                                                                        SelectColumn selects,
                                                                        FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的List转Map集合, key=主键值, value=Entity对象
        等价SQL: SELECT * FROM {table} WHERE {filter node}
        类型参数:
        K - 主键泛型
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        node - FilterNode
        返回:
        Entity的集合
      • queryMapAsync

        public <K extends Serializable,​T> CompletableFuture<Map<K,​T>> queryMapAsync​(Class<T> clazz,
                                                                                                SelectColumn selects,
                                                                                                FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的List转Map集合, key=主键值, value=Entity对象
        等价SQL: SELECT * FROM {table} WHERE {filter node}
        类型参数:
        K - 主键泛型
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        node - FilterNode
        返回:
        Entity的集合CompletableFuture
      • querySet

        public <T> Set<T> querySet​(Class<T> clazz,
                                   SelectColumn selects,
                                   Flipper flipper,
                                   FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的Set集合
        等价SQL: SELECT DISTINCT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        flipper - 翻页对象
        node - 过滤条件
        返回:
        Entity的集合
      • querySetAsync

        public <T> CompletableFuture<Set<T>> querySetAsync​(Class<T> clazz,
                                                           SelectColumn selects,
                                                           Flipper flipper,
                                                           FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的Set集合
        等价SQL: SELECT DISTINCT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        flipper - 翻页对象
        node - 过滤条件
        返回:
        Entity的集合CompletableFuture
      • queryList

        public <T> List<T> queryList​(Class<T> clazz,
                                     SelectColumn selects,
                                     Flipper flipper,
                                     FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的List集合
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        flipper - 翻页对象
        node - 过滤条件
        返回:
        Entity的集合
      • queryListAsync

        public <T> CompletableFuture<List<T>> queryListAsync​(Class<T> clazz,
                                                             SelectColumn selects,
                                                             Flipper flipper,
                                                             FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的List集合
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        flipper - 翻页对象
        node - 过滤条件
        返回:
        Entity的集合CompletableFuture
      • querySheet

        public <T> Sheet<T> querySheet​(Class<T> clazz,
                                       SelectColumn selects,
                                       Flipper flipper,
                                       FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的Sheet集合
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        flipper - 翻页对象
        node - 过滤条件
        返回:
        Entity的集合
      • querySheetAsync

        public <T> CompletableFuture<Sheet<T>> querySheetAsync​(Class<T> clazz,
                                                               SelectColumn selects,
                                                               Flipper flipper,
                                                               FilterNode node)
        从接口复制的说明: DataSource
        查询符合过滤条件记录的Sheet集合
        等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {filter node} ORDER BY {flipper.sort} LIMIT {flipper.limit}
        类型参数:
        T - Entity泛型
        参数:
        clazz - Entity类
        selects - 指定字段
        flipper - 翻页对象
        node - 过滤条件
        返回:
        Entity的集合CompletableFuture