本文通過執行個體介紹使用Spring Boot,使用JDBC Template如何操作記憶體資料庫和MySQL資料庫。
一、Spring Boot使用JDBC Template操作記憶體資料庫(H2)
先建立一個基本的Spring Boot項目,修改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.springboot</groupId>
<artifactId>demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>demo</name>
<description>Demo project for Spring Boot</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.9.RELEASE</version>
</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-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<scope>runtime</scope>
</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>
在pom.xml檔案中,我們添加jdbc和H2的依賴,下一步我們需要建立一個實體類Journal,類放在src/main/java/com/springboot/domain。
src/main/java/com/springboot/domain/Journal.java
package com.springboot.domain;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
public class Journal {
private Long id;
private String title;
private Date created;
private String summary;
private SimpleDateFormat format = new SimpleDateFormat("MM/dd/yyyy");
public Journal(Long id, String title, String summary, Date date)throws ParseException{
this.id = id;
this.title = title;
this.summary = summary;
this.created = date;
}
Journal(){}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public Date getCreated() {
return created;
}
public void setCreated(Date created) {
this.created = created;
}
public String getSummary() {
return summary;
}
public void setSummary(String summary) {
this.summary = summary;
}
public String getCreatedAsShort(){
return format.format(created);
}
public String toString(){
StringBuilder value = new StringBuilder("JournalEntry(");
value.append("Id: ");
value.append(id);
value.append(",Title: ");
value.append(title);
value.append(",Summary: ");
value.append(summary);
value.append(",Created: ");
value.append(getCreatedAsShort());
value.append(")");
return value.toString();
}
}
建立完成實體類之後,我們在src/main/java/com/springboot/service目錄下建立一個服務類JournalService類
src/main/java/com/springboot/service/JournalService.java
package com.springboot.service;
import com.springboot.domain.Journal;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
@Service
public class JournalService {
private static final Logger log = LoggerFactory.getLogger(JournalService.class);
@Autowired
JdbcTemplate jdbcTemplate;
public void insertData(){
log.info("> Table creation");
jdbcTemplate.execute("DROP TABLE JOURNAL IF EXISTS");
jdbcTemplate.execute("CREATE TABLE JOURNAL(id SERIAL, title VARCHAR(255),summary VARCHAR(255), created TIMESTAMP)");
log.info("> Inserting data...");
jdbcTemplate.execute("INSERT INTO JOURNAL(title,summary,created) VALUES('Get to know Spring Boot','Today I will learn Spring Boot','2016-01-01 00:00:00.00')");
jdbcTemplate.execute("INSERT INTO JOURNAL(title,summary,created) VALUES('Simple Spring Boot Project','I will do my first Spring Boot project','2016-01-02 00:00:00.00')");
jdbcTemplate.execute("INSERT INTO JOURNAL(title,summary,created) VALUES('Spring Boot Reading','Read more about Spring Boot','2016-02-01 00:00:00.00')");
jdbcTemplate.execute("INSERT INTO JOURNAL(title,summary,created) VALUES('Spring Boot in the Cloud','Learn Spring Boot using Cloud Foundry','2016-01-01 00:00:00.00')");
jdbcTemplate.execute("INSERT INTO JOURNAL(title,summary,created) VALUES('Spring Boot By Ron','Learn Spring Boot using Cloud Foundry','2016-01-01 00:00:00.00')");
log.info("> Done.");
}
public List<Journal> findAll() {
List<Journal> entries = new ArrayList<>();
entries = jdbcTemplate.query("select * from JOURNAL",new Object[]{},new BeanPropertyRowMapper(Journal.class));
if(entries!=null && entries.size()>){
return entries;
}else{
return null;
}
}
}
- JdbcTemplate:自動裝配的JdbcTemplate類将負責對資料庫執行任務。這個特殊的類基于template設計模式允許開發者隻關心資料和資料的操作(增、删、改、查)。該類可以在短時間内自行決定連結到那個資料庫。
- insertData:如果Journal資料表存在,該方法首先會嘗試删除該資料表,然後建立一張空的Journal資料表,之後他會插入一些資料到資料表中。所有這些操作都是通過JdbcTemplate的執行個體通過執行execute方法完成。
- findAll:該方法使用JdbcTemplate執行個體通過query方法擷取所有的資料,然後傳回一個Journal集合。
接下來在Spring Boot應用啟動類DemoApplication中,在啟動時我們需要插入一些預設資料,建立資料表,是以我們修改DemoApplication類如下。
src/main/java/com/springboot/DemoApplication.java
package com.springboot;
import com.springboot.service.JournalService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class DemoApplication implements CommandLineRunner {
private static final Logger log = LoggerFactory.getLogger(DemoApplication.class);
@Autowired
JournalService service;
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
@Override
public void run(String... strings) throws Exception {
log.info("@@ Inserting Data....");
service.insertData();
}
}
該類定義了一個自動裝配的JournalService,在run方法執行時将運用服務調用insertData方法初始化資料。
DemoApplication 實作了CommandLineRunner接口,是以需要實作 public void run(String… strings) 方法,該方法在Spring Boot應用啟動完成之後會執行,是以在該方法中調用服務初始化資料是最好的一種方案。
接下來,建立一個控制器,擷取資料并在頁面上展示。我們将控制器命名為JournalController。
src/main/java/com/springboot/web/JournalController.java
package com.springboot.web;
import com.springboot.service.JournalService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
@Controller
public class JournalController {
@Autowired
JournalService service;
@RequestMapping("/")
public String index(Model model){
model.addAttribute("journal", service.findAll());
return "index";
}
}
接下來我們需要構模組化闆檔案,在src/main/resources/templates目錄下,需要建立一個index.html檔案并寫入如下内容。
<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
<meta charset="utf-8"></meta>
<meta http-equiv="Content-Type" content="text/html"></meta>
<title>Spring Boot Journal</title>
<link rel="stylesheet" type="text/css" media="all" href="css/bootstrap.min.css"></link>
</head>
<body>
<h1>Spring Boot Journal</h1>
<ul class="timeline">
<div th:each="entry,status : ${journal}">
<li th:attr="class=${status.odd}?'timeline-inverted':''">
<div class="tl-circ"></div>
<div class="timeline-panel">
<div class="tl-heading">
<h4><span th:text="${entry.title}">TITLE</span></h4>
<p><small class="text-muted"><i class="glyphicon glyphicon-time"></i>
<span th:text="${entry.createdAsShort}">CREATED</span></small></p>
</div>
<div class="tl-body">
<p><span th:text="${entry.summary}">SUMMARY</span></p>
</div>
</div>
</li>
</div>
</ul>
</body>
</html>
注意:在static目錄下建立一個css目錄,添加bootstrap.min.css檔案,該檔案自行到bootstrap去下載下傳。
啟動程式,在浏覽器中輸入http://localhost:8080/,頁面顯示如下結果。

