类org.hibernate.loader.custom.CustomLoader源码实例Demo

下面列出了怎么用org.hibernate.loader.custom.CustomLoader的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: lams   文件: SessionImpl.java
@Override
	public ScrollableResultsImplementor scrollCustomQuery(CustomQuery customQuery, QueryParameters queryParameters) {
		checkOpenOrWaitingForAutoClose();
//		checkTransactionSynchStatus();

		if ( log.isTraceEnabled() ) {
			log.tracev( "Scroll SQL query: {0}", customQuery.getSQL() );
		}

		CustomLoader loader = getFactory().getQueryPlanCache().getNativeQueryInterpreter().createCustomLoader( customQuery, getFactory() );

		autoFlushIfRequired( loader.getQuerySpaces() );

		dontFlushFromFind++; //stops flush being called multiple times if this method is recursively called
		try {
			return loader.scroll( queryParameters, this );
		}
		finally {
			delayedAfterCompletion();
			dontFlushFromFind--;
		}
	}
 
源代码2 项目: lams   文件: SessionImpl.java
@Override
	public List listCustomQuery(CustomQuery customQuery, QueryParameters queryParameters) {
		checkOpenOrWaitingForAutoClose();
//		checkTransactionSynchStatus();

		if ( log.isTraceEnabled() ) {
			log.tracev( "SQL query: {0}", customQuery.getSQL() );
		}

		CustomLoader loader = getFactory().getQueryPlanCache().getNativeQueryInterpreter().createCustomLoader( customQuery, getFactory() );

		autoFlushIfRequired( loader.getQuerySpaces() );

		dontFlushFromFind++;
		boolean success = false;
		try {
			List results = loader.list( this, queryParameters );
			success = true;
			return results;
		}
		finally {
			dontFlushFromFind--;
			delayedAfterCompletion();
			afterOperation( success );
		}
	}
 
源代码3 项目: lams   文件: StatelessSessionImpl.java
@Override
public List listCustomQuery(CustomQuery customQuery, QueryParameters queryParameters)
		throws HibernateException {
	checkOpen();
	CustomLoader loader = new CustomLoader( customQuery, getFactory() );

	boolean success = false;
	List results;
	try {
		results = loader.list( this, queryParameters );
		success = true;
	}
	finally {
		afterOperation( success );
	}
	temporaryPersistenceContext.clear();
	return results;
}
 
源代码4 项目: cacheonix-core   文件: SessionImpl.java
public ScrollableResults scrollCustomQuery(CustomQuery customQuery, QueryParameters queryParameters) 
throws HibernateException {
	errorIfClosed();
	checkTransactionSynchStatus();

	if ( log.isTraceEnabled() ) {
		log.trace( "scroll SQL query: " + customQuery.getSQL() );
	}

	CustomLoader loader = new CustomLoader( customQuery, getFactory() );

	autoFlushIfRequired( loader.getQuerySpaces() );

	dontFlushFromFind++; //stops flush being called multiple times if this method is recursively called
	try {
		return loader.scroll(queryParameters, this);
	}
	finally {
		dontFlushFromFind--;
	}
}
 
源代码5 项目: cacheonix-core   文件: SessionImpl.java
public List listCustomQuery(CustomQuery customQuery, QueryParameters queryParameters) 
throws HibernateException {
	errorIfClosed();
	checkTransactionSynchStatus();

	if ( log.isTraceEnabled() ) {
		log.trace( "SQL query: " + customQuery.getSQL() );
	}
	
	CustomLoader loader = new CustomLoader( customQuery, getFactory() );

	autoFlushIfRequired( loader.getQuerySpaces() );

	dontFlushFromFind++;
	boolean success = false;
	try {
		List results = loader.list(this, queryParameters);
		success = true;
		return results;
	}
	finally {
		dontFlushFromFind--;
		afterOperation(success);
	}
}
 
源代码6 项目: cacheonix-core   文件: StatelessSessionImpl.java
public List listCustomQuery(CustomQuery customQuery, QueryParameters queryParameters)
throws HibernateException {
	errorIfClosed();
	CustomLoader loader = new CustomLoader( customQuery, getFactory() );

	boolean success = false;
	List results;
	try {
		results = loader.list(this, queryParameters);
		success = true;
	}
	finally {
		afterOperation(success);
	}
	temporaryPersistenceContext.clear();
	return results;
}
 
源代码7 项目: lams   文件: StatelessSessionImpl.java
@Override
public ScrollableResultsImplementor scrollCustomQuery(CustomQuery customQuery, QueryParameters queryParameters)
		throws HibernateException {
	checkOpen();
	CustomLoader loader = new CustomLoader( customQuery, getFactory() );
	return loader.scroll( queryParameters, this );
}
 
源代码8 项目: cacheonix-core   文件: StatelessSessionImpl.java
public ScrollableResults scrollCustomQuery(CustomQuery customQuery, QueryParameters queryParameters)
throws HibernateException {
	errorIfClosed();
	CustomLoader loader = new CustomLoader( customQuery, getFactory() );
	return loader.scroll(queryParameters, this);
}
 
源代码9 项目: lams   文件: NativeQueryInterpreter.java
/**
 * Creates a {@link CustomLoader} for the given {@link CustomQuery}.
 *
 * @param customQuery The CustomQuery to create a loader for
 * @param sessionFactory The current session factory
 *
 * @deprecated This method will be removed in 6.
 */
@Deprecated
default CustomLoader createCustomLoader(CustomQuery customQuery, SessionFactoryImplementor sessionFactory) {
	return new CustomLoader( customQuery, sessionFactory );
}
 
 类所在包
 类方法
 同包方法