1. 何为数据源
实际上之前我们在没应用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) { // 此处应打印日志 } } } }
2. 数据源实现
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。
3. 使用数据源
我们使用注解的配置启动容器，然后从容器中获取数据源组件使用即可。
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中增删改查的模板代码都替换掉，所以此处暂且稳住兄弟们。
4. 不同的数据源类
上面的示例我们使用了DriverManagerDataSource，Spring还提供了SingleConnectionDataSource，有何区别：
DriverManagerDataSource，每次调用getConnection，都会返回一个新的连接，大家都知道打开JDBC连接是非常消耗性能和资源的，所以只能在测试环境下使用，到了生产环境会严重的拖垮性能。
SingleConnectionDataSource，这个数据源类每次都是使用相同的连接，注意虽然避免了重复获取新连接，但是只使用了一个连接，访问数据库效率是比较低的，所以也仅仅适用于测试环境。
OK，到了生产上，还是需要配置数据库连接池的，数据库连接池的原理此处不再具体介绍，我们直接讲它的实现。
5. 连接池功能的数据源
OK，数据源是一个组件，对于调用组件的一方来说，才不管你这数据源是不是带连接池的。这就是单一职责的思想，所以在更换带连接池的数据源时，只需要修改数据源组件，完全不需要去改动注入数据源的组件即可。
常见的带连接池的数据源C3P0、DBCP、Druid等，因为Druid是国产的且我司项目中用的就是Druid没发现有什么问题，所以此处就只讲解下Druid。
6. 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;
}
