SpringBoot整合SpringData JPA

水深无声 2021-12-03 14:49 498阅读 0赞

## 1.创建maven项目，编写pom.xml文件 ##

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>1.5.2.RELEASE</version>
    
    	</parent>
    	<groupId>per.czt</groupId>
    	<artifactId>22-spring-boot-jpa</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    	<name>22-spring-boot-jpa</name>
    	<url>http://maven.apache.org</url>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    	</properties>
    
    	<dependencies>
    
    
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-thymeleaf</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-jpa</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    			<version>8.0.13</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    			<version>1.1.17</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>javax.xml.bind</groupId>
    			<artifactId>jaxb-api</artifactId>
    			<version>2.2.4</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.glassfish.jaxb</groupId>
    			<artifactId>jaxb-core</artifactId>
    			<version>2.3.0</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>javax.xml</groupId>
    			<artifactId>jaxb-impl</artifactId>
    			<version>2.1</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>javax.activation</groupId>
    			<artifactId>javax.activation-api</artifactId>
    			<version>1.2.0</version>
    		</dependency>
    
    
    
    
    
    	</dependencies>
    </project>

2.编写application.properties文件  
application.properties

spring.datasource.driverName=com.mysql.cj.jdbc.Driver
    spring.datasource.url=jdbc:mysql://127.0.0.1:3306/springbootjpa?serverTimezone=UTC&charset=UTF-8&useSSL=false
    spring.datasource.username=root
    spring.datasource.password=200934652qwe
    spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
    spring.jpa.hibernate.ddl-auto=update
    spring.jpa.show-sql=true

3.测试  
(1)五个接口  
前四个接口就不测试了，这里只给出JpaRepository和JpaSepcificationExecutor接口的测试  
编写个接口继承JpaRepository和JpaSepcificationExecutor接口  
UserRepositorySpecificationExecutor.java

package per.czt.dao;
    
    import org.springframework.data.jpa.repository.JpaRepository;
    import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
    
    import per.czt.pojo.Users;
    
    public interface UsersRepositoryJpaSpecificationExecutor extends JpaRepository<Users, Integer>,JpaSpecificationExecutor<Users>{
    
    }

测试类  
UsersRepositoryJpaSpecificationExecutorTest.java

package per.czt.test;
    
    import java.util.List;
    
    import javax.persistence.criteria.CriteriaBuilder;
    import javax.persistence.criteria.CriteriaQuery;
    import javax.persistence.criteria.Predicate;
    import javax.persistence.criteria.Root;
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    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.domain.Sort.Direction;
    import org.springframework.data.domain.Sort.Order;
    import org.springframework.data.jpa.domain.Specification;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    import per.czt.dao.UsersRepositoryJpaSpecificationExecutor;
    import per.czt.pojo.Users;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest
    public class UsersRepositoryJpaSpecificationExecutorTest {
    
    	@Autowired
    	private UsersRepositoryJpaSpecificationExecutor usersRepositoryJpaSpecificationExecutor;
    	/*
    	*多条件查询+分页+排序
    	*/
    	@Test
    	public void test1() {
    		Specification<Users> spec=new Specification<Users>() {
    
    			@Override
    			public Predicate toPredicate(Root<Users> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
    				// TODO Auto-generated method stub
    				return cb.and(cb.notEqual(root.get("username"), "xiaoming"),cb.isNotNull(root.get("username")));
    			}
    			
    		};
    		Order order1=new Order(Direction.ASC,"username");
    		Order order2=new Order(Direction.ASC,"userage");
    		Sort sort =new Sort(order1,order2);
    		int page=0;
    		int pageSize=1;
    		
    		Pageable pageable=new PageRequest(page, pageSize, sort);
    		Page<Users> pages=usersRepositoryJpaSpecificationExecutor.findAll(spec, pageable);
    		for(Users users:pages.getContent()) {
    			System.out.println(users);
    		}
    		
    	}
    }

(2)一对多关系  
Users.java

package per.czt.pojo;
    
    import javax.persistence.CascadeType;
    import javax.persistence.Column;
    import javax.persistence.Entity;
    import javax.persistence.FetchType;
    import javax.persistence.GeneratedValue;
    import javax.persistence.GenerationType;
    import javax.persistence.Id;
    import javax.persistence.JoinColumn;
    import javax.persistence.ManyToOne;
    import javax.persistence.OneToMany;
    import javax.persistence.Table;
    
    @Entity
    @Table(name="t_users")
    public class Users {
    	@Id
    	@GeneratedValue(strategy=GenerationType.IDENTITY)
    	@Column(name="user_id")
    	private Integer userid;
    	@Column(name="user_name")
    	private String username;
    	@Column(name="user_age")
    	private Integer userage;
    	@Column(name="user_address")
    	private String useraddress;
    	
    	@ManyToOne(cascade=CascadeType.PERSIST,fetch=FetchType.EAGER)
    	@JoinColumn(name="roles_id")
    	private Roles roles;
    	public Roles getRoles() {
    		return roles;
    	}
    
    	public void setRoles(Roles roles) {
    		this.roles = roles;
    	}
    
    	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 Integer getUserage() {
    		return userage;
    	}
    
    	public void setUserage(Integer userage) {
    		this.userage = userage;
    	}
    
    	public String getUseraddress() {
    		return useraddress;
    	}
    
    	public void setUseraddress(String useraddress) {
    		this.useraddress = useraddress;
    	}
    
    	public Users() {
    		super();
    		// TODO Auto-generated constructor stub
    	}
    
    	@Override
    	public String toString() {
    		return "Users [userid=" + userid + ", username=" + username + ", userage=" + userage + ", useraddress="
    				+ useraddress + ", roles=" + roles + "]";
    	}
    
    	
    
    	
    	
    
    }

