使用JSON_EXTRACT从自定义DTO的Spring JPA自定义查询中的JSON获取值

Question

我想从JSON列中获取值，并在spring JPA中返回自定义DTO。

表结构

userId (int)
name (string)
street (string)
zipcode (string)
state (string)
country (string)
meta (JSON)

meta列包含年龄，例如{“年龄”：“45”}

我想获取具有id、name和age的用户列表。由于数据量可能很大，我创建了一个自定义DTOUserDataDto

下面是一个同样的例子：

@Query("SELECT new com.model.UserDataDto(userId, name, FUNCTION('JSON_EXTRACT', meta, '$.age')) " +
    "FROM User " +
    "WHERE userId IN (:userIds) ")
  List<UserDataDto> findUsersByIdIn(@Param("userIds") List<Long> userIds);

用户实体：

@Data
@Table(name = "user")
@Entity
public class User {
  @Id
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Long id;

  private String name;
  private String street;
  private String zipcode;
  private String state;
  private String country;

  @NotNull
  @Convert(converter = UserMetaConverter.class)
  private UserMeta meta;

}

UserMeta结构：

@Data
public class UserMeta {

  private Long age;

}

UserDataDto结构：

public class UserDataDto {
  private Long id;
  private String name;
  private Integer previousId;
}

启动Spring启动应用程序

警告|上下文初始化期间遇到异常-取消刷新尝试：org。springframework。豆。工厂UnsatifiedPendencyException:创建名为“userRepo”的bean时出错：调用init方法失败；嵌套的例外是java。lang.IllegalArgumentException:方法公共抽象java的查询验证失败。util。列出com。db。UserRepo。findUsersByIdIn（列表

我能想到的唯一解决方案是使用本地查询，任何其他解决方案都非常受欢迎。

Answer 1

我能想出的唯一解决方案是使用@namednaviquery和@SqlResultSetMapping

在用户实体

@Data
@Table(name = "user")
@Entity
@NamedNativeQuery(
  name = "findUsersByIdIn",
  query = "SELECT user_id, name, meta->>'$.age' as age " +
    "FROM user " +
    "WHERE user_id = :userIds",
  resultSetMapping = "UserDataDto"
)
@SqlResultSetMapping(
  name = "UserDataDto",
  classes = @ConstructorResult(
    targetClass = UserDataDto.class,
    columns = {
      @ColumnResult(name = "id", type = Long.class),
      @ColumnResult(name = "name", type = String.class),
      @ColumnResult(name = "age", type = Integer.class)
    }
  )
)
public class User {
  @Id
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Long id;

  private String name;
  private String street;
  private String zipcode;
  private String state;
  private String country;

  @NotNull
  @Convert(converter = UserMetaConverter.class)
  private UserMeta meta;

}

存储库中

public interface UserRepo extends JpaRepository<User, Long> {

  @Query("findUsersByIdIn", nativeQuery = true)
  List<UserDataDto> findUsersByIdIn(@Param("userIds") List<Long> userIds);
}