1. 9IM首页
  2. 热点

Spring大神之路(27)–Spring JDBC多种数据源DataSource配置实例

何为数据源

实际上之前我们在没应用Spring JDBC的时候,自己就封装了一个数据源类,代码人如下。

可以看出,数据源也就是将数据库连接相关的参数、获取数据库连接的方法等信息和功能封装好的组件,实际上也就是数据库源头的意思。

package org.maoge.restfulblog;
import java.sql.Connection;
import java.sql.DriverManager;
import javax.annotation.PostConstruct;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Repository;
@Repository
public class DbHelper {
	@Value("com.mysql.jdbc.Driver") // 注入driver属性
	private String driver;
	@Value("jdbc:mysql://127.0.0.1:3306/myblog?useUnicode=true&characterEncoding=utf-8") // 注入数据库url属性
	private String url;
	@Value("root") // 注入用户名属性
	private String username;
	@Value("Easy@0122") // 注入密码属性
	private String password;
	/**
	 * 初始化
	 */
	@PostConstruct // 使用该注解,以便在项目启动时执行数据库驱动加载工作
	public void init() {
		try {
			Class.forName(driver);
		} catch (Exception e) {
			// 此处应打印日志
		}
	}
	/**
	 * 获取数据库连接
	 */
	public Connection getConnection() {
		Connection conn = null;
		try {
			conn = DriverManager.getConnection(url, username, password);
		} catch (Exception e) {
			System.out.println(e);
			// 此处应打印日志
		}
		return conn;
	}
	/**
	 * 关闭数据库连接
	 */
	public void closeConnection(Connection conn) {
		if (conn != null) {
			try {
				conn.close();
			} catch (Exception e) {
				// 此处应打印日志
			}
		}
	}
}

数据源实现

Spring已经提供了几个数据源类(比我实现的DbHelper强多了),我们可以直接拿过来注册为Bean即可,此处我们使用封装好的DriverManagerDataSource数据源类。

在配置类中注册数据源bean:

package org.maoge.springjdbcdemo;
import javax.sql.DataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
@Configuration//配置类
public class DataSourceConfig {
	@Bean
	public DataSource dataSource() {
		DriverManagerDataSource dataSource=new DriverManagerDataSource();
		return dataSource;
	}
}

为数据源添加链接参数:

	@Bean
	public DataSource dataSource() {
		DriverManagerDataSource dataSource = new DriverManagerDataSource();
		dataSource.setDriverClassName("com.mysql.jdbc.Driver");
		dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/myblog?useUnicode=true&characterEncoding=utf-8");
		dataSource.setUsername("root");
		dataSource.setPassword("XXX");
		return dataSource;
	}

这样,当容器启动时,我们就拥有了一个数据源组件,名字是dataSource。

使用数据源

我们使用注解的配置启动容器,然后从容器中获取数据源组件使用即可。

package org.maoge.springjdbcdemo;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
public class DataSourceDemo {
	public static void main(String[] args) throws SQLException {
		// 获取容器
		AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(DataSourceConfig.class);
		// 获取数据源组件
		DataSource dataSource = (DataSource) context.getBean("dataSource");
		// 获取数据库连接
		Connection conn = dataSource.getConnection();
		// 执行一个数据库操作
		String sql = "select * from blog";
		PreparedStatement stmt = conn.prepareStatement(sql);
		ResultSet rs = stmt.executeQuery();
		while (rs.next()) {
			System.out.println(rs.getString("title"));
		}
		// 关闭数据库连接
		conn.close();
	}
}

看到此处,大家想必可以看出,我们之前的BlogService可以直接使用DataSource替代DbHelper,很方便啊。但是我们的目标是星辰大海,我们要把BlogService中增删改查的模板代码都替换掉,所以此处暂且稳住兄弟们。

不同的数据源类

上面的示例我们使用了DriverManagerDataSource,Spring还提供了SingleConnectionDataSource,有何区别:

  • DriverManagerDataSource,每次调用getConnection,都会返回一个新的连接,大家都知道打开JDBC连接是非常消耗性能和资源的,所以只能在测试环境下使用,到了生产环境会严重的拖垮性能。
  • SingleConnectionDataSource,这个数据源类每次都是使用相同的连接,注意虽然避免了重复获取新连接,但是只使用了一个连接,访问数据库效率是比较低的,所以也仅仅适用于测试环境。

