IntelliJ Idea SpringBoot 資料庫增刪改查例項

阿新 • • 發佈：2019-02-01

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::        (v1.4.2.RELEASE)

SpringBoot

這裡寫圖片描述

SpringBoot 是 SpringMVC 的升級版，相對於編碼、配置、部署和監控方面，會更加簡單

微服務

微服務是一個新興的軟體架構，就是把一個大型的單個應用程式和服務拆分為數十個的支援微服務。一個微服務的策略可以讓工作變得更為簡便，它可擴充套件單個元件而不是整個的應用程式堆疊，從而滿足服務等級協議。

Spring 為微服務提供了一整套的元件-SpringClound , SpirngBoot 就是該基礎。

這裡寫圖片描述

第一個SpringBoot程式

這裡使用的開發軟體是IntelliJ Idea，和Eclipse差不太多，介面更炫酷，功能更強大；Android Studio就是基於IntelliJ 開發的，我之前使用過Android Studio，它倆介面幾乎一樣。

maven配置的中央倉庫阿里雲映象

這個地址下載 jar 包的速度，誰用誰知道！

setting.xml

.
.
 <mirrors>
    <mirror>
      <id>alimaven</id>
      <name>aliyun maven</name>
      <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
      <mirrorOf>central</mirrorOf> 
        
    </mirror>
  </mirrors>
  .
  .

使用`IDEA`建立SpringBoot專案

我的IDEA版本：IntelliJ IDEA 2016.3.1

這裡寫圖片描述

專案結構為：

這裡寫圖片描述

專案預設的 maven pom.xml檔案

pom.xml

<?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>com.jxust</groupId>
    <artifactId>spirngbootdemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>spirngbootdemo</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.4.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

執行SpirngbootdemoApplication的main方法，就能開始執行。

控制檯輸出：

"C:\Program Files\Java\jdk1.8.0_91\bin\java" ....

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::        (v1.4.2.RELEASE)
 2016-12-16 14:56:52.083  INFO 15872 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Registering beans for JMX exposure on startup
2016-12-16 14:56:52.215  INFO 15872 --- [           main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 8080 (http)
2016-12-16 14:56:52.255  INFO 15872 --- [           main] com.jxust.SpirngbootdemoApplication      : Started SpirngbootdemoApplication in 7.795 seconds (JVM running for 9.177)

從這裡可以看到 Tomcat 的埠號，因為還沒有自定義Controller，所以還沒有檢視，下面來建立一個輸出Hello SpringBoot!的檢視。

建立一個HelloController，位於controller包下

這裡寫圖片描述

HelloController.java

package com.jxust.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * Created by Peng
 * Time: 2016/12/16 15:45
 */
@RestController
public class HelloController {

    @RequestMapping("/hello")
    public String say(){
        return "Hello SpringBoot!";
    }
}

@RestController Spring4 之後新加的註解,原來返回json需要@ResponseBody配合@Controller,現在一個頂倆

在瀏覽器中輸入http://localhost:8080/hello就能輸出Hello SpringBoot!這句話。

這裡寫圖片描述

自定義屬性配置

用到的是application.properties這個檔案

這裡寫圖片描述

配置埠號和訪問字首

application.properties

server.port=8081
server.context-path=/springboot

這裡寫圖片描述

除了使用.properties格式的檔案，還可以使用.yml格式的配置檔案(推薦)，更加簡便
application.yml
這裡寫圖片描述

把原來的application.properties檔案刪除
注意格式，空格不能少

獲取配置檔案中的屬性值

我們也可以在配置檔案中，配置資料，在 Controller 中獲取,比如：
application.yml

server:
  port: 8081
  context-path: /springboot
name: 小胖

HelloController 獲取配置檔案中的值

HelloController.java

....
@RestController
public class HelloController {

    @Value("${name}")
    private String name;

    @RequestMapping(value = "/hello",method = RequestMethod.GET)
    public String say(){
        return name;
    }
}

返回的為name的值

這裡寫圖片描述

配置檔案中值配置方式的多樣化

配置檔案的值可以是多個，也可以是組合，如：

application.yml

name: 小胖
age: 22

或者

application.yml

name: 小胖
age: 22
content: "name: ${name},age: ${age}"

或者

application.yml

server:
  port: 8081
  context-path: /springboot
person:
  name: 小胖
  age: 22

前兩種配置獲取值的方式都是一樣的,但是對於這種方式，person 有相應的兩個屬性，需要這樣處理

PersonProperties.java

package com.jxust;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/**
 * Created by Peng
 * Time: 2016/12/16 16:34
 */
@Component
@ConfigurationProperties(prefix = "person")
public class PersonProperties {
    private String name;
    private Integer age;

    public String getName() {
        return name;
    }

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

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }
}

