记录SpringDataJpa学习

参考博客:https://blog.csdn.net/phapha1996/article/details/83614975

1.环境搭建

pom文件

<?xml version="1.0" encoding="UTF-8"?>

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

  <groupId>test</groupId>
  <artifactId>springDataJpa</artifactId>
  <version>1.0-SNAPSHOT</version>

  <name>springDataJpa</name>
  <!-- FIXME change it to the project's website -->
  <url>http://www.example.com</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.7</maven.compiler.source>
    <maven.compiler.target>1.7</maven.compiler.target>
  </properties>

  <!-- 引入springboot parent-->
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.2.2.RELEASE</version>
    <relativePath/>
  </parent>

  <dependencies>

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</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>
      <scope>test</scope>
      <exclusions>
        <exclusion>
          <groupId>org.junit.vintage</groupId>
          <artifactId>junit-vintage-engine</artifactId>
        </exclusion>
      </exclusions>
    </dependency>

    <!--mysql依赖-->
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>8.0.11</version>
    </dependency>

    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.12</version>
      <scope>test</scope>
    </dependency>

    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <version>1.18.4</version>
      <scope>provided</scope>
    </dependency>

  </dependencies>

</project>

2.Entity和Dao编写

1.声明实体对应的表和表字段

package com.cwh.Entity;

import javax.persistence.*;

@Entity
@Table(name = "t_car")
public class Car {

    @Id
    @Column(name = "id")
    private String id;

    @Column(name = "name")
    private String name;

    @Column(name = "power")
    private String power;

    @ManyToOne(targetEntity = Person.class)
    @JoinColumn(name = "owner",referencedColumnName = "id")
    private Person person;

    public String getId() {
        return id;
    }

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

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPower() {
        return power;
    }

    public void setPower(String power) {
        this.power = power;
    }

    public Person getPerson() {
        return person;
    }

    public void setPerson(Person person) {
        this.person = person;
    }

}

4.编写dao

继承jpa的两个接口

public interface CarDao extends JpaRepository<Car,String>, JpaSpecificationExecutor<Car> {
}

3.使用JPA进行持久操作

JPA操作有四种方式:
1.JPA接口中的方法
2.编写JPQL语句
3.编写SQL语句
4.按照函数命名规则进行接口名称编写

1.方式一:JPA接口中的方法

