使用IN子句执行Spring Data JPA UPDATE语句时触发SQL语法异常

问题场景 #

你尝试用Spring Data JPA的批量更新方法修改实体状态，代码如下：

@Modifying
@Query("UPDATE Call c set c.locationLocked = false, c.locationLockedBy = null, c.locationLockedOn = null WHERE c.callIdentifier IN :timedOutLockedCallsIdentifiers AND c.audit.retired = false")
int expireTimedOutLockedCalls(@Param("timedOutLockedCallsIdentifiers") List<String> timedOutLockedCallsIdentifiers);

但遭遇了PostgreSQL的语法错误：

Caused by: org.postgresql.util.PSQLException: ERROR: syntax error at or near ")"

根因分析 #

这个错误的核心原因很明确：当你传入的timedOutLockedCallsIdentifiers列表为空时，Spring Data JPA会生成包含IN ()片段的SQL，而PostgreSQL不允许IN子句后面跟空括号，这属于无效的SQL语法，因此直接抛出了语法异常。

解决方案 #

你可以通过以下几种方式解决这个问题：

1. 调用方法前先做空列表判断

在调用Repository方法之前，先检查传入的列表是否为空，如果是空列表直接返回0，避免执行无效的SQL：

// 示例：在Service层中处理空列表逻辑
public int handleExpireTimedOutLockedCalls(List<String> identifiers) {
    if (identifiers == null || identifiers.isEmpty()) {
        return 0;
    }
    return callRepository.expireTimedOutLockedCalls(identifiers);
}

2. 修改JPQL语句，兼容空列表情况

调整你的JPQL查询，增加对空列表的判断，确保生成的SQL始终合法。如果空列表时你不想更新任何数据，可以这样写：

@Modifying
@Query("UPDATE Call c set c.locationLocked = false, c.locationLockedBy = null, c.locationLockedOn = null " +
       "WHERE (:timedOutLockedCallsIdentifiers IS NOT EMPTY AND c.callIdentifier IN :timedOutLockedCallsIdentifiers) " +
       "AND c.audit.retired = false")
int expireTimedOutLockedCalls(@Param("timedOutLockedCallsIdentifiers") List<String> timedOutLockedCallsIdentifiers);

这样当列表为空时，:timedOutLockedCallsIdentifiers IS NOT EMPTY条件不成立，整个WHERE子句结果为false，不会更新任何数据，同时也避免了生成IN()的无效语法。

3. 使用动态查询（进阶方案）

如果你的查询逻辑比较复杂，可以用Spring Data JPA的Specification或者Querydsl构建动态查询，它们会自动处理空参数，不会生成无效SQL片段。比如用Specification的示例：

// 构建Specification
public class CallSpecifications {
    public static Specification<Call> timedOutLockedCalls(List<String> identifiers) {
        return (root, query, criteriaBuilder) -> {
            Predicate predicate = criteriaBuilder.equal(root.get("audit").get("retired"), false);
            if (identifiers != null && !identifiers.isEmpty()) {
                predicate = criteriaBuilder.and(predicate, root.get("callIdentifier").in(identifiers));
            } else {
                // 空列表时返回false，不匹配任何数据
                predicate = criteriaBuilder.and(predicate, criteriaBuilder.isFalse(criteriaBuilder.literal(true)));
            }
            return predicate;
        };
    }
}

// 让Repository继承JpaSpecificationExecutor
public interface CallRepository extends JpaRepository<Call, Long>, JpaSpecificationExecutor<Call> {
}

// 调用动态更新
public int expireTimedOutLockedCalls(List<String> identifiers) {
    Specification<Call> spec = CallSpecifications.timedOutLockedCalls(identifiers);
    return callRepository.updateAll(spec, update -> update
            .set("locationLocked", false)
            .set("locationLockedBy", null)
            .set("locationLockedOn", null));
}

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