亲测有效！一文掌握SpringBoot整合JDBC，数据库操作随心所欲

2023-03-24 11:08:11

SpringBoot集成JDBC：打造高效数据库操作

简介

SpringBoot作为一款功能强大的开源框架，深受开发者的青睐。它整合了Spring、Spring MVC和Spring Data JPA等流行技术，使开发人员能够轻松构建Web应用程序。为了充分发挥SpringBoot的强大功能，本文将深入探讨如何使用SpringBoot整合JDBC，实现高效的数据库操作。

环境配置

首先，我们需要创建一个Maven项目。使用命令行进入项目目录，并执行mvn archetype:generate命令。随后，再执行mvn package命令打包项目。至此，基础环境配置完成。

引入JDBC依赖

接下来，我们在项目中引入JDBC依赖。在pom.xml文件中添加以下依赖：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

配置数据库连接信息

接着，我们需要配置数据库连接信息。在application.properties文件中，添加以下配置：

spring.datasource.url=jdbc:mysql://localhost:3306/test
spring.datasource.username=root
spring.datasource.password=123456

创建DataSource对象

下一步，我们需要创建一个DataSource对象。在项目中创建一个DataSource类，并实现DataSource接口。在DataSource类中，我们可以根据需要对数据库连接进行配置。

public class DataSource implements javax.sql.DataSource {
  // 数据库连接信息
  private String url;
  private String username;
  private String password;

  // 构造函数
  public DataSource() {
    // 从配置文件中获取数据库连接信息
    this.url = Environment.get("spring.datasource.url");
    this.username = Environment.get("spring.datasource.username");
    this.password = Environment.get("spring.datasource.password");
  }

  // 实现DataSource接口的方法
  ...
}

配置SpringBoot应用程序中的DataSource对象

最后，我们需要在SpringBoot应用程序的主类中配置DataSource对象。在SpringBoot应用程序的主类中，添加以下代码：

@SpringBootApplication
public class Application {

  @Bean
  public DataSource dataSource() {
    return new DataSource();
  }

  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }
}

至此，SpringBoot整合JDBC的基础环境配置完成。我们可以使用DataSource对象来操作数据库，实现数据的增删改查。

代码示例

下面是一个代码示例，演示如何使用DataSource对象来操作数据库：

public class JdbcExample {

  @Autowired
  private DataSource dataSource;

  public void insertData() {
    String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
    try (Connection connection = dataSource.getConnection();
        PreparedStatement statement = connection.prepareStatement(sql)) {
      statement.setString(1, "John");
      statement.setString(2, "john@example.com");
      statement.executeUpdate();
    } catch (SQLException e) {
      e.printStackTrace();
    }
  }

  public void queryData() {
    String sql = "SELECT * FROM users WHERE name = ?";
    try (Connection connection = dataSource.getConnection();
        PreparedStatement statement = connection.prepareStatement(sql)) {
      statement.setString(1, "John");
      ResultSet resultSet = statement.executeQuery();
      while (resultSet.next()) {
        System.out.println(resultSet.getInt("id") + " " + resultSet.getString("name") + " " + resultSet.getString("email"));
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }
  }
}