【重温SSM框架系列】2 - Spring配置数据源连接池(手动创建与配置)

x33g5p2x  于2022-03-05 转载在 Spring  
字(7.3k)|赞(0)|评价(0)|浏览(624)

大家好,我是【1+1=王】, 热爱java的计算机(人工智能)渣硕研究生在读。
如果你也对java、人工智能等技术感兴趣,欢迎关注,抱团交流进大厂!!!
Good better best, never let it rest, until good is better, and better best.

近期会重新温习一下SSM的相关知识,相应的博客会更新至专栏【SSM框架】中,欢迎大家关注!
SSM专栏:https://blog.csdn.net/weixin_43598687/category_11652306.html

数据源(连接池概述)

数据源是指数据库应用程序所使用的数据库或者数据库服务器。

数据源(Data Source)顾名思义,数据的来源,是提供某种所需要数据的器件或原始媒体。在数据源中存储了所有建立数据库连接的信息。就像通过指定文件名称可以在文件系统中找到文件一样,通过提供正确的数据源名称,你可以找到相应的数据库连接。

常见的数据源有DBCP、C3P0、Druid等。

在JAVA中我们使用数据源可以按照以下几个步骤进行开发(数据源开发步骤):

  1. 导入数据源和数据库驱动的坐标(依赖包);
  2. 创建出数据源对象;
  3. 配置数据源的基本连接信息;
  4. 使用数据源获取连接资源(连接并操作数据库);
  5. 使用完毕后归还链接资源。

下面首先是一个数据源手动创建的示例,然后是引入Spring来配置数据源的例子。

自定义数据源(手动创建)

以Druid数据源、MySQL数据库为例

在进行下面的操作之前需要在数据库中创建一个数据库(test),并在test数据库下创建一个表(user)。

然后,回到代码中,创建user表所对应的实体类:

  1. public class User {
  2. private Integer id;
  3. private String username;
  4. private String password;
  5. public User() {
  6. }
  7. public User(Integer id, String username, String password) {
  8. this.id = id;
  9. this.username = username;
  10. this.password = password;
  11. }
  12. public Integer getId() {
  13. return id;
  14. }
  15. public void setId(Integer id) {
  16. this.id = id;
  17. }
  18. public String getUsername() {
  19. return username;
  20. }
  21. public void setUsername(String username) {
  22. this.username = username;
  23. }
  24. public String getPassword() {
  25. return password;
  26. }
  27. public void setPassword(String password) {
  28. this.password = password;
  29. }
  30. @Override
  31. public String toString() {
  32. return "User{" +
  33. "id=" + id +
  34. ", username='" + username + '\'' +
  35. ", password='" + password + '\'' +
  36. '}';
  37. }
  38. }

准备工作做完之后,就可以按照下面的步骤进行数据源的操作。

1. 导入Druid和mysql数据库驱动依赖包

  1. <!-- Druid数据源 -->
  2. <dependency>
  3. <groupId>com.alibaba</groupId>
  4. <artifactId>druid</artifactId>
  5. <version>1.1.10</version>
  6. </dependency>
  7. <!-- Mysql数据库驱动 -->
  8. <dependency>
  9. <groupId>mysql</groupId>
  10. <artifactId>mysql-connector-java</artifactId>
  11. <version>8.0.21</version>
  12. </dependency>

2. 创建数据源对象并配置基本连接信息

  1. @Test
  2. public void druidTest() throws SQLException {
  3. //创建数据源
  4. DruidDataSource dataSource = new DruidDataSource();
  5. // 配置数据库连接参数
  6. dataSource.setDriverClassName("com.mysql.jdbc.Driver");
  7. dataSource.setUrl("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai");
  8. dataSource.setUsername("root");
  9. dataSource.setPassword("123456");
  10. //获取连接对象
  11. Connection conn = dataSource.getConnection();
  12. System.out.println(conn);
  13. }


打印连接对象,创建数据源成功。

使用JDBC操作数据库,打印user表的所有记录

  1. @Test
  2. public void druidTest() throws SQLException {
  3. //创建数据源
  4. DruidDataSource dataSource = new DruidDataSource();
  5. // 配置数据库连接参数
  6. dataSource.setDriverClassName("com.mysql.jdbc.Driver");
  7. dataSource.setUrl("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai");
  8. dataSource.setUsername("root");
  9. dataSource.setPassword("123456");
  10. //获取连接对象
  11. Connection conn = dataSource.getConnection();
  12. System.out.println(conn);
  13. Statement statement = conn.createStatement();
  14. ResultSet resultSet = statement.executeQuery("select * from user");
  15. while (resultSet.next()){
  16. User user = new User();
  17. user.setId(resultSet.getInt("id"));
  18. user.setUsername(resultSet.getString("username"));
  19. user.setPassword(resultSet.getString("password"));
  20. System.out.println(user);
  21. }
  22. conn.close();
  23. }

