当前位置：首页 » 《随便一记》 » 正文

SpringBoot2.X基础教程：SpringBoot整合JdbcTemplate【附源码】_java程序鱼的博客

23 人参与  2022年02月20日 09:27  分类 : 《随便一记》  评论

点击全文阅读


微信号：hzy1014211086，如果你正在学习Spring Boot，可以加入我们的Spring技术交流群，共同成长

文章目录

  • 一、准备数据表
  • 二、引入依赖
  • 三、配置数据源
  • 四、编写领域对象
  • 五、新增
  • 六、修改
  • 七、查询
  • 八、删除
  • 九、源码

JdbcTemplate 是 Spring 自带的 JDBC 模板组件，底层实现了对 JDBC 的封装，我们可以借助 JdbcTemplate 来执行所有数据库操作，例如插入、更新、删除和从数据库中检索数据，并且有效避免直接使用 jdbc 带来的繁琐编码。

JdbcTemplate主要提供以下五种类型的方法：

  • execute方法：可以用于执行任何SQL语句，一般用于执行DDL语句。
  • update、batchUpdate方法：用于执行新增、修改、删除等语句。
  • query方法及queryForXXX方法：用于执行查询相关的语句。
  • call方法：用于执行数据库存储过程和函数相关的语句。

当然，在大部分情况下，我们都会直接使用更加强大的持久化框架来访问数据库，比如MyBatis、Hibernate 或者 Spring Data JPA，我们这里讲解 JdbcTemplate 的整合，只是想让家更加了解底层原理。

一、准备数据表

CREATE TABLE `spring_boot`.`article`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `title` varchar(255) NULL COMMENT '文章标题',
  `author` varchar(255) NULL COMMENT '作者',
  PRIMARY KEY (`id`)
) COMMENT = '文章表';

二、引入依赖

<dependencies>
	<!-- MySQL 依赖 -->
	<dependency>
		<groupId>mysql</groupId>
		<artifactId>mysql-connector-java</artifactId>
		<scope>runtime</scope>
	</dependency>
	
	<!-- Spring JDBC 依赖 -->
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-jdbc</artifactId>
	</dependency>
	
	<!-- Spring Web 依赖 -->
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-web</artifactId>
	</dependency>
</dependencies>

三、配置数据源

spring.datasource.url = jdbc:mysql://139.196.20.xxx:3306/spring_boot?useUnicode=true&characterEncoding=utf-8
spring.datasource.username = root
spring.datasource.password = 123456
spring.datasource.driver-class-name = com.mysql.cj.jdbc.Driver

因为 Spring Boot 2.5.4 默认使用了MySQL 8.0.26 的驱动，所以这里采用com.mysql.cj.jdbc.Driver，而不是老的com.mysql.jdbc.Driver。

四、编写领域对象

@Data
@NoArgsConstructor
public class Blog {
  private Integer id;
  private String title;
  private String author;
}

这里我们使用Lombok，需要在IDEA里安装Lombok插件，不然会报错，get、set方法找不到。
在这里插入图片描述

五、新增

JdbcTemplate 中，除了查询有几个 API 之外，增删改统一都使用 update 来操作，自己来传入 SQL 即可。

update 方法的返回值就是 SQL 执行受影响的行数。

@RestController
public class BlogController {

  @Autowired
  public BlogService blogService;

  /**
   * 新增一篇文章
   *
   * @param blog 文章实体类
   * @return
   */
  @PostMapping(value = "/create")
  public Object create(@RequestBody Blog blog) {
    if (StringUtils.isBlank(blog.getTitle())) {
      return ResponseUtil.fail(ResultEnums.BAD_ARGUMENT_VALUE.getCode(), "请输入文章标题");
    }
    if (StringUtils.isBlank(blog.getAuthor())) {
      return ResponseUtil.fail(ResultEnums.BAD_ARGUMENT_VALUE.getCode(), "请输入文章作者");
    }
    return blogService.create(blog);
  }
}

@Service
public class BlogServiceImpl implements BlogService {

  @Autowired
  private JdbcTemplate jdbcTemplate;

  @Override
  public Object create(Blog blog) {
    int count = jdbcTemplate.update("insert into article(title, author) values(?, ?)", blog.getTitle(), blog.getAuthor());
    if (count > 0) {
      return ResponseUtil.ok("插入成功");
    } else {
      return ResponseUtil.fail(ResultEnums.SERIOUS.getCode(), "插入失败");
    }
  }
}

在这里插入图片描述

六、修改

@RestController
public class BlogController {

  @Autowired
  public BlogService blogService;

  /**
   * 通过id修改文章
   *
   * @param blog
   * @return
   */
  @PostMapping(value = "/updateById")
  public Object updateById(@RequestBody Blog blog) {
    if (StringUtils.isBlank(blog.getTitle())) {
      return ResponseUtil.fail(ResultEnums.BAD_ARGUMENT_VALUE.getCode(), "请输入文章标题");
    }
    if (StringUtils.isBlank(blog.getAuthor())) {
      return ResponseUtil.fail(ResultEnums.BAD_ARGUMENT_VALUE.getCode(), "请输入文章作者");
    }
    return blogService.updateById(blog);
  }
}

@Service
public class BlogServiceImpl implements BlogService {

  @Autowired
  private JdbcTemplate jdbcTemplate;

