如何在运行时动态调整Spring Data的@Query查询字符串以适配多参数筛选条件

完全不可以通过运行时修改@Query注解的属性实现动态调整SQL。
原因很简单：Spring Data JPA对@Query的解析、SQL模板缓存全部在应用启动、Repository代理初始化阶段完成，一旦初始化结束，对应的查询模板就被固化到内部的查询元数据缓存中。哪怕你通过字节码修改了注解属性值，Spring Data也不会重新读取、解析新的SQL内容，完全达不到预期效果。

针对你需要多可选筛选、保留原有原生SQL逻辑、支持分页的需求，最灵活、改动最小的方案是自定义Repository片段，手动构建动态原生SQL，完全不需要依赖额外的复杂框架，步骤如下：

• 第一步：定义自定义查询接口
  新建接口MovieRepositoryCustom，把你需要的动态查询方法定义在这里：

  public interface MovieRepositoryCustom {
      Page<Movie> findFilteredMovies(Long userId, Integer minReleaseYear, Integer maxReleaseYear,
                                     Set<Long> likedGenres, Set<Long> dislikedGenres, Pageable pageable);
  }
  

• 第二步：实现自定义接口
  按照Spring Data的默认命名规则，实现类必须命名为MovieRepositoryImpl，放在和MovieRepository同包下，Spring Data会自动扫描识别：

  public class MovieRepositoryImpl implements MovieRepositoryCustom {
      @PersistenceContext
      private EntityManager entityManager;
  
      @Override
      public Page<Movie> findFilteredMovies(Long userId, Integer minReleaseYear, Integer maxReleaseYear,
                                            Set<Long> likedGenres, Set<Long> dislikedGenres, Pageable pageable) {
          // 公共基础WHERE条件（所有场景都必带）
          StringBuilder whereClause = new StringBuilder("WHERE m.approved = true ")
                  .append("AND NOT EXISTS (SELECT 1 FROM movie_lists ml WHERE ml.movie_id = m.id AND ml.user_id = :userId) ");
          Map<String, Object> paramMap = new HashMap<>();
          paramMap.put("userId", userId);
  
          // 动态拼接可选筛选条件
          // 发行年份范围
          if (minReleaseYear != null) {
              whereClause.append("AND m.release_year >= :minReleaseYear ");
              paramMap.put("minReleaseYear", minReleaseYear);
          }
          if (maxReleaseYear != null) {
              whereClause.append("AND m.release_year <= :maxReleaseYear ");
              paramMap.put("maxReleaseYear", maxReleaseYear);
          }
  
          // 喜欢的类型匹配
          if (likedGenres != null && !likedGenres.isEmpty()) {
              whereClause.append("AND EXISTS (SELECT 1 FROM movies_genres mg WHERE mg.movie_id = m.id AND mg.genre_id IN (:likedGenres)) ");
              paramMap.put("likedGenres", likedGenres);
          }
  
          // 排除不喜欢的类型
          if (dislikedGenres != null && !dislikedGenres.isEmpty()) {
              whereClause.append("AND NOT EXISTS (SELECT 1 FROM movies_genres mg WHERE mg.movie_id = m.id AND mg.genre_id IN (:dislikedGenres)) ");
              paramMap.put("dislikedGenres", dislikedGenres);
          }
  
          // 构建count查询和主查询
          String countSql = "SELECT count(*) FROM movies m " + whereClause;
          String mainSql = "SELECT m.* FROM movies m " + whereClause;
  
          // 执行count查询拿总条数
          Query countQuery = entityManager.createNativeQuery(countSql);
          paramMap.forEach(countQuery::setParameter);
          long total = ((Number) countQuery.getSingleResult()).longValue();
  
          // 处理排序、分页
          if (pageable.getSort().isSorted()) {
              StringBuilder orderClause = new StringBuilder(" ORDER BY ");
              pageable.getSort().forEach(order ->
                      orderClause.append(String.format("m.%s %s, ", order.getProperty(), order.getDirection()))
              );
              mainSql += orderClause.deleteCharAt(orderClause.length() - 2);
          }
          Query mainQuery = entityManager.createNativeQuery(mainSql, Movie.class);
          paramMap.forEach(mainQuery::setParameter);
          mainQuery.setFirstResult((int) pageable.getOffset());
          mainQuery.setMaxResults(pageable.getPageSize());
  
          List<Movie> movieList = mainQuery.getResultList();
          return new PageImpl<>(movieList, pageable, total);
      }
  }
  

• 第三步：让原有Repository继承自定义接口即可

  public interface MovieRepository extends JpaRepository<Movie, Long>, MovieRepositoryCustom {
      // 原来写死的@Query查询保持不变即可
  }
  

如果后续筛选条件更复杂、不想手动拼SQL字符串，可以引入QueryDSL（原生SQL模式），通过类型安全的API动态拼接查询条件，避免手动拼字符串的格式错误、SQL注入问题，但需要额外引入依赖、配置框架，对现有代码改动更大。

• 手动拼接SQL时必须使用命名参数绑定，绝对不要直接把参数值拼接到SQL字符串中，避免SQL注入风险。
• 你原有SQL里EXISTS子查询中的LIMIT 1可以删掉，数据库优化器遇到EXISTS判断时，会自动在匹配到第一条结果时终止扫描，和加LIMIT 1的效果完全一致。

内容的提问来源于stack exchange，提问作者alexanoid