IntelliJ Idea SpringBoot 數據庫增刪改查實例詳解

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

微服務

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

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

第一個SpringBoot程序

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

IntelliJ Idea官網：http://www.jetbrains.com/idea/

配置好maven, tomcat, jdk 就可以使用了

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方法，就能開始運行。

其他啟動方式，請看視頻教程http://www.imooc.com/learn/767/

控制台輸出：

 "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] osjeaAnnotationMBeanExporter : Registering beans for JMX exposure on startup2016-12-16 14:56:52.215 INFO 15872 --- [ main] sbcetTomcatEmbeddedServletContainer : 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 */@RestControllerpublic class HelloController { @RequestMapping("/hello") public String say(){ return "Hello SpringBoot!"; }}

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

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

自定義屬性配置

用到的是application.properties這個文件

配置端口號和訪問前綴

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

除了使用.properties格式的文件，還可以使用.yml格式的配置文件(推薦)，更加簡便

application.yml

把原來的application.properties文件刪除

注意格式，空格不能少

獲取配置文件中的屬性值

我們也可以在配置文件中，配置數據，在Controller 中獲取,比如：

application.yml

 server: port: 8081 context-path: /springbootname: 小胖

HelloController 獲取配置文件中的值

HelloController.java

 ....@RestControllerpublic class HelloController { @Value("${name}") private String name; @RequestMapping(value = "/hello",method = RequestMethod.GET) public String say(){ return name; }}

返回的為name的值

配置文件中值配置方式的多樣化

配置文件的值可以是多個，也可以是組合，如：

application.yml

 name: 小胖age: 22或者name: 小胖age: 22content: "name: ${name},age: ${age}"或者server: port: 8081 context-path: /springbootperson: 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 */@RestControllerpublic 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: /springbootperson: name: 小雷age: 21

application-b.yml

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

SpringBoot增刪改查實例

完整的項目結構

Controller的使用

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 */@Entitypublic 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 changedmysql> 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 */@RestControllerpublic 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

在PersonControll

 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 */@Servicepublic 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); }}

er中測試

... @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 */@RestControllerpublic 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 數據庫增刪改查實例詳解，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對武林網網站的支持！