【Spring Boot 应用开发】-04 自动配置-数据源

devtools/2025/1/12 21:36:07/

深入讲解 Spring Boot 自动配置中的数据源配置

为了更好地理解 Spring Boot 中的自动配置机制，我们以数据源配置机制为例，按照以下顺序进行讲解：

  1. 不使用任何框架来连接数据源的方式
  2. 使用 Spring MVC 连接数据源的方式
  3. 使用 Spring Boot 自动配置连接数据源的方式

每个部分都会配有实例代码，并对代码进行详细的解释。

1. 不使用任何框架来连接数据源的方式

1.1 实例代码
java">import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class DataSourceExample {public static void main(String[] args) {Connection connection = null;PreparedStatement preparedStatement = null;ResultSet resultSet = null;try {// 1. 加载数据库驱动Class.forName("com.mysql.cj.jdbc.Driver");// 2. 创建数据库连接String url = "jdbc:mysql://localhost:3306/mydb";String user = "root";String password = "secret";connection = DriverManager.getConnection(url, user, password);// 3. 创建 PreparedStatement 对象String sql = "SELECT id, name, email FROM users WHERE id = ?";preparedStatement = connection.prepareStatement(sql);preparedStatement.setInt(1, 1); // 设置参数// 4. 执行查询resultSet = preparedStatement.executeQuery();// 5. 处理查询结果while (resultSet.next()) {int id = resultSet.getInt("id");String name = resultSet.getString("name");String email = resultSet.getString("email");System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);}} catch (ClassNotFoundException e) {System.out.println("MySQL JDBC Driver not found.");e.printStackTrace();} catch (SQLException e) {System.out.println("Connection failed or query execution failed!");e.printStackTrace();} finally {// 6. 关闭资源try {if (resultSet != null) resultSet.close();if (preparedStatement != null) preparedStatement.close();if (connection != null) connection.close();} catch (SQLException e) {e.printStackTrace();}}}
}
1.2 代码解释

  1. 加载数据库驱动：

    java">Class.forName("com.mysql.cj.jdbc.Driver");

    这行代码用于加载 MySQL 的 JDBC 驱动类。

  2. 创建数据库连接：

    java">String url = "jdbc:mysql://localhost:3306/mydb";
String user = "root";
String password = "secret";
connection = DriverManager.getConnection(url, user, password);

    这里我们定义了数据库的 URL、用户名和密码，然后使用 DriverManager.getConnection 方法创建数据库连接。

  3. 创建 PreparedStatement 对象：

    java">String sql = "SELECT id, name, email FROM users WHERE id = ?";
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setInt(1, 1); // 设置参数

    使用 connection.prepareStatement(sql) 方法创建一个 PreparedStatement 对象，并设置 SQL 查询语句中的参数。

  4. 执行查询：

    java">resultSet = preparedStatement.executeQuery();

    使用 preparedStatement.executeQuery() 方法执行查询，返回一个 ResultSet 对象。

  5. 处理查询结果：

    java">while (resultSet.next()) {int id = resultSet.getInt("id");String name = resultSet.getString("name");String email = resultSet.getString("email");System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
}

    使用 resultSet.next() 方法遍历查询结果集，使用 resultSet.getInt 和 resultSet.getString 方法获取每一行的数据。

  6. 关闭资源：

    java">try {if (resultSet != null) resultSet.close();if (preparedStatement != null) preparedStatement.close();if (connection != null) connection.close();
} catch (SQLException e) {e.printStackTrace();
}

    最后，确保关闭 ResultSet、PreparedStatement 和 Connection 对象，以释放资源。

2. 使用 Spring MVC 连接数据源的方式

2.1 实例代码

首先，我们需要在 pom.xml 中添加 Spring 和 JDBC 的依赖：

<dependencies><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.3.10</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>5.3.10</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.26</version></dependency>
</dependencies>

然后，创建一个配置类来配置数据源：

java">import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DriverManagerDataSource;import javax.sql.DataSource;@Configuration
public class DataSourceConfig {@Beanpublic DataSource dataSource() {DriverManagerDataSource dataSource = new DriverManagerDataSource();dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");dataSource.setUrl("jdbc:mysql://localhost:3306/mydb");dataSource.setUsername("root");dataSource.setPassword("secret");return dataSource;}
}

接下来，创建一个简单的 DAO 类来使用数据源：

java">import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;@Repository
public class UserDao {private final JdbcTemplate jdbcTemplate;@Autowiredpublic UserDao(DataSource dataSource) {this.jdbcTemplate = new JdbcTemplate(dataSource);}public void createUser(String name, String email) {String sql = "INSERT INTO users (name, email) VALUES (?, ?)";jdbcTemplate.update(sql, name, email);}
}

最后，创建一个 Spring 应用上下文来测试数据源配置：

java">import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;public class SpringMVCExample {public static void main(String[] args) {ApplicationContext context = new AnnotationConfigApplicationContext(DataSourceConfig.class);UserDao userDao = context.getBean(UserDao.class);userDao.createUser("John Doe", "john.doe@example.com");System.out.println("User created successfully!");}
}
2.2 代码解释

  1. 配置数据源：

    java">@Bean