Roles.java

package per.czt.pojo;
    
    import java.io.Serializable;
    import java.util.HashSet;
    import java.util.Set;
    
    import javax.persistence.CascadeType;
    import javax.persistence.Column;
    import javax.persistence.Entity;
    import javax.persistence.FetchType;
    import javax.persistence.GeneratedValue;
    import javax.persistence.GenerationType;
    import javax.persistence.Id;
    import javax.persistence.JoinColumn;
    import javax.persistence.JoinColumns;
    import javax.persistence.JoinTable;
    import javax.persistence.ManyToMany;
    import javax.persistence.ManyToOne;
    import javax.persistence.OneToMany;
    import javax.persistence.Table;
    @Entity
    @Table(name="t_roles")
    public class Roles implements Serializable {
    	@Id
    	@GeneratedValue(strategy=GenerationType.IDENTITY)
    	@Column(name="role_id")
    	private Integer roleid;
    	@Column(name="role_name")
    	private String rolename;
    	
    	@OneToMany(mappedBy="roles",cascade=CascadeType.PERSIST,fetch=FetchType.EAGER)
    	private Set<Users> usersSet=new HashSet<Users>();
    	
    
    	
    	
    	public Set<Users> getUsersSet() {
    		return usersSet;
    	}
    	public void setUsersSet(Set<Users> usersSet) {
    		this.usersSet = usersSet;
    	}
    	public Integer getRoleid() {
    		return roleid;
    	}
    	public void setRoleid(Integer roleid) {
    		this.roleid = roleid;
    	}
    	public String getRolename() {
    		return rolename;
    	}
    	public void setRolename(String rolename) {
    		this.rolename = rolename;
    	}
    	@Override
    	public String toString() {
    		return "Roles [roleid=" + roleid + ", rolename=" + rolename + "]";
    	}
    	public Roles() {
    		super();
    		// TODO Auto-generated constructor stub
    	}
    	
    	
    
    }

测试代码:  
OneToManyTest.java

package per.czt.test;
    
    import java.util.List;
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    import per.czt.App;
    import per.czt.dao.UsersRepositoryJpaRepository;
    import per.czt.pojo.Roles;
    import per.czt.pojo.Users;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest(classes= {App.class})
    public class OneToManyTest {
    	
    	@Autowired
    	private UsersRepositoryJpaRepository usersRepositoryJpaRepository;
    	/*
    	 * 添加
    	 */
    	@Test
    	public void test1() {
    		
    		Roles roles=new Roles();
    		roles.setRolename("管理员");
    		
    		Users users=new Users();
    		users.setUseraddress("山东省");
    		users.setUserage(11);
    		users.setUsername("李四");
    		
    		users.setRoles(roles);
    		roles.getUsersSet().add(users);
    		
    		usersRepositoryJpaRepository.save(users);
    	}
    	/*
    	 * 查询
    	 */
    	@Test
    	public void test2() {
    		List<Users> usersList=usersRepositoryJpaRepository.findAll();
    		for(Users users:usersList) {
    			System.out.println(users);
    		}
    	}
    }

(3)多对多关系  
假设roles和menus是多对多关系  
Roles.java

package per.czt.pojo;
    
    import java.io.Serializable;
    import java.util.HashSet;
    import java.util.Set;
    
    import javax.persistence.CascadeType;
    import javax.persistence.Column;
    import javax.persistence.Entity;
    import javax.persistence.FetchType;
    import javax.persistence.GeneratedValue;
    import javax.persistence.GenerationType;
    import javax.persistence.Id;
    import javax.persistence.JoinColumn;
    import javax.persistence.JoinColumns;
    import javax.persistence.JoinTable;
    import javax.persistence.ManyToMany;
    import javax.persistence.ManyToOne;
    import javax.persistence.OneToMany;
    import javax.persistence.Table;
    @Entity
    @Table(name="t_roles")
    public class Roles implements Serializable {
    	@Id
    	@GeneratedValue(strategy=GenerationType.IDENTITY)
    	@Column(name="role_id")
    	private Integer roleid;
    	@Column(name="role_name")
    	private String rolename;
    	
    	@OneToMany(mappedBy="roles",cascade=CascadeType.PERSIST,fetch=FetchType.EAGER)
    	private Set<Users> usersSet=new HashSet<Users>();
    	
    	@ManyToMany(cascade=CascadeType.PERSIST,fetch=FetchType.EAGER)
    	@JoinTable(name="t_roles_menus",joinColumns=@JoinColumn(name="roles_id"),inverseJoinColumns=@JoinColumn(name="menus_id"))
    	private Set<Menus> menusSet=new HashSet<Menus>();
    	
    	
    	public Set<Users> getUsersSet() {
    		return usersSet;
    	}
    	public void setUsersSet(Set<Users> usersSet) {
    		this.usersSet = usersSet;
    	}
    	public Integer getRoleid() {
    		return roleid;
    	}
    	public void setRoleid(Integer roleid) {
    		this.roleid = roleid;
    	}
    	public String getRolename() {
    		return rolename;
    	}
    	public void setRolename(String rolename) {
    		this.rolename = rolename;
    	}
    	@Override
    	public String toString() {
    		return "Roles [roleid=" + roleid + ", rolename=" + rolename + "]";
    	}
    	public Roles() {
    		super();
    		// TODO Auto-generated constructor stub
    	}
    	public Set<Menus> getMenusSet() {
    		return menusSet;
    	}
    	public void setMenusSet(Set<Menus> menusSet) {
    		this.menusSet = menusSet;
    	}
    	
    
    }

