Java框架spring Boot学习笔记（五）：Spring Boot操作MySQL数据库增、删、改、查

在pom.xml添加一下代码，添加操作MySQL的依赖jar包。

1 <dependency>
2 　　<groupId>org.springframework.boot</groupId>
3 　　<artifactId>spring-boot-starter-data-jpa</artifactId>
4 </dependency>
5
6 <dependency>
7 　　<groupId>mysql</groupId>
8 　　<artifactId>mysql-connector-java</artifactId>
9 </dependency>

新建dbpeople的一个数据库,用户名root，密码123456



编写生成配置文件application-prod.yml

1 server:
2   port: 8082
3   context-path: /

修改application.yml文件

1 spring:
2   profiles:
3     active: prod
4   datasource:
5     driver-class-name: com.mysql.jdbc.Driver
6     url: jdbc:mysql://localhost:3306/dbpeople?useSSL=true

7  username: root  8  password: 123456  9  jpa: 10  hibernate: 11  ddl-auto: create #update 12 show-sql: true

添加一个people类People.java

1 package com.example.demo;
2
3 import javax.persistence.Entity;
4 import javax.persistence.GeneratedValue;
5 import javax.persistence.Id;
6
7 //@Entity对应数据库中的一个表
8 @Entity
9 public class People {
10
11     //@Id配合@GeneratedValue，表示id自增长
12     @Id
13     @GeneratedValue
14     private Integer id;
15     private String name;
16     private Integer age;
17
18     //必须要有一个无参的构造函数，不然数据库会报错
19     public People() {
20     }
21
22     public Integer getId() {
23         return id;
24     }
25
26     public void setId(Integer id) {
27         this.id = id;
28     }
29
30     public String getName() {
31         return name;
32     }
33
34     public void setName(String name) {
35         this.name = name;
36     }
37
38     public Integer getAge() {
39         return age;
40     }
41
42     public void setAge(Integer age) {
43         this.age = age;
44     }
45 }

添加一个注入类PeopleProperties.java

1 package com.example.demo;
2
3 import org.springframework.boot.context.properties.ConfigurationProperties;
4 import org.springframework.stereotype.Component;
5
6 //获取注入还需要加一个@Component注解，@ConfigurationProperties(prefix = "people")获取前缀是people的配置
7 @Component
8 @ConfigurationProperties(prefix = "people")
9 public class PeopleProperties {
10
11     private String name;
12     private Integer age;
13
14
15     public void setName(String name) {
16         this.name = name;
17     }
18     public void setAge(Integer age) {
19         this.age = age;
20     }
21
22     public String getName() { return name; }
23     public Integer getAge() { return age; }
24 }

编写一个数据库操作自定义接口，定制操作接口，这里只演示定制查询接口

PeopleRepository.java

1 package com.example.demo;
2
3 import org.springframework.data.jpa.repository.JpaRepository;
4
5 import java.util.List;
6
7 public interface PeopleRepository extends JpaRepository<People,Integer> {
8     //通过年龄来查询
9     public List<People> findByAge(Integer age);
10 }

编写数据库操作类，可以进行增、删、改、查等操作。

1 package com.example.demo;
2
3 import org.springframework.beans.factory.annotation.Autowired;
4 import org.springframework.web.bind.annotation.*;
5
6 import java.util.List;
7
8 @RestController
9 public class PeopleController {
10     @Autowired
11     private PeopleRepository peopleRepository;
12
13     /**
14      * 查询数据库中所有列表
15      * @return
16      */
17     @GetMapping(value = "/people")
18     public List<People> girlList(){
19         return peopleRepository.findAll();
20     }
21
22     /**
23      * 增加一个人的数据
24      * @param name
25      * @param age
26      * @return
27      */
28     @PostMapping(value = "/people")
29     public People peopleAdd(@RequestParam("name") String name,
30                             @RequestParam("age") Integer age){
31         People people = new People();
32         people.setName(name);
33         people.setAge(age);
34
35         return peopleRepository.save(people);
36     }
37
38     /**
39      * 查询一个人
40      * @param id
41      * @return
42      */
43     @GetMapping(value = "/people/{id}")
44     public People peopleFindOne(@PathVariable("id") Integer id){
45         return peopleRepository.findOne(id);
46     }
47
48     /**
49      * 修改一个人的数据
50      * @param id
51      * @param name
52      * @param age
53      */
54     @PutMapping(value = "/people/{id}")
55     public People peopleUpdate(@PathVariable("id") Integer id,
56                              @RequestParam("name") String name,
57                              @RequestParam("age") Integer age){
58         People people = new People();
59         people.setId(id);
60         people.setName(name);
61         people.setAge(age);
62
63         return peopleRepository.save(people);
64     }
65
66     /**
67      * 删除一个人的数据
68      * @param id
69      */
70     @DeleteMapping(value = "/people/{id}")
71     public void peopleDelete(@PathVariable("id") Integer id){
72         peopleRepository.delete(id);
73     }
74
75     /**
76      * 通过年龄查询列表
77      * @param age
78      * @return
79      */
80     @GetMapping(value = "/people/age/{age}")
81     public List<People> peopleListByAge(@PathVariable("age") Integer age){
82         return peopleRepository.findByAge(age);
83     }
84 }

运行，使用postman工具发包给运行起来的服务器

增加三条数据







打开数据库可以看到增加了三条数据



通过id查询数据，看到返回id=2的数据



查询年龄age为22的数据列表



可以看到返回两条age=22的数据

修改数据



可以看到id=2的数据修改成了



删除id=2的数据



可以看到id=2的数据已经被删掉了。