/**
 * 方式一:通过repository的内置方法
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringbootApplication.class)
public class PersonDaoTest {

    @Resource
    private PersonDao personDao;

    @Test
    public void queryByAll(){
        List<Person> all = personDao.findAll();
        for (Person item : all){
            System.out.println(item);
        }
    }

    @Test
    public void save(){
        Person test = new Person();
        test.setId("2222");
        test.setAddress("zh");
        Person save = personDao.save(test);
        System.out.println(save);
    }

    @Test
    public void delete(){
        Person test = new Person();
        test.setId("1");
        personDao.delete(test);
    }

}

2.方式二:编写JPQL语句

DAO:

@Query(value = "from Person")
    public List<Person> JpqlFindAll();

    @Query(value = "from Person where name = ?1")
    public Person JpqlFindByName(String name);

    @Query(value = "update Person set age =?2 where name = ?1")
    @Modifying
    public int JpaqlUpdateAgeByName(String name,int age);

测试类:

/**
 * 方式二:采用jpql
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringbootApplication.class)
public class PersonDaoTest2 {

    @Resource
    private PersonDao personDao;

    @Test
    public void TestFindAll(){
        List<Person> people = personDao.JpqlFindAll();
        for (Person item: people) {
            System.out.println(item);
        }
    }

    @Test
    public void TestFindByName(){
        Person person = personDao.JpqlFindByName("test");
        System.out.println(person);
    }

    @Test
    @Transactional
    @Rollback(value = false)
    public void updateAgeByName(){
        System.out.println(personDao.JpaqlUpdateAgeByName("test",20));
    }

}

3.方式三:编写SQL语句

DAO:

@Query(value = "select * from t_personal",nativeQuery = true)
    public List<Person> sqlFindAll();

    @Query(value = "select * from t_personal where name = ?1",nativeQuery = true)
    public Person sqlFindByName(String name);

    @Query(value = "update t_personal set age =?2 where name=?1",nativeQuery = true)
    @Modifying
    public void sqlUpdateAgeByName(String name,int age);

测试类:

/**
 * 方式三:采用sql
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringbootApplication.class)
public class PersonDaoTest3 {

    @Resource
    private PersonDao personDao;

    @Test
    public void TestFindAll(){
        List<Person> people = personDao.sqlFindAll();
        for (Person item: people) {
            System.out.println(item);
        }
    }

    @Test
    public void TestFindByName(){
        Person person = personDao.sqlFindByName("test2");
        System.out.println(person);
    }

    @Test
    @Transactional
    @Rollback(value = false)
    public void TestUpdate(){
        personDao.sqlUpdateAgeByName("test2",99);
    }
}

4.方式四:使用规定命名的方式

DAO:

public Person findByName(String name);

public List<Person> findByNameLike(String name);

public Person findByNameAndAge(String name,int age);

测试类:

/**
 * 方式四:采用函数名定义
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringbootApplication.class)
public class PersonDaoTest4 {

    @Autowired
    private PersonDao personDao;

    @Test
    public void TestFindByName(){
        Person person = personDao.findByName("test");
        System.out.println(person);
    }

    @Test
    public void TestFindByNameList(){
        List<Person> byNameLike = personDao.findByNameLike("test%");
        for (Person item:byNameLike){
            System.out.println(item);
        }
    }

    @Test
    public void TestFindByNameAndAge(){
        Person person = personDao.findByNameAndAge("test2",99);
        System.out.println(person);

    }
}

4.JPA多表操作

1.一对多

一方实体类:
常规:

@OneToMany(targetEntity = Car.class)
 @JoinColumn(name = "owner",referencedColumnName = "id")
private Set<Car> cars = new HashSet<>();

放弃维护,级联方式:

@OneToMany(mappedBy = "person",cascade = CascadeType.ALL)   //一方维护,级联方式
private Set<Car> cars = new HashSet<>();

放弃维护,级联方式,立即加载:

@OneToMany(mappedBy = "person",cascade = CascadeType.ALL,fetch = FetchType.EAGER) //立即加载
    private Set<Car> cars = new HashSet<>();

多方实体类:
onwer为外键,id为person表主键

 @ManyToOne(targetEntity = Person.class)
 @JoinColumn(name = "owner",referencedColumnName = "id")
    private Person person;

2.多对多

多方实体类:
JoinTable name中间表的名称,joinColumns 本实体,inverseJoinColumns 对方实体
referencedColumnName 中间表字段名称

@ManyToMany(targetEntity = Role.class,cascade = CascadeType.ALL)
    @JoinTable(
            name = "t_person_role",
            joinColumns = {@JoinColumn(name = "personal_id",referencedColumnName = "id")},
            inverseJoinColumns = {@JoinColumn(name = "role_id",referencedColumnName = "id")}
    )

对方实体类:
mappedBy放弃维权

//    @ManyToMany(targetEntity = Role.class)
//    @JoinTable(
//            name = "t_person_role",
//            joinColumns = {@JoinColumn(name = "role_id",referencedColumnName = "id")},
//            inverseJoinColumns = {@JoinColumn(name = "personal_id",referencedColumnName = "id")}
//    )
    @ManyToMany(mappedBy = "roles") //放弃维权
    private Set<Person> persons = new HashSet<>();

5.自定义查询

1.使用JPQL自定义查询

DAO:

@Query(value = "select new com.cwh.Vo.PersonVo(p.name,p.age) from Person p where p.name like :name")
    public List<PersonVo> getNameAndAgeList(@Param("name") String name);

接受类:
需要一一对应查询出来的字段

@Data
public class PersonVo {
    private String name;
    private Integer age;

    public PersonVo(String name, Integer age) {
        this.name = name;
        this.age = age;
    }
}

测试类:

    @Test
    public void getNameAndAgeList(){
        List<PersonVo> persons = personDao.getNameAndAgeList("%11%");
        for (PersonVo item : persons){
            System.out.println(item);
        }

    }

2.使用SQL自定义查询

DAO:
需使用MAP或OBJECT去接收

@Query(value = "select p.name as name,c.name as carName from t_personal p left join t_car c on p.id = c.owner",nativeQuery = true)
    public List<Map<String,Object>> getPersonAndCar();

测试类:

@Test
    public void getPersonAndCar(){
        List<Map<String,Object>> persons = personDao.getPersonAndCar();
        for (Map<String,Object> item : persons){
            System.out.println(item.get("carName"));
        }
    }

6.导航查询

需要在配置了一对多和多对多基础上
测试类:

@Test
    @Transactional
    public void testQuery(){
        Optional<Person> byId = personDao.findById("4444");
        Person person = byId.get();
        Set<Car> cars = person.getCars();
        for (Car car:cars) {
            System.out.println(car);
        }
    }

6.Querydsl使用

官方文档:http://www.querydsl.com/static/querydsl/4.1.3/reference/html_single/

1.导入依赖

<!--queryDsl-->
    <dependency>
      <groupId>com.querydsl</groupId>
      <artifactId>querydsl-apt</artifactId>
      <version>${querydsl.version}</version>
    </dependency>

    <dependency>
      <groupId>com.querydsl</groupId>
      <artifactId>querydsl-jpa</artifactId>
      <version>${querydsl.version}</version>
    </dependency>

2.操作

1.查询实体类,可以直接用实体类去接收

@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringbootApplication.class)
public class QdslTest {
    @Resource
    private EntityManager entityManager;

    private JPAQueryFactory jpaQueryFactory;

    @PostConstruct
    public void initFactory(){
        jpaQueryFactory = new JPAQueryFactory(entityManager);
    }

    @Test
    public void testQueryAll(){
        QPerson qPerson = QPerson.person;
        List<Person> persons = jpaQueryFactory.select(qPerson)
                .from(qPerson)
                .fetch();
        for (Person item:persons) {
            System.out.println(item);
        }
    }

}

2.查询自定义字段,返回值需要自己再去处理

@Test
    public void testQuery(){
        QPerson qPerson = QPerson.person;
        List<Tuple> fetch = jpaQueryFactory.select(qPerson.name, qPerson.age)
                .from(qPerson).fetch();

        for (Tuple item:fetch) {
            System.out.println(item.get(qPerson.name));
            System.out.println(item.get(qPerson.age));
        }
    }

3.左连接查询

@Test
    public void testLeftQuery(){
        QPerson qPerson = QPerson.person;
        QCar qCar = QCar.car;
        List<Tuple> fetch = jpaQueryFactory.select(qPerson, qCar)
                .from(qPerson)
                .leftJoin(qCar)
                .on(qPerson.id.eq(qCar.person.id))
                .fetch();
        for (Tuple item:fetch) {
            System.out.println(item.get(qCar));
        }
    }

4.使用指定类去接收放回参数

@Test
    public void testQueryWithDto(){
        QPerson qPerson = QPerson.person;
        List<PersonVo> personVos = jpaQueryFactory.select(Projections.constructor(PersonVo.class, qPerson.name, qPerson.age))
                .from(qPerson)
                .fetch();
        for (PersonVo item:personVos) {
            System.out.println(item);
        }
    }

5.分组查询

@Test
    public void testGroupQuery(){
        QPerson qPerson = QPerson.person;
        List<Tuple> fetch = jpaQueryFactory.select(qPerson.name ,qPerson.name.count())
                .from(qPerson)
                .groupBy(qPerson.name)
                .fetch();
        for (Tuple item:fetch) {
            System.out.println(item.get(qPerson.name.count()));
        }
    }
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,185评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,445评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,684评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,564评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,681评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,874评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,025评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,761评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,217评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,545评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,694评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,351评论 4 332
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,988评论 3 315
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,778评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,007评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,427评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,580评论 2 349

推荐阅读更多精彩内容

  • 本文参考了Spring Data JPA官方文档,引用了部分文档的代码。 Spring Data JPA是Spri...
    乐百川阅读 25,861评论 3 19
  • 1. 机器学习 评估假设一旦我们通过以下方式在我们的预测中做了一些故障排除:获得更多培训示例尝试更小的功能集尝试其...
    molscar阅读 693评论 0 0
  • JSPXCMS开发架构介绍 V1 – 架构概述 基本概述 配置文件目录 /src/main/resources/...
    Java_Evan阅读 4,376评论 0 0
  • java事务的处理 转 https://www.cnblogs.com/Bonker/p/5417967.html...
    小小的Jobs阅读 1,376评论 0 1
  • 最近很丧,是哪种做什么都没有兴致的丧。工作已经到了半死不活的阶段,生活也是一团乱,朋友聚会全都是大型吐丧现场...
    先保留阅读 125评论 0 0