如何用JPA的createQuery实现jsonb数组首元素匹配查询

如果你的实体类中，jsonb_field列被映射为List<Long>（假设存储的是Long类型的ID列表），可以直接用JPQL的索引访问语法实现，这是最简洁的方式：

1. 实体类字段配置：

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import org.hibernate.annotations.Type;

@Entity(name = "my_table")
public class MyTable {
    @Id
    private Long id;
    
    @Column(name = "jsonb_field", columnDefinition = "jsonb")
    @Type(type = "jsonb") // Hibernate 5+支持，也可使用org.hibernate.type.JsonType
    private List<Long> jsonbField;
    
    // getter、setter省略
}

2. 使用createQuery执行查询：

Long inputId = 123L; // 你的输入参数

String jpql = "SELECT t FROM my_table t WHERE t.jsonbField[0] = :targetId";
TypedQuery<MyTable> query = entityManager.createQuery(jpql, MyTable.class);
query.setParameter("targetId", inputId);

List<MyTable> result = query.getResultList();

JPA会自动将jsonbField[0]转换为对应的PostgreSQL jsonb操作，完全等价于你原有的SQL逻辑。

如果实体类中jsonb_field仅被映射为String类型（未使用特定JSON类型映射），可以通过调用数据库原生函数实现：

1. 实体类字段配置：

@Entity(name = "my_table")
public class MyTable {
    @Id
    private Long id;
    
    @Column(name = "jsonb_field", columnDefinition = "jsonb")
    private String jsonbField;
    
    // getter、setter省略
}

2. 使用createQuery执行查询：

Long inputId = 123L;

String jpql = "SELECT t FROM my_table t WHERE CAST(function('jsonb_extract_path_text', t.jsonbField, '0') AS bigint) = :targetId";
TypedQuery<MyTable> query = entityManager.createQuery(jpql, MyTable.class);
query.setParameter("targetId", inputId);

List<MyTable> result = query.getResultList();

这里的function('jsonb_extract_path_text', t.jsonbField, '0')对应SQL中的jsonb_field ->> 0，再通过CAST(...) AS bigint完成类型转换，和你原有的SQL逻辑完全一致。

如果需要构建动态查询，可以用JPA Criteria API实现：

Long inputId = 123L;

CriteriaBuilder cb = entityManager.getCriteriaBuilder();
CriteriaQuery<MyTable> cq = cb.createQuery(MyTable.class);
Root<MyTable> root = cq.from(MyTable.class);

// 调用jsonb_extract_path_text获取第一个元素的字符串值
Expression<String> jsonElement = cb.function(
    "jsonb_extract_path_text", 
    String.class, 
    root.get("jsonbField"), 
    cb.literal("0")
);
// 转换为bigint类型
Expression<Long> castedElement = cb.function(
    "cast", 
    Long.class, 
    jsonElement, 
    cb.literal("bigint")
);

// 添加查询条件
cq.select(root).where(cb.equal(castedElement, cb.parameter(Long.class, "targetId")));

TypedQuery<MyTable> query = entityManager.createQuery(cq);
query.setParameter("targetId", inputId);

List<MyTable> result = query.getResultList();

这种方式适合需要根据不同条件动态组装查询语句的场景。

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