Spring Data JPA之Spring Data JPA快速入门(三)

生活中,最使人疲惫的往往不是道路的遥远,而是心中的郁闷;最使人痛苦的往往不是生活的不幸,而是希望的破灭;最使人颓废的往往不是前途的坎坷,而是自信的丧失;最使人绝望的往往不是挫折的打击,而是心灵的死亡。所以我们要有自己的梦想,让梦想的星光指引着我们走出落漠,走出惆怅,带着我们走进自己的理想。

导读:本篇文章讲解 Spring Data JPA之Spring Data JPA快速入门(三),希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com,来源:原文

一、Spring Data JPA概述

Spring Data JPA 是 Spring 基于 ORM 框架、JPA 规范的基础上封装的一套JPA应用框架,可以用极简的代码实现对数据库的访问和操作。它提供了包括增删改查等在内的常用功能,且易于扩展!使用SpringDataJpa后,dao层只需要写接口,就自动具有了增删改查、分页查询等方法。

JPA是一套规范,内部是有接口和抽象类组成的。

hibernate是一套成熟的ORM框架,而且Hibernate实现了JPA规范,hibernate为JPA的一种实现方式,使用JPA的API编程,意味着面向接口编程。

Spring Data JPA是Spring提供的一套对JPA操作更加高级的封装,是在JPA规范下的专门用来进行数据持久化的解决方案。

二、Spring Data JPA的快速入门

1.添加依赖

使用Spring Data JPA,需要整合Spring与Spring Data JPA,并且需要提供JPA的服务提供者hibernate,所以需要导入spring相关坐标,hibernate坐标,数据库驱动坐标等

 <properties>
        <spring.version>5.2.8.RELEASE</spring.version>
        <hibernate.version>5.4.3.Final</hibernate.version>
        <slf4j.version>1.7.30</slf4j.version>
        <log4j.version>1.2.17</log4j.version>
        <c3p0.version>0.9.1.2</c3p0.version>
        <mysql.version>5.1.6</mysql.version>
    </properties>

    <dependencies>
        <!-- junit单元测试 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>

        <!-- spring beg -->
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.6.8</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <!-- spring对orm框架的支持包-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-orm</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${spring.version}</version>
        </dependency>


        <!-- hibernate核心包 -->
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-core</artifactId>
            <version>${hibernate.version}</version>
        </dependency>
        <!--hibernate对jpa实现包-->
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-entitymanager</artifactId>
            <version>${hibernate.version}</version>
        </dependency>
        <!--hibernate的校验包-->
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-validator</artifactId>
            <version>${hibernate.version}</version>
        </dependency>


        <!-- c3p0连接池-->
        <dependency>
            <groupId>c3p0</groupId>
            <artifactId>c3p0</artifactId>
            <version>${c3p0.version}</version>
        </dependency>

        <!-- log相关 -->
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>${log4j.version}</version>
        </dependency>

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>${slf4j.version}</version>
        </dependency>

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>${slf4j.version}</version>
        </dependency>


        <!--MYsql驱动-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.version}</version>
        </dependency>

        <!-- spring data jpa-->
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-jpa</artifactId>
            <version>1.9.0.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <!-- 使用spring data jpa 必须引入 -->
        <dependency>
            <groupId>javax.el</groupId>
            <artifactId>javax.el-api</artifactId>
            <version>3.0.0</version>
        </dependency>

        <dependency>
            <groupId>org.glassfish.web</groupId>
            <artifactId>javax.el</artifactId>
            <version>2.2.4</version>
        </dependency>
    </dependencies>

