使用jdbcTemplate访问数据库
This commit is contained in:
@@ -0,0 +1,13 @@
|
||||
package com.didispace;
|
||||
|
||||
import org.springframework.boot.SpringApplication;
|
||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||
|
||||
@SpringBootApplication
|
||||
public class Application {
|
||||
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(Application.class, args);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,35 @@
|
||||
package com.didispace.service;
|
||||
|
||||
/**
|
||||
* @author 程序猿DD
|
||||
* @version 1.0.0
|
||||
* @date 16/3/17 下午7:04.
|
||||
* @blog http://blog.didispace.com
|
||||
*/
|
||||
public interface UserService {
|
||||
|
||||
/**
|
||||
* 新增一个用户
|
||||
* @param name
|
||||
* @param age
|
||||
*/
|
||||
void create(String name, Integer age);
|
||||
|
||||
/**
|
||||
* 根据name删除一个用户高
|
||||
* @param name
|
||||
*/
|
||||
void deleteByName(String name);
|
||||
|
||||
/**
|
||||
* 获取用户总量
|
||||
*/
|
||||
Integer getAllUsers();
|
||||
|
||||
/**
|
||||
* 删除所有用户
|
||||
*/
|
||||
void deleteAllUsers();
|
||||
|
||||
|
||||
}
|
||||
@@ -0,0 +1,38 @@
|
||||
package com.didispace.service;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.jdbc.core.JdbcTemplate;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @author 程序猿DD
|
||||
* @version 1.0.0
|
||||
* @date 16/3/17 下午6:44.
|
||||
* @blog http://blog.didispace.com
|
||||
*/
|
||||
@Service
|
||||
public class UserServiceImpl implements UserService {
|
||||
|
||||
@Autowired
|
||||
private JdbcTemplate jdbcTemplate;
|
||||
|
||||
@Override
|
||||
public void create(String name, Integer age) {
|
||||
jdbcTemplate.update("insert into USER(NAME, AGE) values(?, ?)", name, age);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteByName(String name) {
|
||||
jdbcTemplate.update("delete from USER where NAME = ?", name);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Integer getAllUsers() {
|
||||
return jdbcTemplate.queryForObject("select count(1) from USER", Integer.class);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteAllUsers() {
|
||||
jdbcTemplate.update("delete from USER");
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,4 @@
|
||||
spring.datasource.url=jdbc:mysql://localhost:3306/test
|
||||
spring.datasource.username=root
|
||||
spring.datasource.password=52261340
|
||||
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
|
||||
@@ -0,0 +1,48 @@
|
||||
package com.didispace;
|
||||
|
||||
import com.didispace.service.UserService;
|
||||
import org.junit.Assert;
|
||||
import org.junit.Before;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.test.SpringApplicationConfiguration;
|
||||
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
||||
|
||||
|
||||
@RunWith(SpringJUnit4ClassRunner.class)
|
||||
@SpringApplicationConfiguration(Application.class)
|
||||
public class ApplicationTests {
|
||||
|
||||
@Autowired
|
||||
private UserService userSerivce;
|
||||
|
||||
@Before
|
||||
public void setUp() {
|
||||
// 准备,清空user表
|
||||
userSerivce.deleteAllUsers();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void test() throws Exception {
|
||||
// 插入5个用户
|
||||
userSerivce.create("a", 1);
|
||||
userSerivce.create("b", 2);
|
||||
userSerivce.create("c", 3);
|
||||
userSerivce.create("d", 4);
|
||||
userSerivce.create("e", 5);
|
||||
|
||||
// 查数据库,应该有5个用户
|
||||
Assert.assertEquals(5, userSerivce.getAllUsers().intValue());
|
||||
|
||||
// 删除两个用户
|
||||
userSerivce.deleteByName("a");
|
||||
userSerivce.deleteByName("e");
|
||||
|
||||
// 查数据库,应该有5个用户
|
||||
Assert.assertEquals(3, userSerivce.getAllUsers().intValue());
|
||||
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user