Hibernate 查询
Hibernate 查询
村长大神 发表于4年前
Hibernate 查询
  • 发表于 4年前
  • 阅读 80
  • 收藏 3
  • 点赞 0
  • 评论 0

新睿云服务器60天免费使用,快来体验!>>>   

本文主要通过源码,概述一下session的查询过程。

主要api有get、load。他们基本过程是类似的;

以get为例:

Session

public Object get(String entityName, Serializable id) throws HibernateException;

调用SessionImpl:

Java代码 复制代码 收藏代码
  1. public Object get(String entityName, Serializable id) throws HibernateException {
  2. LoadEvent event = new LoadEvent(id, entityName, false, this);
  3. boolean success = false;
  4. try {
  5. fireLoad(event, LoadEventListener.GET);
  6. success = true;
  7. return event.getResult();
  8. }
  9. finally {
  10. afterOperation(success);
  11. }
  12. }
public Object get(String entityName, Serializable id) throws HibernateException {
		LoadEvent event = new LoadEvent(id, entityName, false, this);
		boolean success = false;
		try {
			fireLoad(event, LoadEventListener.GET);
			success = true;
			return event.getResult();
		}
		finally {
			afterOperation(success);
		}
	}

fireLoad 主要是出发监听器;

主要获取过程就是 event.getResult();

event为LoadEvent,其实是一个很简单的类,其getResult也是非常简单,

Java代码 复制代码 收藏代码
  1. public Object getResult() {
  2. return result;
  3. }
  4. public void setResult(Object result) {
  5. this.result = result;
  6. }
public Object getResult() {
  return result;
 }
 public void setResult(Object result) {
  this.result = result;
 }

其中result其实是由 fireLoad(event, LoadEventListener.GET) 执行过程中赋值的

Java代码 复制代码 收藏代码
  1. private void fireLoad(LoadEvent event, LoadType loadType) {
  2. errorIfClosed();
  3. checkTransactionSynchStatus();
  4. LoadEventListener[] loadEventListener = listeners.getLoadEventListeners();
  5. for ( int i = 0; i < loadEventListener.length; i++ ) {
  6. loadEventListener[i].onLoad(event, loadType);
  7. }
  8. }
private void fireLoad(LoadEvent event, LoadType loadType) {
		errorIfClosed();
		checkTransactionSynchStatus();
		LoadEventListener[] loadEventListener = listeners.getLoadEventListeners();
		for ( int i = 0; i < loadEventListener.length; i++ ) {
			loadEventListener[i].onLoad(event, loadType);
		}
	}

当然,从这段代码中我们仍然看不出什么头绪,我们继续研究

loadEventListener[i].onLoad(event, loadType);

经查找发现loadEvent有一个listener :DefaultLoadEventListener

其onLoad方法主要调用

event.setResult( load(。。。。 ) ); 也就是 DefaultLoadEventListener 的load方法,而其中主要又调用

Object entity = doLoad(event, persister, keyToLoad, options); 来进行“查询”:

Java代码 复制代码 收藏代码
  1. protected Object doLoad(
  2. final LoadEvent event,
  3. final EntityPersister persister,
  4. final EntityKey keyToLoad,
  5. final LoadEventListener.LoadType options)
  6. throws HibernateException {
  7. //1
  8. Object entity = loadFromSessionCache(event, keyToLoad, options);
  9. if ( entity == REMOVED_ENTITY_MARKER ) {
  10. return null;
  11. }
  12. if ( entity != null ) {
  13. return entity;
  14. }
  15. //2
  16. entity = loadFromSecondLevelCache(event, persister, options);
  17. if ( entity != null ) {
  18. return entity;
  19. }
  20. //3
  21. return loadFromDatasource(event, persister, keyToLoad, options);
  22. }
protected Object doLoad(
		final LoadEvent event, 
		final EntityPersister persister,
		final EntityKey keyToLoad, 
		final LoadEventListener.LoadType options) 
	throws HibernateException {
		
		//1
		Object entity = loadFromSessionCache(event, keyToLoad, options);
		if ( entity == REMOVED_ENTITY_MARKER ) {
			return null;
		}
		if ( entity != null ) {
			return entity;
		}

		//2
		entity = loadFromSecondLevelCache(event, persister, options);
		if ( entity != null ) {
			return entity;
		}

		//3
		return loadFromDatasource(event, persister, keyToLoad, options);
	}

去掉其中的注释和logging部分,我们终于可以看到一个比较明显的语义了!!:::

1、loadFromSessionCache————从session缓存中查找, 如果找不到,则2

2、loadFromSecondLevelCache————从二级缓存中查找(如果支持),如果找不到,则3(即从sessionFactory查询)

3、loadFromDatasource————仍然查找不到,则从数据库中查询——这回是真正的查询

loadFromSessionCache 关键:

Object old = session.getEntityUsingInterceptor( keyToLoad );

loadFromSecondLevelCache关键:

Object ce = persister.getCache().get( ck, source.getTimestamp() );

loadFromDatasource关键:

Object entity = persister.load(
event.getEntityId(),
event.getInstanceToLoad(),
event.getLockMode(),
source
);

  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
粉丝 159
博文 441
码字总数 607059
×
村长大神
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: