Spring Boot下如何自定義Repository中的DAO方法

環境配置介紹

jdk 1.8, spring Boot 1.5.3.RELEASE, MySQL, Spring Data, JPAphp

問題描述

Spring Data提供了一套簡單易用的DAO層抽象與封裝,覆蓋的CURD的基本功能,可是在諸多的狀況下,須要用戶自定義DAO的實現方法,來實現更爲複雜和精細的數據庫訪問操做,該如何來解決這個問題?java

目標描述

這裏咱們以自定義testAA的方法爲例,來介紹如何實現自定義的DAO方法擴展。mysql

數據庫表的定義

咱們這裏定義了一個很是簡單的mycity表,來做爲示例的實體類BaseEntity: 
數據庫表定義: 
這裏寫圖片描述spring

import java.util.Date; import javax.persistence.Column; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; import javax.persistence.MappedSuperclass; import javax.persistence.Temporal; import javax.persistence.TemporalType; import javax.persistence.Version; @MappedSuperclass public abstract class BaseEntity implements java.io.Serializable { private static final long serialVersionUID = -2420979951576787924L; @Id @GeneratedValue(strategy=GenerationType.IDENTITY) @Column(name = "ID") private Long id; @Version private Long version; @Temporal(TemporalType.TIMESTAMP) @Column(name = "CREATE_TIME",columnDefinition="timestamp default CURRENT_TIMESTAMP") private Date createTime; @Temporal(TemporalType.TIMESTAMP) @Column(name = "UPDATE_TIME",columnDefinition="timestamp default CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") private Date updateTime; }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31

MyCity的定義以下:sql

import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.Table; import lombok.Data; @Entity @Table(name="mycity") @Data public class City extends BaseEntity { private static final long serialVersionUID = -7510771121759944670L; @Column(name="Name") private String name; @Column(name="country_code") private String countryCode; @Column private String district; @Column private int population; }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24

這裏的@Data使用了lombok提供的強大標註,來簡化冗餘Getter/Setter方法的使用。數據庫

定義Repository

標準的CityRepository.Java,這裏徹底使用缺省提供的方法:app

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

import com.rose.money.City;

@Repository
public interface CityRepository extends JpaRepository<City, Long>, CityRepositoryCustom{ }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

這裏的CityRepository繼承了2個父類,包括用戶自定義的接口類,讓用戶自定義的接口能夠暴漏出來。 
這裏的CityRepsoitoryCustom定義了用戶的自定義方法:ide

public interface CityRepositoryCustom { public void testAA(); }
  • 1
  • 2
  • 3
  • 1
  • 2
  • 3

Notice: 這裏的Custom後綴是約定的,不能隨意修改。 
自定義方法的實現類:測試

import java.util.List; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import org.springframework.beans.factory.annotation.Autowired; public class CityRepositoryImpl implements CityRepositoryCustom { @Autowired @PersistenceContext private EntityManager entityManager; @Override public void testAA() { List<Object[]> cities = entityManager.createNativeQuery("select id, name, district from mycity").getResultList(); for (Object[] objs : cities) { System.out.print("location 1:" + objs[0]); System.out.print("location 2:" + objs[1]); System.out.print("location 3:" + objs[2]); } } }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23

這裏的實現類就是讀取了幾條記錄,而後打印出來。其實現了Custom的接口類。url

配置信息

application.properties:

spring.application.name=custom jpa spring.jpa.database=MYSQL spring.datasource.username=root spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.password=123456 spring.datasource.url=jdbc:mysql://localhost:3306/world?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=true spring.jpa.hibernate.naming.strategy=org.hibernate.cfg.ImprovedNamingStrategy spring.jpa.show-sql=true
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

測試

測試用例:

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.SpringRunner; import com.rose.money.repository.CityRepository; @RunWith(SpringRunner.class) @SpringBootTest public class CustomjpaApplicationTests { @Autowired private CityRepository cityRepo; @Test public void contextLoads() { City city = cityRepo.findOne(1l); System.out.println("city=>" + city); cityRepo.testAA(); } }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22

測試的結果圖示: 
這裏寫圖片描述

總結

約定大於配置,Custom後綴實現與擴展,很是的簡單實用。

http://www.woaipu.com/shops/zuzhuan/61406http://nanning.xjwy.cn/f/bencandy.php?fid=43&id=117777http://nanning.xjwy.cn/f/bencandy.php?fid=43&id=117890http://nanning.xjwy.cn/f/bencandy.php?fid=43&id=117994http://nanning.xjwy.cn/f/bencandy.php?fid=43&id=118376

相關文章
相關標籤/搜索