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

news/2025/1/12 0:33:11/

深入讲解 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.getIntresultSet.getString 方法获取每一行的数据。

  6. 关闭资源

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

    最后,确保关闭 ResultSetPreparedStatementConnection 对象,以释放资源。

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 会自动创建 DataSourceJdbcTemplate,大大简化了配置过程。

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


http://www.ppmy.cn/news/1562364.html

相关文章

【UI自动化测试】selenium操作补充

&#x1f3e1;个人主页&#xff1a;謬熙&#xff0c;欢迎各位大佬到访❤️❤️❤️~ &#x1f472;个人简介&#xff1a;本人编程小白&#xff0c;正在学习互联网求职知识…… 如果您觉得本文对您有帮助的话&#xff0c;记得点赞&#x1f44d;、收藏⭐️、评论&#x1f4ac;&am…

Lianwei 安全周报|2024.1.7

以下是本周「Lianwei周报」&#xff0c;我们总结推荐了本周的政策/标准/指南最新动态、热点资讯和安全事件&#xff0c;保证大家不错过本周的每一个重点&#xff01; 政策/标准/指南最新动态 01 国家发改委等三部门印发《国家数据基础设施建设指引》 国家数据基础设施是从数据…

【微信小程序】回到顶部图标-页面滚动事件 | 漫画-综合实训

一、回到顶部-页面滚动事件 在微信小程序中&#xff0c;如果你想将“回到顶部”的功能按钮换成图标&#xff0c;你可以通过以下步骤实现&#xff1a; 1. 准备图标 首先&#xff0c;你需要准备一个图标图片。这个图标可以是任何你选择的格式&#xff0c;如 PNG 或 SVG。将图标…

Kivy App开发之UX控件Slider滑块

在app中可能会调节如音量,亮度等,可以使用Slider来实现,该控件调用方便,兼容性好,滑动平稳。在一些参数设置中,也可以用来调整数值。 支持水平和垂直方向,可以设置默认值,最小及最大值。 使用方法,需用引入Slider类,通过Slider类生成一个滑块并设置相关的样式后,再…

144.《在 macOS 上安装 Redis》

文章目录 在 macOS 上安装 Redis先决条件安装在前台启动和停止 Redis使用 launchd 启动和停止 Redis连接到 Redis后续步骤Next steps redis 官方安装教程是英文&#xff0c;本文只是将英文文档翻译成中文&#xff0c;方便大家阅读 redis官方安装教程&#xff1a;download redis…

Howland电流源

Howland电流源 本文旨在介绍一个经典电流源—Howland电流源的理论知识以及相关仿真。在本文后再写一篇文章介绍Howland电流的一些影响参数&#xff01; 文章目录 Howland电流源一、 V/I转换电路二、基本Howland电流泵三、改进1.0- Howland电流泵四、改进2.0- Howland电流泵五、…

基于金融新闻微调大语言模型,进行股票回报预测

“Fine-Tuning Large Language Models for Stock Return Prediction Using Newsflow” 论文地址&#xff1a;https://arxiv.org/pdf/2407.18103 摘要 本文研究了利用金融新闻流对大型语言模型&#xff08;LLMs&#xff09;进行微调&#xff0c;以用于预测股票回报的效果&…

鸿蒙开发(29)弹性布局 (Flex)

概述 弹性布局&#xff08;Flex&#xff09;提供更加有效的方式对容器中的子元素进行排列、对齐和分配剩余空间。常用于页面头部导航栏的均匀分布、页面框架的搭建、多行数据的排列等。 容器默认存在主轴与交叉轴&#xff0c;子元素默认沿主轴排列&#xff0c;子元素在主轴方…