Alt+insert快捷鍵提示生成 Getter and Setter

pom.xml需要加入下面的依賴,處理警告

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-configuration-processor</artifactId>
    <optional>true</optional>
</dependency>

HelloController.java

package com.jxust.controller;

import com.jxust.PersonProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

/**
 * Created by Peng
 * Time: 2016/12/15 20:55
 */
@RestController
public class HelloController {

   @Autowired
   private PersonProperties personProperties;

    @RequestMapping(value = "/hello",method = RequestMethod.GET)
    public String say(){
        return personProperties.getName()+personProperties.getAge();
    }
}

這裡寫圖片描述

關於配置檔案`application.yml`的多套配置

類似 il8n 檔案國際化的配置方式i18n_en_US.properties和i18n_zh_CN.properties
這樣能解決，需要頻繁修改配置的尷尬

這裡寫圖片描述

由application.yml配置檔案決定使用那套配置檔案。

application.yml

spring:
  profiles:
    active: a

application-a.yml

server:
  port: 8081
  context-path: /springboot
person:
  name: 小雷
  age: 21

application-b.yml

server:
  port: 8081
  context-path: /springboot
person:
  name: 小胖
  age: 22

SpringBoot增刪改查例項

完整的專案結構

這裡寫圖片描述

Controller的使用

@Controller chu處理http請求

@RestController Spring4 之後新加的註解，原來返回json需要@ResponseBody配合@Controller

@RequestMapping 配置url對映

對於 REST 風格的請求
這裡寫圖片描述

對於 Controller 中的方法上的註解

@RequestMapping(value = "/hello",method = RequestMethod.GET)
@RequestMapping(value = "/hello",method = RequestMethod.POST)
@RequestMapping(value = "/hello",method = RequestMethod.DELETE)
@RequestMapping(value = "/hello",method = RequestMethod.PUT)

SpringBoot 對上面的註解進行了簡化

@GetMapping(value = "/girls")
@PostMapping(value = "/girls")
@PutMapping(value = "/girls/{id}")
@DeleteMapping(value = "/girls/{id}")

瀏覽器需要傳送不同方式的請求，可以安裝HttpRequester外掛，火狐瀏覽器可以直接搜尋該元件安裝。

這裡寫圖片描述

spring-data-jpa

JPA全稱Java Persistence API.JPA通過JDK 5.0註解或XML描述物件－關係表的對映關係，並將執行期的實體物件持久化到資料庫中。

Hibernate3.2+、TopLink 10.1.3以及OpenJPA都提供了JPA的實現。

利用JPA建立MySQL資料庫

pom.xml加入JPA和MySQL的依賴

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>

配置`JPA`和資料庫

application.yml

spring:
  profiles:
    active: a
  datasource:
      driver-class-name: com.mysql.jdbc.Driver
      url: jdbc:mysql://127.0.0.1:3306/db_person
      username: root
      password: root

  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true

格式很重要
需要自己手動去建立 db_person 資料庫

建立與資料表對應的實體類Person

這裡寫圖片描述

Person.java

package com.jxust.entity;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;

/**
 * Created by Peng
 * Time: 2016/12/16 17:56
 */
@Entity
public class Person {
    @Id
    @GeneratedValue
    private  Integer id;
    private String name;
    private Integer age;

    //必須要有建構函式
    public Person() {
    }

    public Integer getId() {
        return id;
    }

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

    public String getName() {
        return name;
    }

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

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }
}

執行專案後，檢視資料庫，會自動建立表 person

mysql> use db_person;
Database changed
mysql> desc person;
+-------+--------------+------+-----+---------+----------------+
| Field | Type         | Null | Key | Default | Extra          |
+-------+--------------+------+-----+---------+----------------+
| id    | int(11)      | NO   | PRI | NULL    | auto_increment |
| age   | int(11)      | YES  |     | NULL    |                |
| name  | varchar(255) | YES  |     | NULL    |                |
+-------+--------------+------+-----+---------+----------------+
3 rows in set (0.09 sec)

接下來就可以進行person表的增刪改查了

建立控制器`PersonController.java`

這裡寫圖片描述

首先建立一個介面PersonRepository，位於dao包下,PersonController呼叫該介面繼承自JpaRepository的方法，來實現和資料庫互動

這個PersonRepository介面的功能，與SSM框架中 dao 層介面功能有異曲同工之妙；在SSM框架中，Service層通過該介面，間接執行Mybatis資料庫對映檔案(.xml)裡的相應sql語句，執行資料庫增刪改查的操作。(Mapper自動實現DAO介面)

