如何使用Spring Data JPA从数据库中检索JSONB数据？

针对PostgreSQL JSONB列的嵌套属性查询，Spring Data JPA有几种标准实践方案，可解决你遇到的->运算符不被JPQL识别的问题：

1. 使用原生SQL查询（最直接） #

JPQL不支持PostgreSQL特有的JSONB运算符，因此直接使用原生SQL并指定nativeQuery=true，就能复用你原本的查询逻辑，同时支持参数绑定：

示例代码 #

@Repository
public interface AlertRepository extends JpaRepository<Alert, String> {

    // 位置参数绑定
    @Query(value = """
            SELECT stuff FROM alerts 
            WHERE id = ?1 
              AND (stuff->'action'->>'actionId' = ?2) 
            ORDER BY (stuff->'action'->>'timestamp')
            """, nativeQuery = true)
    String findStuffByIdAndActionId(String id, String actionId);

    // 命名参数绑定（可读性更好）
    @Query(value = """
            SELECT stuff FROM alerts 
            WHERE id = :id 
              AND (stuff->'action'->>'actionId' = :actionId) 
            ORDER BY (stuff->'action'->>'timestamp')
            """, nativeQuery = true)
    String findStuffByIdAndActionIdNamed(@Param("id") String id, @Param("actionId") String actionId);
}

注意点 #

• 实体类中stuff字段需用@Column(columnDefinition = "jsonb")声明类型：

  @Entity
  @Table(name = "alerts")
  public class Alert {
      @Id
      private String id;
  
      @Column(columnDefinition = "jsonb")
      private String stuff; // 存储JSON字符串
  
      // getter、setter
  }
  

2. 映射JSONB到Java对象（JPQL风格） #

如果希望用JPA原生的JPQL语法查询，可借助Hibernate Types库，将JSONB列直接映射为Java嵌套对象，无需手写JSON运算符：

步骤1：引入依赖 #

<!-- Maven -->
<dependency>
    <groupId>com.vladmihalcea</groupId>
    <artifactId>hibernate-types-55</artifactId> <!-- 对应Hibernate版本，如5.5.x -->
    <version>2.20.0</version>
</dependency>

步骤2：定义嵌套实体并映射JSONB列 #

@Entity
@Table(name = "alerts")
public class Alert {
    @Id
    private String id;

    @Type(type = "jsonb")
    @Column(columnDefinition = "jsonb")
    private ActionWrapper stuff; // 直接映射为Java对象

    // getter、setter
}

// 嵌套对象：对应JSON中的action外层结构
public class ActionWrapper {
    private Action action;

    // getter、setter
}

// 嵌套对象：对应JSON中的action属性
public class Action {
    private String actionId;
    private LocalDateTime timestamp;

    // getter、setter
}

步骤3：编写JPQL查询 #

@Repository
public interface AlertRepository extends JpaRepository<Alert, String> {

    @Query("""
            SELECT a.stuff FROM Alert a 
            WHERE a.id = :id 
              AND a.stuff.action.actionId = :actionId 
            ORDER BY a.stuff.action.timestamp
            """)
    ActionWrapper findStuffByIdAndActionId(@Param("id") String id, @Param("actionId") String actionId);
}

Hibernate会自动将JPQL中的属性访问转换为PostgreSQL的JSONB函数调用，无需关心底层运算符。

3. 动态查询场景：使用QueryDSL或Specification #

如果需要动态构建查询条件（比如根据不同参数组合过滤），可以用QueryDSL或Spring Data的Specification：

QueryDSL示例 #

1. 引入QueryDSL依赖并配置插件，生成Q类。
2. 自定义Predicate：

public class AlertPredicates {
    public static Predicate hasActionId(String actionId) {
        // 用stringTemplate调用JSONB函数
        return Expressions.stringTemplate(
            "jsonb_extract_path_text({0}, 'action', 'actionId') = {1}",
            QAlert.alert.stuff,
            actionId
        );
    }
}

3. 仓库接口继承QuerydslPredicateExecutor：

@Repository
public interface AlertRepository extends JpaRepository<Alert, String>, QuerydslPredicateExecutor<Alert> {
}

4. 调用查询：

alertRepository.findAll(AlertPredicates.hasActionId("123"));

4. 复杂逻辑：自定义Repository实现 #

如果上述方案无法满足需求，可自定义Repository实现类，直接通过EntityManager执行原生SQL：

步骤1：定义自定义接口 #

public interface AlertRepositoryCustom {
    String findStuffByIdAndActionId(String id, String actionId);
}

步骤2：实现自定义接口 #

public class AlertRepositoryImpl implements AlertRepositoryCustom {
    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public String findStuffByIdAndActionId(String id, String actionId) {
        String sql = """
                SELECT stuff FROM alerts 
                WHERE id = :id 
                  AND (stuff->'action'->>'actionId' = :actionId) 
                ORDER BY (stuff->'action'->>'timestamp')
                """;
        return (String) entityManager.createNativeQuery(sql)
                .setParameter("id", id)
                .setParameter("actionId", actionId)
                .getSingleResult();
    }
}

步骤3：主仓库接口继承自定义接口 #

@Repository
public interface AlertRepository extends JpaRepository<Alert, String>, AlertRepositoryCustom {
}

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