Spring Boot JPA操作PostgreSQL的jsonb類型

Tips:
springboot版本:2.0.8.RELEASE
jdk:1.8

在設(shè)計數(shù)據(jù)庫表的時候,不確定后期升級是否需要擴展字段宾抓,大多數(shù)人會添加擴展字段,PostgreSQL的jsonb類型為我們提供了極大的便利。

  1. 為了讓JPA支持jsonb牲距,需要自定義PostgreSQL9Dialect
import org.hibernate.dialect.PostgreSQL9Dialect;

import java.sql.Types;

public class CustomPostgreSqlDialect extends PostgreSQL9Dialect {

    public CustomPostgreSqlDialect() {
        super();
        this.registerColumnType(Types.JAVA_OBJECT, "jsonb");
    }
}
  1. 指定方言spring.jpa.database-platform: com.xxx.PostgreSqlDialect,如下
spring:
  datasource:
    driver-class-name: org.postgresql.Driver
    url: jdbc:postgresql://localhost:5432/postgres
    username: postgres
    password: 123456
    hikari:
      connection-timeout: 20000
      maximum-pool-size: 5
  jpa:
    hibernate:
      ddl-auto: create
    show-sql: true
    database-platform: com.example.jsonb.config.CustomPostgreSqlDialect
    properties:
      hibernate.temp.use_jdbc_metadata_defaults: false
logging:
  level:
    org.hibernate.type.descriptor.sql.BasicBinder: trace
  1. 自定義jsonb數(shù)據(jù)類型
import com.fasterxml.jackson.databind.ObjectMapper;
import org.hibernate.HibernateException;
import org.hibernate.engine.spi.SharedSessionContractImplementor;
import org.hibernate.type.SerializationException;
import org.hibernate.usertype.UserType;
import org.postgresql.util.PGobject;
import org.springframework.util.ObjectUtils;

import java.io.IOException;
import java.io.Serializable;
import java.sql.*;
import java.util.HashMap;
import java.util.Map;

public class JsonbType implements UserType {

    private final ObjectMapper mapper = new ObjectMapper();

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

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

    @Override
    public boolean equals(Object x, Object y) throws HibernateException {
        return ObjectUtils.nullSafeEquals(x, y);
    }

    @Override
    public int hashCode(Object x) throws HibernateException {
        return x == null ? 0 : x.hashCode();
    }

