MySQL报错operand should contain 2 column(s)的JPA多列查询求助

这个错误是因为JPA默认无法直接将List<List<String>>或Map这类参数正确映射为SQL中多列IN子句所需的元组格式，以下是几种可行的解决方法：

方法1：使用List<Object[]>作为参数类型 #

修改你的查询方法，将参数类型改为List<Object[]>，每个数组元素对应一组empId和empRating的组合：

import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import java.util.List;

// 仓库接口中的方法
@Query("select u from employee u where (u.empId, u.empRating) in (:pairs)")
List<User> getUsers(@Param("pairs") List<Object[]> pairs);

调用时构造参数的示例：

List<Object[]> pairs = Arrays.asList(
    new Object[]{101, 4},
    new Object[]{102, 5}
);
List<User> users = userRepository.getUsers(pairs);

这种方式是JPA对多列IN子句的原生支持，能直接将Object数组映射为SQL中的元组（比如(101,4)），避免语法错误。

方法2：用自定义DTO封装元组 #

如果希望参数类型更具可读性，可以创建一个简单的DTO类来封装empId和empRating：

// 自定义DTO类
public class EmpIdRatingPair {
    private Integer empId;
    private Integer empRating;

    // 必须提供全参构造器
    public EmpIdRatingPair(Integer empId, Integer empRating) {
        this.empId = empId;
        this.empRating = empRating;
    }

    // 可选：添加getter方法
    public Integer getEmpId() { return empId; }
    public Integer getEmpRating() { return empRating; }
}

然后修改仓库方法的参数类型为List<EmpIdRatingPair>：

@Query("select u from employee u where (u.empId, u.empRating) in (:pairs)")
List<User> getUsers(@Param("pairs") List<EmpIdRatingPair> pairs);

调用时构造参数：

List<EmpIdRatingPair> pairs = Arrays.asList(
    new EmpIdRatingPair(101, 4),
    new EmpIdRatingPair(102, 5)
);
List<User> users = userRepository.getUsers(pairs);

注意：这种方式需要你的JPA Provider（比如Hibernate 5.2+）支持将自定义DTO映射为查询元组，确保依赖版本符合要求。

方法3：动态生成查询条件（适合数据量小的场景） #

如果不想依赖元组参数支持，可以用Criteria API动态生成OR连接的AND条件，模拟多列IN的效果：

import jakarta.persistence.EntityManager;
import jakarta.persistence.criteria.CriteriaBuilder;
import jakarta.persistence.criteria.CriteriaQuery;
import jakarta.persistence.criteria.Predicate;
import jakarta.persistence.criteria.Root;
import org.springframework.stereotype.Repository;
import java.util.List;
import java.util.stream.Collectors;

@Repository
public class UserCustomRepositoryImpl implements UserCustomRepository {

    private final EntityManager entityManager;

    public UserCustomRepositoryImpl(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    @Override
    public List<User> getUsers(List<Object[]> pairs) {
        CriteriaBuilder cb = entityManager.getCriteriaBuilder();
        CriteriaQuery<User> query = cb.createQuery(User.class);
        Root<User> userRoot = query.from(User.class);

        // 为每组id和rating生成一个AND条件，再用OR连接所有条件
        List<Predicate> predicates = pairs.stream()
                .map(pair -> cb.and(
                        cb.equal(userRoot.get("empId"), pair[0]),
                        cb.equal(userRoot.get("empRating"), pair[1])
                ))
                .collect(Collectors.toList());

        query.where(cb.or(predicates.toArray(new Predicate[0])));
        return entityManager.createQuery(query).getResultList();
    }
}

为什么之前的方法无效？ #

• List<List<String>>：JPA无法将嵌套列表正确解析为SQL元组，会导致参数绑定格式错误，触发MySQL的列数不匹配报错。
• Map<Integer, Integer>：Map的键值对结构只能表示单键对应单值，无法对应两列组合的元组需求，JPA无法将其映射为多列IN条件。
• 拼接字符串：手动构造SQL元组会引入SQL注入风险，且字符串引号、格式处理容易出错，导致SQL执行失败。

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