數(shù)據(jù)源
所謂數(shù)據(jù)源也就是數(shù)據(jù)的來源,它存儲(chǔ)了所有建立數(shù)據(jù)庫連接需要的信息。就像通過指定文件名稱可以在文件系統(tǒng)中找到文件一樣,通過提供正確的數(shù)據(jù)源名稱,你可以找到相應(yīng)的數(shù)據(jù)庫連接。

因此,一個(gè)數(shù)據(jù)源只對應(yīng)于一個(gè)數(shù)據(jù)庫,如果項(xiàng)目中需要連多個(gè)數(shù)據(jù)庫,那么就要配置多個(gè)數(shù)據(jù)源。
數(shù)據(jù)源xml配置實(shí)例:
<!--數(shù)據(jù)源-->
<bean id=dataSource class=com.zaxxer.hikari.HikariDataSource destroy-method=close>
<constructor-arg>
<bean class=com.zaxxer.hikari.HikariConfig>
<property name=poolName value=HikariDataSource />
<property name=driverClassName value=${jdbc.driverClassName} />
<property name=jdbcUrl value=${jdbc.url} />
<property name=username value=${jdbc.username} />
<property name=password value=${jdbc.password} />
<property name=autoCommit value=false />
<property name=connectionTimeout value=30000 />
<property name=idleTimeout value=600000 />
<property name=maxLifetime value=1800000 />
<property name=connectionTestQuery value=${jdbc.testSql} />
<property name=maximumPoolSize value=500 />
<property name=minimumIdle value=1 />
</bean>
</constructor-arg>
</bean>
<!--jdbcTemplate需要引用數(shù)據(jù)源-->
<bean id=jdbcTemplate class=org.springframework.jdbc.core.JdbcTemplate>
<property name=dataSource ref=dataSource></property>
</bean>
<!--事務(wù)也是加在數(shù)據(jù)源之上的-->
<bean id=transactionManager class=org.springframework.jdbc.datasource.DataSourceTransactionManager>
<property name=dataSource ref=dataSource></property>
</bean>
<tx:advice id=transactionAdvice transaction-manager=transactionManager>
<tx:attributes>
<tx:method name=* propagation=REQUIRED />
</tx:attributes>
</tx:advice>
<aop:config>
<aop:pointcut expression=execution(* com.btzh.service.impl.*.*(..)) id=allManagerMethod />
<aop:advisor advice-ref=transactionAdvice pointcut-ref=allManagerMethod />
</aop:config>可見,jdbc模板、事務(wù)都是以數(shù)據(jù)源為基礎(chǔ),所有配置都是圍繞著數(shù)據(jù)源開展的。
再看springboot的數(shù)據(jù)源配置:
#-------------------------------------------------- 數(shù)據(jù)庫配置 --------------------------------------------------#
spring.datasource.ms.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.ms.jdbcurl=jdbc:mysql://192.168.47.130:3306/faith?useSSL=false&serverTimezone=CTT
spring.datasource.ms.username=faith
spring.datasource.ms.password=faith
# 連接池的配置信息,下面為連接池的補(bǔ)充設(shè)置,應(yīng)用到上面所有數(shù)據(jù)源中
# 初始化大小,最小,
spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=20
# 配置獲取連接等待超時(shí)的時(shí)間
spring.datasource.maxWait=60000
# 配置間隔多久才進(jìn)行一次檢測,檢測需要關(guān)閉的空閑連接,單位是毫秒
spring.datasource.timeBetweenEvictionRunsMillis=60000
# 配置一個(gè)連接在池中最小生存的時(shí)間,單位是毫秒
spring.datasource.minEvictableIdleTimeMillis=300000
spring.datasource.validationQuery=SELECT 1 FROM DUAL
spring.datasource.testWhileIdle=true
spring.datasource.testOnBorrow=false
spring.datasource.testOnReturn=false
# 打開PSCache,并且指定每個(gè)連接上PSCache的大小
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
# 配置監(jiān)控統(tǒng)計(jì)攔截的filters,去掉后監(jiān)控界面sql無法統(tǒng)計(jì),\'wall\'用于防火墻
spring.datasource.filters=stat,wall,log4j
spring.datasource.logSlowSql=true
# 通過connectProperties屬性來打開mergeSql功能;慢SQL記錄
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
/**
* 阿里Druid連接池配置方式
*/
@Slf4j
@Configuration
public class DruidDbConfig {
@Value(${spring.datasource.ms.driver-class-name})
private String driverClassName;
@Value(${spring.datasource.ms.jdbcurl})
private String dbUrl;
@Value(${spring.datasource.ms.username})
private String username;
@Value(${spring.datasource.ms.password})
private String password;
@Value(${spring.datasource.initialSize})
private int initialSize;
@Value(${spring.datasource.minIdle})
private int minIdle;
@Value(${spring.datasource.maxActive})
private int maxActive;
@Value(${spring.datasource.maxWait})
private int maxWait;
/**
* 配置間隔多久才進(jìn)行一次檢測,檢測需要關(guān)閉的空閑連接,單位是毫秒
*/
@Value(${spring.datasource.timeBetweenEvictionRunsMillis})
private int timeBetweenEvictionRunsMillis;
/**
* 配置一個(gè)連接在池中最小生存的時(shí)間,單位是毫秒
*/
@Value(${spring.datasource.minEvictableIdleTimeMillis})
private int minEvictableIdleTimeMillis;
@Value(${spring.datasource.validationQuery})
private String validationQuery;
@Value(${spring.datasource.testWhileIdle})
private boolean testWhileIdle;
@Value(${spring.datasource.testOnBorrow})
private boolean testOnBorrow;
@Value(${spring.datasource.testOnReturn})
private boolean testOnReturn;
/**
* 打開PSCache,并且指定每個(gè)連接上PSCache的大小
*/
@Value(${spring.datasource.poolPreparedStatements})
private boolean poolPreparedStatements;
@Value(${spring.datasource.maxPoolPreparedStatementPerConnectionSize})
private int maxPoolPreparedStatementPerConnectionSize;
/**
* 配置監(jiān)控統(tǒng)計(jì)攔截的filters
*/
@Value(${spring.datasource.filters})
private String filters;
/**
* 通過connectProperties屬性來打開mergeSql功能;慢SQL記錄
*/
@Value(${spring.datasource.connectionProperties})
private String connectionProperties;
@Bean
@Primary
public DataSource msDataSource() {
return getDruidDataSource(driverClassName, username, password, dbUrl);
}
private DruidDataSource getDruidDataSource(String driverClassName, String username, String password, String url) {
DruidDataSource datasource = new DruidDataSource();
datasource.setUrl(url);
datasource.setUsername(username);
datasource.setPassword(password);
datasource.setDriverClassName(driverClassName);
//configuration
datasource.setInitialSize(initialSize);
datasource.setMinIdle(minIdle);
datasource.setMaxActive(maxActive);
datasource.setMaxWait(maxWait);
datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
datasource.setValidationQuery(validationQuery);
datasource.setTestWhileIdle(testWhileIdle);
datasource.setTestOnBorrow(testOnBorrow);
datasource.setTestOnReturn(testOnReturn);
datasource.setPoolPreparedStatements(poolPreparedStatements);
datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
try {
datasource.setFilters(filters);
} catch (SQLException e) {
log.error(druid configuration initialization filter : {0}, e);
}
datasource.setConnectionProperties(connectionProperties);
return datasource;
}
}發(fā)現(xiàn),無論是配置類方式還是xml定義方式,目的都是得到一個(gè)DataSource類型的對象,這個(gè)DataSource對象屬于jdk定義:
package javax.sql;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Wrapper;
public interface DataSource extends CommonDataSource, Wrapper {
/**
* <p>Attempts to establish a connection with the data source that
* this {@code DataSource} object represents.
*/
Connection getConnection() throws SQLException;
/**
* <p>Attempts to establish a connection with the data source that
* this {@code DataSource} object represents.
*/
Connection getConnection(String username, String password)
throws SQLException;
}所有第三方實(shí)現(xiàn)的數(shù)據(jù)源,例如C3P0、阿里的druid都需要實(shí)現(xiàn)這個(gè)DataSource接口。
如果把數(shù)據(jù)比作水,那么數(shù)據(jù)庫就是水庫,數(shù)據(jù)源就是連接水庫的管道,客戶端看到的數(shù)據(jù)集就是從管道中流出的水。
連接池池化技術(shù),以數(shù)據(jù)庫連接池為例,基本的思想是系統(tǒng)初始化時(shí),創(chuàng)建若干連接并保存在內(nèi)存中,當(dāng)用戶需要訪問數(shù)據(jù)庫時(shí),無需建立新的連接,而是從連接池中取出一個(gè)已建立的空閑連接對象,當(dāng)這個(gè)連接使用完畢后,將返回到連接池中,等待下次被使用。
C3P0、druid都會(huì)維護(hù)自己的數(shù)據(jù)庫連接池,數(shù)據(jù)庫連接池就負(fù)責(zé)分配、管理和釋放連接,連接池的主要優(yōu)點(diǎn)有以下三個(gè)方面:
減少連接創(chuàng)建時(shí)間:連接池中的連接可直接使用,這樣減少了連接創(chuàng)建的資源消耗;
提高效率:用戶可以直接使用連接,提升響應(yīng)效率;
資源控制:連接池能夠使資源利用控制在一定的水平之下,如果不使用連接池,每次訪問數(shù)據(jù)庫都需要?jiǎng)?chuàng)建一個(gè)連接,很容易產(chǎn)生資源浪費(fèi)和高負(fù)載異常。
文章名稱:數(shù)據(jù)源和連接池
文章鏈接:http://chinadenli.net/article22/cjiecc.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供靜態(tài)網(wǎng)站、網(wǎng)站排名、用戶體驗(yàn)、企業(yè)網(wǎng)站制作、網(wǎng)站改版、微信小程序
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)