PersonRepository.java

package com.jxust.dao;

import com.jxust.entity.Person;
import org.springframework.data.jpa.repository.JpaRepository;

/**
 * Created by Peng
 * Time: 2016/12/16 18:07
 */
public interface PersonRepository extends JpaRepository<Person,Integer> {
}

PersonController.java

package com.jxust.controller;

import com.jxust.dao.PersonRepository;
import com.jxust.entity.Person;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * Created by Peng
 * Time: 2016/12/16 18:04
 */
@RestController
public class PersonController {
    @Autowired
    PersonRepository personRepository;
    @GetMapping(value = "/person")
    private List<Person> personList() {
        return personRepository.findAll();
    }
}

在資料庫中新增兩條資料

mysql> select * from person;
+----+------+--------+
| id | age  | name   |
+----+------+--------+
|  1 |   23 | 夏洛   |
|  2 |   21 | 馬冬梅 |
+----+------+--------+
2 rows in set (0.04 sec)

啟動專案執行請求http://localhost:8081/springboot/person

這裡寫圖片描述

控制檯輸出的sql語句：

Hibernate: select person0_.id as id1_0_, person0_.age as age2_0_, person0_.name as name3_0_ from person person0_

其他增刪改查的方法

PersonController.java

....
    /**
     * 新增一個人員
     *
     * @param name
     * @param age
     * @return
     */
    @PostMapping(value = "/person")
    public Person personAdd(@RequestParam("name") String name,
                        @RequestParam("age") Integer age) {
        Person person = new Person();
        person.setName(name);
        person.setAge(age);

        return personRepository.save(person);
    }

    /**
     * 查詢一個人員
     *
     * @param id
     * @return
     */
    @GetMapping(value = "/person/{id}")
    public Person personFindOne(@PathVariable("id") Integer id) {
        return personRepository.findOne(id);
    }

    /**
     * 刪除一個人員
     *
     * @param id
     */
    @DeleteMapping(value = "/person/{id}")
    public void personDelete(@PathVariable("id") Integer id) {
        personRepository.delete(id);
    }

    /**
     * 更新一個人員
     *
     * @param id
     * @param name
     * @param age
     * @return
     */
    @PutMapping(value = "/person/{id}")
    public Person personUpdate(@PathVariable("id") Integer id,
                           @RequestParam("name") String name,
                           @RequestParam("age") Integer age) {
        Person person = new Person();
        person.setId(id);
        person.setName(name);
        person.setAge(age);
        return personRepository.save(person);
    }

對應的請求方式為：

查詢一個使用者：
新增一個使用者
刪除一個使用者（無返回值）
更新一個使用者

那麼根據年齡查詢，可不可以呢。答案是此刻還不行

從控制檯的語句可以看出，sql 語句都是根據id來查詢的

Hibernate: select person0_.id as id1_0_0_, person0_.age as age2_0_0_, person0_.name as name3_0_0_ from person person0_ where person0_.id=?

根據年齡查詢

在PersonRepository增加一個方法findByAge(Integer age)

public interface PersonRepository extends JpaRepository<Person,Integer> {
    /**
     *  通過年齡來查詢
     *  方法名固定findByAge
     * @param age
     * @return
     */
    public List<Person> findByAge(Integer age);
}

在PersonController中加入相應的查詢方法

....
    /**
     * 通過年齡來查詢
     * @param age
     * @return
     */
    @GetMapping(value = "/person/age/{age}")
    public List<Person> personListByAge(@PathVariable("age") Integer age) {
        return personRepository.findByAge(age);
    }

輸入請求http://localhost:8081/springboot/person/age/23，查詢年齡為23的人員

這裡寫圖片描述

控制檯輸出SQL語句：

Hibernate: select person0_.id as id1_0_, person0_.age as age2_0_, person0_.name as name3_0_ from person person0_ where person0_.age=?

事務管理

兩條 sql 語句同時在一個方法中執行，為了防止一個 sql 語句執行成功而另一個 sql 語句執行失敗，引入了事務管理，需要在方法上加 @Transactional事務註解

事務確保了資料庫資料的完整性和一致性

這裡寫圖片描述

PersonService.java

package com.jxust.service;

import com.jxust.dao.PersonRepository;
import com.jxust.entity.Person;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.transaction.Transactional;
/**
 * Created by Peng
 * Time: 2016/12/16 19:30
 */
@Service
public class PersonService {
    @Autowired
    private PersonRepository personRepository;

