1. 程式人生 > >SpringBoot連線資料庫JDBCTemplate方式

SpringBoot連線資料庫JDBCTemplate方式

廢話不多說,直接上程式碼了,因為在學習的過程中經常要用到,所以掌握下是必要的!
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的同學可以參考下。