Skip to content

Commit

Permalink
开启 v2.0.0 版本的快照，升级了一些依赖项，修改了 FenixJpaQuery 类，用来支持 spring-data-jpa 2.2…
Browse files Browse the repository at this point in the history 
….0 版本
  • Loading branch information
@blinkfox
blinkfox committed Oct 17, 2019
1 parent a99af06 commit a68b5ad
Show file tree
Hide file tree
Showing 2 changed files with 54 additions and 49 deletions.
14 changes: 7 additions & 7 deletions pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

<groupId>com.blinkfox</groupId>
<artifactId>fenix</artifactId>
<version>1.1.1</version>
<version>2.0.0-SNAPSHOT</version>
<packaging>jar</packaging>

<name>fenix</name>
Expand Down Expand Up @@ -46,19 +46,19 @@
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-jpa</artifactId>
<version>2.1.9.RELEASE</version>
<version>2.2.0.RELEASE</version>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.hibernate</groupId>
<artifactId>hibernate-core</artifactId>
<version>5.3.10.Final</version>
<version>5.4.6.Final</version>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.26</version>
<version>1.7.28</version>
<optional>true</optional>
</dependency>
<dependency>
Expand Down Expand Up @@ -122,7 +122,7 @@
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.1.8.RELEASE</version>
<version>5.2.0.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
Expand All @@ -134,13 +134,13 @@
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.59</version>
<version>1.2.62</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.blinkfox</groupId>
<artifactId>stalker</artifactId>
<version>1.0.0</version>
<version>1.0.1</version>
<scope>test</scope>
</dependency>
</dependencies>
Expand Down
89 changes: 47 additions & 42 deletions src/main/java/com/blinkfox/fenix/jpa/FenixJpaQuery.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,18 +19,22 @@
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.repository.query.AbstractJpaQuery;
import org.springframework.data.jpa.repository.query.JpaParameters;
import org.springframework.data.jpa.repository.query.JpaParametersParameterAccessor;
import org.springframework.data.jpa.repository.query.JpaQueryMethod;
import org.springframework.data.jpa.repository.query.QueryUtils;
import org.springframework.data.repository.query.Parameter;
import org.springframework.data.repository.query.ParametersParameterAccessor;
import org.springframework.data.repository.query.RepositoryQuery;
import org.springframework.data.repository.query.ReturnedType;