    /**
     * 事務管理測試
     * 兩條資料同時成功，或者同時不成功
     * 保證資料庫資料的完整性和一致性
     */
    @Transactional
    public void insertTwo(){
        Person personA = new Person();
        personA.setName("秋雅");
        personA.setAge(19);
        personRepository.save(personA);

        System.out.print(1/0);

        Person personB = new Person();
        personB.setName("夢特嬌");
        personB.setAge(25);
        personRepository.save(personB);
    }
}

在PersonController中測試

    ...
    @Autowired
    private PersonService personService;
    ...
     /**
     * 事務測試
     */
    @PostMapping("/person/two")
    public void personTwo(){
        personService.insertTwo();
    }

重新執行專案，執行請求 post方式http://localhost:8081/springboot/person/two
資料庫並沒有新增第一條資料，說明存在事務管理

完整的`PersonController.java`、`PersonRepository.java`和`pom.xml`

PersonController.java

package com.jxust.controller;

import com.jxust.dao.PersonRepository;
import com.jxust.entity.Person;
import com.jxust.service.PersonService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * Created by Peng
 * Time: 2016/12/16 18:04
 */
@RestController
public class PersonController {
    @Autowired
    PersonRepository personRepository;
    @Autowired
    private PersonService personService;
    /**
     * 查詢所有人員列表
     *
     * @return
     */
    @GetMapping(value = "/person")
    private List<Person> personList() {
        return personRepository.findAll();
    }

    /**
     * 新增一個人員
     *
     * @param name
     * @param age
     * @return
     */
    @PostMapping(value = "/person")
    public Person personAdd(@RequestParam("name") String name,
                        @RequestParam("age") Integer age) {
        Person person = new Person();
        person.setName(name);
        person.setAge(age);

        return personRepository.save(person);
    }

    /**
     * 查詢一個人員
     *
     * @param id
     * @return
     */
    @GetMapping(value = "/person/{id}")
    public Person personFindOne(@PathVariable("id") Integer id) {
        return personRepository.findOne(id);
    }

    /**
     * 刪除一個人員
     *
     * @param id
     */
    @DeleteMapping(value = "/person/{id}")
    public void personDelete(@PathVariable("id") Integer id) {
        personRepository.delete(id);
    }

    /**
     * 更新一個人員
     *
     * @param id
     * @param name
     * @param age
     * @return
     */
    @PutMapping(value = "/person/{id}")
    public Person personUpdate(@PathVariable("id") Integer id,
                           @RequestParam("name") String name,
                           @RequestParam("age") Integer age) {
        Person person = new Person();
        person.setId(id);
        person.setName(name);
        person.setAge(age);
        return personRepository.save(person);
    }

    /**
     * 通過年齡來查詢
     * @param age
     * @return
     */
    @GetMapping(value = "/person/age/{age}")
    public List<Person> personListByAge(@PathVariable("age") Integer age) {
        return personRepository.findByAge(age);
    }

   /**
     * 事務測試
     */
    @PostMapping("/person/two")
    public void personTwo(){
        personService.insertTwo();
    }
}

PersonRepository.java

package com.jxust.dao;

import com.jxust.entity.Person;
import org.springframework.data.jpa.repository.JpaRepository;

import java.util.List;

/**
 * Created by Peng
 * Time: 2016/12/16 18:07
 */
public interface PersonRepository extends JpaRepository<Person,Integer> {
    /**
     *  通過年齡來查詢
     *  方法名固定
     * @param age
     * @return
     */
    public List<Person> findByAge(Integer age);
}

pom.xml

<?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>com.jxust</groupId>
    <artifactId>spirngbootdemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>spirngbootdemo</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.4.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

IntelliJ Idea SpringBoot 資料庫增刪改查例項

SpringBoot

微服務

第一個SpringBoot程式

maven配置的中央倉庫阿里雲映象

使用IDEA建立SpringBoot專案

自定義屬性配置

配置埠號和訪問字首

獲取配置檔案中的屬性值

配置檔案中值配置方式的多樣化

關於配置檔案application.yml的多套配置

SpringBoot增刪改查例項

完整的專案結構

Controller的使用

spring-data-jpa

利用JPA建立MySQL資料庫

配置JPA和資料庫

建立與資料表對應的實體類Person

建立控制器PersonController.java

其他增刪改查的方法

根據年齡查詢

事務管理

完整的PersonController.java、PersonRepository.java和pom.xml

原始碼下載

相關推薦

使用`IDEA`建立SpringBoot專案

關於配置檔案`application.yml`的多套配置

配置`JPA`和資料庫

建立控制器`PersonController.java`

完整的`PersonController.java`、`PersonRepository.java`和`pom.xml`