行业资讯

SpringBoot怎么整合JdbcTemplate

发布时间：2022-08-30 15:11:27 作者：iii
来源：亿速云 阅读：151

SpringBoot怎么整合JdbcTemplate

1. 引言

在现代的Java开发中，Spring Boot已经成为了一个非常流行的框架，它简化了Spring应用的初始搭建和开发过程。而JdbcTemplate是Spring框架提供的一个用于简化JDBC操作的工具类，它封装了JDBC的核心操作，使得开发者可以更加专注于业务逻辑的实现，而不必过多关注底层的数据库操作细节。

本文将详细介绍如何在Spring Boot项目中整合JdbcTemplate，并通过示例代码展示如何使用JdbcTemplate进行数据库操作。我们将从项目的创建开始，逐步讲解如何配置数据源、如何使用JdbcTemplate进行增删改查操作，以及如何处理事务等。

2. 创建Spring Boot项目

首先，我们需要创建一个Spring Boot项目。可以通过Spring Initializr来快速生成一个Spring Boot项目。

2.1 使用Spring Initializr创建项目

  1. 打开浏览器，访问 Spring Initializr。
  2. 在页面中填写项目的基本信息：
    • Project: Maven Project
    • Language: Java
    • Spring Boot: 2.7.0 (或其他稳定版本)
    • Group: com.example
    • Artifact: springboot-jdbctemplate
    • Name: springboot-jdbctemplate
    • Package Name: com.example.springbootjdbctemplate
    • Packaging: Jar
    • Java Version: 11
  3. 在 Dependencies 部分，添加以下依赖：
    • Spring Web (可选，用于构建RESTful API)
    • Spring Data JDBC
    • H2 Database (或其他数据库，如MySQL、PostgreSQL等)
  4. 点击 Generate 按钮，下载生成的项目压缩包。
  5. 解压项目压缩包，并使用IDE（如IntelliJ IDEA或Eclipse）导入项目。

2.2 项目结构

导入项目后，项目结构如下：

springboot-jdbctemplate
├── src
│   ├── main
│   │   ├── java
│   │   │   └── com
│   │   │       └── example
│   │   │           └── springbootjdbctemplate
│   │   │               ├── SpringbootJdbctemplateApplication.java
│   │   │               ├── controller
│   │   │               ├── model
│   │   │               ├── repository
│   │   │               └── service
│   │   └── resources
│   │       ├── application.properties
│   │       └── static
│   │       └── templates
│   └── test
│       └── java
│           └── com
│               └── example
│                   └── springbootjdbctemplate
└── pom.xml

3. 配置数据源

在Spring Boot中，数据源的配置非常简单。我们只需要在application.properties文件中添加相应的配置即可。

3.1 配置H2数据库

H2是一个内存数据库，非常适合在开发和测试环境中使用。我们可以在application.properties文件中添加以下配置：

# H2 Database Configuration
spring.datasource.url=jdbc:h2:mem:testdb
spring.datasource.driverClassName=org.h2.Driver
spring.datasource.username=sa
spring.datasource.password=password
spring.h2.console.enabled=true
spring.h2.console.path=/h2-console

3.2 配置MySQL数据库

如果你使用的是MySQL数据库，可以在application.properties文件中添加以下配置：

# MySQL Database Configuration
spring.datasource.url=jdbc:mysql://localhost:3306/mydatabase
spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver
spring.datasource.username=root
spring.datasource.password=root
spring.jpa.database-platform=org.hibernate.dialect.MySQL5InnoDBDialect

4. 创建实体类

在Spring Boot中，实体类通常用于映射数据库中的表。我们可以创建一个简单的实体类User，用于表示用户信息。

package com.example.springbootjdbctemplate.model;

public class User {
    private Long id;
    private String name;
    private String email;

    // Getters and Setters
    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }
}

5. 创建Repository类

在Spring Boot中，Repository类通常用于封装数据库操作。我们可以创建一个UserRepository类，用于操作用户数据。

package com.example.springbootjdbctemplate.repository;

import com.example.springbootjdbctemplate.model.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import java.util.List;

@Repository
public class UserRepository {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    public List<User> findAll() {
        return jdbcTemplate.query("SELECT * FROM users", (rs, rowNum) ->
                new User(
                        rs.getLong("id"),
                        rs.getString("name"),
                        rs.getString("email")
                ));
    }

    public User findById(Long id) {
        return jdbcTemplate.queryForObject("SELECT * FROM users WHERE id = ?", new Object[]{id}, (rs, rowNum) ->
                new User(
                        rs.getLong("id"),
                        rs.getString("name"),
                        rs.getString("email")
                ));
    }

    public int save(User user) {
        return jdbcTemplate.update("INSERT INTO users (name, email) VALUES (?, ?)",
                user.getName(), user.getEmail());
    }

    public int update(User user) {
        return jdbcTemplate.update("UPDATE users SET name = ?, email = ? WHERE id = ?",
                user.getName(), user.getEmail(), user.getId());
    }

    public int deleteById(Long id) {
        return jdbcTemplate.update("DELETE FROM users WHERE id = ?", id);
    }
}

在这个UserRepository类中，我们使用了JdbcTemplate来执行SQL语句。JdbcTemplate提供了多种方法来执行SQL查询、更新等操作。

6. 创建Service类

Service类通常用于封装业务逻辑。我们可以创建一个UserService类，用于处理与用户相关的业务逻辑。

package com.example.springbootjdbctemplate.service;

import com.example.springbootjdbctemplate.model.User;
import com.example.springbootjdbctemplate.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class UserService {

    @Autowired
    private UserRepository userRepository;

    public List<User> findAll() {
        return userRepository.findAll();
    }

    public User findById(Long id) {
        return userRepository.findById(id);
    }

    public int save(User user) {
        return userRepository.save(user);
    }

    public int update(User user) {
        return userRepository.update(user);
    }

    public int deleteById(Long id) {
        return userRepository.deleteById(id);
    }
}