2.Spring Data JPA与Spring整合

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:jpa="http://www.springframework.org/schema/data/jpa" xmlns:task="http://www.springframework.org/schema/task"
       xsi:schemaLocation="
		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
		http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd
		http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
		http://www.springframework.org/schema/data/jpa
		http://www.springframework.org/schema/data/jpa/spring-jpa.xsd">

    <!--spring 和 spring data jpa的配置-->

    <!-- 创建entityManagerFactory对象交给spring容器管理-->
    <bean id="entityManagerFactoty" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <!--配置扫描的包(实体类所在的包) -->
        <property name="packagesToScan" value="cn.ybzy.domain" />
        <!-- jpa的实现厂家 -->
        <property name="persistenceProvider">
            <bean class="org.hibernate.jpa.HibernatePersistenceProvider"/>
        </property>

        <!--jpa的供应商适配器 -->
        <property name="jpaVendorAdapter">
            <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
                <!--配置是否自动创建数据库表 -->
                <property name="generateDdl" value="false" />
                <!--指定数据库类型 -->
                <property name="database" value="MYSQL" />
                <!--数据库方言:支持的特有语法 -->
                <property name="databasePlatform" value="org.hibernate.dialect.MySQLDialect" />
                <!--是否显示sql -->
                <property name="showSql" value="true" />
            </bean>
        </property>

        <!--jpa的方言 :高级的特性 -->
        <property name="jpaDialect" >
            <bean class="org.springframework.orm.jpa.vendor.HibernateJpaDialect" />
        </property>
        
    <!--注入jpa的配置信息
            加载jpa的基本配置信息和jpa实现方式(hibernate)的配置信息
            hibernate.hbm2ddl.auto : 自动创建数据库表
                create : 每次都会重新创建数据库表
                update:有表不会重新创建,没有表会重新创建表
        -->
        <property name="jpaProperties" >
            <props>
                <prop key="hibernate.hbm2ddl.auto">create</prop>
            </props>
        </property>
    </bean>

    <!--创建数据库连接池 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="user" value="root"></property>
        <property name="password" value="123456"></property>
        <property name="jdbcUrl" value="jdbc:mysql:///jpa" ></property>
        <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
    </bean>

    <!--整合spring dataJpa-->
    <jpa:repositories base-package="cn.ybzy.dao" transaction-manager-ref="transactionManager"
                   entity-manager-factory-ref="entityManagerFactoty" ></jpa:repositories>

    <!--配置JPA事务管理器 -->
    <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
        <property name="entityManagerFactory" ref="entityManagerFactoty"></property>
    </bean>

    <!-- txAdvice-->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="save*" propagation="REQUIRED"/>
            <tx:method name="insert*" propagation="REQUIRED"/>
            <tx:method name="update*" propagation="REQUIRED"/>
            <tx:method name="delete*" propagation="REQUIRED"/>
            <tx:method name="get*" read-only="true"/>
            <tx:method name="find*" read-only="true"/>
            <tx:method name="*" propagation="REQUIRED"/>
        </tx:attributes>
    </tx:advice>

    <!-- aop-->
    <aop:config>
        <aop:pointcut id="pointcut" expression="execution(* cn.itcast.service.*.*(..))" />
        <aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut" />
    </aop:config>

    <!-- 配置包扫描-->
    <context:component-scan base-package="cn.ybzy" ></context:component-scan>
</beans>

3.使用JPA注解配置映射关系

 //声明实体类
@Entity
//建立实体类和表的映射关系
@Table(name="tb_user")
public class User{
	
	//声明当前私有属性为主键
	@Id
	//配置主键的生成策略
	@GeneratedValue(strategy=GenerationType.IDENTITY) 
	//指定和表中user_id字段的映射关系
	@Column(name="user_id") 
	private Long userId;
	
	@Column(name="user_name") 
	//指定和表中user_name字段的映射关系
	private String userName;
	
	@Column(name="user_address")
	//指定和表中user_address字段的映射关系
	private String userAddress;
	
	@Column(name="user_phone")
	//指定和表中user_phone字段的映射关系
	private String userPhone;
}	


4.创建Spring Data JPA规范的Dao层接口

Spring Data JPA是spring提供的一款对于数据访问层(Dao层)的框架,使用Spring Data
JPA,只需要按照框架的规范提供dao接口,不需要实现类就可以完成数据库的增删改查、分页查询等方法的定义。

符合Spring Data JPA规范的Dao层接口步骤:

1.创建一个Dao层接口,并实现JpaRepository和JpaSpecificationExecutor

