跳至主要內容

Spring Boot集成MySQL - 基于Spring Data JDBC的封装

bsfc.tech大约 2 分钟框架Spring Boot

在Spring Boot中使用MySQL数据库,并基于Spring JDBC进行数据访问层的封装是一个相对直接的过程。

Spring JDBC是Spring框架提供的一个JDBC抽象层,它简化了数据库访问并消除了样板代码。

下面是集成MySQL数据库并使用Spring JDBC的详细步骤。

1. 添加依赖

首先,在pom.xml文件中添加Spring Boot Starter for MySQL数据库和Spring JDBC的依赖。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>cn.org.bsfc</groupId>
    <artifactId>spring-boot-example-0210</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.0</version>
        <relativePath/>
    </parent>

    <dependencies>
        <!-- Spring Boot Starter for Web -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Spring Boot Starter for Data Jdbc -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jdbc</artifactId>
        </dependency>
        <!-- MySQL Driver -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <!-- Spring Boot Starter Test for testing -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- Lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>

</project>

2. 配置数据库连接

application.properties中配置MySQL数据库连接信息。

# application.properties 示例
# server
server.port=8080

# spring datasource
spring.datasource.url=jdbc:mysql://localhost:3306/db-example?useSSL=false&serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

3. 创建实体类(Optional)

虽然不是必须的,但通常我们会为数据库表创建对应的Java实体类。

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

    // Getter and Setter methods...
}

4. 数据访问层(Repository)

使用Spring Data JDBC的接口方式定义数据访问操作。如果需要自定义查询,可以继承JdbcRepository并实现所需方法。

import org.springframework.data.repository.CrudRepository;

public interface UserRepository extends CrudRepository<User, Long> {
    // Additional custom methods if needed...
}

5. 服务层(Service)

在服务层中注入Repository并使用它来执行数据库操作。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class UserService {

    private final UserRepository userRepository;

    @Autowired
    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }

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

    // Other service methods...
}

6. 控制器(Controller)

最后,在控制器中调用服务层的方法来处理HTTP请求。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {

    private final UserService userService;

    @Autowired
    public UserController(UserService userService) {
        this.userService = userService;
    }

    @PostMapping("/users")
    public User createUser(@RequestBody User user) {
        return userService.saveUser(user);
    }
}

以上就是集成MySQL数据库并使用Spring Data JDBC进行数据访问的基本配置和代码示例。请根据实际需求调整实体类、Repository接口以及业务逻辑。