微服務 SpringBoot 2.0（七）：使用JdbcTemplates訪問Mysql
阿新 • • 發佈：2018-12-12
一切沒有與資料庫互動的網站都是假網站 —— Java面試必修
引言
在web開發服務中，開發人員要做的事情就是將資料庫中的資料返回至前端頁面，在第五章我們已經整合了頁面，今天我們再結合資料庫做一個完整的增刪改查功能，馬上要進入資料互動了，緊不緊張
在接下來的文章中，我在末尾處會公佈原始碼，原始碼將託管在碼雲上
JdbcTemplate
工具
SpringBoot版本：2.0.4 開發工具：IDEA 2018 Maven：3.3 9 DB：mysql JDK：1.8
依賴
<dependency>
<groupId>org.springframework.boot</ 新增上面程式碼後一定要重新整理依賴噢
資料來源配置
在src/main/resources/application.yml中配置資料來源資訊。
spring.datasource:
url: jdbc:mysql://192.168.2.211:3306/springboot?useUnicode=true&characterEncoding=utf-8
username: root
password: 123456
driver-class-name: com.mysql.jdbc.Driver
spring-boot-starter-jdbc 預設使用tomcat-jdbc資料來源，如果你想使用其他的資料來源，比如這裡使用了阿里巴巴的資料池管理,你應該額外新增以下依賴：
<dependency>
< 初始化mysql
-- create table `website_jdbc`
CREATE TABLE `website_jdbc` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(50) NOT NULL,
`url` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8;
INSERT INTO `website_jdbc` VALUES (1,'Java面試必修', 'www.itmsbx.com');
INSERT INTO `website_jdbc` VALUES (2,'物件無憂', 'www.51object.com');
INSERT INTO `website_jdbc` VALUES (3,'上海恆驪資訊科技', 'www.henliy.com');
INSERT INTO `website_jdbc` VALUES (4 , '淘寶網', 'www.taobao.com');
編寫Bean，Service，Dao
bean
public class WebSiteBean {
//省略 getter 和 setter
private Long id;
private String name;
private String url;
}
service
public interface WebSiteService {
int add(WebSiteBean webSiteBean);
int update(WebSiteBean webSiteBean);
int deleteByIds(String ids);
List<WebSiteBean> queryWebSiteList(Map<String,Object> params);
}
@Service
public class WebSiteServiceImpl implements WebSiteService {
@Autowired
private WebSiteDao webSiteDao;
@Override
public int add(WebSiteBean webSiteBean) {
return webSiteDao.add(webSiteBean);
}
@Override
public int update(WebSiteBean webSiteBean) {
return webSiteDao.update(webSiteBean);
}
@Override
public int deleteByIds(String ids) {
return webSiteDao.deleteByIds(ids);
}
@Override
public List<WebSiteBean> queryWebSiteList(Map<String, Object> params) {
return webSiteDao.queryWebSiteList(params);
}
}
dao
public interface WebSiteDao {
int add(WebSiteBean webSiteBean);
int update(WebSiteBean webSiteBean);
int deleteByIds(String ids);
List<WebSiteBean> queryWebSiteList(Map<String,Object> params);
}
@Repository
public class WebSiteDaoImpl implements WebSiteDao {
@Autowired
private JdbcTemplate jdbcTemplate;
@Override
public int add(WebSiteBean webSiteBean) {
return jdbcTemplate.update("insert into website_jdbc(name,url) values(?, ?)"
,webSiteBean.getName(),webSiteBean.getUrl());
}
@Override
public int update(WebSiteBean webSiteBean) {
return jdbcTemplate.update("update website_jdbc set name=?,url where id = ?",
new Object[]{webSiteBean.getName(),webSiteBean.getUrl(),webSiteBean.getId()});
}
@Override
public int deleteByIds(String ids) {
return jdbcTemplate.update("delete from website_jdbc where id in(" + ids + ")");
}
@Override
public List<WebSiteBean> queryWebSiteList(Map<String, Object> params) {
StringBuffer sql =new StringBuffer();
sql.append("select * from website_jdbc where 1=1");
if(params.containsKey("name")){
sql.append(" and name like '%").append(String.valueOf(params.get("name"))).append("%'");
}
if(params.containsKey("url")){
sql.append(" and url like '%").append((String)params.get("url")).append("%'");
}
List<WebSiteBean> list = jdbcTemplate.query(sql.toString() , new BeanPropertyRowMapper(WebSiteBean.class));
return list;
}
}
Dao實現類,這裡注入我們需要的JdbcTemplate，然後通過JdbcTemplate提供的介面進行增刪查該的操作，這裡我就寫幾個簡單的，更多可以自行檢視JdbcTemplate提供的api
編寫Controller
@Controller
@RequestMapping("/jdbc")
public class WebSiteController {
@Autowired
private WebSiteService websiteService;
@RequestMapping("query")
public ModelAndView query(){
Map<String,Object> params = new HashMap<>();
params.put("name","Java面試必修");
List<WebSiteBean> webSiteBeans = websiteService.queryWebSiteList(params);
ModelAndView mav = new ModelAndView("/list");
mav.addObject("webSiteBeans",webSiteBeans);
mav.addObject("hint","想學習更多面試技巧和知識，請關注公眾號：Java面試必修（itmsbx）");
return mav;
}
}
更改Application
@SpringBootApplication
public class DemoJdbcApplication {
@Autowired
private Environment env;
//destroy-method="close"的作用是當資料庫連線不使用的時候,就把該連線重新放到資料池中,方便下次使用呼叫.
@Bean(destroyMethod = "close")
public DataSource dataSource() {
DruidDataSource dataSource = new DruidDataSource();
dataSource.setUrl(env.getProperty("spring.datasource.url"));
dataSource.setUsername(env.getProperty("spring.datasource.username"));//使用者名稱
dataSource.setPassword(env.getProperty("spring.datasource.password"));//密碼
dataSource.setDriverClassName(env.getProperty("spring.datasource.driver-class-name"));
dataSource.setInitialSize(2);//初始化時建立物理連線的個數
dataSource.setMaxActive(20);//最大連線池數量
dataSource.setMinIdle(0);//最小連線池數量
dataSource.setMaxWait(60000);//獲取連線時最大等待時間，單位毫秒。
dataSource.setValidationQuery("SELECT 1");//用來檢測連線是否有效的sql
dataSource.setTestOnBorrow(false);//申請連線時執行validationQuery檢測連線是否有效
dataSource.setTestWhileIdle(true);//建議配置為true，不影響效能，並且保證安全性。
dataSource.setPoolPreparedStatements(false);//是否快取preparedStatement，也就是PSCache
return dataSource;
}
public static void main(String[] args) {
SpringApplication.run(DemoJdbcApplication.class, args);
}
}
到這裡啟動伺服器，瀏覽器輸入http://localhost:8080/jdbc/query 看看效果吧
總結
本章講解了使用JdbcTemplates訪問Mysql資料庫，實現了資料互動，看上去是不是還是很簡單呢？不過光是JdbcTemplates還是不夠的，畢竟咱們還是要深入企業主流框架，下一章我將帶大家整合Mybatis框架，後面的原始碼將整合一個開源的網站來進行講解，學完這些框架之後，你也能收穫一個自己動手的網站，一舉多得是不是很有動力
原始碼地址：
作者有話說：喜歡的話就請移步Java面試必修網，請自備水，更多幹、幹、乾貨等著你