TOP → Java → spring → This Page

3.3.3.(JpaRepository)(複合主キーテーブルのCRUD) Spring+MVC+DB+Test構築サンプル

前提

目次

1.PrimaryKeyクラスの作成

package jp.mitchy.entity;

import java.io.Serializable;

import javax.persistence.Column;
import javax.persistence.Embeddable;

@Embeddable
public class AttendancePk implements Serializable {
	private static final long serialVersionUID = 1L;
	
	@Column
	private Long staffid;
	
	@Column
	private Integer yyyymmdd;

	public AttendancePk() {
	}

	public AttendancePk(Long staffid, Integer yyyymmdd) {
		this();
		this.staffid = staffid;
		this.yyyymmdd = yyyymmdd;
	}

	public Long getStaffid() {
		return staffid;
	}

	public void setStaffid(Long staffid) {
		this.staffid = staffid;
	}

	public Integer getYyyymmdd() {
		return yyyymmdd;
	}

	public void setYyyymmdd(Integer yyyymmdd) {
		this.yyyymmdd = yyyymmdd;
	}

	public int hashCode() {
		int hashCode = 0;
		if (staffid != null) {
			hashCode ^= staffid.hashCode();
		}
		if (yyyymmdd != null) {
			hashCode ^= yyyymmdd.hashCode();
		}
		return hashCode;
	}

	public boolean equals(Object obj) {
		if (!(obj instanceof AttendancePk)) {
			return false;
		}
		
		AttendancePk target = (AttendancePk) obj;
		return ((this.staffid == null) ? (target.staffid == null) : this.staffid.equals(target.staffid))
				&& ((this.yyyymmdd == null) ? (target.yyyymmdd == null) : this.yyyymmdd.equals(target.yyyymmdd));
	}
	
}

2.Entityクラスの作成

package jp.mitchy.entity;

import javax.persistence.Column;
import javax.persistence.EmbeddedId;
import javax.persistence.Entity;
import javax.persistence.Table;

@Entity
@Table(name="attendance")
public class Attendance {
	@EmbeddedId
	private AttendancePk id;
	
	@Column(nullable=false)
	private int state;
	
	public Attendance() {
	}
	
	public Attendance(AttendancePk id, int state) {
		this();
		this.id = id;
		this.state = state;
	}

	public AttendancePk getId() {
		return id;
	}

	public void setId(AttendancePk id) {
		this.id = id;
	}

	public int getState() {
		return state;
	}

	public void setState(int state) {
		this.state = state;
	}
	
	@Override
	public String toString() {
		return "[staffid=" + id.getStaffid() + ",yyyymmdd=" + id.getYyyymmdd()
		+ ",state=" + state + "]";
	}
	
}

3.Repositoryインタフェースの作成

package jp.mitchy.repository;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

import jp.mitchy.entity.Attendance;
import jp.mitchy.entity.AttendancePk;

@Repository
public interface AttendanceRepository extends JpaRepository<Attendance, AttendancePk> {
}

4.Daoインタフェースの作成

package jp.mitchy.dao;

import java.util.List;

import jp.mitchy.entity.Attendance;
import jp.mitchy.entity.AttendancePk;

public interface AttendanceDao {
	public List<Attendance> getAllEntity();
	public Attendance findById(AttendancePk id);
	public void addEntity(Attendance entity);
	public void updateEntity(Attendance entity);
	public void removeEntity(Attendance data);
	public void removeEntity(AttendancePk id);
}

5.Daoクラスの作成

package jp.mitchy.dao.impl;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
// import org.springframework.web.context.support.SpringBeanAutowiringSupport;

import jp.mitchy.dao.AttendanceDao;
import jp.mitchy.entity.Attendance;
import jp.mitchy.entity.AttendancePk;
import jp.mitchy.repository.AttendanceRepository;

@Repository
public class AttendanceDaoImpl implements AttendanceDao {
	
	@Autowired
	private AttendanceRepository repository;
	
	public AttendanceDaoImpl() {
		init();
	}
	
	public void init(){
		// @Autowired がうまく機能しない場合は以下のコメントを外す
		// SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
	}

	public List<Attendance> getAllEntity() {
		System.out.println("getAllEntity()");
		return repository.findAll();
	}

	public Attendance findById(AttendancePk id) {
		System.out.println("findById(AttendancePk)");
		return repository.findOne(id);
	}
	
	public void addEntity(Attendance entity) {
		System.out.println("addEntity(entity)");
		repository.saveAndFlush(entity);
	}

	public void updateEntity(Attendance entity) {
		System.out.println("updateEntity(entity)");
		repository.saveAndFlush(entity);
	}

	public void removeEntity(Attendance entity) {
		System.out.println("removeEntity(entity)");
		repository.delete(entity);
	}