/**
* 继承了 {@link AbstractJpaQuery} 抽象类，
* 并隐性实现了 {@link RepositoryQuery} 接口的 JPA 查询处理器类，
* 继承了 {@code AbstractJpaQuery} 抽象类，
* 并隐性实现了 {@code RepositoryQuery} 接口的 JPA 查询处理器类，
* 该类主要用来处理标注了 {@link QueryFenix} 注解的 JPA 查询.
*
* <p>v2.0.0 修改记录：升级 Spring-data-jpa 的版本为 {@code 2.2.0.RELEASE} 之后，
* 由于 {@code AbstractJpaQuery} 抽象类重写了 {@code doCreateQuery} 和 {@code doCreateCountQuery} 方法。
* 所以，本 Fenix 库在 v2.0.0 也必须跟着重写这两个方法，才能正常使用. </p>
*
* @author blinkfox on 2019-08-04.
*/
public class FenixJpaQuery extends AbstractJpaQuery {
Expand All @@ -51,13 +55,13 @@ public class FenixJpaQuery extends AbstractJpaQuery {
private JpaParameters jpaParams;

/**
* 标注了 {@link QueryFenix} 注解的注解实例.
* 标注了 {@code QueryFenix} 注解的注解实例.
*/
@Setter
private QueryFenix queryFenix;

/**
* 执行 {@link QueryFenix} 注解的执行的类 class.
* 执行 {@code QueryFenix} 注解的执行的类 class.
*/
@Setter
private Class<?> queryClass;
Expand All @@ -78,7 +82,7 @@ public class FenixJpaQuery extends AbstractJpaQuery {
private String querySql;

/**
* Creates a new {@link AbstractJpaQuery} from the given {@link JpaQueryMethod}.
* Creates a new {@code AbstractJpaQuery} from the given {@code JpaQueryMethod}.
*
* @param method JpaQueryMethod
* @param em EntityManager
Expand All @@ -88,15 +92,17 @@ public class FenixJpaQuery extends AbstractJpaQuery {
}

/**
* Creates a {@link Query} instance for the given values.
* 基于 {@code JpaParametersParameterAccessor} 实例参数创建 {@code Query} 实例.
*
* @param values must not be {@literal null}.
* @return Query
* @param accessor 访问器.
* @return {@code Query} 实例
*/
@Override
protected Query doCreateQuery(Object[] values) {
protected Query doCreateQuery(JpaParametersParameterAccessor accessor) {
// 获取 QueryFenix 上下文参数，来从 XML 文件或 Java 中动态构建出 SQL 信息.
this.jpaParams = getQueryMethod().getParameters();
JpaQueryMethod jpaMethod = super.getQueryMethod();
this.jpaParams = jpaMethod.getParameters();
Object[] values = accessor.getValues();
this.contextParams = this.buildContextParams(values);
this.getSqlInfoByFenix();
this.querySql = this.sqlInfo.getSql();
Expand All @@ -108,8 +114,8 @@ protected Query doCreateQuery(Object[] values) {
Query query;
EntityManager em = super.getEntityManager();
if (queryFenix.nativeQuery()) {
Class<?> type = this.getTypeToQueryFor(getQueryMethod().getResultProcessor().withDynamicProjection(
new ParametersParameterAccessor(getQueryMethod().getParameters(), values)).getReturnedType());
Class<?> type = this.getTypeToQueryFor(jpaMethod.getResultProcessor().withDynamicProjection(
new ParametersParameterAccessor(jpaMethod.getParameters(), values)).getReturnedType());
query = type == null ? em.createNativeQuery(this.querySql) : em.createNativeQuery(this.querySql, type);
} else {
query = em.createQuery(this.querySql);
Expand All @@ -131,6 +137,33 @@ protected Query doCreateQuery(Object[] values) {
return query;
}

/**
* 根据给定的参数访问对象创建一个 {@code Query} 对象，用于查询分页时的记录数.
*
* <p>这里要区分是否手动设置了 {@link QueryFenix#countQuery()} 和 {@link QueryFenix#countMethod()} 的值。</p>
* <ul>
* <li>如果没有设置这个两个值，就默认使用先前的 SQL 来替换处理为查询条数的SQL；</li>
* <li>如果设置了这两个值，就依据优先级来构建新的 {@link SqlInfo} 对象，得到查询条数的 SQL；</li>
* </ul>
*
* @param accessor JPA 参数访问对象
* @return Query
*/
@Override
protected Query doCreateCountQuery(JpaParametersParameterAccessor accessor) {
// 如果计数查询的 SQL 不为空（区分 Java和 Xml 两者方式），就重新构建 SqlInfo 信息，
// 否则就替换查询字符串中的字段值为 'count(*) as count'.
String countSql = this.getCountSql();

// 创建 Query，并循环设置命名绑定参数，并返回 Query 实例.
EntityManager em = getEntityManager();
Query query = this.queryFenix.nativeQuery()
? em.createNativeQuery(countSql)
: em.createQuery(countSql, Long.class);
this.sqlInfo.getParams().forEach(query::setParameter);
return query;
}

/**
* 根据返回类型获取对应的 class.
*
Expand All @@ -154,7 +187,7 @@ private Class<?> getTypeToQueryFor(ReturnedType returnedType) {
/**
* 根据 JPA 参数和值的数组来分析构建出 JPQL 语句和参数的 Map 型上下文参数.
*
* @param values JPA 参数值
* @param values JPA 的有序数组参数
* @return Map
*/
private Map<String, Object> buildContextParams(Object[] values) {
Expand Down Expand Up @@ -249,34 +282,6 @@ private Pageable buildPagableAndSortSql(Object[] values) {
return pageable;
}

/**
* 根据给定的数组参数创建一个 {@link Query}，用于查询分页时的记录数.
*
* <p>这里要区分是否手动设置了 {@link QueryFenix#countQuery()} 和 {@link QueryFenix#countMethod()} 的值。</p>
* <ul>
* <li>如果没有设置这个两个值，就默认使用先前的 SQL 来替换处理为查询条数的SQL；</li>
* <li>如果设置了这两个值，就依据优先级来构建新的 {@link SqlInfo} 对象，得到查询条数的 SQL；</li>
* </ul>
*
* @param values 参数数组
* @return Query
*/
@Override
protected Query doCreateCountQuery(Object[] values) {
// 如果计数查询的 SQL 不为空（区分 Java和 Xml 两者方式），就重新构建 SqlInfo 信息，
// 否则就替换查询字符串中的字段值为 'count(*) as count'.
String countSql = this.getCountSql();

// 创建 Query，并循环设置命名绑定参数.
EntityManager em = getEntityManager();
Query query = this.queryFenix.nativeQuery()
? em.createNativeQuery(countSql)
: em.createQuery(countSql, Long.class);
this.sqlInfo.getParams().forEach(query::setParameter);

return query;
}

/**
* 获取总记录数查询的 JPQL 或者 SQL 语句.
*
Expand Down

0 comments on commit a68b5ad

Please sign in to comment.