二、Spring Boot使用JDBC Template操作MySQL
以上我們講述了如何通過JDBC Template操作記憶體資料庫,但是記憶體資料庫一般情況下隻是在測試環境中使用,在生産環境中,我們需要使用的是如MySQL、SQLServer、Oracle等外部的資料庫,下面我們以MySQL為例講解Spring Boot如何通過JDBC Template操作MySQL。
在上述代碼的基礎上,如果要操作MySQL,首先我們需要添加MySQL依賴(首先需要確定您已經在某台機器上安裝了MySQL且安裝的MySQL可以使用)。修改後的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.springboot</groupId>
<artifactId>demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>demo</name>
<description>Demo project for Spring Boot</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.9.RELEASE</version>
</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-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>6.0.5</version>
</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>
在application.properties配置檔案中添加資料源資訊如下
spring.datasource.url=jdbc:mysql://:/test?useUnicode=true&characterEncoding=UTF8&zeroDateTimeBehavior=convertToNull&useSSL=true&allowMultiQueries=true&serverTimezone=Asia/Hong_Kong
spring.datasource.username=root
spring.datasource.password=
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.tomcat.max-wait=
spring.datasource.tomcat.max-active=
spring.datasource.tomcat.test-on-borrow=true
spring.datasource.testWhileIdle = true
spring.datasource.timeBetweenEvictionRunsMillis =
啟動應用,如果應用不報錯,則證明配置成功,啟動之後在浏覽器輸入http://localhost:8080/,結果将會成功展示在浏覽器中。