  @Override
  public Object updateById(Blog blog) {
    int count = jdbcTemplate.update("update article set title=?,author=? where id=?", blog.getTitle(), blog.getAuthor(), blog.getId());
    if (count > 0) {
      return ResponseUtil.ok("修改成功");
    } else {
      return ResponseUtil.fail(ResultEnums.SERIOUS.getCode(), "修改失败");
    }
  }
}

在这里插入图片描述

七、查询

@RestController
public class BlogController {

  @Autowired
  public BlogService blogService;

  /**
   * 查询所有文章
   *
   * @return
   */
  @GetMapping(value = "/getAll")
  public List<Blog> getAll() {
    return blogService.getAll();
  }


  /**
   * 通过标题查询文章
   *
   * @param title
   * @return
   */
  @GetMapping(value = "/getByTitle")
  public Object getByTitle(String title) {
    if (StringUtils.isBlank(title)) {
      return ResponseUtil.fail(ResultEnums.BAD_ARGUMENT_VALUE.getCode(), "请输入文章标题");
    }
    return blogService.getByTitle(title);
  }
}

@Service
public class BlogServiceImpl implements BlogService {

  @Autowired
  private JdbcTemplate jdbcTemplate;

  @Override
  public List<Blog> getAll() {
    return jdbcTemplate.query("select * from article", new BeanPropertyRowMapper<>(Blog.class));
  }

  @Override
  public List<Blog> getByTitle(String title) {
  	// 如果不会Lambda表达式的小伙伴可以看下面的代码
    return jdbcTemplate.query("select * from article where title = ?", (resultSet, i) -> {
      Blog blog = new Blog();
      blog.setId(resultSet.getInt("id"));
      blog.setTitle(resultSet.getString("title"));
      blog.setAuthor(resultSet.getString("author"));
      return blog;
    }, title);
  }

  @Override
  public List<Blog> getByTitle(String title) {
  	// 照顾到有小伙伴不会Lambda表达式，我这里把另一种方案也写出来
    return jdbcTemplate.query("select * from article where title = ?", new RowMapper<Blog>() {
      @Override
      public Blog mapRow(ResultSet resultSet, int i) throws SQLException {
        Blog blog = new Blog();
        blog.setId(resultSet.getInt("id"));
        blog.setTitle(resultSet.getString("title"));
        blog.setAuthor(resultSet.getString("author"));
        return blog;
      }
    }, title);
  }

}

在这里插入图片描述
在这里插入图片描述

八、删除

删除也是使用 update API，传入你的 SQL 即可

@RestController
public class BlogController {

  @Autowired
  public BlogService blogService;
  
  /**
   * 通过ID删除文章
   *
   * @param id
   * @return
   */
  @PostMapping(value = "/deleteById")
  public Object deleteById(Integer id) {
    if (null == id || 0 == id.longValue()) {
      return ResponseUtil.fail(ResultEnums.BAD_ARGUMENT_VALUE.getCode(), "请输入文章id");
    }
    return blogService.deleteById(id);
  }
}

@Service
public class BlogServiceImpl implements BlogService {

  @Autowired
  private JdbcTemplate jdbcTemplate;
  
  @Override
  public Object deleteById(Integer id) {
    int count = jdbcTemplate.update("delete from article where id=?", id);
    if (count > 0) {
      return ResponseUtil.ok("删除成功");
    } else {
      return ResponseUtil.fail(ResultEnums.SERIOUS.getCode(), "删除失败");
    }
  }
}

在这里插入图片描述

更多其他数据访问操作的使用请参考：JdbcTemplate API

彩蛋，很多小伙伴会发现一个问题，项目启动一段时间放那里不动，然后在访问接口时，就会报错，这和我们使用的数据源有关（Hikari），在后面《数据源详解》章节我会教大家如何解决。

九、源码

本文的相关例子可以查看下面仓库中的 chapter4 目录：

  • Gitee：https://gitee.com/hezhiyuan007/spring-boot-study
  • Github：https://github.com/java-fish-0907/spring-boot-study

点击全文阅读


本文链接：http://m.zhangshiyu.com/post/35000.html

文章  请输入  删除  
<< 上一篇 下一篇 >>

  • 评论（0）
  • 赞助本站

◎欢迎参与讨论，请在这里发表您的看法、交流您的观点。

最新文章

  • C++——string的模拟实现（上）
  • WebStorm用Debug模式调试Vue等前端项目
  • 介绍18种WEB常见漏洞
  • docker配置镜像加速器
  • Docker 构建报错：Get https://registry-1.docker.io/v2/: net/http: request canceled while waiting for conne
  • 因为爱你，所以用死来惩罚你小说有没有完结版在线？
  • 叶秋小说《终极狂少：无敌从解锁神级系统开始》在线阅读
  • 在线阅读无敌疯皇子，父皇跪求我登基！秦笑姜凝雪小说章节目录大结局
  • 当影帝开始模拟犯罪精彩章节免费在线阅读，陈树苏小小完结版
  • 祁愿小说盗笔：开启空间，我带主角团起飞在线阅读章节
  • 秦川陈欢（当失望已成习惯，我放手了）小说章节在线免费试读
  • 《心碎！我们的仙女明星有老公》小说精彩章节免费试读，江予棠许清樾小说在线阅读

    关于我们 | 我要投稿 | 免责申明

    Copyright © 2020-2022 ZhangShiYu.com Rights Reserved.豫ICP备2022013469号-1