- 浏览: 143856 次
- 性别:
- 来自: 大连
文章分类
最新评论
-
qinjian379:
也不一定,有时候memory leak严重的情况下,是会影响t ...
This is very likely to create a memory leak ? -
springdata_spring:
可以参考最新的文档:如何在eclipse jee中检出项目并转 ...
maven的pom 提示错误 Failure to transfer com.thoughtworks.xstream:xstream:jar: -
xredman:
呵呵,蛮搞的
一个网吧网管在自杀前的遗书 -
jiahch:
....
else if ( properties.get ...
hibernate3 源码阅读 (三) Connection -
jiahch:
很好的文章,在结合 配置文件讲解一下就更好了! 多些楼主
& ...
hibernate3 源码阅读 (三) Connection
用 jdbc 操作数据库,是围绕 Connection 这个类 进行的,
hibernate 也一样,
这篇我们围绕 Connection, 看看hibernate是如何做的。
SessionImpl 里有一个方法 connection()
public Connection connection() throws HibernateException { errorIfClosed(); return jdbcContext.borrowConnection(); }
Session 取得 Connection, 是委托 jdbcContext 。
看下 jdbcContext.borrowConnection();
public Connection borrowConnection() { return connectionManager.borrowConnection(); }
jdbcContext 取得 Connection, 则又要委托 connectionManager,
那我们在看下ConnectionManager,
public Connection borrowConnection() { if ( isClosed ) { throw new HibernateException( "connection manager has been closed" ); } if ( isSuppliedConnection() ) { return connection; } else { if ( borrowedConnection == null ) { borrowedConnection = BorrowedConnectionProxy.generateProxy( this ); } return borrowedConnection; } }
ConnectionManager
private void openConnection() throws HibernateException { if ( connection != null ) { return; } log.debug("opening JDBC connection"); try { connection = factory.getConnectionProvider().getConnection(); } catch (SQLException sqle) { throw JDBCExceptionHelper.convert( factory.getSQLExceptionConverter(), sqle, "Cannot open connection" ); } callback.connectionOpened(); // register synch; stats.connect() }
关键一句
connection = factory.getConnectionProvider().getConnection();
这个factory是从哪来的呢?
new ConnectionManager( owner.getFactory(), this, owner.getConnectionReleaseMode(), connection, interceptor );
是在JdbcContext 初始化时, ConnectionManager 构造函数中作为参数传进来的,
我们已经知道了这个 owner,就是SessionImpl,
那么看看SessionImpl 的 factory ,
SessionImpl( final Connection connection, final SessionFactoryImpl factory, final boolean autoclose, final long timestamp, final Interceptor interceptor, final EntityMode entityMode, final boolean flushBeforeCompletionEnabled, final boolean autoCloseSessionEnabled, final ConnectionReleaseMode connectionReleaseMode) { super( factory );
SessionImpl 中的 factory,又是在SessionImpl 构造函数中作为参数传进来的,
那我们再往上一层看,谁初始化的SessionImpl 呢,前边说了,SessionFactory
private SessionImpl openSession(
Connection connection,
boolean autoClose,
long timestamp,
Interceptor sessionLocalInterceptor
) {
return new SessionImpl(
connection,
this,
autoClose,
timestamp,
sessionLocalInterceptor == null ? interceptor : sessionLocalInterceptor,
settings.getDefaultEntityMode(),
settings.isFlushBeforeCompletionEnabled(),
settings.isAutoCloseSessionEnabled(),
settings.getConnectionReleaseMode()
);
}
看到这个this了吗,就是他,从SessionImpl 传给 JdbcContext 又传个 ConnectionManager ,
ConnectionManager 里的 factory 就是 SessionFactoryImpl,
factory 找到了,再看看取 ConnectionProvider,
ConnectionManager
factory.getConnectionProvider().getConnection();
要从 factory 中取一个 ConnectionProvider,
SessionFactory
public ConnectionProvider getConnectionProvider() { return settings.getConnectionProvider(); }
Settings
public ConnectionProvider getConnectionProvider() { return connectionProvider; }
原来这个ConnectionProvider 最终是放在 Settings 里边的,
那么我们看一下 settings 的初始化 看看 settings 是怎么构造出 ConnectionProvider 的,
Configuration
Settings settings = buildSettings( copy );
public Settings buildSettings(Properties props) throws HibernateException { return settingsFactory.buildSettings( props ); }
SettingsFactory
public Settings buildSettings(Properties props) { Settings settings = new Settings(); //SessionFactory name: String sessionFactoryName = props.getProperty(Environment.SESSION_FACTORY_NAME); settings.setSessionFactoryName(sessionFactoryName); //JDBC and connection settings: ConnectionProvider connections = createConnectionProvider(props); settings.setConnectionProvider(connections);
protected ConnectionProvider createConnectionProvider(Properties properties) { return ConnectionProviderFactory.newConnectionProvider(properties); }
可以看到,hibernate 通过 ConnectionProviderFactory 类,以hibernate配置文件 (properties) 做参数,
构造了 Settings 里边的 ConnectionProvider,
我们看一下具体实现,
public static ConnectionProvider newConnectionProvider(Properties properties, Map connectionProviderInjectionData) throws HibernateException { ConnectionProvider connections; String providerClass = properties.getProperty(Environment.CONNECTION_PROVIDER); if ( providerClass!=null ) { try { log.info("Initializing connection provider: " + providerClass); connections = (ConnectionProvider) ReflectHelper.classForName(providerClass).newInstance(); } catch ( Exception e ) { log.error( "Could not instantiate connection provider", e ); throw new HibernateException("Could not instantiate connection provider: " + providerClass); } } else if ( properties.getProperty(Environment.DATASOURCE)!=null ) { connections = new DatasourceConnectionProvider(); } else if ( properties.getProperty(Environment.URL)!=null ) { connections = new DriverManagerConnectionProvider(); } else { connections = new UserSuppliedConnectionProvider(); } if ( connectionProviderInjectionData != null && connectionProviderInjectionData.size() != 0 ) { //inject the data try { BeanInfo info = Introspector.getBeanInfo( connections.getClass() ); PropertyDescriptor[] descritors = info.getPropertyDescriptors(); int size = descritors.length; for (int index = 0 ; index < size ; index++) { String propertyName = descritors[index].getName(); if ( connectionProviderInjectionData.containsKey( propertyName ) ) { Method method = descritors[index].getWriteMethod(); method.invoke( connections, new Object[] { connectionProviderInjectionData.get( propertyName ) } ); } } } catch (IntrospectionException e) { throw new HibernateException("Unable to inject objects into the conenction provider", e); } catch (IllegalAccessException e) { throw new HibernateException("Unable to inject objects into the conenction provider", e); } catch (InvocationTargetException e) { throw new HibernateException("Unable to inject objects into the conenction provider", e); } } connections.configure(properties); return connections; }
好了,我们终于找到了 ConnectionProvider构造的具体实现细节,
根据配置文件,
先判断具体类型,是DatasourceConnectionProvider,DriverManagerConnectionProvider 或是其他,
然后调用 ConnectionProvider 的 Configuration 方法
connections.configure(properties);
一个 ConnectionProvider 就构造完了,
有了ConnectionProvider,就可以通过他的 getConnection 方法,得到我们要的Connection,
public Connection getConnection() throws SQLException {
if ( log.isTraceEnabled() ) log.trace( "total checked-out connections: " + checkedOut );
synchronized (pool) {
if ( !pool.isEmpty() ) {
int last = pool.size() - 1;
if ( log.isTraceEnabled() ) {
log.trace("using pooled JDBC connection, pool size: " + last);
checkedOut++;
}
Connection pooled = (Connection) pool.remove(last);
if (isolation!=null) pooled.setTransactionIsolation( isolation.intValue() );
if ( pooled.getAutoCommit()!=autocommit ) pooled.setAutoCommit(autocommit);
return pooled;
}
}
log.debug("opening new JDBC connection");
Connection conn = DriverManager.getConnection(url, connectionProps);
if (isolation!=null) conn.setTransactionIsolation( isolation.intValue() );
if ( conn.getAutoCommit()!=autocommit ) conn.setAutoCommit(autocommit);
if ( log.isDebugEnabled() ) {
log.debug( "created connection to: " + url + ", Isolation Level: " + conn.getTransactionIsolation() );
}
if ( log.isTraceEnabled() ) checkedOut++;
return conn;
}
Connection conn = DriverManager.getConnection(url, connectionProps);
至此,我们就把 hibernate 中 关于Connection的构造以及调用 大概看了一遍。
评论
.... else if ( properties.getProperty(Environment.DATASOURCE)!=null ) { <SPAN style="COLOR: #ff0000">connections = new DatasourceConnectionProvider();</SPAN> } else if ( properties.getProperty(Environment.URL)!=null ) { <SPAN style="COLOR: #ff0000">connections = new DriverManagerConnectionProvider();</SPAN> } ....
上面的代码中 的
Environment.DATASOURCE 如果和 spring 联合起来使用的话 就应该是 其中的 属性dataSource
<bean id="sessionFactory" |
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" /> <!--<property name="url" value="jdbc:mysql://localhost:3306/testmysql"/>--> <!-- <property name="url" value="jdbc:oracle:thin:@localhost:1521:HELL" /> <property name="url" value="jdbc:oracle:thin:@localhost:1521:ORCL" /> --> <property name="url" value="jdbc:oracle:thin:@111.111.2.3:1521:FEEL" /> <property name="username" value="grgbanking" /> <property name="password" value="passw0rd" /> <property name="initialSize" value="3"/> <property name="maxIdle" value="2"/> <property name="minIdle" value="1"/> <property name="maxActive" value="50"/> <property name="removeAbandoned" value="true"/> <property name="removeAbandonedTimeout" value="180"/> <property name="maxWait" value="1000"/> </bean> <bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"> <property name="dataSource"> <ref local="dataSource"/> </property> <property name="annotatedClasses"> <list> <value>com.dne.framework.security.Role</value> <value>com.dne.framework.security.User</value> <value>com.dne.framework.security.Resource</value>
发表评论
-
ScriptEngineManager NashornScriptEngineFactory
2018-03-09 21:50 0NashornScriptEngineFactory 的 b ... -
http://www.codedata.com.tw/java/java-restful-1-jersey-and-jax-rs
2014-08-01 17:33 0http://www.codedata.com.tw/java ... -
Spring 学习 JdbcTemplate,模板模式,回调
2008-12-04 15:45 3960先通过一个小例子,简单使用一下。 配置文件 applica ... -
hibernate3 源码阅读 (二) Session
2008-11-24 17:12 2806上一篇我们看了Configu ... -
hibernate3 源码阅读 (一) Configuration
2008-11-24 16:46 3926最近简略看了一下hibernate的源代码,比较晕,不过也看出 ... -
Xwork2 源码阅读(五)
2008-11-20 15:46 1477在前边的几篇中,我们已经看了Action的执行, 实际上 Ac ... -
Xwork2 源码阅读(四)
2008-11-20 11:05 1620xwork2 的Inteceptor,是实现AOP的,我理解的 ... -
Xwork2 源码阅读(三)
2008-11-17 17:14 1764接着看Dispatcher Act ... -
Xwork2 源码阅读(二)
2008-11-17 11:45 2389Dispatcher类 Dispatcher类是在struts ... -
Xwork2 源码阅读(一)
2008-11-17 11:11 3050利用工作之余,看了一下xwork2 的源码,借此学学设计模式, ...
相关推荐
《Hibernate源码解析(一)》 在Java开发领域,Hibernate作为一款强大的对象关系映射(ORM)框架,极大地简化了数据库操作。深入理解Hibernate的源码,不仅可以帮助开发者更好地运用该工具,还能提升对Java编程和...
<property name="connection.provider_class">org.hibernate.connection.C3P0ConnectionProvider <property name="hibernate.c3p0.min_size">5 <property name="hibernate.c3p0.max_size">20 <property name="...
<property name="hibernate.connection.datasource">org.hibernate.connection.C3P0DataSource <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/testdb <property name="hibernate....
"-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"> <!-- Generated by MyEclipse Hibernate Tools. --> <hibernate-configuration> ...
源码中涉及的`org.hibernate.connection`包揭示了这一过程。 通过深入学习这些关键概念和组件,开发者可以更好地掌握Hibernate的工作原理,提升数据库操作的效率和灵活性,同时也能为解决实际项目中的问题提供理论...
### Struts2 + Spring2 + Hibernate3 整合实例源码分析 #### 一、概述 随着企业级应用的发展,为了提高开发效率和系统维护性,越来越多的项目开始采用MVC设计模式。其中,Struts2作为MVC框架中的佼佼者,在前端...
【hibernate 连接数据库基础源码】的解析与详解 Hibernate 是一款强大的对象关系映射(ORM)框架,它极大地简化了Java应用程序与数据库之间的交互。在本教程中,我们将深入探讨Hibernate如何连接到MySQL、Oracle等...
Hibernate3是Hibernate项目的第三个主要版本,它提供了强大的对象关系映射功能,能够将Java对象与数据库表进行映射,从而简化数据库操作。它支持多种数据库,包括MySQL、Oracle、SQL Server等,并且具备事务管理、...
**Hibernate 5.2.4 环境搭建与源码解析** Hibernate 是一个流行的 Java 对象关系映射(ORM)框架,它极大地简化了数据库操作。在本教程中,我们将详细探讨如何搭建 Hibernate 5.2.4 的开发环境,并理解其源码。 ...
在这个“hibernate源代码”压缩包中,包含的是Hibernate框架的核心源码,这为我们深入理解其工作原理、自定义功能或者优化性能提供了可能。 在Hibernate源代码中,有几个关键的模块和类值得我们关注: 1. **...
Hibernate是一个开源的对象关系映射(ORM)框架,它允许Java开发者在Java对象和数据库之间建立映射,从而简化数据操作。下面将详细讲解Hibernate的核心代码及其相关知识点。 1. **配置文件**: Hibernate的核心...
标题中的“Hibernate lazy加载FOR Connection”指的是Hibernate框架中的一种特性,即懒加载(Lazy Loading)。在Hibernate中,懒加载是一种优化策略,它推迟对关联对象的加载,直到真正需要使用这些对象时才进行加载...
**hibernate 连接数据库基础源码3** 在初学者的编程旅程中,学习如何使用Hibernate连接到数据库是至关重要的一步。Hibernate是一款强大的对象关系映射(ORM)框架,它简化了Java应用程序与数据库之间的交互。在这个...
Connection con = session.connection(); PreparedStatement pstmt = con.prepareStatement(sql); ResultSet rs = pstmt.executeQuery(); ResultSetMetaData rsmd = rs.getMetaData(); Hashtable ht = null; ...
通过深入研究Hibernate源码,我们可以了解到其内部的工作机制,包括对象关系映射(ORM)、查询语言(HQL)处理、缓存策略等核心概念。这篇内容将详细解析Hibernate的关键组件和工作流程,帮助你深化对数据持久化框架...
<property name="hibernate.connection.provider_class">org.hibernate.connection.C3P0ConnectionProvider <property name="hibernate.c3p0.min_size">5 <property name="hibernate.c3p0.max_size">20 ...
**hibernate学习笔记第四天源码解析** 在hibernate学习的过程中,第四天通常会深入探讨实体类、映射文件、配置文件以及查询语言等方面的内容。...建议结合源码仔细阅读并实践,以便更好地掌握hibernate的使用。
《深入理解Hibernate_first项目源码》 Hibernate,作为一款强大的对象关系映射(ORM)框架,使得Java开发者在处理数据库操作时,可以更加专注于业务逻辑,而非底层的SQL语句。"hibernate_first"项目源码为我们提供...
**Hibernate5 + MySQL实现Demo源码详解** 在Java开发中,ORM(对象关系映射)框架使得数据库操作变得更加便捷,而Hibernate作为其中的佼佼者,深受开发者喜爱。本Demo基于Hibernate5,结合MySQL数据库,提供了完整...