2.提供相应的泛型
/**
 * JpaRepository<实体类类型,主键类型>:用来完成基本CRUD操作
 * 
 * JpaSpecificationExecutor<实体类类型>:用于复杂查询(分页等查询操作)
 */
public interface UserDao extends JpaRepository<User,Long> ,JpaSpecificationExecutor<User> {
}

5.执行测试

//声明spring提供单元测试环境
@RunWith(SpringJUnit4ClassRunner.class) 
//指定spring容器的配置信息
@ContextConfiguration(locations = "classpath:applicationContext.xml")
public class UserDaoTest {
    @Autowired
    private UserDao userDao;
    
    @Test
    public void testFindAll() {
        List<User> list = userDao.findAll();
        for(User user : list) {
            System.out.println(user);
        }
    }
}

三、基于接口的方法列表

编写符合Spring Data JPA 规范的Dao层接口后,就可以使用Dao层基于父类的方法,进行基本的CRUD操作。

继承JpaRepository后的方法列表

在这里插入图片描述

继承JpaSpecificationExecutor的方法列表

在这里插入图片描述

四、基本的CRUD

//声明spring提供单元测试环境
@RunWith(SpringJUnit4ClassRunner.class) 
//指定spring容器的配置信息
@ContextConfiguration(locations = "classpath:applicationContext.xml")
public class UserDaoTest {
    @Autowired
    private UserDao userDao;

    /**
     * 根据id查询
     */
    @Test
    public void testFindOne() {
        User user = userDao.findOne(2l);
        System.out.println(user);
    }

    /**
     * save : 保存或者更新
     *    根据传递的对象是否存在主键id,没有id主键属性:保存,存在id主键属性,根据id查询数据,更新数据
     */
    @Test
    public void testSave() {
        User user  = new User();
        user.setUserName("大白");
        user.setUserAddress("中国");
        user.setUserPhone("8888");
        userDao.save(user);
    }

    @Test
    public void testUpdate() {
        User user  = new User();
        user.setUserId(4l);
        user.setUserName("小白白");
        userDao.save(user);
    }

    @Test
    public void testDelete () {
        userDao.delete(4l);
    }

    @Test
    public void testFindAll() {
        List<User> list = userDao.findAll();
        for(User user : list) {
            System.out.println(user);
        }
    }

    /**
     * 统计查询:查询用户的总数量
     *      count:统计总条数
     */
    @Test
    public void testCount() {
    	//查询全部用户数量
        long count = userDao.count();
        System.out.println(count);
    }

    /**
     * 测试:判断id为4的用户是否存在
     *      1. 查询id为4的用户
     *          如果值为空,代表不存在,如果不为空,代表存在
     *      2. 判断数据库中id为4的用户的数量
     *          如果数量为0,代表不存在,如果大于0,代表存在
     */
    @Test
    public void  testExists() {
        boolean exists = userDao.exists(4l);
        System.out.println("id为4的用户 是否存在:"+exists);
    }


    /**
     * 根据id从数据库查询
     *      @Transactional : 保证getOne正常运行
     *
     *  findOne:
     *      em.find()           :立即加载
     *  getOne:
     *      em.getReference     :延迟加载
     *      * 返回的是一个客户的动态代理对象
     *      * 什么时候用,什么时候查询
     */
    @Test
    @Transactional
    public void  testGetOne() {
        User user = userDao.getOne(2l);
        System.out.println(user);
    }

}

五、基于JPQL的查询

Spring Data JPA提供的查询方法已经可以解决大部分的应用场景,但是对于某些业务来说,还需要灵活的构造查询条件,这时就可以使用@Query注解,结合JPQL的语句方式完成查询。

@Query 注解的使用非常简单,只需在方法上面标注该注解,同时提供一个JPQL查询语句即可。

