java - HibernateException：无法使用 spring-data-jpa 本机查询为 postgresql 确定类异常的类型

问题描述

我有一个带有 bean 和存储库的 Spring Boot 应用程序。我使用 postgresql 作为数据库。该数据库有一个名为 testjob 的表，有两列：id（UUID 类型）和参数（jsonb 类型）。我按照这篇文章支持 jsonb：https ://thoughts-on-java.org/persist-postgresqls-jsonb-data-type-hibernate/ 我创建了文章中提到的每个类，但是当我运行我的测试时，它只是调用存储库上的 upsert 方法，它会引发异常，原因如下：

Caused by: org.hibernate.HibernateException: Could not determine a type for class: com.test.Parameters

仅当我运行本机查询时才会引发此异常，但使用 JPQL 一切正常。遗憾的是，我需要在本机中运行它，因为将来我将不得不使用 postgresql ON_CONFLICT 语句。我会提出任何建议，谢谢。

我的课程：

TestJobBean.java

@Entity
@Table(name = "testjob")
public class TestJobBean {

    @Id
    private UUID id;

    @NotNull @Column(name = "parameters") @Type(type = "ParametersType")
    private Parameters parameters;
    ...
}

TestJobRepository.java

@Repository
@Transactional
public interface TestJobRepository extends JpaRepository<TestJobBean, UUID>, TestJobRepositoryCustom {
}

TestJobRepositoryCustom.java

public interface TestJobRepositoryCustom {
    int upsert(UUID id, Parameters parameters);
}

TestJobRepositoryCustomImpl.java

@Transactional
public class TestJobRepositoryCustomImpl implements TestJobRepositoryCustom {

    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public int upsert(UUID id, Parameters parameters) {
        final Query query = entityManager.createNativeQuery("INSERT INTO testjob (id, parameters) VALUES(:id, :parameters)");
        query.setParameter("id", id);
        query.setParameter("parameters", parameters);
        return query.executeUpdate();
    }

}

package-info.java

@org.hibernate.annotations.TypeDef(name = "ParametersType", typeClass = ParametersType.class)
package com.test.job;

Parameters.java

@Immutable
public class Parameters {

    private final long from;
    private final long to;
    private final @Nonnull String name;

    public Parameters(@JsonProperty("from") long from, @JsonProperty("to") long to,
            @JsonProperty("name") String name) {
        this.from = from;
        this.to = to;
        this.name = name;
    }

    @JsonProperty("from")
    public long getFrom() {
        return from;
    }

    @JsonProperty("to")
    public long getTo() {
        return to;
    }

    @JsonProperty("name")
    public long getName() {
        return name;
    }
}

TestPostgreSQL95Dialect.java

public class TestPostgreSQL95Dialect extends PostgreSQL95Dialect {

    public TestPostgreSQL95Dialect() {
        this.registerColumnType(Types.JAVA_OBJECT, "jsonb");
    }
}

ParametersType.java

public class ParametersType implements UserType {

    private final @Nonnull ObjectMapper mapper = new ObjectMapper();

    @Override
    public int[] sqlTypes() {
        return new int[] {Types.JAVA_OBJECT};
    }

    @Override
    public Class<ParametersType> returnedClass() {
        return ParametersType.class;
    }

    @Override
    public Object nullSafeGet(final ResultSet rs, final String[] names, final SharedSessionContractImplementor session,
            final Object owner) throws HibernateException, SQLException {
        final String cellContent = rs.getString(names[0]);
        if (cellContent == null) {
            return null;
        }
        try {
            return mapper.readValue(cellContent, returnedClass());
        } catch (final IOException ex) {
            throw new RuntimeException("Failed to convert string to an instance!", ex);
        }
    }

    @Override
    public void nullSafeSet(final PreparedStatement ps, final Object value, final int idx,
            final SharedSessionContractImplementor session) throws HibernateException, SQLException {
        if (value == null) {
            ps.setNull(idx, Types.OTHER);
            return;
        }
        try {
            final String valueAsJson = mapper.writeValueAsString(value);
            ps.setObject(idx, valueAsJson, Types.OTHER);
        } catch (final Exception ex) {
            throw new RuntimeException("Failed to convert the instance to string!", ex);
        }
    }

    @Override
    public Object deepCopy(final Object value) throws HibernateException {
        return value;
    }

    @Override
    public boolean isMutable() {
        return false;
    }

    @Override
    public Serializable disassemble(final Object value) throws HibernateException {
        try {
            final String valueAsJson = mapper.writeValueAsString(value);
            return valueAsJson;
        } catch (final Exception ex) {
            throw new RuntimeException("Failed to convert the instance to string!", ex);
        }
    }

    @Override
    public Object assemble(final Serializable cached, final Object owner) throws HibernateException {
        try {
            return mapper.readValue((String) cached, returnedClass());
        } catch (final IOException ex) {
            throw new RuntimeException("Failed to convert string to an instance!", ex);
        }
    }

    @Override
    public Object replace(final Object original, final Object target, final Object owner) throws HibernateException {
        return original;
    }

    @Override
    public boolean equals(final Object obj1, final Object obj2) throws HibernateException {
        return Objects.equals(obj1, obj2);
    }

    @Override
    public int hashCode(final Object obj) throws HibernateException {
        return obj.hashCode();
    }
}

标签： javapostgresqlhibernatehibernate-mappingusertype

java - HibernateException：无法使用 spring-data-jpa 本机查询为 postgresql 确定类异常的类型

问题描述

解决方案

推荐阅读