3 Commits
Author SHA1 Message Date
Timi 25c3944d5f v0.0.20
CI/CD / build-deploy (pull_request) Successful in 15s
2026-09-18 01:48:43 +08:00
Timi ba9fa7ef97 support Boolean for page 2026-09-18 01:48:34 +08:00
Timi a4a9317731 v0.0.19
CI/CD / build-deploy (pull_request) Successful in 13s
2026-08-11 23:59:02 +08:00
5 changed files with 131 additions and 68 deletions
+2 -2
View File
@@ -13,7 +13,7 @@
<groupId>com.imyeyu.spring</groupId> <groupId>com.imyeyu.spring</groupId>
<artifactId>timi-spring</artifactId> <artifactId>timi-spring</artifactId>
<version>0.0.18</version> <version>0.0.20</version>
<packaging>jar</packaging> <packaging>jar</packaging>
<properties> <properties>
@@ -141,7 +141,7 @@
<dependency> <dependency>
<groupId>com.imyeyu.io</groupId> <groupId>com.imyeyu.io</groupId>
<artifactId>timi-io</artifactId> <artifactId>timi-io</artifactId>
<version>0.0.5</version> <version>0.0.6</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.imyeyu.java</groupId> <groupId>com.imyeyu.java</groupId>
@@ -37,34 +37,6 @@ public class Page<T> extends BasePage {
/** 排序字段映射 */ /** 排序字段映射 */
protected LinkedHashMap<String, BaseMapper.OrderType> orderMap; protected LinkedHashMap<String, BaseMapper.OrderType> orderMap;
/**
* 创建分页参数
*
* @param index 页码
* @param size 每页数量
*/
public Page(int index, int size) {
super(index, size);
}
/**
* 获取偏移量
*
* @return 偏移量
*/
public long getOffset() {
return (long) index * size;
}
/**
* 获取限制数量
*
* @return 限制数量
*/
public long getLimit() {
return size;
}
/** /**
* 添加排序字段 * 添加排序字段
* *
@@ -31,6 +31,7 @@ import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@@ -81,6 +82,21 @@ public abstract class BaseSQLProvider {
* @return SQL * @return SQL
*/ */
protected String buildSelectByPageSQL(EntityMeta meta, String tableName, Page<?> page, String offset, String limit) { protected String buildSelectByPageSQL(EntityMeta meta, String tableName, Page<?> page, String offset, String limit) {
return buildSelectByPageSQL(meta, tableName, page, offset, limit, "");
}
/**
* 构建分页查询 SQL
*
* @param meta 实体元数据
* @param tableName 表名
* @param page 分页参数
* @param offset 偏移量占位符
* @param limit 限制数量占位符
* @param pageParameterPath Page 参数路径前缀
* @return SQL
*/
protected String buildSelectByPageSQL(EntityMeta meta, String tableName, Page<?> page, String offset, String limit, String pageParameterPath) {
StringBuilder sql = new StringBuilder(); StringBuilder sql = new StringBuilder();
sql.append("SELECT %s FROM `%s` WHERE 1 = 1".formatted(meta.selectPageClause, tableName)); sql.append("SELECT %s FROM `%s` WHERE 1 = 1".formatted(meta.selectPageClause, tableName));
@@ -88,7 +104,11 @@ public abstract class BaseSQLProvider {
appendSoftDeleteCondition(sql, meta); appendSoftDeleteCondition(sql, meta);
// 添加 Page 查询条件 // 添加 Page 查询条件
appendPageConditions(sql, page); if (pageParameterPath.isEmpty()) {
appendPageConditions(sql, page);
} else {
appendPageConditions(sql, page, pageParameterPath);
}
// 添加排序 // 添加排序
appendOrderBy(sql, meta, page); appendOrderBy(sql, meta, page);
@@ -107,6 +127,19 @@ public abstract class BaseSQLProvider {
* @return SQL * @return SQL
*/ */
protected String buildCountByPageSQL(EntityMeta meta, String tableName, Page<?> page) { protected String buildCountByPageSQL(EntityMeta meta, String tableName, Page<?> page) {
return buildCountByPageSQL(meta, tableName, page, "");
}
/**
* 构建分页统计 SQL
*
* @param meta 实体元数据
* @param tableName 表名
* @param page 分页参数
* @param pageParameterPath Page 参数路径前缀
* @return SQL
*/
protected String buildCountByPageSQL(EntityMeta meta, String tableName, Page<?> page, String pageParameterPath) {
StringBuilder sql = new StringBuilder(); StringBuilder sql = new StringBuilder();
sql.append("SELECT COUNT(*) FROM `%s` WHERE 1 = 1".formatted(tableName)); sql.append("SELECT COUNT(*) FROM `%s` WHERE 1 = 1".formatted(tableName));
@@ -114,7 +147,11 @@ public abstract class BaseSQLProvider {
appendSoftDeleteCondition(sql, meta); appendSoftDeleteCondition(sql, meta);
// 添加 Page 查询条件 // 添加 Page 查询条件
appendPageConditions(sql, page); if (pageParameterPath.isEmpty()) {
appendPageConditions(sql, page);
} else {
appendPageConditions(sql, page, pageParameterPath);
}
return sql.toString(); return sql.toString();
} }
@@ -138,30 +175,82 @@ public abstract class BaseSQLProvider {
* @param page 分页参数 * @param page 分页参数
*/ */
protected void appendPageConditions(StringBuilder sql, Page<?> page) { protected void appendPageConditions(StringBuilder sql, Page<?> page) {
appendPageConditions(sql, page, "");
}
/**
* 添加 Page 查询条件
*
* @param sql SQL 构建器
* @param page 分页参数
* @param pageParameterPath Page 参数路径前缀
*/
protected void appendPageConditions(StringBuilder sql, Page<?> page, String pageParameterPath) {
// 精准查询 // 精准查询
if (TimiJava.isNotEmpty(page.getEqualsExample())) { appendPageExampleConditions(
Object obj = page.getEqualsExample(); sql,
EntityMeta metaExample = getEntityMeta(obj.getClass()); page.getEqualsExample(),
String conditionClause = metaExample.fieldColumnList.stream() page.getEqualsLogic(),
.filter(fc -> fc.isNotEmpty(obj)) false,
.map(fc -> "`%s` = '%s'".formatted(fc.columnName, fc.getAsString(obj))) pageParameterPath
.collect(Collectors.joining(" %s ".formatted(page.getEqualsLogic()))); );
if (TimiJava.isNotEmpty(conditionClause)) {
sql.append(" AND ").append(conditionClause);
}
}
// 模糊查询 // 模糊查询
if (TimiJava.isNotEmpty(page.getLikesExample())) { appendPageExampleConditions(
Object obj = page.getLikesExample(); sql,
EntityMeta metaExample = getEntityMeta(obj.getClass()); page.getLikesExample(),
String conditionClause = metaExample.fieldColumnList.stream() page.getLikesLogic(),
.filter(fc -> fc.isNotEmpty(obj)) true,
.map(fc -> "`%s` LIKE CONCAT('%%', '%s', '%%')".formatted(fc.columnName, fc.getAsString(obj))) pageParameterPath
.collect(Collectors.joining(" %s ".formatted(page.getLikesLogic()))); );
if (TimiJava.isNotEmpty(conditionClause)) { }
sql.append(" AND (").append(conditionClause).append(')');
} /**
* 添加一组 Page 示例条件
*
* @param sql SQL 构建器
* @param example 示例对象
* @param logic 条件连接逻辑
* @param likes 是否使用模糊匹配
* @param pageParameterPath Page 参数路径前缀
*/
private void appendPageExampleConditions(StringBuilder sql, Object example, Logic logic, boolean likes, String pageParameterPath) {
if (TimiJava.isEmpty(example)) {
return;
} }
EntityMeta metaExample = getEntityMeta(example.getClass());
String parameterPrefix = "%s%s.".formatted(pageParameterPath, likes ? "likesExample" : "equalsExample");
String conditionClause = metaExample.fieldColumnList.stream()
.map(fc -> buildPageCondition(fc, example, likes, parameterPrefix))
.filter(Objects::nonNull)
.collect(Collectors.joining(" %s ".formatted(logic == null ? Logic.AND : logic)));
if (TimiJava.isNotEmpty(conditionClause)) {
sql.append(" AND (").append(conditionClause).append(')');
}
}
/**
* 构建单个 Page 示例条件
*
* @param fieldColumn 字段元数据
* @param example 示例对象
* @param likes 是否使用模糊匹配
* @param parameterPrefix 参数路径前缀
* @return 条件子句;字段值为空时返回 null
*/
private String buildPageCondition(FieldColumn fieldColumn, Object example, boolean likes, String parameterPrefix) {
Object value = fieldColumn.getValue(example);
if (TimiJava.isEmpty(value)) {
return null;
}
if (value instanceof Boolean booleanValue) {
return "`%s` IS %s".formatted(fieldColumn.columnName, booleanValue ? "TRUE" : "FALSE");
}
String parameter = "#{%s%s}".formatted(parameterPrefix, fieldColumn.fieldName);
if (likes) {
return "`%s` LIKE CONCAT('%%', %s, '%%')".formatted(fieldColumn.columnName, parameter);
}
return "`%s` = %s".formatted(fieldColumn.columnName, parameter);
} }
/** /**
@@ -648,11 +737,7 @@ public abstract class BaseSQLProvider {
* @return true 为 null * @return true 为 null
*/ */
public boolean isNull(Object entity) { public boolean isNull(Object entity) {
try { return getValue(entity) == null;
return Ref.getFieldValue(entity, field, Object.class) == null;
} catch (IllegalAccessException e) {
throw new RuntimeException(e);
}
} }
/** /**
@@ -672,11 +757,7 @@ public abstract class BaseSQLProvider {
* @return true 为空 * @return true 为空
*/ */
public boolean isEmpty(Object entity) { public boolean isEmpty(Object entity) {
try { return TimiJava.isEmpty(getValue(entity));
return TimiJava.isEmpty(Ref.getFieldValue(entity, field, Object.class));
} catch (IllegalAccessException e) {
throw new RuntimeException(e);
}
} }
/** /**
@@ -696,8 +777,18 @@ public abstract class BaseSQLProvider {
* @return 字符串值 * @return 字符串值
*/ */
public String getAsString(Object obj) { public String getAsString(Object obj) {
return getValue(obj).toString();
}
/**
* 获取字段值
*
* @param entity 实体
* @return 字段值
*/
public Object getValue(Object entity) {
try { try {
return field.get(obj).toString(); return Ref.getFieldValue(entity, field, Object.class);
} catch (IllegalAccessException e) { } catch (IllegalAccessException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
@@ -25,7 +25,7 @@ public class DynamicTableSQLProvider extends BaseSQLProvider {
*/ */
public String selectByPage(ProviderContext context, @Param("tableName") String tableName, @Param("page") Page<?> page) { public String selectByPage(ProviderContext context, @Param("tableName") String tableName, @Param("page") Page<?> page) {
EntityMeta meta = getEntityMeta(context); EntityMeta meta = getEntityMeta(context);
return buildSelectByPageSQL(meta, tableName, page, "#{page.offset}", "#{page.limit}"); return buildSelectByPageSQL(meta, tableName, page, "#{page.offset}", "#{page.limit}", "page.");
} }
/** /**
@@ -38,7 +38,7 @@ public class DynamicTableSQLProvider extends BaseSQLProvider {
*/ */
public String countByPage(ProviderContext context, @Param("tableName") String tableName, @Param("page") Page<?> page) { public String countByPage(ProviderContext context, @Param("tableName") String tableName, @Param("page") Page<?> page) {
EntityMeta meta = getEntityMeta(context); EntityMeta meta = getEntityMeta(context);
return buildCountByPageSQL(meta, tableName, page); return buildCountByPageSQL(meta, tableName, page, "page.");
} }
/** /**
@@ -30,7 +30,7 @@ public class SQLProvider extends BaseSQLProvider {
*/ */
public String selectByPage(ProviderContext context, @Param("page") Page<?> page) { public String selectByPage(ProviderContext context, @Param("page") Page<?> page) {
EntityMeta meta = getEntityMeta(context); EntityMeta meta = getEntityMeta(context);
return buildSelectByPageSQL(meta, meta.table, page, "#{offset}", "#{limit}"); return buildSelectByPageSQL(meta, meta.table, page, "#{offset}", "#{limit}", "");
} }
/** /**
@@ -42,7 +42,7 @@ public class SQLProvider extends BaseSQLProvider {
*/ */
public String countByPage(ProviderContext context, @Param("page") Page<?> page) { public String countByPage(ProviderContext context, @Param("page") Page<?> page) {
EntityMeta meta = getEntityMeta(context); EntityMeta meta = getEntityMeta(context);
return buildCountByPageSQL(meta, meta.table, page); return buildCountByPageSQL(meta, meta.table, page, "");
} }
/** /**