查询示例

  /**
     *  jpql: from User where userName= ? and userId = ?
     * 
     * 	配置jpql语句,使用的@Query注解
     * 
     *  对于多个占位符参数,赋值的时候,默认情况下,占位符的位置需要和方法参数中的位置保持一致。
     *
     *  对于多个占位符参数,赋值的时候,可以指定占位符参数的位置
     * 
     *  ? 索引的方式,指定此占位的取值来源
     */
	@Query(value = "from User where userName= ? and userId = ?")
    public User findUserNameAndId(String name,Long id);
    
   /**
     *  对于多个占位符参数,赋值的时候,可以指定占位符参数的位置
     * 
     *  ?1代表参数的占位符,其中1对应方法中的参数索引
     */
	@Query(value = "from User where userName= ?2 and userId = ?1")
    public User findUserNameAndId(Long id,String name);
 @Test
    public void findUserNameAndId() {
       // User  user=  userDao.findUserNameAndId("大白白",1l);
        User user=  userDao.findUserNameAndId(1l,"大白白");
        System.out.println(user);
    }

更新示例

	/**
     *  sql  :update tb_user set user_name= ? where user_id = ?
     *  jpql : update User set userName= ? where userId= ?
     *
     *  @Query : 代表进行查询
     *  @Modifying,该操作标识为更新操作
     *
     */
    @Query(value = " update User set userName= ?2 where userId= ?1 ")
    @Modifying
    public void updateUser(long userId,String userName);

springDataJpa中使用jpql完成 更新/删除操作,需要手动添加事务的支持,默认会在执行结束之后,回滚事务。使用@Rollback : 设置是否自动回滚(false | true)

    @Test
    @Transactional //添加事务的支持
    @Rollback(value = false)
    public void testUpdateUser() {
        userDao.updateUser(10l,"大黑");
    }

六、基于SQL语句的查询

Spring Data JPA同样也支持sql语句的查询。

Query : 配置sql查询

	value : sql语句
	
	nativeQuery : 查询方式( true : sql查询,false:jpql查询)		
	/**
     * sql形式查询
     * 
     *  sql : select * from tb_user;
     * 
     *  Query : 配置sql查询
     *      value : sql语句
     *      nativeQuery : 查询方式
     *          true : sql查询
     *          false:jpql查询
     *
     */
    //@Query(value = " select * from tb_user" ,nativeQuery = true)
    @Query(value="select * from tb_user where user_name like ?",nativeQuery = true)
    public List<Object [] > findSql(String name);
  @Test
    public void testFindSql() {
        List<Object[]> list = userDao.findSql("白%");
        for(Object [] obj : list) {
            System.out.println(Arrays.toString(obj));
        }
    }

七、基于方法命名规则查询

方法命名规则查询就是根据方法的名字,就能创建查询。只需要按照Spring Data JPA提供的方法命名规则定义方法的名称,就可以完成查询工作。Spring Data JPA在程序执行的时候会根据方法名称进行解析,并自动生成查询语句进行查询。

按照Spring Data JPA 定义的规则,查询方法以findBy开头,涉及条件查询时,条件的属性用条件关键字连接,要注意的是:条件属性首字母需大写。框架在进行方法名解析时,会先把方法名多余的前缀截取掉,然后对剩下部分进行解析。

1.方法名约定概要:

查询:findBy开头

查询的条件: 对象中的属性名(首字母大写)

默认情况 : 使用 等于的方式查询

方式: findBy  + 属性名称 + “查询方式(Like | isnull) + 多条件的连接符(and|or)  + 属性名 + “查询方式”

例子:findByUserNameLIkeAndUserPhone
	//依据名称精准匹配
    public User findByUserName(String userName);
    
    //依据名称模糊匹配
    public List<User > findByUserNameLike(String userName);
  
    //依据名称模糊匹配和精准匹配电话的查询
    public List<User> findByUserNameLikeAndUserPhone(String userName,String userPhone);
  @Test
    public void findByUserNameLikeAndUserPhone() {
        User user= userDao.findByUserNameLikeAndUserPhone("白%", "66666");
        System.out.println(user);
    }

2.关键字、方法名约定、生成SQL查看表