	public void removeEntity(AttendancePk id) {
		System.out.println("removeEntity(AttendancePk)");
		Attendance entity = repository.findOne(id);
		repository.delete(entity);
	}

}

6.Serviceインタフェースの作成

package jp.mitchy.service;

import jp.mitchy.dto.TestResultDto;
import jp.mitchy.entity.Attendance;

public interface AttendanceService {
	public TestResultDto<Attendance> execute(Attendance entity);
}

7.Serviceクラスの作成

package jp.mitchy.service.impl;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import jp.mitchy.dao.AttendanceDao;
import jp.mitchy.dto.TestResultDto;
import jp.mitchy.entity.Attendance;
import jp.mitchy.entity.AttendancePk;
import jp.mitchy.service.AttendanceService;

@Service
public class AttendanceServiceImpl implements AttendanceService {
	
	@Autowired
	private AttendanceDao dao;
	
	public AttendanceServiceImpl() {
		init();
	}
	
	public void init(){
		// @Autowired がうまく機能しない場合は以下のコメントを外す
		// SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
	}

	public TestResultDto<Attendance> execute(Attendance entity) {
		TestResultDto<Attendance> result = new TestResultDto<Attendance>();
		
		// INSERT
		dao.addEntity(entity);
		
		// UPDATE
		entity.setState(2);
		dao.updateEntity(entity);
		
		// DELETE
		dao.removeEntity(entity.getId());
		
		// SELECT 単体
		AttendancePk id2 = new AttendancePk(102L, 20180801);
		Attendance entity2 = dao.findById(id2);
		result.setEntity(entity2);
		
		// SELECT 複数
		List<Attendance> list = dao.getAllEntity();
		result.setList(list);

		return result;
	}
	
}

8.TestController.java編集

package jp.mitchy.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import jp.mitchy.dto.TestResultDto;
import jp.mitchy.entity.Attendance;
import jp.mitchy.entity.AttendancePk;
import jp.mitchy.entity.Department;
import jp.mitchy.entity.Staff;
import jp.mitchy.service.AttendanceService;
import jp.mitchy.service.DepartmentService;
import jp.mitchy.service.StaffService;

@RequestMapping("/test/*")
@Controller
public class TestController {
	
	@Autowired
	private DepartmentService deptService;
	
	@Autowired
	private StaffService staffService;
	
	@Autowired
	private AttendanceService AttendanceService;
	
	@RequestMapping(value = "/dept", method = RequestMethod.GET)
	public String dept(Model model) {
		// ------------------------------
		// 単テーブルのCURD確認
		// ------------------------------
		
		Department entity = new Department(4L, "新事業部");
		
		// サービスの実行
		TestResultDto<Department> dto = deptService.execute(entity);
		
		// 結果をセット
		model.addAttribute("data", dto.getEntity());
		model.addAttribute("list", dto.getList());

		// view/test/result.jsp を表示
		return "test/result";
	}
	
	@RequestMapping(value = "/staff", method = RequestMethod.GET)
	public String staff(Model model) {
		// ------------------------------
		// N:1 テーブルのCURD確認
		// ------------------------------
		
		Staff entity = new Staff(103L, "人事太郎３", 50, 1L);
		
		// サービスの実行
		TestResultDto<Staff> dto = staffService.execute(entity);
		
		// 結果をセット
		model.addAttribute("data", dto.getEntity());
		model.addAttribute("list", dto.getList());

		// view/test/result.jsp を表示
		return "test/result";
	}
	
	@RequestMapping(value = "/attend", method = RequestMethod.GET)
	public String attend(Model model) {
		// ------------------------------
		// 複合主キー テーブルのCURD確認
		// ------------------------------
		
		AttendancePk id = new AttendancePk(201L, 20180101);
		Attendance entity = new Attendance(id, 1);
		
		// サービスの実行
		TestResultDto<Attendance> dto = AttendanceService.execute(entity);
		
		// 結果をセット
		model.addAttribute("data", dto.getEntity());
		model.addAttribute("list", dto.getList());

		// view/test/result.jsp を表示
		return "test/result";
	}
	
}

9.index.jsp編集

<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%>
<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>

<!DOCTYPE html>

<html>
	<head>
		<meta charset="utf-8">
		<title>Welcome</title>
	</head> 
	<body>
		<c:url value="/test/dept" var="messageUrl1" />
		<a href="${messageUrl1}">Department Test</a><br/>
		<c:url value="/test/Attendance" var="messageUrl2" />
		<a href="${messageUrl2}">Staff Test</a><br/>
		<c:url value="/test/attend" var="messageUrl3" />
		<a href="${messageUrl3}">Attendance Test</a><br/>
	</body>
</html>

10.確認実行

ダウンロード

更新履歴

2018/10/06　新規作成

---

TOP → Java → spring → This Page