public DataSource dataSource() {DriverManagerDataSource dataSource = new DriverManagerDataSource();dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");dataSource.setUrl("jdbc:mysql://localhost:3306/mydb");dataSource.setUsername("root");dataSource.setPassword("secret");return dataSource;
}

    在 DataSourceConfig 类中，我们定义了一个 dataSource Bean，使用 DriverManagerDataSource 来配置数据库连接信息。

  2. 创建 DAO 类：

    java">@Repository
public class UserDao {private final JdbcTemplate jdbcTemplate;@Autowiredpublic UserDao(DataSource dataSource) {this.jdbcTemplate = new JdbcTemplate(dataSource);}public void createUser(String name, String email) {String sql = "INSERT INTO users (name, email) VALUES (?, ?)";jdbcTemplate.update(sql, name, email);}
}

    UserDao 类使用 @Repository 注解标记为 Spring 的 DAO 组件。通过构造函数注入 DataSource，并使用 JdbcTemplate 执行 SQL 操作。

  3. 创建 Spring 应用上下文：

    java">ApplicationContext context = new AnnotationConfigApplicationContext(DataSourceConfig.class);
UserDao userDao = context.getBean(UserDao.class);
userDao.createUser("John Doe", "john.doe@example.com");

    在 SpringMVCExample 类中，我们创建了一个 Spring 应用上下文，并获取 UserDao Bean 来执行数据库操作。

3. 使用 Spring Boot 自动配置连接数据源的方式

3.1 实例代码

首先，在 pom.xml 中添加 Spring Boot 和 JDBC 的依赖：

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jdbc</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency>
</dependencies>

然后，在 application.yaml 中配置数据源：

spring:datasource:url: jdbc:mysql://localhost:3306/mydbusername: rootpassword: secretdriver-class-name: com.mysql.cj.jdbc.Driver

接下来，创建一个简单的 DAO 类来使用数据源：

java">import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;@Repository
public class UserDao {private final JdbcTemplate jdbcTemplate;@Autowiredpublic UserDao(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}public void createUser(String name, String email) {String sql = "INSERT INTO users (name, email) VALUES (?, ?)";jdbcTemplate.update(sql, name, email);}
}

最后，创建一个 Spring Boot 应用类来测试数据源配置：

java">import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class SpringBootExample implements CommandLineRunner {@Autowiredprivate UserDao userDao;public static void main(String[] args) {SpringApplication.run(SpringBootExample.class, args);}@Overridepublic void run(String... args) throws Exception {userDao.createUser("John Doe", "john.doe@example.com");System.out.println("User created successfully!");}
}
3.2 代码解释

  1. 配置数据源：

    spring:datasource:url: jdbc:mysql://localhost:3306/mydbusername: rootpassword: secretdriver-class-name: com.mysql.cj.jdbc.Driver

    在 application.yaml 文件中，我们配置了数据库的 URL、用户名、密码和驱动类名。Spring Boot 会自动读取这些配置并创建 DataSource。

  2. 创建 DAO 类：

    java">@Repository
public class UserDao {private final JdbcTemplate jdbcTemplate;@Autowiredpublic UserDao(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}public void createUser(String name, String email) {String sql = "INSERT INTO users (name, email) VALUES (?, ?)";jdbcTemplate.update(sql, name, email);}
}

    UserDao 类与 Spring MVC 示例中的相同，使用 @Repository 注解标记为 Spring 的 DAO 组件，并通过构造函数注入 JdbcTemplate。

  3. 创建 Spring Boot 应用类：

    java">@SpringBootApplication
public class SpringBootExample implements CommandLineRunner {@Autowiredprivate UserDao userDao;public static void main(String[] args) {SpringApplication.run(SpringBootExample.class, args);}@Overridepublic void run(String... args) throws Exception {userDao.createUser("John Doe", "john.doe@example.com");System.out.println("User created successfully!");}
}

    在 SpringBootExample 类中，我们使用 @SpringBootApplication 注解来启用 Spring Boot 的自动配置。通过实现 CommandLineRunner 接口，我们可以在应用启动后执行一些初始化操作，例如调用 UserDao 的方法来创建用户。

4. 总结