OK,到了生产上,还是需要配置数据库连接池的,数据库连接池的原理此处不再具体介绍,我们直接讲它的实现。

连接池功能的数据源

OK,数据源是一个组件,对于调用组件的一方来说,才不管你这数据源是不是带连接池的。这就是单一职责的思想,所以在更换带连接池的数据源时,只需要修改数据源组件,完全不需要去改动注入数据源的组件即可。

常见的带连接池的数据源C3P0、DBCP、Druid等,因为Druid是国产的且我司项目中用的就是Druid没发现有什么问题,所以此处就只讲解下Druid。

Druid配置与使用

首先导入jar包druid-1.1.21.jar

然后将DriverManagerDataSource改为druid数据源类即可。

@Configuration // 配置类
public class DataSourceConfig {
	@Bean
	public DataSource dataSource() {
		DruidDataSource dataSource = new DruidDataSource();
		dataSource.setDriverClassName("com.mysql.jdbc.Driver");
		dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/myblog?useUnicode=true&characterEncoding=utf-8");
		dataSource.setUsername("root");
		dataSource.setPassword("Easy@0122");
		return dataSource;
	}
}

这么简单吗?我去,就这么简单。

当然,如果想要发挥druid的性能,往往还需要根据服务器配置等环节信息配置更多参数,此处提供一个常用的配置,这块其实也基本是参考网上提供的信息,还希望能有一个生产环境下的稳定配置。

@Bean
	public DataSource dataSource() {
		DruidDataSource dataSource = new DruidDataSource();
		// 可配可不配,如果不配置druid会根据url自动识别dbType,然后选择相应的driverClassName,不过还是建议配置下
		dataSource.setDriverClassName("com.mysql.jdbc.Driver");
		// 连接数据库的url
		dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/myblog?useUnicode=true&characterEncoding=utf-8");
		// 连接数据库的用户名
		dataSource.setUsername("root");
		// 连接数据库的密码
		dataSource.setPassword("XXX");
		// 如果存在多个数据源,监控的时候可以通过名字来区分开来
		dataSource.setName("druidDataSource");
		// 启动程序时,在连接池中初始化多少个连接,设为0表示无限制
		dataSource.setInitialSize(10);
		// 连接池的最大数据库连接数
		dataSource.setMaxActive(50);
		// 连接池的最小数据库连接数,设为0表示无限制,建议与initialSize相同
		dataSource.setMinIdle(10);
		// 获取连接时最大等待时间,单位毫秒,超过maxWait的值后,认为本次请求失败
		dataSource.setMaxWait(60000);
		// 用来检测连接是否有效的sql,要求是一个查询语句
		dataSource.setValidationQuery("SELECT 1 FROM DUAL");
		// 建议配置为true,不影响性能,并且保证安全性。申请连接的时候检测,如果空闲时间大于timeBetweenEvictionRunsMillis,执行validationQuery检测连接是否有效。
		dataSource.setTestWhileIdle(true);
		// 申请连接时执行validationQuery检测连接是否有效
		dataSource.setTestOnBorrow(false);
		// 归还连接时执行validationQuery检测连接是否有效
		dataSource.setTestOnReturn(false);
		// 是否缓存preparedStatement,也就是PSCache
		dataSource.setPoolPreparedStatements(true);
		// 每个连接最多缓存多少个SQL
		dataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
		// 检查空闲连接的频率,单位毫秒, 非正整数时表示不进行检查
		dataSource.setTimeBetweenEvictionRunsMillis(60000);
		// 池中某个连接的空闲时长达到 N 毫秒后, 连接池在下次检查空闲连接时,将回收该连接
		dataSource.setMinEvictableIdleTimeMillis(300000);
		// 要求程序从池中get到连接后, N 秒后必须close,否则druid
		// 会强制回收该连接,不管该连接中是活动还是空闲,以防止进程不会进行close而霸占连接
		dataSource.setRemoveAbandoned(true);
		// 设置druid 强制回收连接的时限当程序从池中get到连接开始算起,超过此 应大于业务运行最长时间值后,druid将强制回收该连接,单位秒。
		dataSource.setRemoveAbandonedTimeout(80);
		return dataSource;
	}

原创文章,作者:9IM,如若转载,请注明出处:https://www.9im.cn/1155.html

发表评论

电子邮件地址不会被公开。 必填项已用*标注