Spring Boot整合JdbcTemplate訪問數據庫

這篇文章是介紹 Spring Boot整合JdbcTemplate，配置數據源來訪問數據庫。

在pom文件裏添加 spring-boot-starter-jdbc 和mysql依賴。

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

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

配置數據源 ：在 src/main/resources/application.properties 中配置數據源信息
```
spring.datasource.url=jdbc:mysql://localhost:3306/springboot_demo
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
```

建表:
```
DROP TABLE IF EXISTS Student;

CREATE TABLE Student (
　　id int(5) NOT NULL,
　　name varchar(60) NOT NULL,
　　age int(2) NOT NULL,
　　score double(5,2) NOT NULL,
　　PRIMARY KEY (id)
) ;

啓動類：

package cn.yideng;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
@EnableAutoConfiguration
public class DemoApplication {

　　public static void main(String[] args) {
　　　　SpringApplication.run(DemoApplication.class, args);
　　}
}

實體類：

public class Student {

　　private int id;
　　private String name;
　　private int age;
　　private double score;

　　public Student() {}

　　public Student(int id, String name, int age, double score) {
　　　　this.id = id;
　　　　this.name = name;
　　　　this.age = age;
　　　　this.score = score;
　　}

// 省略 getter/setter, toString
}

service：

public interface StudentService {

　　// 新增
　　void create(Student student);

　　// 查詢全部記錄
　　List<Student> getAll();

　　// 刪除全部
　　void deleteAllUsers();

　　// 根據id修改
　　void updateById(Student s);

　　// 根據ID查詢
　　Student getOneById(int id);

}

service實現類：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;

@Service(value="studentService")
public class StudentServiceImpl implements StudentService{

　　@Autowired
　　private JdbcTemplate jdbcTemplate;

　　@Override
　　public void create(Student s) {
　　　　String sql = "insert into STUDENT(ID, NAME, AGE, score) values(?, ?, ?, ?)";
　　　　jdbcTemplate.update(sql, s.getId(), s.getName(), s.getAge(), s.getScore());
　　}

　　@Override
　　public List<Student> getAll() {
　　　　String sql = "select * from STUDENT ";
　　　　return jdbcTemplate.query(sql, new BeanPropertyRowMapper(Student.class));
　　}

　　@Override
　　　　public void deleteAllUsers() {
　　　　String sql = "delete from STUDENT";
　　　　jdbcTemplate.execute(sql);
　　}

　　@Override
　　public void updateById(Student s) {
　　　　String sql = "update STUDENT set name=?, age=?, score=? where id=?";
　　　　jdbcTemplate.update(sql, new Object[]{s.getName(), s.getAge(), s.getScore(), s.getId()});
　　}

　　@Override
　　public Student getOneById(int id) {
　　　　String sql = "select * from STUDENT where id = ?";
　　　　return jdbcTemplate.queryForObject(sql, new Object[]{id}, new BeanPropertyRowMapper<>(Student.class));
　　}

}

使用JUnit測試，在pom文件裏先添加依賴

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

寫測試類，

import java.util.List;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.context.web.WebAppConfiguration;

@RunWith(SpringRunner.class)
@SpringBootTest(classes=DemoApplication.class)
@WebAppConfiguration
public class JdbcTest {

　　@Autowired
　　private StudentService studentService;

　　@Test
　　public void test() throws Exception {

　　// 先刪除全部數據 　　studentService.deleteAllUsers(); 　　Student s1 = new Student(1001, "andy lau", 11, 80.00); 　　Student s2 = new Student(1002, "lucy 1", 12, 85.00); 　　Student s3 = new Student(1003, "lily", 13, 75.00); 　　Student s4 = new Student(1004, "tom kk", 14, 94.00); 　　studentService.create(s1); 　　studentService.create(s2); 　　studentService.create(s3); 　　studentService.create(s4); 　　// 查詢全部 　　List<Student> stuList = studentService.getAll(); 　　for(Student stu : stuList){ 　　　　System.out.println(stu); 　　} 　　// 根據ID查詢 　　Student stu = studentService.getOneById(1003); 　　System.out.println("---update 前----" + stu); 　　stu.setName("lily Green"); 　　stu.setScore(90.00); 　　// 根據id修改 　　studentService.updateById(stu); 　　System.out.println("---update 後----" + stu); 　　}}