Keyword Sample JPQL
And findByUserNameAndUserPhone where tb_user.user_name = ?1 and tb_user.user_phone= ?2
Or findByUserNameOrUserPhone where tb_user.user_name = ?1 or tb_user.user_phone= ?2
Equals findByUserPhoneEquals where tb_user.user_phone= ?1
Between findByStartDateBetween where tb_user.start_date between ?1 and ?2
LessThan findByAgeLessThan where tb_user.age < ?1
GreaterThan findByAgeGreaterThan where tb_user.age > ?1
GreaterThanEqual findByAgeGreaterThanEqual where tb_user.age >= ?1
After findByStartDateAfter where tb_user.start_date > ?1
Before findByStartDateBefore where tb_user.start_date < ?1
IsNull findByAgeIsNull where tb_user.age is null
IsNotNull,NotNull findByAge(Is)NotNull where tb_user.age not null
Like findByUserPhoneLike where tb_user.user_phone like ?1
NotLike findByUserPhoneNotLike where tb_user.user_phone not like ?
StartingWith findByUserPhoneStartingWith where tb_user.user_phone like ?1 (parameter bound with appended %)
EndingWith findByUserPhoneEndingWith where tb_user.user_phone like ?1 (parameter bound with prepended %)
Containing findByUserPhoneContaining where tb_user.user_phone like ?1 (parameter bound wrapped in %)
OrderBy findByAgeOrderByUserNameDesc where tb_user.age = ?1 order by tb_user.user_name desc
Not findByUserNameNot where tb_user.user_name <> ?1
In findByAgeIn(Collection ages) where tb_user.age in ?1
NotIn findByAgeNotIn(Collection age) where tb_user.age not in ?1
TRUE findByActiveTrue() where tb_user.active = true
FALSE findByActiveFalse() where tb_user.active = false
IgnoreCase findByUserPhoneIgnoreCase where UPPER(tb_user.user_phone) = UPPER(?1)

八、基于Specifications的动态查询

在查询某个实体的时候,给定的条件是不固定的,这时就需要动态构建相应的查询语句,在Spring DataJPA中可以通过JpaSpecificationExecutor接口查询。相比JPQL,其优势是类型安全,更加的面向对象。

JpaSpecificationExecutor中定义的方法
 public interface JpaSpecificationExecutor<T> {
   	//根据条件查询一个对象
 	T findOne(Specification<T> spec);	
   	//根据条件查询集合
 	List<T> findAll(Specification<T> spec);
   	//根据条件分页查询
 	Page<T> findAll(Specification<T> spec, Pageable pageable);
   	//排序查询查询
 	List<T> findAll(Specification<T> spec, Sort sort);
   	//统计查询
 	long count(Specification<T> spec);
 	
}

JpaSpecificationExecutor接口主要是围绕着Specification接口定义构造的查询条件。而Specification接口中只定义了一个方法toPredicate();

 public interface Specification<T> {

	/**
	 * @param root Root是一个接口,代表查询的根对象,可以通过root获取实体中的属性
	 * @param query 代表一个顶层查询对象,用来自定义查询
	 * @param cb 用来构建查询,此对象里有很多条件方法
	 */
	Predicate toPredicate(Root<T> root, CriteriaQuery<?> query, CriteriaBuilder cb);
}

Root接口:

public interface Root<X> extends From<X, X> {
	/**
	 * 返回相对应的实体类
	 */
	EntityType<X> getModel();
}

CriteriaQuery接口:

在这里插入图片描述

CriteriaBuilder 接口:
在这里插入图片描述

1.根据条件查询一个对象

    @Test
    public void testSpec1() {
    
        /**
	     * 使用匿名内部类的方式,创建一个Specification的实现类(提供泛型:查询的对象类型),并实现toPredicate方法(构造查询条件)。
	     * 
	     * 使用root和CriteriaBuilder两个参数。
	     *      root获取需要查询的对象属性,
	     *      CriteriaBuilder构造查询条件,内部封装了很多的查询条件
	     */
        Specification<user> spec = new Specification<user>() {
            @Override
            public Predicate toPredicate(Root<user> root, CriteriaQuery<?> query, CriteriaBuilder cb) {

				//构造查询条件 select * from tb_user where user_name = '大白'
				
                //获取比较的属性
                Path<Object> userName = root.get("userName");

                 //第一个参数:需要比较的属性,第二个参数:当前需要比较的取值
                Predicate predicate = cb.equal(userName, "大白");
                return predicate;
            }
        };
        user user = userDao.findOne(spec);
        System.out.println(user);
    }