Menus.java

package per.czt.pojo;
    
    import java.util.HashSet;
    import java.util.Set;
    
    import javax.persistence.CascadeType;
    import javax.persistence.Column;
    import javax.persistence.Entity;
    import javax.persistence.FetchType;
    import javax.persistence.GeneratedValue;
    import javax.persistence.GenerationType;
    import javax.persistence.Id;
    import javax.persistence.ManyToMany;
    import javax.persistence.Table;
    
    @Entity
    @Table(name="t_menus")
    public class Menus {
    	
    
    	@Id
    	@GeneratedValue(strategy=GenerationType.IDENTITY)
    	@Column(name="menu_id")
    	private Integer menuid;
    	@Column(name="menu_name")
    	private String menuname;
    	@Column(name="menu_url")
    	private String menuurl;
    	@Column(name="father_id")
    	private Integer fatherid;
    	@ManyToMany(mappedBy="menusSet",cascade=CascadeType.PERSIST,fetch=FetchType.EAGER)
    	private Set<Roles> rolesSet=new HashSet<Roles>();
    	public Integer getMenuid() {
    		return menuid;
    	}
    	public void setMenuid(Integer menuid) {
    		this.menuid = menuid;
    	}
    	public String getMenuname() {
    		return menuname;
    	}
    	public void setMenuname(String menuname) {
    		this.menuname = menuname;
    	}
    	public String getMenuurl() {
    		return menuurl;
    	}
    	public void setMenuurl(String menuurl) {
    		this.menuurl = menuurl;
    	}
    	public Integer getFatherid() {
    		return fatherid;
    	}
    	public void setFatherid(Integer fatherid) {
    		this.fatherid = fatherid;
    	}
    	public Set<Roles> getRolesSet() {
    		return rolesSet;
    	}
    	public void setRolesSet(Set<Roles> rolesSet) {
    		this.rolesSet = rolesSet;
    	}
    	@Override
    	public String toString() {
    		return "Menus [menuid=" + menuid + ", menuname=" + menuname + ", menuurl=" + menuurl + ", fatherid=" + fatherid
    				+ "]";
    	}
    	
    
    }

RolesRepository.java

package per.czt.dao;
    
    import org.springframework.data.jpa.repository.JpaRepository;
    
    import per.czt.pojo.Roles;
    
    public interface RolesRepository extends JpaRepository<Roles, Integer>{
    
    }

多对多测试  
ManyToManyTest,java

package per.czt.test;
    
    import java.util.List;
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    import per.czt.App;
    import per.czt.dao.RolesRepository;
    import per.czt.dao.UsersRepositoryJpaRepository;
    import per.czt.pojo.Menus;
    import per.czt.pojo.Roles;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest(classes= {App.class})
    public class ManyToManyTest {
    	@Autowired
    	private RolesRepository rolesRepository;
    	/*
    	 * 添加
    	 */
    	/*@Test
    	public void test1() {
    		
    		Roles roles=new Roles();
    		roles.setRolename("管理员");
    		
    		Menus menus=new Menus();
    		menus.setFatherid(1);
    		menus.setMenuname("xx管理");
    		menus.setMenuurl(null);
    		
    		Menus menus1=new Menus();
    		menus1.setFatherid(2);
    		menus1.setMenuname("aa管理");
    		menus1.setMenuurl(null);
    		
    		menus.getRolesSet().add(roles);
    		
    		menus1.getRolesSet().add(roles);
    	
    		roles.getMenusSet().add(menus1);
    		roles.getMenusSet().add(menus);
    		
    		rolesRepository.save(roles);
    		
    	}*/
    	/*
    	 * 查询
    	 */
    	@Test
    	public void test2() {
    		List<Roles> rolesList=rolesRepository.findAll();
    		for(Roles roles:rolesList) {
    			System.out.println(roles);
    			System.out.println(roles.getMenusSet());
    		}
    	}
    
    }