如何使用SpringBoot JPA存储PostgreSQL jsonb？

Question

我正在开发一个迁移软件，它将使用来自REST服务的未知数据。

我已经考虑过使用MongoDB，但我决定不使用它，而是使用PostgreSQL。

读完本文后，我试图在我的SpringBoot应用程序中使用SpringJPA实现它，但我不知道在我的实体中映射jsonb。

我试过了，但什么也不懂！

这里就是我所在的地方：

@Repository
@Transactional
public interface DnitRepository extends JpaRepository<Dnit, Long> {

    @Query(value = "insert into dnit(id,data) VALUES (:id,:data)", nativeQuery = true)
    void insertdata( @Param("id")Integer id,@Param("data") String data );

}

和...

@RestController
public class TestController {

    @Autowired
    DnitRepository dnitRepository;  

    @RequestMapping(value = "/dnit", method = RequestMethod.GET)
    public String testBig() {
        dnitRepository.insertdata(2, someJsonDataAsString );
    }

}

下表：

CREATE TABLE public.dnit
(
    id integer NOT NULL,
    data jsonb,
    CONSTRAINT dnit_pkey PRIMARY KEY (id)
)

我该怎么做？

注意：我不想/不需要一个实体来工作。我的JSON将永远是String，但我需要jsonb来查询数据库

Answer 1

对于这种情况，我使用上面定制的转换器类，您可以自由地将其添加到您的库中。它正在与Eclipse Link JPA提供商合作。

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.log4j.Logger;
import org.postgresql.util.PGobject;

import javax.persistence.AttributeConverter;
import javax.persistence.Converter;
import java.io.IOException;
import java.sql.SQLException;
import java.util.Map;

@Converter
public final class PgJsonbToMapConverter implements AttributeConverter<Map<String, ? extends Object>, PGobject> {

    private static final Logger LOGGER = Logger.getLogger(PgJsonbToMapConverter.class);
    private static final ObjectMapper MAPPER = new ObjectMapper();

    @Override
    public PGobject convertToDatabaseColumn(Map<String, ? extends Object> map) {
        PGobject po = new PGobject();
        po.setType("jsonb");

        try {
            po.setValue(map == null ? null : MAPPER.writeValueAsString(map));
        } catch (SQLException | JsonProcessingException ex) {
            LOGGER.error("Cannot convert JsonObject to PGobject.");
            throw new IllegalStateException(ex);
        }
        return po;
    }

    @Override
    public Map<String, ? extends Object> convertToEntityAttribute(PGobject dbData) {
        if (dbData == null || dbData.getValue() == null) {
            return null;
        }
        try {
            return MAPPER.readValue(dbData.getValue(), new TypeReference<Map<String, Object>>() {
            });
        } catch (IOException ex) {
            LOGGER.error("Cannot convert JsonObject to PGobject.");
            return null;
        }
    }

}

使用示例，用于名为Customer的实体。

@Entity
@Table(schema = "web", name = "customer")
public class Customer implements Serializable {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;

    @Convert(converter = PgJsonbToMapConverter.class)
    private Map<String, String> info;

    public Customer() {
        this.id = null;
        this.info = null;
    }

    // Getters and setter omitted.

Answer 2

添加Spring数据JPA只是为了执行一个简单的insert语句，这使事情变得过于复杂。您没有使用任何JPA功能。相反，请执行以下操作

1. 将spring boot starter数据jpa替换为spring boot starter jdbc
2. 删除您的DnitRepository界面
3. InjectionJdbcTemplate在何处注入DnitRepository
4. 替换dnitRepository。insertdata（2，somejsondatastring） 使用jdbc模板。executeUpdate（“插入到dnit（id，数据）值（？，到json（？）”，id（数据）

您已经在使用普通SQL（以一种非常复杂的方式），如果您需要普通SQL（并且不需要JPA），那么只需使用SQL即可。

当然，您可能希望在存储库或服务中隐藏逻辑/复杂性，而不是直接将JdbcTem板注入到您的控制器中。

Answer 3

我试过了，但什么也不懂！

要使用Vlad Mihalcea的Hibernate类型库在Spring Data JPA（Hibernate）项目中完全使用jsonb，您只需执行以下操作：

1） 将此库添加到项目中：

<dependency>
    <groupId>com.vladmihalcea</groupId>
    <artifactId>hibernate-types-52</artifactId>
    <version>2.2.2</version>
</dependency>

2） 然后在实体中使用其类型，例如：

@Data
@NoArgsConstructor
@Entity
@Table(name = "parents")
@TypeDef(name = "jsonb", typeClass = JsonBinaryType.class)
public class Parent implements Serializable {

    @Id
    @GeneratedValue(strategy = SEQUENCE)
    private Integer id;

    @Column(length = 32, nullable = false)
    private String name;

    @Type(type = "jsonb") @Column(columnDefinition = "jsonb")
    private List<Child> children;

    @Type(type = "jsonb") @Column(columnDefinition = "jsonb")
    private Bio bio;

    public Parent(String name, List children, Bio bio) {
        this.name = name;
        this.children = children;
        this.bio = bio;
    }
}

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Child implements Serializable {
    private String name;
}

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Bio implements Serializable {
    private String text;
}

然后，您将能够使用，例如，一个简单的JpaRepository来处理您的对象：

public interface ParentRepo extends JpaRepository<Parent, Integer> {
}

parentRepo.save(new Parent(
                     "parent1", 
                     asList(new Child("child1"), new Child("child2")), 
                     new Bio("bio1")
                )
);

Parent result = parentRepo.findById(1);
List<Child> children = result.getChildren();
Bio bio = result.getBio();