通过以上三个部分的讲解，我们可以看到 Spring Boot 的自动配置机制是如何简化数据源配置的：

  1. 不使用任何框架：需要手动加载驱动、创建连接、执行 SQL 操作并关闭连接。
  2. 使用 Spring MVC：需要手动配置数据源 Bean，并通过依赖注入使用数据源。
  3. 使用 Spring Boot：只需在配置文件中配置数据库信息，Spring Boot 会自动创建 DataSource 和 JdbcTemplate，大大简化了配置过程。

整个架构的演变遵循着单一职责原则，将配置何代码分割开，提高内聚减少耦合，隐藏和业务无关的底层实现。这种思想我们可以在自己的编码工作中借鉴。


http://www.ppmy.cn/devtools/149528.html

相关文章

深度求索的新突破——DeepSeek-V3

深度求索的新突破——DeepSeek-V3

在人工智能领域不断发展的浪潮中&#xff0c;DeepSeek-V3的出现犹如一颗璀璨的新星&#xff0c;引起了广泛的关注和热议 DeepSeek-V3是由杭州深度求索人工智能基础技术研究有限公司于2024年12月26日发布的混合专家&#xff08;MoE&#xff09;语言模型 官网&#xff1a;https…
阅读更多...
2025新春烟花代码（二）HTML5实现孔明灯和烟花效果

2025新春烟花代码（二）HTML5实现孔明灯和烟花效果

效果展示 源代码 <!DOCTYPE html> <html lang"en"> <script>var _hmt _hmt || [];(function () {var hm document.createElement("script");hm.src "https://hm.baidu.com/hm.js?45f95f1bfde85c7777c3d1157e8c2d34";var …
阅读更多...
vue常用功能收集

vue常用功能收集

文章目录 vue如何实现输入条件后点击enter进行查询vue项目启动修改后报错vue禁止iframe里面的右键启动 vue如何实现输入条件后点击enter进行查询 在Vue中&#xff0c;您可以通过监听键盘事件来实现在输入条件后点击Enter进行查询的功能。以下是一个简单的示例&#xff1a; &l…
阅读更多...
视频编辑最新SOTA！港中文Adobe等发布统一视频生成传播框架——GenProp

视频编辑最新SOTA！港中文Adobe等发布统一视频生成传播框架——GenProp

文章链接&#xff1a;https://arxiv.org/pdf/2412.19761 项目链接&#xff1a;https://genprop.github.io 亮点直击 定义了一个新的生成视频传播问题&#xff0c;目标是利用 I2V 模型的生成能力&#xff0c;将视频第一帧的各种变化传播到整个视频中。 精心设计了模型 GenProp&…
阅读更多...
C++ STL 中的 `unordered_map` 和 `unordered_set` 总结

C++ STL 中的 `unordered_map` 和 `unordered_set` 总结

1. unordered_map unordered_map 是一个基于哈希表实现的容器&#xff0c;存储键值对&#xff08;key-value&#xff09;&#xff0c;每个键必须唯一&#xff0c;可以快速插入、删除、查找。 基本特性 存储结构&#xff1a;键值对 (key-value)。键唯一性&#xff1a;每个键在…
阅读更多...
Vue2与Vue3在项目开发中的选择：深入探讨

Vue2与Vue3在项目开发中的选择：深入探讨

文章目录 前言一、Vue2的优势与挑战二、Vue3的进步与特性三、如何做出选择&#xff1f;结语 前言 Vue.js 是一个用于构建用户界面的渐进式JavaScript框架。Vue2和Vue3是其两个主要版本&#xff0c;它们各自拥有一系列特点和优势。随着Vue3的发布&#xff0c;开发者们面临着在新…
阅读更多...
【cs.AI】25.1.8 arxiv更新速递

【cs.AI】25.1.8 arxiv更新速递

—第1篇---- ===== Beyond Sight: Finetuning Generalist Robot Policies with Heterogeneous Sensors via Language Grounding 🔍 关键词: 机器人策略, 异构传感器, 语言基础, 多模态交互 链接1 摘要: 与世界的互动是多感官体验：实现有效的通用交互需要利用所有可用的…
阅读更多...
互斥与独立在组合数学、概率论、线性代数中的理解

互斥与独立在组合数学、概率论、线性代数中的理解

互斥与独立在组合数学、概率论、线性代数中的详细理解 1. 组合数学 互斥&#xff1a; 定义&#xff1a;两个事件不能同时发生。例子&#xff1a;从一副牌中抽出一张牌&#xff0c;事件A为抽到红桃&#xff0c;事件B为抽到黑桃。这两个事件互斥&#xff0c;因为一张牌不能同时是…
阅读更多...
最新文章

Copyright @ 2022~2023