当前位置： 首页 > news >正文

【SpringBoot Web框架实战教程】05 Spring Boot 使用 JdbcTemplate 操作数据库

news 2025/6/26 15:08:00

不积跬步，无以至千里；不积小流，无以成江海。大家好，我是闲鹤，微信：xxh_1459，十多年开发、架构经验，先后在华为、迅雷服役过，也在高校从事教学3年；目前已创业了7年多，主要从事物联网/车联网相关领域和业务。喜欢交友、骑行、写毛笔字、弹吉他、折腾硬件和写代码。

导读

这是一系列关于 SpringBoot Web框架实战 的教程，从项目的创建，到一个完整的 web 框架（包括异常处理、拦截器、context 上下文等）；从0开始，到一个可以直接运用在生产环境中的web框架，所有源码均开源。

正文

这篇我们再深入学习 Spring Boot 如何来操作数据库。

本篇，我们使用 JdbcTemplate 方式来作为 Spring Boot 连接 数据库（MySQL）的工具。

创建数据库表

  • 创建库：

    create database app_test;

  • 创建 user 表:

    create table `jdz_user`
(`uid` int unsigned not null auto_increment,`name` varchar(64) not null default '',`age` tinyint not null default 0,`addr` varchar(128) not null default '',primary key (`uid`),unique (`name`)
)engine = innodb default charset = utf8;

添加依赖

<!--导入JDBC的场景启动器-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jdbc</artifactId>
</dependency><!--导入数据库驱动-->
<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId>
</dependency>

增加配置文件

新建文件: app/src/main/resources/application.properties

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/app_test?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC&characterEncoding=utf8
spring.datasource.username=root
spring.datasource.password=# 空闲时，最少的连接池数量
spring.datasource.hikari.minimum-idle=5

注： 1. spring.datasource.url 中，characterEncoding 是规定编码方式，最好加上，否则可能出现中文乱码情况 2. spring.datasource.hikari.minimum-idle 为 HikariPool 数据库连接池最小的与mysql连接数

代码编写

创建实体类

创建与数据表对应的实体类：

package com.jdz.entity;public class User {private Integer uid;private String name;private Integer age;private String addr;
}

创建 DAO

1. 创建 IUserDAO 接口
package com.jdz.dao;import com.jdz.entity.User;import java.util.List;public interface IUserDAO {public boolean doCreate(User user);public User findByUid(Integer uid);public List<User> findAll();
}
2. 创建具体的 DAO 实现

创建 DAO 具体的实现类，并在这层进行数据库操作

package com.jdz.dao.impl;import com.jdz.dao.IUserDAO;
import com.jdz.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Repository;import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;@Repository
public class UserDAOImpl implements IUserDAO {@Autowiredprivate JdbcTemplate jdbcTemplate;@Overridepublic boolean doCreate(User user) {return jdbcTemplate.update("insert into `jdz_user`(`name`, `age`, `addr`) values (?, ?, ?)", user.getName(), user.getAge(), user.getAddr()) > 0;}@Overridepublic boolean doDel(Integer uid) {return jdbcTemplate.update("DELETE from `jdz_user` where uid=?", uid) > 0;}@Overridepublic User findByUid(Integer uid) {try {return jdbcTemplate.queryForObject("select * from `jdz_user` where uid=?", new RowMapper<User>() {@Overridepublic User mapRow(ResultSet rs, int rowNum) throws SQLException {User user = new User();user.setUid(rs.getInt(1));user.setName(rs.getString(2));user.setAge(rs.getInt(3));user.setAddr(rs.getString(4));return user;}}, uid);} catch (EmptyResultDataAccessException e) {return null;}}@Overridepublic List<User> findAll() {return jdbcTemplate.query("SELECT * FROM `jdz_user`", new BeanPropertyRowMapper<User>(User.class));}
}

有几点要注意 1. jdbcTemplate 使用 @Autowired 注解

@Autowired
private JdbcTemplate jdbcTemplate;

  1. UserDAOImpl 类使用 @Repository 注解

    @Repository
public class UserDAOImpl implements IUserDAO {}

  2. 在使用 jdbcTemplate.queryForObject，当查询结果为空时，会报异常，所以使用 try{}catch(){} 进行异常捕获（当然也可以用其他方式替代）

