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

 更新时间:2017年06月01日 17:06:25   作者:bladestone  
这篇文章主要介绍了Spring Boot下如何自定义Repository中的DAO方法,需要的朋友可以参考下

 环境配置介绍

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

问题描述

Spring Data提供了一套简单易用的DAO层抽象与封装,覆盖的CURD的基本功能,但是在诸多的情况下,需要用户自定义DAO的实现方法,来实现更为复杂和精细的数据库访问操作,该如何来解决这个问题?

目标描述

这里我们以自定义testAA的方法为例,来介绍如何实现自定义的DAO方法扩展。

数据库表的定义

我们这里定义了一个非常简单的mycity表,来作为示例的实体类BaseEntity:

数据库表定义:

这里写图片描述

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;
}

MyCity的定义如下:

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;
}

这里的@Data使用了lombok提供的强大标注,来简化冗余Getter/Setter方法的使用。

定义Repository

标准的CityRepository.Java,这里完全使用缺省提供的方法:

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{
}

这里的CityRepository继承了2个父类,包括用户自定义的接口类,让用户自定义的接口可以暴漏出来。
这里的CityRepsoitoryCustom定义了用户的自定义方法:

public interface CityRepositoryCustom {
 public void testAA();
}

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]);
  }
 }
}

这里的实现类就是读取了几条记录,然后打印出来。其实现了Custom的接口类。

配置信息

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

测试

测试用例:

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();
 }
}

测试的结果图示:

这里写图片描述

总结

约定大于配置,Custom后缀实现与扩展,非常的简单实用。

以上所述是小编给大家介绍的Spring Boot下如何自定义Repository中的DAO方法,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

相关文章

  • SpringBoot项目实现MyBatis流式查询的教程详解

    SpringBoot项目实现MyBatis流式查询的教程详解

    这篇文章主要介绍了SpringBoot项目如何实现MyBatis的流式查询,mybatis的流式查询,有点冷门,实际用的场景比较少,但是在某些特殊场景下,却是十分有效的一个方法,感兴趣的同学可以参考一下
    2023-06-06
  • java中extends与implements的区别浅谈

    java中extends与implements的区别浅谈

    java中extends与implements的区别浅谈,需要的朋友可以参考一下
    2013-03-03
  • Java MongoDB实现REST过程解析

    Java MongoDB实现REST过程解析

    这篇文章主要介绍了Java MongoDB实现REST过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-08-08
  • Spring Cloud入门教程之Zuul实现API网关与请求过滤

    Spring Cloud入门教程之Zuul实现API网关与请求过滤

    这篇文章主要给大家介绍了关于Spring Cloud入门教程之Zuul实现API网关与请求过滤的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧。
    2018-05-05
  • MybatisPlus创建时间不想用默认值的问题

    MybatisPlus创建时间不想用默认值的问题

    MybatisPlus通过FieldFill注解和MpMetaObjectHandler类支持自动填充字段功能,特别地,可以设置字段在插入或更新时自动填充创建时间和更新时间,但在特定场景下,如导入数据时,可能需要自定义创建时间
    2024-09-09
  • 了解java Struts拦截器的相关操作

    了解java Struts拦截器的相关操作

    Struts为我们实现了很多的功能,比如数据自动封装,文件上传功能阿。Struts为我们提供的这些功能都是通过拦截器完成的。下面我们来详细了解一下吧
    2019-06-06
  • SpringMVC跨服务器上传文件中出现405错误的解决

    SpringMVC跨服务器上传文件中出现405错误的解决

    这篇文章主要介绍了SpringMVC跨服务器上传文件中出现405错误的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • java中常见的6种线程池示例详解

    java中常见的6种线程池示例详解

    这篇文章主要介绍了java中常见的6种线程池示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-11-11
  • Java利用for循环打印菱形的实例教程

    Java利用for循环打印菱形的实例教程

    这篇文章主要给大家介绍了关于Java利用for循环打印菱形的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-03-03
  • Java两种方式实现动态代理

    Java两种方式实现动态代理

    Java 在 java.lang.reflect 包中有自己的代理支持,该类(Proxy.java)用于动态生成代理类,只需传入目标接口、目标接口的类加载器以及 InvocationHandler 便可为目标接口生成代理类及代理对象。我们称这个Java技术为:动态代理
    2020-10-10

最新评论