SpringDataJPA系列06自定义操作（JPQLSQL）
6、自定义操作（JPQL / SQL）
在我们经过了上面的学习，我们会发现一个问题：那就是我们所支持的就是一些简单的增删查改等等的操作，对于复杂的一些操作并不支持，所以我们也需要进行一些自定义，可以通过SQL或者 JPQL进行自定义操作！
自定义操作： 1、JPQL（原生SQL）@Query 查询如果返回单个实体，就使用pojo类进行接收即可，如果是多个就使用list进行接收！ 参数设置方式 索引：?数字 具名：:参数名 结合@Param注解指定参数名称 | 增删改： 要加上事务的支持： 如果是插入方法：一定只能在hibernate下才支持（Insert into … select） @Transactional // 开启事务！通常会放在业务逻辑层上去声明！ @Modifying // 通知springdatajpa 是增删改的操作！ 复制代码
测试代码如下： 创建repository/CustomerRepository package com.yykk.repositories; import com.yykk.pojo.Customer; import org.springframework.data.jpa.repository.Modifying; import org.springframework.data.jpa.repository.Query; import org.springframework.data.repository.PagingAndSortingRepository; import org.springframework.data.repository.query.Param; import org.springframework.transaction.annotation.Transactional; import java.util.List; public interface CustomerRepositories extends PagingAndSortingRepository{ // 使用JPQL实现增删改查 // 查询 //@Query(＂from Customer where custName=?1＂) @Query(value = ＂from Customer where custName=:custName＂) List findCustomerByCustName(@Param(＂custName＂) String custName); /** * 更新操作！ * 在这里如果没有事务的支持，那么我们会报错！需要定义在业务逻辑层里面！ * @Modifying // 通知springdatajpa 是增删改的操作！ */ @Query(＂update Customer c set c.custName=:custName where c.id=:id＂) @Transactional // 开启事务！ @Modifying // 通知springdatajpa 是增删改的操作！ int updateCustomerById(@Param(＂custName＂) String custName,@Param(＂id＂) Long id); // 删除 @Query(＂delete from Customer c where c.id=?1＂) @Transactional // 开启事务！ @Modifying // 通知springdatajpa 是增删改的操作！ String deleteCustomer(Long id); // 新增 JPQL 默认是不支持的，但是这里是使用的伪插入，底层是hibernate！ // 通知springdatajpa 是增删改的操作！ //@Transactional // 开启事务！ //@Modifying //@Query(value = ＂insert into Customer(custName) select cust_name from Customer where id=?1＂) //这里推荐使用其他方法insert方法不推荐使用！如果要使用可以使用原生的！这里没有values报错！可以尝试一下拼接！ //int insertCustomerBySelect(Long id); // 原生SQL查询 // 在这个查询中写成custName之后就报错！ @Query(value = ＂select * FROM tb_Customer where cust_name= ? ＂ ,nativeQuery = true) List findCustomerByCustNameBySql(@Param(＂custName＂) String custName); } 复制代码测试！ import com.yykk.config.SpringDataJPAConfig; import com.yykk.pojo.Customer; import com.yykk.repositories.CustomerRepositories; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.util.List; @ContextConfiguration(classes = SpringDataJPAConfig.class) @RunWith(SpringJUnit4ClassRunner.class) public class JPQLTest { @Autowired CustomerRepositories repositories; /** * 查询测试！ * 因为可能会遇到返回的结果是多个相同的，就使用list接收！ */ @Test public void testQuery() { List customer = repositories.findCustomerByCustName(＂yykk＂); System.out.println(customer); } /** * 更新操作！ * 在这里如果没有事务的支持，那么我们会报错！需要定义在业务逻辑层里面！ */ @Test public void testUpdate() { int result = repositories.updateCustomerById(＂apple＂, 3L); System.out.println(result); } @Test public void testDelete() { String result = repositories.deleteCustomer( 9L); System.out.println(result); } //@Test //public void testInsert() { // int result = repositories.insertCustomerBySelect(1L); // System.out.println(result); //} @Test public void testQuery_sql() { List list = repositories.findCustomerByCustNameBySql(＂yykk＂); System.out.println(list); } } 复制代码2、规定方法名只支持查询方法主题关键字（前缀）只有查询和删除！决定当前方法作用！查询主题关键字
关键字
描述
find…By 、`read…By 、get…By 、query..By 、search…By 、stream…By
通过查询方法通常返回存储库类型、Collection 或Streamable 子类型或结果包装器，例如：Page 、GeoResults 或任何其他特定于商店的结果包装器。可用于 findBy… ，findMyDomainTypeBy…
exists…By
存在投影，通常返回 boolean 结果
count…By
计数投影返回数字结果。
delete…By、remove…By
删除查询方法返回无结果（ void ）或删除计数。
…First… ，…Top…
将查询结果限制为第一个 结果。此关键字可以出现在主题的find （和其他关键字）和之间的任何位置by 。
…Distinct…
使用不同的查询仅返回唯一的结果。查询特定与商店的文档是否支持该功能。此关键字可以出现在主题的 find （和其他关键字）和之间的任意位置 by 。支持的查询方法谓词关键字和修饰符决定查询条件
Keyword
Sample
JPQL snippet
And
findByNameAndPwd
where name= ? and pwd =?
Or
findByNameOrSex
where name= ? or sex=?
Is,Equals
findById,findByIdEquals
where id= ?
Between
findByIdBetween
where id between ? and ?
LessThan
findByIdLessThan
where id < ?
LessThanEquals
findByIdLessThanEquals
where id <= ?
GreaterThan
findByIdGreaterThan
where id > ?
GreaterThanEquals
findByIdGreaterThanEquals
where id > = ?
After
findByIdAfter
where id > ?
Before
findByIdBefore
where id < ?
IsNull
findByNameIsNull
where name is null
isNotNull,NotNull
findByNameNotNull
where name is not null
Like
findByNameLike
where name like ?
NotLike
findByNameNotLike
where name not like ?
StartingWith
findByNameStartingWith
where name like ‘?%’
EndingWith
findByNameEndingWith
where name like ‘%?’
Containing
findByNameContaining
where name like ‘%?%’
OrderBy
findByIdOrderByXDesc
where id=? order by x desc
Not
findByNameNot
where name <> ?
In
findByIdIn(Collection<?> c)
where id in (?)
NotIn
findByIdNotIn(Collection<?> c)
where id not in (?)
TRUE
findByAaaTue
where aaa = true
FALSE
findByAaaFalse
where aaa = false
IgnoreCase
findByNameIgnoreCase
where UPPER(name)=UPPER(?)
top
findTop10
top 10/where ROWNUM <=10
Distinct
findDistinctByLastnameAndFirstname
select distinct … where x.lastname = ?1 and x.firstname = ?2
1、repository/CustomerMethodNameRepositories package com.yykk.repositories; import com.yykk.pojo.Customer; import org.springframework.data.jpa.repository.Modifying; import org.springframework.data.repository.PagingAndSortingRepository; import org.springframework.transaction.annotation.Transactional; import java.util.List; public interface CustomerMethodNameRepositories extends PagingAndSortingRepository{ List findByCustName(String custName); boolean existsByCustName(String custName); @Transactional @Modifying int deleteByid(Long id); List findByCustNameLike(String custName); } 复制代码
2、测试！ import com.yykk.config.SpringDataJPAConfig; import com.yykk.pojo.Customer; import com.yykk.repositories.CustomerMethodNameRepositories; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.util.List; @ContextConfiguration(classes = SpringDataJPAConfig.class) @RunWith(SpringJUnit4ClassRunner.class) public class MethodName { @Autowired CustomerMethodNameRepositories repository; @Test public void list(){ List list = repository.findByCustName(＂yykk＂); System.out.println(list); } @Test public void exists(){ boolean exists = repository.existsByCustName(＂yykk＂); System.out.println(exists); } @Test public void delete(){ int del = repository.deleteByid(12L); System.out.println(del); } @Test public void like(){ List list = repository.findByCustNameLike(＂y%＂); System.out.println(list); } } 复制代码
这里的都是静态的固定查询，对于动态的查询要根据以下的这几种方法！3、通过Query by Example只支持查询不支持嵌套或分组的属性约束，如firstname = ？0 or（firstname = ？ 1 and lastname = ？ 2）只支持字符串 start/contains/ends/regex 匹配和其他属性类型的精确匹配。
实现：
1、将Repository继承QueryByExampleExecutor package com.yykk.repositories; import com.yykk.pojo.Customer; import org.springframework.data.repository.PagingAndSortingRepository; import org.springframework.data.repository.query.QueryByExampleExecutor; public interface CustomerQBERepositories extends PagingAndSortingRepository , QueryByExampleExecutor { } 复制代码
2、测试代码！ import com.yykk.config.SpringDataJPAConfig; import com.yykk.pojo.Customer; import com.yykk.repositories.CustomerQBERepositories; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Example; import org.springframework.data.domain.ExampleMatcher; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; @ContextConfiguration(classes = SpringDataJPAConfig.class) @RunWith(SpringJUnit4ClassRunner.class) public class QueryByExampleExecutor { @Autowired CustomerQBERepositories repository; /** * 简单实例：客户名称，客户地址动态查询！ */ @Test public void list() { Customer customer = new Customer(); customer.setCustName(＂yykk＂); customer.setCustAddress(＂上海＂); // 通过 Example构造查询条件！ Example example = Example.of(customer); Iterable all = repository.findAll(example); System.out.println(all); } /** * 通过匹配器，进行条件的限制！ * 简单实例：客户名称，客户地址动态查询！ */ @Test public void test() { Customer customer = new Customer(); customer.setCustName(＂kk＂); customer.setCustAddress(＂HAI＂); // 通过匹配器对条件行为进行设置！ ExampleMatcher matcher = ExampleMatcher.matching() .withIgnorePaths(＂custName＂) // 设置忽略的属性！ //.withIgnoreCase(＂cust_address＂) // 设置忽略大小写，默认不写就是全部属性的设置！ //.withStringMatcher(ExampleMatcher.StringMatcher.ENDING); // 对字符串进行结尾匹配 .withMatcher(＂cust_address＂,m -> m.endsWith().ignoreCase(true)); // 针对单个条件进行设置,会使withIgnoreCase失效！ //.withMatcher(＂custAddress＂, ExampleMatcher.GenericPropertyMatchers.endsWith()); // 通过 Example构造查询条件！ Example example = Example.of(customer,matcher); Iterable list = repository.findAll(example); System.out.println(list); } } 复制代码4、通过Specifications
之前使用Query by Example只能针对字符串进行条件设置，那如果希望对所有类型支持，可以使用Specifcations
实现
1、继承接口 package com.yykk.repositories; import com.yykk.pojo.Customer; import org.springframework.data.jpa.repository.JpaSpecificationExecutor; import org.springframework.data.repository.PagingAndSortingRepository; public interface CustomerSpecificationsRepositories extends PagingAndSortingRepository ,JpaSpecificationExecutor { } 复制代码root：查询哪个表（关联查询）= fromCriteriaQuery：查询哪些字段，排序是什么 = 组合（order by 、where）CriteriaBuilder：条件之间是什么关系，如何生成一个查询条件，每一个查询条件是什么类型（> between in …）= wherePredicate（Expression）：每一条查询条件的详细描述
2、测试！ import com.yykk.config.SpringDataJPAConfig; import com.yykk.pojo.Customer; import com.yykk.repositories.CustomerSpecificationsRepositories; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.jpa.domain.Specification; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import org.springframework.util.StringUtils; import javax.persistence.EntityManager; import javax.persistence.criteria.*; import java.util.ArrayList; import java.util.List; @ContextConfiguration(classes = SpringDataJPAConfig.class) @RunWith(SpringJUnit4ClassRunner.class) public class SpecificationsTest { @Autowired CustomerSpecificationsRepositories repository; @Autowired EntityManager entityManager; @Test public void test_All(){ List customer = repository.findAll(new Specification() { @Override public Predicate toPredicate(Root root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) { // root from Customer ,获取列 // CriteriaBuilder 设置各种条件 (< > in ...) // query 组合(order by ,where ) return null; } }); } /** * 查询客户范围（in） * id > 大于 * 地址：精确 */ @Test public void test_Coll(){ List customer = repository.findAll(new Specification() { @Override public Predicate toPredicate(Root root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) { // root from Customer ,获取列 // CriteriaBuilder 设置各种条件 (< > in ...) // query 组合(order by ,where ) Path id = root.get(＂id＂); Path custName = root.get(＂custName＂); Path custAddress = root.get(＂custAddress＂); // 参数1：为哪个字段设置条件 参数2：值 Predicate address = criteriaBuilder.equal(custAddress, ＂SHANGHAI＂); Predicate ids = criteriaBuilder.greaterThan(id, 0L); CriteriaBuilder.In in = criteriaBuilder.in(custName); in.value(＂yykk＂).value(＂张三＂); Predicate predicate = criteriaBuilder.and(address, ids,in); return predicate; } }); System.out.println(customer); } /** * 查询客户范围（in） * id > 大于 * 地址：精确 * 将这里的值设置为动态的！ */ @Test public void test_dynamic(){ Customer params = new Customer(); params.setId(0L); params.setCustAddress(＂SHANGHAI＂); params.setCustName(＂yykk,apple＂); List customer = repository.findAll(new Specification() { @Override public Predicate toPredicate(Root root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) { // root from Customer ,获取列 // CriteriaBuilder 设置各种条件 (< > in ...) // query 组合(order by ,where ) Path id = root.get(＂id＂); Path custName = root.get(＂custName＂); Path custAddress = root.get(＂custAddress＂); // 参数1：为哪个字段设置条件 参数2：值 List list = new ArrayList<>(); if (StringUtils.isEmpty(params.getCustAddress())) { list.add(criteriaBuilder.equal(custAddress, ＂SHANGHAI＂)); } if (params.getId() > -1) { list.add(criteriaBuilder.greaterThan(id, 0L)); } if (StringUtils.isEmpty(params.getCustName())) { CriteriaBuilder.In in = criteriaBuilder.in(custName); in.value(＂yykk＂).value(＂张三＂); list.add(in); } Predicate predicate = criteriaBuilder.and(list.toArray(new Predicate[list.size()])); return predicate; } }); System.out.println(customer); } /** * 查询客户范围（in） * id > 大于 * 地址：精确 * 将这里的值设置为动态的！ */ @Test public void test_dynamicx(){ CriteriaBuilder builder = entityManager.getCriteriaBuilder(); CriteriaQuery
10部适合46岁宝宝看的启蒙动画片，陪孩子过春节假期上次呢，给各位家长朋友推荐了24岁小朋友适合看的动画片，今天呢，我就给各位家长朋友推荐几部46岁宝宝适合看的动画片。46岁这是个充满了矛盾的年纪，自我意识蓬勃生长，能力又困顿于发育
家里有学生，建议妈妈多做这7种早餐，营养丰富，一周不重样早餐是一日之中最为重要的一餐，经过了长达8个小时的睡眠，身体正是吸收营养的阶段，所以早餐不能将就，尤其是家里有学生的家长，早餐更不应该含糊，今天就给宝妈们分享6种早餐，简单好吃又有
我在新西兰经历的无差别人为车祸死里逃生！（一）读万卷书，行万里路。哪个更重要？我的亲身体验告诉我。行万里路可能远远比读万卷书更有可能让你深切的体悟生命的真相和世界的真相。我曾经学医，也在美国硅谷做过脑科学科研，一直对生死问题十
中国发展密码五问之五丨2022年如何进一步推动乡村振兴？3月11日，游客在贵州省贵定县盘江镇金海雪山景区观赏油菜花。新华社记者杨文斌摄2022年是巩固拓展脱贫攻坚成果同乡村振兴有效衔接的关键一年。2022年的政府工作报告提出，大力抓好农
这些免票的美景，徒步可赏！为什么说春天适合徒步？因为一抬眼就会被美到！田间的风山间的花倒映着天空的水面广仔整理了几个徒步踏青好去处登山古道赏湖趁着和煦暖阳一起去打卡吧！广东峡天下广东峡天下地处阳山喀斯特大峡
长期便秘拖着不理？这3个危害不是开玩笑，缓解做好这3点有的人排便轻松，感觉想要排便第一时间上厕所，不用两三分钟就能完成。而有的人备受便秘困扰，连续几天没有排便，上厕所时费很多劲依然无法排便顺畅，要引起重视。因为保持健康，肠道动力充足，
春季失眠睡不好？别着急，这5招帮你沾床就睡不待春来呼我困，四时何日不堪眠？春暖花开是最适合睡觉的时节，但是很多人却深受失眠的困扰。有调查显示，60岁以上老人睡眠障碍的患病率在3040之间。广州市第一人民医院精神心理科副主任
少年时读书和玩耍之间，春分来回好几度，无奈心智未熟透，不知不觉中到了青年。未到19岁，已经混社会，那段少年时代的气息仿如昨日，一去不回。直到步入中年的春分，对未来老年的春分充满期待
儿童游乐设备种类繁多，有灵魂游乐项目，仅此一家不容错过要管理好儿童乐园，有灵魂游乐项目是必不可少的。如今，儿童游乐设备种类繁多，对于娱乐业的新进入者来说，选择一款好的设备是一件困难的事情。那么我们如何选择最适合儿童的游乐设备呢？泛娱文
马云承诺每年在沙漠种1亿棵树，5年过去了，如今怎么样了？声明原创不易，禁止搬运，违者必究！支付宝是我们常用的第三方软件，有使用过支付宝也发现，这不单单是一款支付软件，里面还有很多的板块。其中还有一个蚂蚁森林，也有不少的用户都有参与，用户
在撒哈拉沙漠无人区，被当地警察护送是什么样的体验2018年3月底，我和几个旅行的朋友要从阿尔及利亚首都阿尔及利亚乘坐飞机到南部的沙漠腹地贾奈特，开始十天的撒哈拉沙漠旅行。这个飞往贾奈特的飞机是小型飞机，还带螺旋桨的，在很多人眼里
