没有网站怎么做熊掌号,网站怎么做pc导流页,公司如何做网站推广,仿爱客wordpressSpringDataJPA Java 是第一大编程语言和开发平台。它有助于企业降低成本、缩短开发周期、推动创新以及改善应用服务。如今全球有数百万开发人员运行着超过 51 亿个 Java 虚拟机#xff0c;Java 仍是企业和开发人员的首选开发平台。 课程内容的介绍 1. Spring整合Hibernate 2…SpringDataJPA Java 是第一大编程语言和开发平台。它有助于企业降低成本、缩短开发周期、推动创新以及改善应用服务。如今全球有数百万开发人员运行着超过 51 亿个 Java 虚拟机Java 仍是企业和开发人员的首选开发平台。 课程内容的介绍 1. Spring整合Hibernate 2. Spring整合HibernateJPA 3. SpringDataJPA介绍 4. SpringBoot整合SpringDataJPA Spring Data JPASpring Data JPA 是 Spring Data 项目下的一个模块。提供了一套基于 JPA标准操作数据库的简化方案。底层默认的是依赖 Hibernate JPA 来实现的。 Spring Data JPA 的技术特点我们只需要定义接口并集成 Spring Data JPA 中所提供的接口就可以了。不需要编写接口实现类。 一、Spring整合Hibernate 1. 创建项目 创建一个普通的Maven项目即可。 2.添加相关的依赖 dependenciesdependencygroupIdorg.springframework/groupIdartifactIdspring-orm/artifactIdversion5.1.6.RELEASE/version/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.1.6.RELEASE/version/dependencydependencygroupIdorg.aspectj/groupIdartifactIdaspectjweaver/artifactIdversion1.9.2/version/dependencydependencygroupIdcom.alibaba/groupIdartifactIddruid/artifactIdversion1.1.8/version/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.11/version/dependencydependencygroupIdorg.hibernate/groupIdartifactIdhibernate-core/artifactIdversion5.0.7.Final/version/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion4.12/versionscopetest/scope/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-test/artifactIdversion5.1.6.RELEASE/version/dependency/dependencies 3. 添加相关的配置文件 添加数据库的配置文件和Spring的配置文件。 ?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd
!-- 引入db.properties文件 --context:property-placeholder locationclasspath:db.properties /!-- 创建druid 的数据源 --bean classcom.alibaba.druid.pool.DruidDataSource iddataSourceproperty nameurl value${jdbc.url} /property namedriverClassName value${jdbc.driver} /property nameusername value${jdbc.username} /property namepassword value${jdbc.password} //bean!-- 配置Hibernate的SessionFactory对象 --bean classorg.springframework.orm.hibernate5.LocalSessionFactoryBean idsessionFactory!-- 关联数据源 --property namedataSource refdataSource/!-- 配置Hibernate的属性信息 --property namehibernatePropertiespropsprop keyshow_sqltrue/propprop keyhibernate.hbm2ddl.autoupdate/prop/props/property!-- 扫描路径 --property namepackagesToScanlistvaluecom.bobo.pojo/value/list/property/bean!-- 配置HibernateTemplate对象 --bean classorg.springframework.orm.hibernate5.HibernateTemplate idhibernateTemplateproperty namesessionFactory refsessionFactory//bean!-- 配置事务管理--bean classorg.springframework.orm.hibernate5.HibernateTransactionManager idtransactionManagerproperty namesessionFactory refsessionFactory //bean!-- 配置开启事务注解 --tx:annotation-driven transaction-managertransactionManager /!-- 配置扫描路径 --context:component-scan base-packagecom.bobo /
/beans 4. 创建POJO 和表结构中的t_user表对应即可。 package com.bobo.pojo;import javax.persistence.*;
import java.io.Serializable;Entity
Table(namet_user)
public class Users implements Serializable {IdGeneratedValue(strategy GenerationType.IDENTITY)Column(nameuser_id)private Integer userId;Column(nameuser_name)private String userName;Column(namereal_name)private String realName;public Integer getUserId() {return userId;}public void setUserId(Integer userId) {this.userId userId;}public String getUserName() {return userName;}public void setUserName(String userName) {this.userName userName;}public String getRealName() {return realName;}public void setRealName(String realName) {this.realName realName;}}5. 创建持久层 定义持久层接口定义要实现的相关的方法。 package com.bobo.dao;import com.bobo.pojo.Users;import java.util.List;public interface IUserDao {void insertUsers(Users users);void updateUsers(Users users);void deleteUsers(Users users);Users selectUsersById(Integer userId);ListUsers selectUsersByName(String userName);ListUsers selectUsersByNameUseSQL(String userName);ListUsers selectUsersByNameUseCriteria(String userName);
}package com.bobo.dao.impl;import com.bobo.dao.IUserDao;
import com.bobo.pojo.Users;
import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.criterion.Restrictions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.hibernate5.HibernateTemplate;
import org.springframework.stereotype.Repository;import java.util.List;Repository
public class UserDaoImpl implements IUserDao {Autowiredprivate HibernateTemplate template;Overridepublic void insertUsers(Users users) {this.template.save(users);}Overridepublic void updateUsers(Users users) {this.template.update(users);}Overridepublic void deleteUsers(Users users) {this.template.delete(users);}Overridepublic Users selectUsersById(Integer userId) {return this.template.get(Users.class,userId);}Overridepublic ListUsers selectUsersByName(String userName) {// 我们要执行特殊的查询操作 我们需要获取对应的Session对象Session session this.template.getSessionFactory().getCurrentSession();// 通过Session对象创建Query对象 HQL 语句Query query session.createQuery( from Users where userName :abc);Query queryTemp query.setString(abc, userName);return queryTemp.list();}Overridepublic ListUsers selectUsersByNameUseSQL(String userName) {// 我们要执行特殊的查询操作 我们需要获取对应的Session对象Session session this.template.getSessionFactory().getCurrentSession();// 通过Session对象创建Query对象 SQL 语句Query query session.createSQLQuery(select * from t_user where user_name ?).addEntity(Users.class).setString(0, userName);return query.list();}Overridepublic ListUsers selectUsersByNameUseCriteria(String userName) {Session session this.template.getSessionFactory().getCurrentSession();Criteria criteria session.createCriteria(Users.class);criteria.add(Restrictions.eq(userName,userName));return criteria.list();}
}6. 单元测试 package com.bobo.test;import com.bobo.dao.IUserDao;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.annotation.Rollback;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;import java.util.List;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test1 {Autowiredprivate IUserDao dao;TestTransactionalRollback(false)public void testInsertUser(){Users user new Users();user.setUserName(Tom);user.setRealName(张三丰);dao.insertUsers(user);}TestTransactionalpublic void testQuery1(){Users users this.dao.selectUsersById(22);System.out.println(users);}TestTransactionalpublic void testQuery2(){ListUsers list this.dao.selectUsersByNameUseSQL(Tom);for (Users users : list) {System.out.println(users);}}}二、Spring整合HibernateJPA 现如今的ORM框架还是比较多的比如HibernateTopLink以及OpenJPA等等为了简化ORM框架的使用JPA随之产生。 JPA是Java Persistence API的简称中文名Java持久层API由 Sun 公司提供了一对对于持久层操作的标准(接口文档),说白了就是在各种ORM框架之上封装了一套API实现统一操作。同时又依赖各种ORM框架去实现。hibernate3.2版本后提供了对JPA的实现。 1. 创建项目 创建一个普通的Maven项目即可。 2. 添加相关的依赖 dependenciesdependencygroupIdorg.springframework/groupIdartifactIdspring-orm/artifactIdversion5.1.6.RELEASE/version/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.1.6.RELEASE/version/dependencydependencygroupIdorg.aspectj/groupIdartifactIdaspectjweaver/artifactIdversion1.9.2/version/dependencydependencygroupIdcom.alibaba/groupIdartifactIddruid/artifactIdversion1.1.8/version/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.11/version/dependencydependencygroupIdorg.hibernate/groupIdartifactIdhibernate-entitymanager/artifactIdversion5.0.7.Final/version/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion4.12/versionscopetest/scope/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-test/artifactIdversion5.1.6.RELEASE/version/dependency/dependencies 3. 添加相关的配置文件 jdbc.drivercom.mysql.cj.jdbc.Driver
jdbc.urljdbc:mysql://localhost:3306/logistics?characterEncodingutf-8serverTimezoneUTC
jdbc.usernameroot
jdbc.password123456 Spring的配置文件 ?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd
!-- 引入db.properties文件 --context:property-placeholder locationclasspath:db.properties /!-- 创建druid 的数据源 --bean classcom.alibaba.druid.pool.DruidDataSource iddataSourceproperty nameurl value${jdbc.url} /property namedriverClassName value${jdbc.driver} /property nameusername value${jdbc.username} /property namepassword value${jdbc.password} //bean!-- 配置Hibernate的SessionFactory对象 --bean classorg.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean idsessionFactory!-- 关联数据源 --property namedataSource refdataSource/!-- 配置Hibernate的属性信息 --property namejpaVendorAdapterbean classorg.springframework.orm.jpa.vendor.HibernateJpaVendorAdapterproperty namedatabase valueMYSQL/property namegenerateDdl valuetrue/property nameshowSql valuetrue//bean!--propsprop keyshow_sqltrue/propprop keyhibernate.hbm2ddl.autoupdate/prop/props--/property!-- 扫描路径 --property namepackagesToScanlistvaluecom.bobo.pojo/value/list/property/bean!-- 配置事务管理--bean classorg.springframework.orm.jpa.JpaTransactionManager idtransactionManagerproperty nameentityManagerFactory refsessionFactory //bean!-- 配置开启事务注解 --tx:annotation-driven transaction-managertransactionManager /!-- 配置扫描路径 --context:component-scan base-packagecom.bobo /
/beans 4. 创建POJO package com.bobo.pojo;import javax.persistence.*;
import java.io.Serializable;Entity
Table(namet_user)
public class Users implements Serializable {IdGeneratedValue(strategy GenerationType.IDENTITY)Column(nameuser_id)private Integer userId;Column(nameuser_name)private String userName;Column(namereal_name)private String realName;public Integer getUserId() {return userId;}public void setUserId(Integer userId) {this.userId userId;}public String getUserName() {return userName;}public void setUserName(String userName) {this.userName userName;}public String getRealName() {return realName;}public void setRealName(String realName) {this.realName realName;}Overridepublic String toString() {return Users{ userId userId , userName userName \ , realName realName \ };}
}5. 创建持久层 package com.bobo.dao;import com.bobo.pojo.Users;import java.util.List;public interface IUserDao {void insertUsers(Users users);void updateUsers(Users users);void deleteUsers(Users users);Users selectUsersById(Integer userId);ListUsers selectUsersByName(String userName);ListUsers selectUsersByNameUseSQL(String userName);ListUsers selectUsersByNameUseCriteria(String userName);
}实现类 package com.bobo.dao.impl;import com.bobo.dao.IUserDao;
import com.bobo.pojo.Users;
import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.criterion.Restrictions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.hibernate5.HibernateTemplate;
import org.springframework.stereotype.Repository;import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.TypedQuery;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import java.util.List;Repository
public class UserDaoImpl implements IUserDao {PersistenceContext(name entityManagerFactory)private EntityManager manager;Overridepublic void insertUsers(Users users) {manager.persist(users);}Overridepublic void updateUsers(Users users) {manager.merge(users);}Overridepublic void deleteUsers(Users users) {users this.selectUsersById(users.getUserId());manager.remove(users);}Overridepublic Users selectUsersById(Integer userId) {return manager.find(Users.class,userId);}Overridepublic ListUsers selectUsersByName(String userName) {return manager.createQuery( from Users where userName :abc).setParameter(abc,userName).getResultList();}Overridepublic ListUsers selectUsersByNameUseSQL(String userName) {return manager.createNativeQuery(select * from t_user where user_name ?,Users.class).setParameter(1,userName).getResultList();}Overridepublic ListUsers selectUsersByNameUseCriteria(String userName) {CriteriaBuilder builder manager.getCriteriaBuilder();CriteriaQueryUsers query builder.createQuery(Users.class);RootUsers root query.from(Users.class);Predicate cate builder.equal(root.get(userName), userName);query.where(cate);TypedQueryUsers typedQuery manager.createQuery(query);return typedQuery.getResultList();}
}6. 单元测试 package com.bobo.test;import com.bobo.dao.IUserDao;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.annotation.Rollback;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;import java.util.List;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test1 {Autowiredprivate IUserDao dao;TestTransactionalRollback(false)public void testInsertUser(){Users user new Users();user.setUserName(Mic);user.setRealName(李逵);dao.insertUsers(user);}TestTransactionalpublic void testQuery1(){Users users this.dao.selectUsersById(22);System.out.println(users);}TestTransactionalpublic void testQuery2(){ListUsers list this.dao.selectUsersByNameUseSQL(Tom);for (Users users : list) {System.out.println(users);}}}三、SpringDataJPA介绍 1. 入门案例 1.1 创建项目 创建一个普通的Maven项目。 1.2 添加相关的依赖 dependenciesdependencygroupIdorg.springframework/groupIdartifactIdspring-orm/artifactIdversion5.1.6.RELEASE/version/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.1.6.RELEASE/version/dependencydependencygroupIdorg.aspectj/groupIdartifactIdaspectjweaver/artifactIdversion1.9.2/version/dependencydependencygroupIdcom.alibaba/groupIdartifactIddruid/artifactIdversion1.1.8/version/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.11/version/dependencydependencygroupIdorg.hibernate/groupIdartifactIdhibernate-entitymanager/artifactIdversion5.0.7.Final/version/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion4.12/versionscopetest/scope/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-test/artifactIdversion5.1.6.RELEASE/version/dependencydependencygroupIdorg.springframework.data/groupIdartifactIdspring-data-jpa/artifactIdversion1.9.0.RELEASE/version/dependency/dependencies 1.3 添加配置文件 jdbc.drivercom.mysql.cj.jdbc.Driver
jdbc.urljdbc:mysql://localhost:3306/logistics?characterEncodingutf-8serverTimezoneUTC
jdbc.usernameroot
jdbc.password123456Spring的配置文件 ?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:txhttp://www.springframework.org/schema/txxmlns:jpahttp://www.springframework.org/schema/data/jpaxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsdhttp://www.springframework.org/schema/data/jpahttp://www.springframework.org/schema/data/jpa/spring-jpa.xsd
!-- 引入db.properties文件 --context:property-placeholder locationclasspath:db.properties /!-- 创建druid 的数据源 --bean classcom.alibaba.druid.pool.DruidDataSource iddataSourceproperty nameurl value${jdbc.url} /property namedriverClassName value${jdbc.driver} /property nameusername value${jdbc.username} /property namepassword value${jdbc.password} //bean!-- 配置Hibernate的SessionFactory对象 id必须得是 entityManagerFactory --bean classorg.springframework.orm.jpa.LocalContainerEntityManagerFactoryBeanidentityManagerFactory!-- 关联数据源 --property namedataSource refdataSource/!-- 配置Hibernate的属性信息 --property namejpaVendorAdapterbean classorg.springframework.orm.jpa.vendor.HibernateJpaVendorAdapterproperty namedatabase valueMYSQL/property namegenerateDdl valuetrue/property nameshowSql valuetrue//bean!--propsprop keyshow_sqltrue/propprop keyhibernate.hbm2ddl.autoupdate/prop/props--/property!-- 扫描路径 --property namepackagesToScanlistvaluecom.bobo.pojo/value/list/property/bean!-- 配置事务管理--bean classorg.springframework.orm.jpa.JpaTransactionManager idtransactionManagerproperty nameentityManagerFactory refentityManagerFactory //bean!-- 配置开启事务注解 --tx:annotation-driven transaction-managertransactionManager /!-- 配置扫描路径 --context:component-scan base-packagecom.bobo /!-- Spring Data Jpa 配置--!-- 配置Dao的扫描 --jpa:repositories base-packagecom.bobo.dao /
/beans 1.4 创建POJO对象 package com.bobo.pojo;import javax.persistence.*;
import java.io.Serializable;Entity
Table(namet_user)
public class Users implements Serializable {IdGeneratedValue(strategy GenerationType.IDENTITY)Column(nameuser_id)private Integer userId;Column(nameuser_name)private String userName;Column(namereal_name)private String realName;public Integer getUserId() {return userId;}public void setUserId(Integer userId) {this.userId userId;}public String getUserName() {return userName;}public void setUserName(String userName) {this.userName userName;}public String getRealName() {return realName;}public void setRealName(String realName) {this.realName realName;}Overridepublic String toString() {return Users{ userId userId , userName userName \ , realName realName \ };}
}1.5 创建持久层 package com.bobo.dao;import com.bobo.pojo.Users;
import org.springframework.data.jpa.repository.JpaRepository;public interface UserDao extends JpaRepositoryUsers,Integer {}1.6 单元测试 package com.bobo.test;import com.bobo.dao.UserDao;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.annotation.Rollback;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test1 {Autowiredprivate UserDao dao;TestTransactionalRollback(false)public void test1(){Users user new Users();user.setUserName(admin-jpa);user.setRealName(测试);dao.save(user);}
}2. Repository接口 public interface RepositoryT, ID extends Serializable {
} Repository 接口是 Spring Data JPA 中为我我们提供的所有接口中的顶层接口,而且是个标志接口Repository 提供了两种查询方式的支持。 1基于方法名称命名规则查询 2基于Query 注解查询 2.1 基于方法名称命名规则查询 package com.bobo.dao;import com.bobo.pojo.Users;
import org.springframework.data.repository.Repository;import javax.persistence.criteria.CriteriaBuilder;
import java.util.List;/*** Repository接口的使用*/
public interface UserDaoRepository extends RepositoryUsers, Integer {ListUsers findByUserNameIs(String string);ListUsers findByUserNameLike(String username);ListUsers findByUserNameAndRealNameIs(String name,String realName);
}测试代码 package com.bobo.test;import com.bobo.dao.UserDaoRepository;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.annotation.Rollback;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;import java.util.List;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test2 {Autowiredprivate UserDaoRepository dao;TestTransactionalRollback(false)public void query1(){ListUsers list this.dao.findByUserNameIs(Tom);for (Users users : list) {System.out.println(users);}}TestTransactionalRollback(false)public void query2(){ListUsers list this.dao.findByUserNameLike(Tom);for (Users users : list) {System.out.println(users);}}TestTransactionalRollback(false)public void query3(){ListUsers list this.dao.findByUserNameAndRealNameIs(Tom,张三丰);for (Users users : list) {System.out.println(users);}}
}2.2 基于Query 注解查询 通过上面的命令的方式使用的情况如果查询条件比较复杂的情况下那么方法的名称会很长不是很方便而且容易出错这时我们可以通过Query注解来实现。 2.2.1 JPQL语句 JPQL是通过Hibernate的HQL语句演变而来的他和HQL语句很相似。 package com.bobo.dao;import com.bobo.pojo.Users;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.Repository;import java.util.List;/*** Repository接口的使用* Query* JPQL语句* SQL语句* 更新操作*/
public interface UserDaoRepository2 extends RepositoryUsers, Integer {Query(value from Users where userName ?)ListUsers queryUsersByNameUseJPQL(String name);Query(value from Users where userName like ?)ListUsers queryUserLikeNameUseJPQL(String name);Query(value from Users where userName ? and realName ?)ListUsers queryUserByNameAndRealName(String userName,String realName);}单元测试 package com.bobo.test;import com.bobo.dao.UserDaoRepository;
import com.bobo.dao.UserDaoRepository2;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.annotation.Rollback;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;import java.util.List;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test3 {Autowiredprivate UserDaoRepository2 dao;TestTransactionalRollback(false)public void query1(){ListUsers list this.dao.queryUsersByNameUseJPQL(Tom);for (Users users : list) {System.out.println(users);}}TestTransactionalRollback(false)public void query2(){ListUsers list this.dao.queryUserLikeNameUseJPQL(Tom);for (Users users : list) {System.out.println(users);}}TestTransactionalRollback(false)public void query3(){ListUsers list this.dao.queryUserByNameAndRealName(Tom,张三丰);for (Users users : list) {System.out.println(users);}}
}2.2.2 SQL语句 声明接口 package com.bobo.dao;import com.bobo.pojo.Users;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.Repository;import java.util.List;/*** Repository接口的使用* Query* JPQL语句* SQL语句* 更新操作*/
public interface UserDaoRepository3 extends RepositoryUsers, Integer {// 在使用Query注解 查询SQL语句的时候 nativeQuery默认是false我们需要设置为trueQuery(value select * from t_user where user_name?,nativeQuery true)ListUsers queryUsersByNameUseSQL(String name);Query(value select * from t_user where user_name like ? ,nativeQuery true)ListUsers queryUserLikeNameUseSQL(String name);Query(value select * from t_user where user_name ? and real_name ? , nativeQuery true)ListUsers queryUserByNameAndRealName(String userName,String realName);}单元测试 package com.bobo.test;import com.bobo.dao.UserDaoRepository2;
import com.bobo.dao.UserDaoRepository3;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.annotation.Rollback;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;import java.util.List;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test4 {Autowiredprivate UserDaoRepository3 dao;TestTransactionalRollback(false)public void query1(){ListUsers list this.dao.queryUsersByNameUseSQL(Tom);for (Users users : list) {System.out.println(users);}}TestTransactionalRollback(false)public void query2(){ListUsers list this.dao.queryUserLikeNameUseSQL(Tom);for (Users users : list) {System.out.println(users);}}TestTransactionalRollback(false)public void query3(){ListUsers list this.dao.queryUserByNameAndRealName(Tom,张三丰);for (Users users : list) {System.out.println(users);}}
}2.2.3 完成更新数据 Query注解可以完成数据更新操作但是不能实现数据的添加和删除操作。 Query(value update Users set userName ? where userId?)
Modifying// 被Modifying修饰的方法是一个更新操作
void updateUserNameById(String userName,Integer userId); 测试 Test
Transactional
Rollback(false)
public void updateTest(){this.dao.updateUserNameById(Tommm,25);
} 3. CrudRepository接口 CrudRepository接口继承自Repository接口所以Repository接口具有的功能CrudRepository接口都具有而且又扩展了CRUD相关的功能。 NoRepositoryBean
public interface CrudRepositoryT, ID extends Serializable extends RepositoryT, ID {S extends T S save(S var1);S extends T IterableS save(IterableS var1);T findOne(ID var1);boolean exists(ID var1);IterableT findAll();IterableT findAll(IterableID var1);long count();void delete(ID var1);void delete(T var1);void delete(Iterable? extends T var1);void deleteAll();
} 应用声明接口 /**
* CrudRepository接口的使用
*/
public interface UserDaoCrudRepository extends CrudRepositoryUsers,Integer {
} 单元测试 package com.bobo.test;import com.bobo.dao.UserDaoCrudRepository;
import com.bobo.dao.UserDaoRepository3;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.experimental.theories.suppliers.TestedOn;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.support.CustomSQLErrorCodesTranslation;
import org.springframework.test.annotation.Rollback;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test5 {Autowiredprivate UserDaoCrudRepository dao;/*** 添加数据*/Testpublic void test1(){Users user new Users();user.setRealName(成龙);user.setUserName(chengnong);dao.save(user);}/*** 批量添加数据*/Testpublic void test2(){ListUsers list new ArrayList();for (int i 0; i 10; i) {Users user new Users();user.setRealName(成龙i);user.setUserName(chengnongi);list.add(user);}dao.save(list);}/*** 查询单条数据*/Testpublic void test3(){Users user dao.findOne(25);System.out.println(user);}/*** 查询所有的数据*/Testpublic void test4(){IterableUsers list dao.findAll();IteratorUsers iterator list.iterator();while(iterator.hasNext()){Users user iterator.next();System.out.println(user);}}/*** 删除数据*/Testpublic void delete1(){dao.delete(32);}/*** 更新数据*/Testpublic void update1(){// 根据save方法来实现 如果Users对象的userId属性不为空则updateUsers user dao.findOne(34);user.setUserName(hahahaha);dao.save(user);}/*** 更新数据 方式二*/TestTransactionalRollback(false)public void update2(){Users user dao.findOne(34);user.setUserName(aaaa); // User 是一个持久化的状态}
}4.PagingAndSortingRepository接口 PagingAndSortingRepository继承自CrudRepository接口那么显然PagingAndSortingRepository就具备了CrudRepository接口的相关的功能同时也扩展了分页和排序的功能。 NoRepositoryBean
public interface PagingAndSortingRepositoryT, ID extends Serializable extends CrudRepositoryT, ID {// 排序的支持IterableT findAll(Sort var1);// 分页的支持PageT findAll(Pageable var1);
} 创建接口文件 package com.bobo.dao;import com.bobo.pojo.Users;
import org.springframework.data.repository.PagingAndSortingRepository;/*** PagingAndSortingRepository接口的使用* 新增的功能是* 分页* 排序* 注意本接口不支持条件查询*/
public interface UserDaoPageAndSortRepository extends PagingAndSortingRepositoryUsers,Integer {
}分页测试 package com.bobo.test;import com.bobo.dao.UserDaoCrudRepository;
import com.bobo.dao.UserDaoPageAndSortRepository;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.test.annotation.Rollback;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test6 {Autowiredprivate UserDaoPageAndSortRepository dao;/*** 分页查询*/Testpublic void test1(){int page 1; // page:当前分页的索引 从0开始int size 5; // size:每页显示的条数PageRequest pageable new PageRequest(page,size);PageUsers pages dao.findAll(pageable);System.out.println(总的条数: pages.getTotalElements());System.out.println(总的页数: pages.getTotalPages());ListUsers list pages.getContent();for (Users user : list) {System.out.println(user);}}
}排序功能 /*** 排序*/Testpublic void test2(){// Sort.Direction.DESC 降序 ASC 升序Sort sort new Sort(Sort.Direction.DESC,userId);ListUsers list (ListUsers) this.dao.findAll(sort);for (Users users : list) {System.out.println(users);}} 多条件排序 /*** 多条件排序*/Testpublic void test3(){Sort.Order order1 new Sort.Order(Sort.Direction.DESC,realName);Sort.Order order2 new Sort.Order(Sort.Direction.ASC,userId);Sort sort new Sort(order1,order2);ListUsers list (ListUsers) this.dao.findAll(sort);for (Users users : list) {System.out.println(users);}} 5. JpaRepository接口 JpaRepository接口是我们开发时使用最多接口其特点是可以帮助我们将其他接口的方法的返回值做适配处理可以使我们在开发的时候更方便的使用这些方法。 NoRepositoryBean
public interface JpaRepositoryT, ID extends Serializable extends PagingAndSortingRepositoryT, ID {ListT findAll();ListT findAll(Sort var1);ListT findAll(IterableID var1);S extends T ListS save(IterableS var1);void flush();S extends T S saveAndFlush(S var1);void deleteInBatch(IterableT var1);void deleteAllInBatch();T getOne(ID var1);
} 6. JpaSpecificationExecutor 提供的有多条件查询并支持分页和排序功能此接口不能单独使用需要和其他的接口一块使用。 /**
* JpaSpecificationExecutor的使用
* JpaSpecificationExecutor 是不能够单独使用的。需要配置JPA中的其他的接口一块来使用
*/
public interface UserDaoSpecfication extends JpaRepositoryUsers,Integer, JpaSpecificationExecutor {
} 6.1 单条件查询 package com.bobo.test;import com.bobo.dao.UserDaoSpecfication;
import com.bobo.pojo.Users;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import java.util.ArrayList;
import java.util.List;RunWith(SpringJUnit4ClassRunner.class)
ContextConfiguration(classpath:applicationContext.xml)
public class Test7 {Autowiredprivate UserDaoSpecfication dao;Testpublic void test1(){SpecificationUsers speci new SpecificationUsers() {/*** 定义查询条件* param root 根对象 封装查询条件的对象* param criteriaQuery 基本的查询* param criteriaBuilder 创建查询条件* return*/Overridepublic Predicate toPredicate(RootUsers root, CriteriaQuery? criteriaQuery, CriteriaBuilder criteriaBuilder) {Predicate pre criteriaBuilder.equal(root.get(userName),Tommm);return pre;}};ListUsers list dao.findAll(speci);for (Users users : list) {System.out.println(users);}}
}6.2 多条件 /*** 多条件查询*/Testpublic void test2(){SpecificationUsers spec new SpecificationUsers() {/*** 指定查询的条件* param root* param criteriaQuery* param criteriaBuilder* return*/Overridepublic Predicate toPredicate(RootUsers root, CriteriaQuery? criteriaQuery, CriteriaBuilder criteriaBuilder) {ListPredicate list new ArrayList();list.add(criteriaBuilder.equal(root.get(userName),Tommm));list.add(criteriaBuilder.equal(root.get(realName),张三丰));Predicate[] arr new Predicate[list.size()];return criteriaBuilder.and(list.toArray(arr));}};ListUsers list dao.findAll(spec);for (Users users : list) {System.out.println(users);}} 6.3 分页 /*** 单条件分页*/Testpublic void test3(){SpecificationUsers speci new SpecificationUsers() {/*** 定义查询条件* param root 根对象 封装查询条件的对象* param criteriaQuery 基本的查询* param criteriaBuilder 创建查询条件* return*/Overridepublic Predicate toPredicate(RootUsers root, CriteriaQuery? criteriaQuery, CriteriaBuilder criteriaBuilder) {Predicate pre criteriaBuilder.equal(root.get(userName),Tommm);return pre;}};Pageable pagealbe (Pageable) new PageRequest(0,3);Page page dao.findAll(speci, pagealbe);System.out.println(page.getTotalElements());System.out.println(page.getTotalPages());List content page.getContent();System.out.println(content);}6.4 排序 /*** 单条件排序*/Testpublic void test4(){SpecificationUsers speci new SpecificationUsers() {/*** 定义查询条件* param root 根对象 封装查询条件的对象* param criteriaQuery 基本的查询* param criteriaBuilder 创建查询条件* return*/Overridepublic Predicate toPredicate(RootUsers root, CriteriaQuery? criteriaQuery, CriteriaBuilder criteriaBuilder) {Predicate pre criteriaBuilder.equal(root.get(userName),Tommm);return pre;}};Sort sort new Sort(Sort.Direction.DESC,userId);ListUsers list dao.findAll(speci, sort);System.out.println(list);} 6.5 分页和排序 /*** 单条件分页 排序*/Testpublic void test5(){SpecificationUsers speci new SpecificationUsers() {/*** 定义查询条件* param root 根对象 封装查询条件的对象* param criteriaQuery 基本的查询* param criteriaBuilder 创建查询条件* return*/Overridepublic Predicate toPredicate(RootUsers root, CriteriaQuery? criteriaQuery, CriteriaBuilder criteriaBuilder) {Predicate pre criteriaBuilder.equal(root.get(userName),Tommm);return pre;}};Sort sort new Sort(Sort.Direction.DESC,userId);// 封装分页对象的时候我们可以直接指定 排序的规则Pageable pagealbe (Pageable) new PageRequest(0,3,sort);Page page dao.findAll(speci, pagealbe);System.out.println(page.getTotalElements());System.out.println(page.getTotalPages());List content page.getContent();System.out.println(content);} 四、SpringBoot整合SpringDataJPA 1. 添加依赖 2. 添加配置文件 # jdbc 的相关信息
spring.datasource.driverClassNamecom.mysql.cj.jdbc.Driver
spring.datasource.urljdbc:mysql://localhost:3306/logistics?
characterEncodingutf-8serverTimezoneUTC
spring.datasource.usernameroot
spring.datasource.password123456# 配置连接池信息
spring.datasource.typecom.alibaba.druid.pool.DruidDataSource# 配置jpa的相关参数
spring.jpa.hibernate.ddl-autoupdate
spring.jpa.show-sqltrue 3. 创建POJO package com.bobo.pojo;import javax.persistence.*;
import java.io.Serializable;Table(name t_user)
Entity
public class Users implements Serializable {IdGeneratedValue(strategy GenerationType.IDENTITY)Column(nameuser_id)private Integer userId;Column(nameuser_name)private String usreName;Column(namereal_name)private String realName;public Integer getUserId() {return userId;}public void setUserId(Integer userId) {this.userId userId;}public String getUsreName() {return usreName;}public void setUsreName(String usreName) {this.usreName usreName;}public String getRealName() {return realName;}public void setRealName(String realName) {this.realName realName;}
}4. 创建接口 package com.bobo.dao;import com.bobo.pojo.Users;
import org.springframework.data.jpa.repository.JpaRepository;public interface UsersRepository extends JpaRepositoryUsers,Integer {
}5. 测试 package com.bobo;import com.bobo.dao.UsersRepository;
import com.bobo.pojo.Users;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;SpringBootTest
class SpringdatajpaSpringbootApplicationTests {Autowiredprivate UsersRepository dao;Testvoid contextLoads() {Users users new Users();users.setUsreName(test1);users.setRealName(测试数据);dao.save(users);}}
