This commit is contained in:
Redkale
2019-01-12 11:28:29 +08:00
parent 2e1ff333f5
commit bb09aea8bb

View File

@@ -35,45 +35,45 @@ public interface DataSource {
/** /**
* 新增记录, 多对象必须是同一个Entity类且必须在同一张表中 <br> * 新增记录, 多对象必须是同一个Entity类且必须在同一张表中 <br>
* *
* @param <T> 泛型 * @param <T> 泛型
* @param values Entity对象 * @param entitys Entity对象
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int insert(final T... values); public <T> int insert(final T... entitys);
/** /**
* 新增记录, 多对象必须是同一个Entity类且必须在同一张表中 <br> * 新增记录, 多对象必须是同一个Entity类且必须在同一张表中 <br>
* *
* @param <T> 泛型 * @param <T> 泛型
* @param values Entity对象 * @param entitys Entity对象
* *
* @return CompletableFuture * @return CompletableFuture
*/ */
public <T> CompletableFuture<Integer> insertAsync(final T... values); public <T> CompletableFuture<Integer> insertAsync(final T... entitys);
//-------------------------deleteAsync-------------------------- //-------------------------deleteAsync--------------------------
/** /**
* 删除指定主键值的记录, 多对象必须是同一个Entity类且必须在同一张表中 <br> * 删除指定主键值的记录, 多对象必须是同一个Entity类且必须在同一张表中 <br>
* 等价SQL: DELETE FROM {table} WHERE {primary} IN {values.id} <br> * 等价SQL: DELETE FROM {table} WHERE {primary} IN {values.id} <br>
* *
* @param <T> 泛型 * @param <T> 泛型
* @param values Entity对象 * @param entitys Entity对象
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int delete(final T... values); public <T> int delete(final T... entitys);
/** /**
* 删除指定主键值的记录, 多对象必须是同一个Entity类且必须在同一张表中 <br> * 删除指定主键值的记录, 多对象必须是同一个Entity类且必须在同一张表中 <br>
* 等价SQL: DELETE FROM {table} WHERE {primary} IN {values.id} <br> * 等价SQL: DELETE FROM {table} WHERE {primary} IN {values.id} <br>
* *
* @param <T> 泛型 * @param <T> 泛型
* @param values Entity对象 * @param entitys Entity对象
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> deleteAsync(final T... values); public <T> CompletableFuture<Integer> deleteAsync(final T... entitys);
/** /**
* 删除指定主键值的记录,多主键值必须在同一张表中 <br> * 删除指定主键值的记录,多主键值必须在同一张表中 <br>
@@ -81,11 +81,11 @@ public interface DataSource {
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param ids 主键值 * @param pks 主键值
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int delete(final Class<T> clazz, final Serializable... ids); public <T> int delete(final Class<T> clazz, final Serializable... pks);
/** /**
* 删除指定主键值的记录,多主键值必须在同一张表中 <br> * 删除指定主键值的记录,多主键值必须在同一张表中 <br>
@@ -93,11 +93,11 @@ public interface DataSource {
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param ids 主键值 * @param pks 主键值
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> deleteAsync(final Class<T> clazz, final Serializable... ids); public <T> CompletableFuture<Integer> deleteAsync(final Class<T> clazz, final Serializable... pks);
/** /**
* 删除符合过滤条件的记录 <br> * 删除符合过滤条件的记录 <br>
@@ -253,12 +253,12 @@ public interface DataSource {
* UPDATE {table} SET column1 = value1, column2 = value2, &#183;&#183;&#183; WHERE {primary} = {id2} <br> * UPDATE {table} SET column1 = value1, column2 = value2, &#183;&#183;&#183; WHERE {primary} = {id2} <br>
* &#183;&#183;&#183; <br> * &#183;&#183;&#183; <br>
* *
* @param <T> 泛型 * @param <T> 泛型
* @param values Entity对象 * @param entitys Entity对象
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int update(final T... values); public <T> int update(final T... entitys);
/** /**
* 更新记录, 多对象必须是同一个Entity类且必须在同一张表中 <br> * 更新记录, 多对象必须是同一个Entity类且必须在同一张表中 <br>
@@ -267,12 +267,12 @@ public interface DataSource {
* UPDATE {table} SET column1 = value1, column2 = value2, &#183;&#183;&#183; WHERE {primary} = {id2} <br> * UPDATE {table} SET column1 = value1, column2 = value2, &#183;&#183;&#183; WHERE {primary} = {id2} <br>
* &#183;&#183;&#183; <br> * &#183;&#183;&#183; <br>
* *
* @param <T> 泛型 * @param <T> 泛型
* @param values Entity对象 * @param entitys Entity对象
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> updateAsync(final T... values); public <T> CompletableFuture<Integer> updateAsync(final T... entitys);
/** /**
* 更新单个记录的单个字段 <br> * 更新单个记录的单个字段 <br>
@@ -281,13 +281,13 @@ public interface DataSource {
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param id 主键 * @param pk 主键
* @param column 待更新的字段名 * @param column 待更新的字段名
* @param value 更新值 * @param value 更新值
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int updateColumn(final Class<T> clazz, final Serializable id, final String column, final Serializable value); public <T> int updateColumn(final Class<T> clazz, final Serializable pk, final String column, final Serializable value);
/** /**
* 更新单个记录的单个字段 <br> * 更新单个记录的单个字段 <br>
@@ -296,13 +296,13 @@ public interface DataSource {
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param id 主键 * @param pk 主键
* @param column 待更新的字段名 * @param column 待更新的字段名
* @param value 更新值 * @param value 更新值
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final Serializable id, final String column, final Serializable value); public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final Serializable pk, final String column, final Serializable value);
/** /**
* 更新符合过滤条件记录的单个字段 <br> * 更新符合过滤条件记录的单个字段 <br>
@@ -341,12 +341,12 @@ public interface DataSource {
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param id 主键 * @param pk 主键
* @param values 更新字段 * @param values 更新字段
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int updateColumn(final Class<T> clazz, final Serializable id, final ColumnValue... values); public <T> int updateColumn(final Class<T> clazz, final Serializable pk, final ColumnValue... values);
/** /**
* 更新指定主键值记录的部分字段 <br> * 更新指定主键值记录的部分字段 <br>
@@ -355,12 +355,12 @@ public interface DataSource {
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param id 主键 * @param pk 主键
* @param values 更新字段 * @param values 更新字段
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final Serializable id, final ColumnValue... values); public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final Serializable pk, final ColumnValue... values);
/** /**
* 更新符合过滤条件记录的部分字段 <br> * 更新符合过滤条件记录的部分字段 <br>
@@ -430,12 +430,12 @@ public interface DataSource {
* 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id} <br> * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id} <br>
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param bean 待更新的Entity对象 * @param entity 待更新的Entity对象
* @param columns 需更新的字段名 * @param columns 需更新的字段名
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int updateColumn(final T bean, final String... columns); public <T> int updateColumn(final T entity, final String... columns);
/** /**
* 更新单个记录的指定字段 <br> * 更新单个记录的指定字段 <br>
@@ -443,12 +443,12 @@ public interface DataSource {
* 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id} <br> * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id} <br>
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param bean 待更新的Entity对象 * @param entity 待更新的Entity对象
* @param columns 需更新的字段名 * @param columns 需更新的字段名
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final String... columns); public <T> CompletableFuture<Integer> updateColumnAsync(final T entity, final String... columns);
/** /**
* 更新符合过滤条件记录的指定字段 <br> * 更新符合过滤条件记录的指定字段 <br>
@@ -456,13 +456,13 @@ public interface DataSource {
* 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node} <br> * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node} <br>
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param bean 待更新的Entity对象 * @param entity 待更新的Entity对象
* @param node 过滤条件 * @param node 过滤条件
* @param columns 需更新的字段名 * @param columns 需更新的字段名
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int updateColumn(final T bean, final FilterNode node, final String... columns); public <T> int updateColumn(final T entity, final FilterNode node, final String... columns);
/** /**
* 更新符合过滤条件记录的指定字段 <br> * 更新符合过滤条件记录的指定字段 <br>
@@ -470,13 +470,13 @@ public interface DataSource {
* 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node} <br> * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node} <br>
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param bean 待更新的Entity对象 * @param entity 待更新的Entity对象
* @param node 过滤条件 * @param node 过滤条件
* @param columns 需更新的字段名 * @param columns 需更新的字段名
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final FilterNode node, final String... columns); public <T> CompletableFuture<Integer> updateColumnAsync(final T entity, final FilterNode node, final String... columns);
/** /**
* 更新单个记录的指定字段 <br> * 更新单个记录的指定字段 <br>
@@ -484,12 +484,12 @@ public interface DataSource {
* 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id} <br> * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id} <br>
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param bean 待更新的Entity对象 * @param entity 待更新的Entity对象
* @param selects 指定字段 * @param selects 指定字段
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int updateColumn(final T bean, final SelectColumn selects); public <T> int updateColumn(final T entity, final SelectColumn selects);
/** /**
* 更新单个记录的指定字段 <br> * 更新单个记录的指定字段 <br>
@@ -497,12 +497,12 @@ public interface DataSource {
* 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id} <br> * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {primary} = {bean.id} <br>
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param bean 待更新的Entity对象 * @param entity 待更新的Entity对象
* @param selects 指定字段 * @param selects 指定字段
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final SelectColumn selects); public <T> CompletableFuture<Integer> updateColumnAsync(final T entity, final SelectColumn selects);
/** /**
* 更新符合过滤条件记录的指定字段 <br> * 更新符合过滤条件记录的指定字段 <br>
@@ -510,13 +510,13 @@ public interface DataSource {
* 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node} <br> * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node} <br>
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param bean 待更新的Entity对象 * @param entity 待更新的Entity对象
* @param node 过滤条件 * @param node 过滤条件
* @param selects 指定字段 * @param selects 指定字段
* *
* @return 影响的记录条数 * @return 影响的记录条数
*/ */
public <T> int updateColumn(final T bean, final FilterNode node, final SelectColumn selects); public <T> int updateColumn(final T entity, final FilterNode node, final SelectColumn selects);
/** /**
* 更新符合过滤条件记录的指定字段 <br> * 更新符合过滤条件记录的指定字段 <br>
@@ -524,13 +524,13 @@ public interface DataSource {
* 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node} <br> * 等价SQL: UPDATE {table} SET {column1} = {value1}, {column2} = {value2}, {column3} = {value3}, &#183;&#183;&#183; WHERE {filter node} <br>
* *
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param bean 待更新的Entity对象 * @param entity 待更新的Entity对象
* @param node 过滤条件 * @param node 过滤条件
* @param selects 指定字段 * @param selects 指定字段
* *
* @return 影响的记录条数CompletableFuture * @return 影响的记录条数CompletableFuture
*/ */
public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final FilterNode node, final SelectColumn selects); public <T> CompletableFuture<Integer> updateColumnAsync(final T entity, final FilterNode node, final SelectColumn selects);
//############################################# 查询接口 ############################################# //############################################# 查询接口 #############################################
//-----------------------getXXXXResult----------------------------- //-----------------------getXXXXResult-----------------------------
@@ -950,11 +950,11 @@ public interface DataSource {
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return Entity对象 * @return Entity对象
*/ */
public <T> T find(final Class<T> clazz, final String column, final Serializable key); public <T> T find(final Class<T> clazz, final String column, final Serializable colval);
/** /**
* 获取符合过滤条件单个记录, 返回null表示不存在值 <br> * 获取符合过滤条件单个记录, 返回null表示不存在值 <br>
@@ -963,11 +963,11 @@ public interface DataSource {
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return Entity对象CompletableFuture * @return Entity对象CompletableFuture
*/ */
public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final String column, final Serializable key); public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final String column, final Serializable colval);
/** /**
* 获取符合过滤条件单个记录, 返回null表示不存在值 <br> * 获取符合过滤条件单个记录, 返回null表示不存在值 <br>
@@ -1313,11 +1313,11 @@ public interface DataSource {
* @param selectedColumn 指定字段 * @param selectedColumn 指定字段
* @param clazz Entity类 * @param clazz Entity类
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return 字段值的集合 * @return 字段值的集合
*/ */
public <T, V extends Serializable> HashSet<V> queryColumnSet(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key); public <T, V extends Serializable> HashSet<V> queryColumnSet(final String selectedColumn, final Class<T> clazz, final String column, final Serializable colval);
/** /**
* 查询符合过滤条件记录的某个字段Set集合 <br> * 查询符合过滤条件记录的某个字段Set集合 <br>
@@ -1328,11 +1328,11 @@ public interface DataSource {
* @param selectedColumn 指定字段 * @param selectedColumn 指定字段
* @param clazz Entity类 * @param clazz Entity类
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return 字段值的集合CompletableFuture * @return 字段值的集合CompletableFuture
*/ */
public <T, V extends Serializable> CompletableFuture<HashSet<V>> queryColumnSetAsync(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key); public <T, V extends Serializable> CompletableFuture<HashSet<V>> queryColumnSetAsync(final String selectedColumn, final Class<T> clazz, final String column, final Serializable colval);
/** /**
* 查询符合过滤条件记录的某个字段Set集合 <br> * 查询符合过滤条件记录的某个字段Set集合 <br>
@@ -1399,11 +1399,11 @@ public interface DataSource {
* @param selectedColumn 指定字段 * @param selectedColumn 指定字段
* @param clazz Entity类 * @param clazz Entity类
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return 字段值的集合 * @return 字段值的集合
*/ */
public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key); public <T, V extends Serializable> List<V> queryColumnList(final String selectedColumn, final Class<T> clazz, final String column, final Serializable colval);
/** /**
* 查询符合过滤条件记录的某个字段List集合 <br> * 查询符合过滤条件记录的某个字段List集合 <br>
@@ -1414,11 +1414,11 @@ public interface DataSource {
* @param selectedColumn 指定字段 * @param selectedColumn 指定字段
* @param clazz Entity类 * @param clazz Entity类
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return 字段值的集合CompletableFuture * @return 字段值的集合CompletableFuture
*/ */
public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key); public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final String column, final Serializable colval);
/** /**
* 查询符合过滤条件记录的某个字段List集合 <br> * 查询符合过滤条件记录的某个字段List集合 <br>
@@ -1765,11 +1765,11 @@ public interface DataSource {
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return Entity的集合 * @return Entity的集合
*/ */
public <T> List<T> queryList(final Class<T> clazz, final String column, final Serializable key); public <T> List<T> queryList(final Class<T> clazz, final String column, final Serializable colval);
/** /**
* 查询符合过滤条件记录的List集合 <br> * 查询符合过滤条件记录的List集合 <br>
@@ -1778,11 +1778,11 @@ public interface DataSource {
* @param <T> Entity泛型 * @param <T> Entity泛型
* @param clazz Entity类 * @param clazz Entity类
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return Entity的集合CompletableFuture * @return Entity的集合CompletableFuture
*/ */
public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final String column, final Serializable key); public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final String column, final Serializable colval);
/** /**
* 查询符合过滤条件记录的List集合 <br> * 查询符合过滤条件记录的List集合 <br>
@@ -1918,11 +1918,11 @@ public interface DataSource {
* @param clazz Entity类 * @param clazz Entity类
* @param flipper 翻页对象 * @param flipper 翻页对象
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return Entity的集合 * @return Entity的集合
*/ */
public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final String column, final Serializable key); public <T> List<T> queryList(final Class<T> clazz, final Flipper flipper, final String column, final Serializable colval);
/** /**
* 查询符合过滤条件记录的List集合 <br> * 查询符合过滤条件记录的List集合 <br>
@@ -1932,11 +1932,11 @@ public interface DataSource {
* @param clazz Entity类 * @param clazz Entity类
* @param flipper 翻页对象 * @param flipper 翻页对象
* @param column 过滤字段名 * @param column 过滤字段名
* @param key 过滤字段值 * @param colval 过滤字段值
* *
* @return Entity的集合CompletableFuture * @return Entity的集合CompletableFuture
*/ */
public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final Flipper flipper, final String column, final Serializable key); public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final Flipper flipper, final String column, final Serializable colval);
/** /**
* 查询符合过滤条件记录的List集合 <br> * 查询符合过滤条件记录的List集合 <br>