7. 创建Controller类

Controller类用于处理HTTP请求。我们可以创建一个UserController类，用于处理与用户相关的HTTP请求。

package com.example.springbootjdbctemplate.controller;

import com.example.springbootjdbctemplate.model.User;
import com.example.springbootjdbctemplate.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController
@RequestMapping("/users")
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping
    public List<User> findAll() {
        return userService.findAll();
    }

    @GetMapping("/{id}")
    public User findById(@PathVariable Long id) {
        return userService.findById(id);
    }

    @PostMapping
    public int save(@RequestBody User user) {
        return userService.save(user);
    }

    @PutMapping
    public int update(@RequestBody User user) {
        return userService.update(user);
    }

    @DeleteMapping("/{id}")
    public int deleteById(@PathVariable Long id) {
        return userService.deleteById(id);
    }
}

8. 创建数据库表

在使用JdbcTemplate之前，我们需要先创建数据库表。可以在src/main/resources目录下创建一个schema.sql文件，用于定义数据库表结构。

CREATE TABLE users (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255) NOT NULL,
    email VARCHAR(255) NOT NULL
);

然后，在application.properties文件中添加以下配置，以便在应用启动时自动执行schema.sql文件：

spring.datasource.initialization-mode=always

9. 测试应用

现在，我们可以启动应用并测试各个接口。可以使用Postman或curl等工具来发送HTTP请求。

9.1 添加用户

发送POST请求到/users接口，添加一个新用户：

curl -X POST -H "Content-Type: application/json" -d '{"name": "John Doe", "email": "john.doe@example.com"}' http://localhost:8080/users

9.2 查询所有用户

发送GET请求到/users接口，查询所有用户：

curl -X GET http://localhost:8080/users

9.3 查询单个用户

发送GET请求到/users/{id}接口，查询指定ID的用户：

curl -X GET http://localhost:8080/users/1

9.4 更新用户

发送PUT请求到/users接口，更新用户信息：

curl -X PUT -H "Content-Type: application/json" -d '{"id": 1, "name": "Jane Doe", "email": "jane.doe@example.com"}' http://localhost:8080/users

9.5 删除用户

发送DELETE请求到/users/{id}接口，删除指定ID的用户：

curl -X DELETE http://localhost:8080/users/1

10. 处理事务

在数据库操作中，事务管理是非常重要的。Spring Boot提供了简单的事务管理机制，我们可以通过在方法上添加@Transactional注解来启用事务管理。

10.1 在Service类中添加事务管理

我们可以在UserService类中的方法上添加@Transactional注解，以确保这些方法在事务中执行。

package com.example.springbootjdbctemplate.service;

import com.example.springbootjdbctemplate.model.User;
import com.example.springbootjdbctemplate.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

@Service
public class UserService {

    @Autowired
    private UserRepository userRepository;

    @Transactional
    public List<User> findAll() {
        return userRepository.findAll();
    }

    @Transactional
    public User findById(Long id) {
        return userRepository.findById(id);
    }

    @Transactional
    public int save(User user) {
        return userRepository.save(user);
    }

    @Transactional
    public int update(User user) {
        return userRepository.update(user);
    }

    @Transactional
    public int deleteById(Long id) {
        return userRepository.deleteById(id);
    }
}

10.2 测试事务

为了测试事务管理，我们可以在UserService类中添加一个方法，该方法在执行过程中抛出异常，以验证事务是否会回滚。

@Transactional
public int saveWithException(User user) {
    int result = userRepository.save(user);
    if (result > 0) {
        throw new RuntimeException("Simulated exception");
    }
    return result;
}

然后，在UserController中添加一个接口来调用这个方法：

@PostMapping("/with-exception")
public int saveWithException(@RequestBody User user) {
    return userService.saveWithException(user);
}

发送POST请求到/users/with-exception接口，添加一个新用户：

curl -X POST -H "Content-Type: application/json" -d '{"name": "John Doe", "email": "john.doe@example.com"}' http://localhost:8080/users/with-exception

由于在saveWithException方法中抛出了异常，事务将会回滚，用户不会被添加到数据库中。

11. 总结

通过本文的介绍，我们了解了如何在Spring Boot项目中整合JdbcTemplate，并使用JdbcTemplate进行数据库操作。我们从项目的创建开始，逐步讲解了如何配置数据源、如何创建实体类、Repository类、Service类和Controller类，以及如何处理事务。

JdbcTemplate是Spring框架提供的一个非常强大的工具类，它简化了JDBC操作，使得开发者可以更加专注于业务逻辑的实现。通过本文的学习，你应该能够在自己的Spring Boot项目中使用JdbcTemplate进行数据库操作，并掌握事务管理的基本知识。

希望本文对你有所帮助，祝你在Spring Boot开发中取得更大的进步！

推荐阅读：
  1. WebSocket 整合 Springboot
  2. springboot如何整合swagger

免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。

springboot jdbctemplate

上一篇：JAVA基于Slack怎么实现异常日志报警

下一篇：怎么利用insert into values插入多条数据

相关阅读

您好，登录后才能下订单哦！

密码登录
登录注册
获取短信验证码
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》
产品服务
地区划分
帮助支持
关于我们
行业资讯-文章归档 问答-问答归档
广州亿速云计算有限公司

7*24小时在线电话：400-100-2938

7*24小时在线QQ：800811969

Copyright © Yisu Cloud Ltd. All Rights Reserved. 2018 版权所有
粤ICP备17096448号-1 粤公网安备 44010402001142号