Spring Boot 2.x基础教程：使用JdbcTemplate访问MySQL数据库

Author: dyc87112

2.1.x/chapter3-1/pom.xml

@@ -32,7 +32,7 @@
 		<dependency>
 			<groupId>mysql</groupId>
 			<artifactId>mysql-connector-java</artifactId>
-			<version>5.1.21</version>
+			<version>5.1.46</version>
 		</dependency>
 
 		<dependency>

2.1.x/chapter3-1/src/main/java/com/didispace/chapter31/UserService.java

@@ -10,7 +10,7 @@ public interface UserService {
      * @param name
      * @param age
      */
-    void create(String name, Integer age);
+    int create(String name, Integer age);
 
     /**
      * 根据name查询用户
@@ -25,16 +25,16 @@ public interface UserService {
      *
      * @param name
      */
-    void deleteByName(String name);
+    int deleteByName(String name);
 
     /**
      * 获取用户总量
      */
-    Integer getAllUsers();
+    int getAllUsers();
 
     /**
      * 删除所有用户
      */
-    void deleteAllUsers();
+    int deleteAllUsers();
 
 }

2.1.x/chapter3-1/src/main/java/com/didispace/chapter31/UserServiceImpl.java

@@ -19,8 +19,9 @@ public class UserServiceImpl implements UserService {
     }
 
     @Override
-    public void create(String name, Integer age) {
-        jdbcTemplate.update("insert into USER(NAME, AGE) values(?, ?)", name, age);
+    public int create(String name, Integer age) {
+        int row = jdbcTemplate.update("insert into USER(NAME, AGE) values(?, ?)", name, age);
+        return row;
     }
 
     @Override
@@ -35,18 +36,21 @@ public List<User> getByName(String name) {
     }
 
     @Override
-    public void deleteByName(String name) {
-        jdbcTemplate.update("delete from USER where NAME = ?", name);
+    public int deleteByName(String name) {
+        int row = jdbcTemplate.update("delete from USER where NAME = ?", name);
+        return row;
     }
 
     @Override
-    public Integer getAllUsers() {
-        return jdbcTemplate.queryForObject("select count(1) from USER", Integer.class);
+    public int getAllUsers() {
+        int row = jdbcTemplate.queryForObject("select count(1) from USER", Integer.class);
+        return row;
     }
 
     @Override
-    public void deleteAllUsers() {
-        jdbcTemplate.update("delete from USER");
+    public int deleteAllUsers() {
+        int row = jdbcTemplate.update("delete from USER");
+        return row;
     }
 
 }

2.1.x/chapter3-1/src/test/java/com/didispace/chapter31/Chapter31ApplicationTests.java

@@ -7,10 +7,12 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.http.MediaType;
+import org.springframework.test.annotation.Rollback;
 import org.springframework.test.context.junit4.SpringRunner;
 import org.springframework.test.web.servlet.MockMvc;
 import org.springframework.test.web.servlet.RequestBuilder;
 import org.springframework.test.web.servlet.setup.MockMvcBuilders;
+import org.springframework.transaction.annotation.Transactional;
 
 import static org.hamcrest.Matchers.equalTo;
 import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.*;
@@ -41,14 +43,14 @@ public void test() throws Exception {
         userSerivce.create("Linda", 17);
 
         // 查数据库，应该有5个用户
-        Assert.assertEquals(5, userSerivce.getAllUsers().intValue());
+        Assert.assertEquals(5, userSerivce.getAllUsers());
 
         // 删除两个用户
         userSerivce.deleteByName("Tom");
         userSerivce.deleteByName("Mike");
 
         // 查数据库，应该有5个用户
-        Assert.assertEquals(3, userSerivce.getAllUsers().intValue());
+        Assert.assertEquals(3, userSerivce.getAllUsers());
 
     }