    @Override
    public Object nullSafeGet(ResultSet rs, String[] names, SharedSessionContractImplementor sharedSessionContractImplementor, Object owner) throws HibernateException, SQLException {
        Object obj = rs.getObject(names[0]);
        if (obj == null) {
            return null;
        }
        PGobject o = (PGobject) obj;
        if (o.getValue() != null) {
            try {
                // return JSON.parse(o.getValue(), Map.class);
                return mapper.readValue(o.getValue(), Map.class);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return new HashMap<String, Object>();
    }

    @Override
    public void nullSafeSet(PreparedStatement st, Object value, int index, SharedSessionContractImplementor sharedSessionContractImplementor) throws HibernateException, SQLException {
        if (value == null) {
            st.setNull(index, Types.OTHER);
        } else {
            try {
                // st.setObject(index, JSON.toJSON(value), Types.OTHER);
                st.setObject(index, mapper.writeValueAsString(value), Types.OTHER);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    @Override
    public Object deepCopy(Object originalValue) throws HibernateException {
        if (originalValue != null) {
            try {
                // 替換為其他JSON解析器
                // return JSON.parse(JSON.toJSON(originalValue), returnedClass());
                return mapper.readValue(mapper.writeValueAsString(originalValue), returnedClass());
            } catch (IOException e) {
                throw new HibernateException("Failed to deep copy object", e);
            }
        }
        return null;
    }

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

    @Override
    public Serializable disassemble(Object value) throws HibernateException {
        Object copy = deepCopy(value);

        if (copy instanceof Serializable) {
            return (Serializable) copy;
        }
        throw new SerializationException(String.format("Cannot serialize '%s', %s is not Serializable.", value, value.getClass()), null);
    }


    @Override
    public Object assemble(Serializable cached, Object o) throws HibernateException {
        return deepCopy(cached);
    }

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

  1. 在Entity上使用
import com.example.jsonb.config.JsonbListType;
import com.example.jsonb.config.JsonbType;
import lombok.Data;
import lombok.experimental.Accessors;
import org.hibernate.annotations.*;

import javax.persistence.*;
import javax.persistence.Entity;
import java.util.List;
import java.util.Map;

@Entity
@Data
@Accessors(chain = true)
@TypeDef(name = "JsonbType", typeClass = JsonbType.class)
public class Account {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;

    @Column(columnDefinition = "jsonb")
    @Type(type = "JsonbType")
    private Map<String, Object> info;
}

5.定義repository

import com.example.jsonb.po.Account;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

public interface AccountRepository extends JpaRepository<Account, Integer> {
    @Query(value = "select * from account where info ->> 'name' = :name", nativeQuery = true)
    List<Account> findByName(@Param("name") String name);
}
  1. 測試
import com.example.jsonb.po.Account;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.*;

@RunWith(SpringRunner.class)
@SpringBootTest
public class AccountRepositoryTest {

    @Autowired
    AccountRepository accountRepository;

    @Before
    public void setUp() throws Exception {
        HashMap<String, Object> info = new HashMap<>();
        info.put("name", "光頭強");
        info.put("age", 3);
        info.put("tel", "110");
        info.put("Hobby", Arrays.asList("吃飯", "睡覺", "砍樹", "打豆豆"));
        Account account = new Account().setInfo(info);
        accountRepository.save(account);
    }

    @Test
    public void findByName() {
        List<Account> accounts = accountRepository.findByName("光頭強");
        System.out.println(accounts);
    }
}
測試結(jié)果
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末江咳,一起剝皮案震驚了整個濱河市逢净,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌歼指,老刑警劉巖爹土,帶你破解...
    沈念sama閱讀 222,807評論 6 518
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異踩身,居然都是意外死亡胀茵,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,284評論 3 399
  • 文/潘曉璐 我一進店門挟阻,熙熙樓的掌柜王于貴愁眉苦臉地迎上來琼娘,“玉大人,你說我怎么就攤上這事附鸽⊥哑矗” “怎么了?”我有些...
    開封第一講書人閱讀 169,589評論 0 363
  • 文/不壞的土叔 我叫張陵坷备,是天一觀的道長熄浓。 經(jīng)常有香客問我,道長省撑,這世上最難降的妖魔是什么赌蔑? 我笑而不...
    開封第一講書人閱讀 60,188評論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮竟秫,結(jié)果婚禮上娃惯,老公的妹妹穿的比我還像新娘。我一直安慰自己肥败,他們只是感情好趾浅,可當我...
    茶點故事閱讀 69,185評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著拙吉,像睡著了一般潮孽。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上筷黔,一...
    開封第一講書人閱讀 52,785評論 1 314
  • 那天往史,我揣著相機與錄音,去河邊找鬼佛舱。 笑死椎例,一個胖子當著我的面吹牛挨决,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播订歪,決...
    沈念sama閱讀 41,220評論 3 423
  • 文/蒼蘭香墨 我猛地睜開眼脖祈,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了刷晋?” 一聲冷哼從身側(cè)響起盖高,我...
    開封第一講書人閱讀 40,167評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎眼虱,沒想到半個月后喻奥,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,698評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡捏悬,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,767評論 3 343
  • 正文 我和宋清朗相戀三年撞蚕,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片过牙。...
    茶點故事閱讀 40,912評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡甥厦,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出寇钉,到底是詐尸還是另有隱情刀疙,我是刑警寧澤,帶...
    沈念sama閱讀 36,572評論 5 351
  • 正文 年R本政府宣布摧莽,位于F島的核電站庙洼,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏镊辕。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 42,254評論 3 336
  • 文/蒙蒙 一蚁袭、第九天 我趴在偏房一處隱蔽的房頂上張望征懈。 院中可真熱鬧,春花似錦揩悄、人聲如沸卖哎。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,746評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽亏娜。三九已至,卻和暖如春蹬挺,著一層夾襖步出監(jiān)牢的瞬間维贺,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,859評論 1 274
  • 我被黑心中介騙來泰國打工巴帮, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留溯泣,地道東北人虐秋。 一個月前我還...
    沈念sama閱讀 49,359評論 3 379
  • 正文 我出身青樓,卻偏偏與公主長得像垃沦,于是被迫代替她去往敵國和親客给。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 45,922評論 2 361