SpringBoot連線資料庫JDBCTemplate方式
阿新 • • 發佈:2018-12-07
廢話不多說,直接上程式碼了,因為在學習的過程中經常要用到,所以掌握下是必要的!
Maven專案建立好SpringBoot專案之後,就可以開始編寫程式碼,注意各自的資料庫連線地址是不一樣的,但是大多數人是jdbc:mysql://localhost:30306/liangtest:
第一步 : 匯入jdbc的jar包依賴
<!-- 新增jdbc依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId >
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
第二步 : 建立application.yml資料庫配置檔案 , 配置相關資料庫資訊
#設定jdbc相關配置
spring:
datasource:
url: jdbc:mysql://10.1.1.3:3306/liangtest
username: root
password: root
driver-class-name: com.mysql.jdbc.Driver
max-idle: 10
max-wait: 10000
min-idle: 5
initial-size: 5
#設定執行埠
server:
port: 8081
session:
timeout: 10
#設定字元編碼集
tomcat:
uri-encoding: utf-8
第三步: 建立相關實體類 和 資料庫表
第四步 : 建立Controller類 , 進行相關的操作
具體的程式碼如下:
package com.example.demo.com.example.controller;
import com.example.demo.pojp.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.web.bind.annotation.*;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
/**
* Created by rcc on 2017/12/11.
*/
@RestController
public class DbController {
@Autowired
private JdbcTemplate jdbcTemplate;
//獲取user列表
@RequestMapping("/getUserList")
@ResponseBody
public List<Map<String, Object>> getUserList(){
String sql = "select * from user";
List<Map<String, Object>> userList = jdbcTemplate.queryForList(sql);
return userList;
}
//通過使用者id查詢
@RequestMapping("/getUserById/{id}")
@ResponseBody
public User getUserById(@PathVariable Integer id){
String sql = "select * from user where id="+id;
RowMapper<User> mapper = new RowMapper<User>() {
@Override
public User mapRow(ResultSet rs, int i) throws SQLException {
User user = new User();
user.setId(rs.getLong("id"));
user.setName(rs.getString("name"));
user.setAge(rs.getInt("age"));
return user;
}
};
User user = jdbcTemplate.queryForObject(sql, mapper);
return user;
}
//新增使用者
@RequestMapping(value = "/addUser/{name}/{age}" , method = RequestMethod.GET )
public void addUser(@PathVariable String name , @PathVariable Integer age){
String sql = "insert into user(name,age) values('"+name+"','"+age+"')";
jdbcTemplate.execute(sql);
}
//刪除使用者
@RequestMapping(value = "/delete/{id}" , method = RequestMethod.GET)
public void deleteUser(@PathVariable Integer id){
String sql = "delete from user where id = "+id;
jdbcTemplate.execute(sql);
}
//修改使用者
@RequestMapping(value = "/update/{id}/{name}" , method = RequestMethod.GET)
public void updateUser(@PathVariable Integer id,@PathVariable String name){
String sql = "update user set name='"+name+"' where id='"+id+"'";
jdbcTemplate.execute(sql);
}
}
以上簡單地實現了有關於資料庫的增刪改查功能,剛入手SpringBoot的同學可以參考下。