如何在Spring Data中传递动态JPQL至@Query注解实现查询？

你之前的写法行不通，因为@Query的value是编译期固定的，不能通过运行时参数直接替换整个查询语句——Spring Data会把:DynamicQuery当成普通参数占位符，而不是完整的JPQL，自然会触发语法错误。下面是几种可行的替代方案：

1. 直接使用EntityManager动态执行JPQL #

这是最灵活的方式，完全支持自定义动态JPQL：

首先定义一个自定义Repository接口：

public interface PrizeInsuranceCustomRepository {
    List<PrizeInsuranceConfiguration> filterConfigurPrizeInsurance(String dynamicJpql);
}

然后实现这个接口：

@Repository
public class PrizeInsuranceCustomRepositoryImpl implements PrizeInsuranceCustomRepository {

    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public List<PrizeInsuranceConfiguration> filterConfigurPrizeInsurance(String dynamicJpql) {
        // 直接执行传入的JPQL语句
        return entityManager.createQuery(dynamicJpql, PrizeInsuranceConfiguration.class)
                .getResultList();
    }
}

最后让你的Spring Data Repository继承这个自定义接口：

public interface PrizeInsuranceConfigurationRepository extends JpaRepository<PrizeInsuranceConfiguration, Long>, PrizeInsuranceCustomRepository {
}

调用时直接传入拼接好的完整JPQL即可。注意：这种方式要警惕SQL注入风险，绝对不能直接拼接用户输入的未校验内容，如果需要动态参数，建议用setParameter绑定：

// 安全的动态参数绑定示例
public List<PrizeInsuranceConfiguration> filterWithParams(String status, BigDecimal minAmount) {
    String jpql = "SELECT p FROM PrizeInsuranceConfiguration p WHERE p.status = :status AND p.amount >= :minAmount";
    return entityManager.createQuery(jpql, PrizeInsuranceConfiguration.class)
            .setParameter("status", status)
            .setParameter("minAmount", minAmount)
            .getResultList();
}

2. 使用Specification（推荐用于条件拼接场景） #

如果你的动态查询是基于不同条件组合（而非完全自由的JPQL），Spring Data的Specification是更规范的选择，还能避免手动拼接JPQL的错误：

首先让Repository继承JpaSpecificationExecutor：

public interface PrizeInsuranceConfigurationRepository extends JpaRepository<PrizeInsuranceConfiguration, Long>, JpaSpecificationExecutor<PrizeInsuranceConfiguration> {
}

然后编写动态条件的Specification：

public class PrizeInsuranceSpecs {
    public static Specification<PrizeInsuranceConfiguration> withStatusAndAmount(String status, BigDecimal minAmount) {
        return (root, query, cb) -> {
            List<Predicate> predicates = new ArrayList<>();
            // 动态添加条件
            if (status != null) {
                predicates.add(cb.equal(root.get("status"), status));
            }
            if (minAmount != null) {
                predicates.add(cb.ge(root.get("amount"), minAmount));
            }
            return cb.and(predicates.toArray(new Predicate[0]));
        };
    }
}

调用时：

List<PrizeInsuranceConfiguration> result = repository.findAll(PrizeInsuranceSpecs.withStatusAndAmount("ACTIVE", new BigDecimal("100")));

3. 用SpEL替换JPQL片段（仅限局部动态） #

如果只是需要动态替换JPQL的部分片段（比如WHERE子句），可以结合SpEL表达式，但不能替换整个查询：

@Query("SELECT p FROM PrizeInsuranceConfiguration p WHERE #{#dynamicWhere}")
List<PrizeInsuranceConfiguration> filterConfigurPrizeInsurance(@Param("dynamicWhere") String dynamicWhere);

注意：这种方式需要确保传入的片段语法正确，同样存在SQL注入风险，仅适用于可控的场景，且需要Spring Data支持SpEL（默认开启）。

内容的提问来源于stack exchange，提问作者PAVAN KALYAN RAVULA