3. 创建 Service
package com.jdz.service;import com.jdz.dao.impl.UserDAOImpl;
import com.jdz.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.List;@Service
public class UserService {@Autowiredprivate UserDAOImpl userDAO;public boolean createUser(User user) {return userDAO.doCreate(user);}public boolean delUser(Integer uid) {return userDAO.doDel(uid);}public User getUser(Integer uid) {return userDAO.findByUid(uid);}public List<User> getAll() {return userDAO.findAll();}
}

有几点要注意 1. userDAO 使用 @Autowired 注解 2. UserService 类使用 @Service 注解

4. 创建 controller
package com.jdz.controllers;import com.jdz.entity.User;
import com.jdz.service.UserService;
import com.jdz.util.ErrType;
import com.jdz.util.RtData;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;@RestController
public class UserController extends BaseController {@Autowiredprivate UserService userService;@RequestMapping("/user/add")public RtData<User> addUser(User user) {if(user.getName() == null || user.getAge() == null || user.getAddr() == null) {return rtJson(ErrType.ERR_PARAMS);}userService.createUser(user);return rtJson(user);}@RequestMapping("/user/info")public RtData<User> info(Integer uid) {return rtJson(userService.getUser(uid));}@RequestMapping("/user/del")public RtData<Boolean> delUser(Integer uid) {return rtJson(userService.delUser(uid));}@RequestMapping("/user/list")public RtData<List<User>> userList() {return rtJson(userService.getAll());}
}

有几点要注意 1. userService 使用 @Autowired 注解 2. 关于 JdbcTemplate 的理解

启动服务后，浏览器访问相应的路由，即可操作数据库中的数据。

这里比较难理解的是，@Autowired 注解，以及相应的字段的初始化过程。（在 spring 启动时，通过 @Autowired ，由 spring 进行初始化）

系列文章
【SpringBoot Web框架实战教程】01 使用 pom 方式创建 SpringBoot 第一个项目
【SpringBoot Web框架实战教程】02 SpringBoot 返回 JSON
【SpringBoot Web框架实战教程】03 SpingBoot 获取 http 请求参数
【SpringBoot Web框架实战教程】04 SpringBoot 规范统一输出 json

近期文章
# 车联网
【自动化运维】不要相信人，把所有的东西都交给机器去处理
从华为无线网络框架说Dispatch服务
百万级物联网框架设计
高并发服务器之泄峰
 

# 硬件
stm32驱动直流电机实现启动/加速/减速/倒车/停车等功能
stm32 定时器输出比较(OC)与PWM的理解和应用
stm32 定时器中断
STM32 外部中断的理解

http://www.lryc.cn/news/386224.html

相关文章：

  • Spark基于DPU的Native引擎算子卸载方案
  • Mini2440 start.s 修改支持串口输出，方便调试 （四）
  • 【教程】几种不同的RBF神经网络
  • 【Liunx-后端开发软件安装】Liunx安装FDFS并整合nginx
  • 【Java笔记】Flyway数据库管理工具的基本原理
  • 国际数字影像产业园创业培训，全面提升创业能力！
  • pyqt5 制作视频剪辑软件，切割视频
  • VUE----通过nvm管理node版本
  • R语言进行字符的替换和删减gsub，substr函数
  • 2024年6月27日，欧盟REACH法规新增第31批1项SVHC高关注物质
  • 高通410-linux棒子设置网络驱动
  • PostgreSQL的系统视图pg_stat_archiver
  • 【D3.js in Action 3 精译】第一部分 D3.js 基础知识
  • 面试经验分享 | 渗透测试工程师(实习岗)
  • STM32 IWDG(独立看门狗)
  • ios swift5 获取wifi列表
  • 回溯法c++学习 解决八皇后问题
  • 5. Spring IoCDI ★ ✔
  • 数据库自动备份到gitee上，实现数据自动化备份
  • 探索 Spring Cloud Gateway：构建微服务架构的关键一环
  • P1114 “非常男女”计划最优解
  • C++ | Leetcode C++题解之第187题重复的DNA序列
  • 构建、标记和发布镜像
  • [Go Web] Kratos 使用的简单总结
  • 首个实时 AI 视频生成技术发布；科大讯飞发布星火大模型 4.0 丨 RTE 开发者日报
  • 什么是容器镜像
  • ElasticSearch-Windows系统ElasticSearch(ES)的下载及安装
  • 【应用开发二】GPIO操控（输出、输入、中断）
  • 单点登录方法
  • springboot集成JPA并配置hikariCP连接池问题解决