国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁技術文章
文章詳情頁

Spring Data JPA使用JPQL與原生SQL進行查詢的操作

瀏覽:113日期:2023-07-10 14:43:47
1、使用JPQL語句進行查詢

JPQL語言(Java Persistence Query Language)是一種和SQL非常類似的中間性和對象化查詢語言,它最終會被編譯成針對不同底層數據庫的SQL語言,從而屏蔽不同數據庫的差異。

JPQL語言通過Query接口封裝執行,Query 接口封裝了執行數據庫查詢的相關方法。調用 EntityManager 的 Query、NamedQuery 及 NativeQuery 方法可以獲得查詢對象,進而可調用Query接口的相關方法來執行查詢操作。

JPQL是面向對象進行查詢的語言,可以通過自定義的JPQL完成UPDATE和DELETE操作。JPQL不支持使用INSERT。對于UPDATE或DELETE操作,必須使用注解 @Modifying 進行修飾。

【示例】使用JPQL語言進行查詢

package com.pjb.jpauserdemo.dao; import com.pjb.jpauserdemo.entity.UserInfo;import org.springframework.data.jpa.repository.JpaRepository;import org.springframework.data.jpa.repository.Modifying;import org.springframework.data.jpa.repository.Query;import org.springframework.data.repository.query.Param;import org.springframework.stereotype.Repository;import java.util.List; /** * 用戶信息數據庫訪問接口 * 使用JPQL語言 * @author pan_junbiao **/@Repositorypublic interface UserJpqlDao extends JpaRepository<UserInfo,Integer>{ /** * 根據用戶姓名,查詢用戶信息 */ @Query('SELECT u FROM UserInfo u WHERE u.userName = ?1') public UserInfo getUserInfoByName(String name); /** * 根據用戶姓名,模糊查詢用戶列表 */ @Query('SELECT u FROM UserInfo u WHERE u.userName like %:name%') public List<UserInfo> getUserListByName(String name); /** * 修改用戶姓名 */ @Modifying @Query('UPDATE UserInfo u SET u.userName = :name WHERE u.userId = :id') public int updateUserName(@Param('id')int userId, @Param('name')String userName);}2、使用原生SQL語句進行查詢

在使用原生SQL查詢時,也使用@Query注解。此時,nativeQuery參數需要設置為true。

【示例】使用原生SQL語句進行查詢

package com.pjb.jpauserdemo.dao;import com.pjb.jpauserdemo.entity.UserInfo;import org.springframework.data.jpa.repository.JpaRepository;import org.springframework.data.jpa.repository.Modifying;import org.springframework.data.jpa.repository.Query;import org.springframework.data.repository.query.Param;import org.springframework.stereotype.Repository;import org.springframework.transaction.annotation.Transactional;import java.util.List; /** * 用戶信息數據庫訪問接口測試類 * 使用原生SQL語言 * @author pan_junbiao **/@Repositorypublic interface UserSqlDao extends JpaRepository<UserInfo,Integer>{ /** * 根據用戶ID,獲取用戶信息 */ @Query(value = 'SELECT * FROM tb_user WHERE user_id = :id',nativeQuery = true) public UserInfo getUserById(@Param('id')int userId); /** * 根據用戶姓名,模糊查詢用戶列表 */ @Query(value = 'SELECT * FROM tb_user WHERE user_name LIKE %:userName%',nativeQuery = true) public List<UserInfo> getUserListByName(@Param('userName')String userName); /** * 修改用戶姓名 */ @Modifying @Query(value = 'UPDATE tb_user SET user_name = :name WHERE user_id = :id',nativeQuery = true) public int updateUserName(@Param('id')int userId, @Param('name')String userName);}

可以看到,@Query與@Modifying這兩個注解一起聲明,可以定義個性化更新操作。

Spring data jpa@query使用原生SQl,需要注意的坑

根據代碼來解說:

@Query(value = 'select bill.id_ as id, bill.created_date as date, bill.no, lawyer_case .case_no as caseNo, ' + 'lawyer_case .case_name as caseName, customer.no as customerNo, customer.cn_name as customerName, ' + 'bill.total_expense_after_tax, bill.collected_money, bill.book_ticket_amount, bill.version ' + 'e1.name as creator, bill.status' + 'from bill ' + 'left join lawyer_case on lawyer_case .case_no=bill.case_no ' + 'left join customer on customer.no=bill.customer_no ' + 'left join employee e1 on e1.id_=bill.creator ' + 'where IF (?1!=’’, customer_no=?1, 1=1) ' + 'and IF (?2!=’’, case_no=?2, 1=1) ' + 'and IF (?3!=’’, status=?3, 1=1) ' + 'and IF (?4!=’’, creator’%’,?4,’%’)), 1=1) ' + 'and create_by=?5 ' + 'ORDER BY ?#{#pageable} ', countQuery = 'select count(*) ' + 'from bill ' + 'left join lawyer_case on lawyer_case .case_no=bill.case_no ' + 'left join customer on customer.no=bill.customer_no ' + 'left join employee e1 on e1.id_=bill.creator ' + 'where IF (?1!=’’, customer_no=?1, 1=1) ' + 'and IF (?2!=’’, case_no=?2, 1=1) ' + 'and IF (?3!=’’, status=?3, 1=1) ' + 'and IF (?4!=’’, creator’%’,?4,’%’)), 1=1) ' + 'and create_by=?5 '+ 'ORDER BY ?#{#pageable} ', nativeQuery = true) Page<Object[]> findAllBill(String customerNo, String caseNo, Integer status, String creator, String createBy, Pageable pageable);需要注意的方法有以下幾點:

1、From 不支持重命名.

2、返回的是一個page<Object[]>,數組中只保存了數據,沒有對應的key,只能根據返回數據的順序,依次注入到DTO中。

3、對于使用分頁,需要:“ORDER BY ?#{#pageable}”,可以直接傳入一個pageable對象,會自動解析。

4、注意格式問題,很多時候就是換行的時候,沒有空格。

5、仔細對應數據庫中表字段,很多時候報某個字段找不到,就是因為字段名寫錯,和數據庫中對應不上。

6、這是解決使用微服務,大量的數據都需要遠程調用,會降低程序的性能。

7、使用Pageabel作為參數的時候,去進行分頁。剛開始的時候,覺得還是一個可行的辦法,但是得注意的時候,當需要排序的時候,是無法加入sort字段的。 會一直報錯left*。

8、針對7的解決方案,把原生SQL的數據查詢和countQuery分成兩個查詢方法。得到count,然后進行判斷,若是等于0,則直接返回空集合;反之,則取獲取數據。 需要自己進行分頁計算,傳入正確的pageNumber和pageSize。 大部分系統都是按照修改時間進行降序排序。 所以,order by可以寫死。然后pageNumber和pageSize動態傳入。 pageNumber的算法= (pageNumber - 1) * pageSize, 前提是PageNumber是從1開始,若0,則pageNumber=pageNumber * PageSize; 這樣就可以保證數據的正確。

/*** pageInfos: 轉換之后的數據。* pageable:傳入的pageable.* totalPage: 第一條SQL算好的返回值。* 這樣就可以統一的返回各種pageDTO。*/private Page<T> convertForPage(List<T> pageInfos, Pageable pageable, Integer totalPage) {return new PageImpl<>(pageInfos, pageable, totalPage); }

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持好吧啦網。

標簽: Spring
相關文章:
主站蜘蛛池模板: 欧美一级日韩一级 | 欧美亚洲一区 | 欧美一区二区三区在线视频 | 日韩精品中文字幕一区三区 | 中文字幕乱码在线观看 | 欧美三级日韩 | 欧美性精品hd在线观看 | 中文字幕日韩有码 | 久久免费视频在线 | 国产网站黄 | 日韩黄在线观看免费视频 | 亚洲精品国产综合久久一线 | 久久黄色视屏 | a级片免费观看视频 | 亚洲免费播放 | 精品欧美高清一区二区免费 | 黄片毛片在线观看 | 国产精品美女久久久久网站 | 欧美成人午夜免费完成 | 波多野结衣被强在线视频 | 国产爱啪啪 | 91伊人国产 | 欧美成人二区 | 亚洲日韩中文字幕天堂不卡 | 一级特黄爽大片刺激 | 欧美日韩精品乱国产538 | 99视频在线免费 | 中文字幕最新中文字幕中文字幕 | 成人牲交一极毛片 | 亚洲欧美一区二区三区在线 | 老太婆性杂交毛片 | 超级碰碰碰在线观看 | 在线视频 自拍 | 亚洲精品午夜久久久伊人 | 99色在线播放 | 毛片免费看看 | 99久久精品国产一区二区 | 成年女人黄小视频 | 国产三级播放 | 精品亚洲永久免费精品 | 一区二区亚洲精品 |