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

server/2025/1/11 19:18:03/

深入讲解 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/server/157554.html

相关文章

bash相关习题复习

bash相关习题复习

1、由于 ~/.bash_history 仅能记录指令&#xff0c;我想要在每次注销时都记录时间&#xff0c;并将后续的指令 50 笔记录下来&#xff0c; 可以如何处理&#xff1f; [rootptivitic ~]# vim ~/.bash_logout date >> ~/.myhistory history 50 >> ~/.myhistory 2…
阅读更多...
conntrack iptables 安全组

conntrack iptables 安全组

centos 安装yum install conntrack-tools 1. conntrack状态 NEW: 新建连接&#xff08;第一次包&#xff09;。 ESTABLISHED: 已建立连接&#xff0c;正在传输数据。 RELATED: 与已有连接相关的连接&#xff0c;如 FTP 数据连接。 INVALID: 无效连接&#xff0c;无法识别或不…
阅读更多...
计算机网络之---网络层的基本功能

计算机网络之---网络层的基本功能

网络层简述 网络层&#xff08;Network Layer&#xff09;是OSI&#xff08;开放系统互联&#xff09;模型的第三层&#xff0c;主要负责将数据包从源主机传输到目的主机&#xff0c;处理数据传输过程中的路由选择、寻址和分段等任务。网络层的主要目的是确保数据能够从源设备准…
阅读更多...
软考中级 软件设计师 第一章 第一节 数据的表示

软考中级 软件设计师 第一章 第一节 数据的表示

目录 1、 进制转换 1.1、基础转换 1.2、二进制与八进制与十六进制 1.2.1、二进制与八进制 1.2.2、二进制与十六进制 2、码制 2.1、原码/反码/补码/移码 2.2、数值范围 3、浮点数 3.1、浮点数的表示 3.2、特点 3.3、对阶 4、运算 4.1、关系运算符 4.2、逻辑运算符…
阅读更多...
Gin 框架中间件原理

Gin 框架中间件原理

一、引言 在现代 Web 应用开发中&#xff0c;中间件扮演着至关重要的角色。Gin 作为一个流行的 Go 语言 Web 框架&#xff0c;其强大的中间件功能使得开发者能够高效地处理各种通用任务&#xff0c;如日志记录、身份验证、错误处理等。理解 Gin 框架中间件的原理&#xff0c;不…
阅读更多...
vue3+element-plus暗黑模式切换动画圆弧过渡

vue3+element-plus暗黑模式切换动画圆弧过渡

vue3element-plus暗黑模式切换动画圆弧过渡 效果 html <div class"toggle" ref"switchRef" click.stop"toggleDark()"><el-icon v-show"!isDark" :size"30"><Moon /></el-icon><el-icon v-sh…
阅读更多...
利用 Python 爬虫获取 1688 关键字 API 接口

利用 Python 爬虫获取 1688 关键字 API 接口

在当今电商蓬勃发展的时代&#xff0c;掌握市场动态、洞察消费者需求已成为商家制胜的关键。而 1688 作为中国领先的 B2B 电商平台&#xff0c;汇聚了海量商品与交易数据&#xff0c;其关键字 API 接口更是蕴含着丰富的市场信息。本文将详细解读如何借助 Python 爬虫技术&#…
阅读更多...
【git】-2 分支管理

【git】-2 分支管理

目录 一、分支的概念 二、查看、创建、切换分支 1、查看分支-git branch 2、创建分支- git branch 分支名 3、切换分支- git checkout 分支名 三、git指针 -实现分支和版本间的切换 四、普通合并分支 git merge 文件名 五、冲突分支合并 ​​​​​​【git】-初始gi…
阅读更多...
最新文章

Copyright @ 2022~2023