提取数据库连接信息至配置文件

上面在配置数据库连接参数的时候,我们直接把数据库信息放在代码里面的,这样是很不优雅的。

可以把数据库的连接信息提取出来放入一个配置文件中,当代码中需要时,再从配置文件中获取连接信息。

创建配置文件(jdbc.properties)

  1. jdbc.driver=com.mysql.cj.jdbc.Driver
  2. jdbc.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
  3. jdbc.user=root
  4. jdbc.password=123456

从配置文件获取数据库连接信息

  1. @Test
  2. public void druidTest() throws SQLException {
  3. // 加载类路径下的jdbc.properties
  4. ResourceBundle bundle = ResourceBundle.getBundle("jdbc");
  5. //创建数据源
  6. DruidDataSource dataSource = new DruidDataSource();
  7. // 配置数据库连接参数
  8. dataSource.setDriverClassName(bundle.getString("jdbc.driver"));
  9. dataSource.setUrl(bundle.getString("jdbc.url"));
  10. dataSource.setUsername(bundle.getString("jdbc.user"));
  11. dataSource.setPassword(bundle.getString("jdbc.password"));
  12. Connection conn = dataSource.getConnection();
  13. System.out.println(conn);
  14. Statement statement = conn.createStatement();
  15. ResultSet resultSet = statement.executeQuery("select * from user");
  16. while (resultSet.next()){
  17. User user = new User();
  18. user.setId(resultSet.getInt("id"));
  19. user.setUsername(resultSet.getString("username"));
  20. user.setPassword(resultSet.getString("password"));
  21. System.out.println(user);
  22. }
  23. conn.close();
  24. }

使用Spring配置数据源

上一篇文章中介绍了Spring的依赖注入(【重温SSM框架系列】1 - Spring快速入门(配置文件及API详解):https://blog.csdn.net/weixin_43598687/article/details/123128711)

所以,对于数据源的创建,也可以将DataSource的创建权交由Spring容器去完成。

在Spring核心配置文件中配置数据源及数据库信息```

  1. <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
  2. <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  3. <property name="url" value="jdbc:mysql://localhost:3306/test?useUnicode=true&amp;characterEncoding=utf-8&amp;serverTimezone=Asia/Shanghai"/>
  4. <property name="username" value="root"/>
  5. <property name="password" value="123456"/>
  6. </bean>

从Spring容器中获取DataSource实例对象

  1. @Test
  2. public void druidTest2() throws SQLException {
  3. ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  4. DataSource dataSource = (DataSource) context.getBean("dataSource");
  5. Connection conn = dataSource.getConnection();
  6. System.out.println(conn);
  7. Statement statement = conn.createStatement();
  8. ResultSet resultSet = statement.executeQuery("select * from user");
  9. while (resultSet.next()){
  10. User user = new User();
  11. user.setId(resultSet.getInt("id"));
  12. user.setUsername(resultSet.getString("username"));
  13. user.setPassword(resultSet.getString("password"));
  14. System.out.println(user);
  15. }
  16. conn.close();
  17. }

提取数据库连接信息至配置文件

使用Spring也可以把数据库的连接信息提取出来放入一个配置文件中,使用时再从配置文件中获取连接信息。

创建配置文件(jdbc.properties)

  1. jdbc.driver=com.mysql.cj.jdbc.Driver
  2. jdbc.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
  3. jdbc.user=root
  4. jdbc.password=123456

applicationContext.xml加载jdbc.properties配置文件获得连接信息。

在applicationContext.xml加载jdbc.properties配置文件获得连接信息之前,需要引入context命名空间和约束路径:

  • 命名空间:xmlns:context=“http://www.springframework.org/schema/context”
  • 约束路径:http://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsd

applicationContext.xml完整内容

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:context="http://www.springframework.org/schema/context"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  6. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
  7. <context:property-placeholder location="jdbc.properties"/>
  8. <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
  9. <property name="driverClassName" value="${jdbc.driver}"/>
  10. <property name="url" value="${jdbc.url}"/>
  11. <property name="username" value="${jdbc.user}"/>
  12. <property name="password" value="${jdbc.password}"/>
  13. </bean>
  14. </beans>

相关文章