使用SpringBoot-JPA進(jìn)行自定義保存及批量保存功能
說(shuō)明
SpringBoot版本:2.1.4.RELEASE
java版本:1.8
文中所說(shuō)JPA皆指spring-boot-starter-data-jpa
使用JPA保存一個(gè)Student對(duì)象
在JPA中保存一個(gè)對(duì)象,僅需要該對(duì)象,一個(gè)倉(cāng)儲(chǔ)即可。
StudentDO實(shí)體類:
@Getter @Setter @Entity @Table(name = "t_student") public class StudentDO { @Id @GeneratedValue(strategy = GenerationType.IDENTITY) @Column private Long id; @Column private String seq; @Column private String name; @Column private int sex; }
JPA倉(cāng)儲(chǔ):
@Repository public interface StudentRepo extends JpaRepository<StudentDO, String> { }
一般的,我們只需要調(diào)用StudentRepo.save()
方法即可完成對(duì)實(shí)體對(duì)象的保存操作。
@Test public void testSave() { StudentDO student = new StudentDO(); student.setName("張三"); student.setSex(1); student.setSeq("123456"); studentRepo.save(student); Assert.assertNotNull(student.getId()); }
在插入過(guò)程中使用mysql函數(shù)
如果我們希望student的seq值由系統(tǒng)自動(dòng)生成,且生成規(guī)則為“yyMMdd + 8位自增序列”(例如19060310000000)又該如何實(shí)現(xiàn)呢?
首先想到的是該如何生成這一串序列,mysql不像oracle自身支持sequence,因此在這里可以借用函數(shù)以及額外的sequence表來(lái)實(shí)現(xiàn)這一操作,網(wǎng)上有很多實(shí)現(xiàn)方式,這里就不再贅述。
現(xiàn)在已經(jīng)有了函數(shù)getseq('student_seq')
可以獲取到該序列,該如何將其應(yīng)用到保存對(duì)象的方法中?顯然的一個(gè)問(wèn)題是,像上面那樣再直接調(diào)用save方法已經(jīng)行不通了,應(yīng)該得需要自定義插入的sql實(shí)現(xiàn)。
一個(gè)容易想到的辦法是,在StudentDO類上使用注解@SQLInsert來(lái)定義insert的實(shí)現(xiàn),它寫起來(lái)應(yīng)該會(huì)像這個(gè)樣子:
@SQLInsert(sql = "INSERT INTO t_student(seq, name, sex) VALUES (getseq('student_seq'), ?, ?")
這條sql語(yǔ)句本身并沒(méi)有什么問(wèn)題,再次調(diào)用save()方法也確實(shí)能夠執(zhí)行。但是很可惜,它確會(huì)拋出一個(gè)sql異常:
java.sql.SQLException: Parameter index out of range (3 > number of parameters, which is 2).
顯然是程序認(rèn)為有多少個(gè)參數(shù),就得有多少個(gè)“?”與之匹配,目前我并沒(méi)有找到解決這個(gè)問(wèn)題的方案,所以這種方法宣告失敗。
既然@SQLInsert行不通,或許可以考慮使用@Query注解來(lái)自定義一個(gè)實(shí)現(xiàn)。我們可以在StudentRepo中定義這樣一個(gè)方法:
@Transactional @Modifying @Query(value = "INSERT INTO t_student(seq, name, sex) VALUES (getseq('student_seq'), :#{#student.name}, :#{#student.sex})", nativeQuery = true) int insert(@Param("student") StudentDO student);
試著運(yùn)行一下,結(jié)果很成功,對(duì)象被正常的存儲(chǔ)到數(shù)據(jù)庫(kù)中,并且seq的取值也正常??瓷先ノ覀兊膯?wèn)題已經(jīng)得到了解決,但事實(shí)真的如此么?
自定義的批量存儲(chǔ)
上面的例子中,我們成功通過(guò)JPA調(diào)用了mysql函數(shù)將對(duì)象存儲(chǔ)到數(shù)據(jù)庫(kù)中。但上面的例子只提供了單個(gè)保存的方法,如果我們想批量保存呢?@Query里面的sql能夠進(jìn)行改造么?我并沒(méi)有找到@Query中使用List作為參數(shù)的insert方法,但是這并不代表這一操作不能執(zhí)行。JPA仍舊提供給了使用者原始的使用方式:利用EntityManager來(lái)構(gòu)造sql并執(zhí)行。
@PersistenceContext private EntityManager entityManager; private int batchInsert(List<StudentDO> students) { StringBuilder sb = new StringBuilder(); sb.append("INSERT INTO t_student(seq, name, sex) VALUES "); for(StudentDO student : students) { sb.append("(getseq('student_seq'), ?, ?),"); } String sql = sb.toString().substring(0, sb.length() - 1); Query query = entityManager.createNativeQuery(sql); int paramIndex = 1; for(StudentDO student : students) { query.setParameter(paramIndex++, student.getName()); query.setParameter(paramIndex++, student.getSex()); } return query.executeUpdate(); }
就像MyBatis一樣,使用者也可以自定義SQL來(lái)執(zhí)行,試試看,同樣沒(méi)有問(wèn)題,再多的數(shù)據(jù)也可以被保存到數(shù)據(jù)庫(kù)中!批量保存的效果達(dá)到了。
再仔細(xì)想一想,通過(guò)上面的過(guò)程,還有什么問(wèn)題么?對(duì)比JPA自帶的save()方法,似乎我們的自定義保存返回的都是int結(jié)果,也就是操作影響的數(shù)據(jù)庫(kù)行數(shù)。使用過(guò)JPA的人都應(yīng)該了解,JPA的save()方法(或者其他JPA方法)返回的對(duì)象是經(jīng)過(guò)持久化的,得益于這一特性,使用者可以在調(diào)用save()方法之后獲取到對(duì)象的id等必須先插入到數(shù)據(jù)庫(kù)之后才會(huì)有的值。顯然這里的操作已經(jīng)失去了這一特性,那如果我們把返回值對(duì)應(yīng)的改為Object或者List可以做到么?答案是并不能,我們會(huì)得到如下異常:
org.springframework.dao.InvalidDataAccessApiUsageException: Modifying queries can only use void or int/Integer as return type!; nested exception is java.lang.IllegalArgumentException: Modifying queries can only use void or int/Integer as return type!
insert方法必須使用@Modifying進(jìn)行注解,而@Modifying注解的方法又只能返回int類型的結(jié)果。這種情況下或許只能先利
用查詢得到seq的值再進(jìn)行操作。
總結(jié)
對(duì)于JPA的使用還不夠了解,一些復(fù)雜的情況下沒(méi)有找到最理想的實(shí)現(xiàn)方案。
- @Query注解中是否能夠使用List以及實(shí)現(xiàn)動(dòng)態(tài)拼接參數(shù)的效果沒(méi)有得到解決
- 自定義的sql語(yǔ)句返回持久化對(duì)象的問(wèn)題沒(méi)有方案
在以后的使用了解中希望能夠找到解決辦法,將問(wèn)題記錄在這里,以便后續(xù)查看。
以上所述是小編給大家介紹的使用SpringBoot-JPA進(jìn)行自定義保存及批量保存功能,希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)歡迎給我留言,小編會(huì)及時(shí)回復(fù)大家的!
相關(guān)文章
Java中數(shù)組與集合的相互轉(zhuǎn)換實(shí)現(xiàn)解析
這篇文章主要介紹了Java中數(shù)組與集合的相互轉(zhuǎn)換實(shí)現(xiàn)解析,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-08-08Tornadofx學(xué)習(xí)筆記之IconTextFx開(kāi)源庫(kù)整合5000+個(gè)字體圖標(biāo)
這篇文章主要介紹了Tornadofx學(xué)習(xí)筆記之IconTextFx開(kāi)源庫(kù)整合5000+個(gè)字體圖標(biāo)的相關(guān)知識(shí),本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-12-12Java類初始化和實(shí)例化中的2個(gè)“雷區(qū)”
這篇文章主要介紹了Java類初始化和實(shí)例化中的2個(gè)“雷區(qū)”,大家要注意,感興趣的小伙伴們可以參考一下2016-02-02@PathVariable為空時(shí)指定默認(rèn)值的操作
這篇文章主要介紹了@PathVariable為空時(shí)指定默認(rèn)值的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-02-02Spring?Boot?整合持久層之Spring Data JPA
在介紹Spring Data JPA的時(shí)候,我們首先認(rèn)識(shí)下Hibernate。Hibernate是數(shù)據(jù)訪問(wèn)解決技術(shù)的絕對(duì)霸主,使用O/R映射技術(shù)實(shí)現(xiàn)數(shù)據(jù)訪問(wèn),O/R映射即將領(lǐng)域模型類和數(shù)據(jù)庫(kù)的表進(jìn)行映射,通過(guò)程序操作對(duì)象而實(shí)現(xiàn)表數(shù)據(jù)操作的能力,讓數(shù)據(jù)訪問(wèn)操作無(wú)須關(guān)注數(shù)據(jù)庫(kù)相關(guān)的技術(shù)2022-08-08Spring?Boot實(shí)現(xiàn)分布式系統(tǒng)中的服務(wù)發(fā)現(xiàn)和注冊(cè)(最新推薦)
在本文中,我們深入探討了Spring?Boot如何實(shí)現(xiàn)分布式系統(tǒng)中的服務(wù)發(fā)現(xiàn)和注冊(cè),我們使用Eureka作為服務(wù)注冊(cè)中心,Ribbon作為負(fù)載均衡器,Hystrix作為熔斷器,成功地實(shí)現(xiàn)了服務(wù)發(fā)現(xiàn)、服務(wù)注冊(cè)、負(fù)載均衡和服務(wù)熔斷等功能,需要的朋友參考下吧2023-06-06