2.根据条件查询集合

    @Test
    public void testSpec2() {
    
       /**
	     * 使用匿名内部类的方式,创建一个Specification的实现类(提供泛型:查询的对象类型),并实现toPredicate方法(构造查询条件)。
	     * 
	     * 使用root和CriteriaBuilder两个参数。
	     *      root获取需要查询的对象属性,
	     *      CriteriaBuilder构造查询条件,内部封装了很多的查询条件
	     */
        Specification<user> spec = new Specification<user>() {
            @Override
            public Predicate toPredicate(Root<user> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
            	//获取比较的属性
                Path<Object> userName = root.get("userName");
                Path<Object> userAddress= root.get("userAddress");

                 //第一个参数:需要比较的属性,第二个参数:当前需要比较的取值
                Predicate p1 = cb.equal(userName, "大白");
              
              	/**
			     * 得到path对象,根据path指定比较的参数类型,再去进行比较,类似比较有gt,lt,ge,le,like...
			     * 
			     *       指定参数类型:path.as(类型的字节码对象)
			     *       Predicate like = cb.ge(userName.as(userAge.class),20);
			     *
			     */
                Predicate p2 = cb.like(userAddress.as(String.class),"深圳%");
                
                /**
			     * 将多个查询条件组合到一起
			     *      adn与关系: 满足条件一并且满足条件二
			     *      or或关系: 满足条件一或满足条件二即可
			     */
   
             	 //以与的形式拼接多个查询条件
                Predicate and = cb.and(p1, p2);
                // Predicate or= cb.or(p1, p2);//以或的形式拼接多个查询条件
                return and;
            }
        };
        List<User> userList = userDao.findAll(spec);
        for (User user : userList) {
            System.out.println(user);
        }
    }

3.根据条件分页查询

    @Test
    public void testSpec3() {
	
		//构造查询条件,这里不构造
        Specification spec = null;
        
       	/**
         * 要实现分页功能,需使用PageRequest,PageRequest对象是Pageable接口的实现类
         * 
		 * 调用PageRequest对象的构造方法传入两个参数,第一个参数:当前查询的页数(从0开始),第二个参数:每页查询的数量
         */
        Pageable pageable = new PageRequest(0,5);
        //执行分页查询
        Page<user> page = userDao.findAll(null, pageable);
        //得到数据集合列表
        System.out.println(page.getContent()); 
        //得到总条数
        System.out.println(page.getTotalElements());
        //得到总页数
        System.out.println(page.getTotalPages());
    }

4.根据条件排序查询

 @Test
    public void testSpec4() {
        //构造查询条件
        Specification<user> spec = new Specification<user>() {
            @Override
            public Predicate toPredicate(Root<user> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
                //获取比较的属性
                Path<Object> userName = root.get("userName");
                //查询方式:模糊匹配
               Predicate like = cb.like(userName.as(String.class), "大白%");
                return like;
            }
        };

        /**
         * 
         * 创建排序对象,并调用构造方法实例化sort对象
         * 
         * 第一个参数:排序的顺序(倒序,正序)
         *      Sort.Direction.DESC:倒序
         *      Sort.Direction.ASC : 升序
         *      
         * 第二个参数:排序的属性名称
         */
        Sort sort = new Sort(Sort.Direction.DESC,"userId");
        List<user> list = userDao.findAll(spec, sort);
        for (user user : list) {
            System.out.println(user);
        }
    }

5.根据条件统计查询

    public void testSpec5(){
        Specification<User> specification = new Specification<User>() {
            @Override
            public Predicate toPredicate(Root<User> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
                Path<Object> userAge = root.get("userAge");
                Predicate predicate = cb.ge(userAge.as(Number.class),20);
                return predicate;
            }
        };
        long count = userDao.count(specification);
        System.out.println("count = " + count);
    }

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/137105.html

(0)
飞熊的头像飞熊bm

相关推荐

发表回复

登录后才能评论
极客之音——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!