类org.hibernate.sql.SimpleSelect源码实例Demo

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

default String generateSelectLockString(LockOptions lockOptions) {
	final SessionFactoryImplementor factory = getFactory();
	Dialect dialect = factory.getJdbcServices().getDialect();
	final SimpleSelect select = new SimpleSelect(dialect)
			.setLockOptions( lockOptions )
			.setTableName( getRootTableName() )
			.addColumn( getRootTableIdentifierColumnNames()[0] )
			.addCondition( getRootTableIdentifierColumnNames(), "=?" );
	if ( isVersioned() ) {
		select.addCondition( getVersionColumnName(), "=?" );
	}
	if ( factory.getSessionFactoryOptions().isCommentsEnabled() ) {
		select.setComment( lockOptions.getLockMode() + " lock " + getEntityName() );
	}
	return select.toStatementString();
}
 
protected String generateLockString(int lockTimeout) {
	final SessionFactoryImplementor factory = getLockable().getFactory();
	final LockOptions lockOptions = new LockOptions( getLockMode() );
	lockOptions.setTimeOut( lockTimeout );
	final SimpleSelect select = new SimpleSelect( factory.getDialect() )
			.setLockOptions( lockOptions )
			.setTableName( getLockable().getRootTableName() )
			.addColumn( getLockable().getRootTableIdentifierColumnNames()[0] )
			.addCondition( getLockable().getRootTableIdentifierColumnNames(), "=?" );
	if ( getLockable().isVersioned() ) {
		select.addCondition( getLockable().getVersionColumnName(), "=?" );
	}
	if ( factory.getSessionFactoryOptions().isCommentsEnabled() ) {
		select.setComment( getLockMode() + " lock " + getLockable().getEntityName() );
	}
	return select.toStatementString();
}
 
源代码3 项目: lams   文件: SelectLockingStrategy.java
protected String generateLockString(int timeout) {
	final SessionFactoryImplementor factory = getLockable().getFactory();
	final LockOptions lockOptions = new LockOptions( getLockMode() );
	lockOptions.setTimeOut( timeout );
	final SimpleSelect select = new SimpleSelect( factory.getDialect() )
			.setLockOptions( lockOptions )
			.setTableName( getLockable().getRootTableName() )
			.addColumn( getLockable().getRootTableIdentifierColumnNames()[0] )
			.addCondition( getLockable().getRootTableIdentifierColumnNames(), "=?" );
	if ( getLockable().isVersioned() ) {
		select.addCondition( getLockable().getVersionColumnName(), "=?" );
	}
	if ( factory.getSessionFactoryOptions().isCommentsEnabled() ) {
		select.setComment( getLockMode() + " lock " + getLockable().getEntityName() );
	}
	return select.toStatementString();
}
 
protected String generateLockString(int lockTimeout) {
	final SessionFactoryImplementor factory = getLockable().getFactory();
	final LockOptions lockOptions = new LockOptions( getLockMode() );
	lockOptions.setTimeOut( lockTimeout );
	final SimpleSelect select = new SimpleSelect( factory.getDialect() )
			.setLockOptions( lockOptions )
			.setTableName( getLockable().getRootTableName() )
			.addColumn( getLockable().getRootTableIdentifierColumnNames()[0] )
			.addCondition( getLockable().getRootTableIdentifierColumnNames(), "=?" );
	if ( getLockable().isVersioned() ) {
		select.addCondition( getLockable().getVersionColumnName(), "=?" );
	}
	if ( factory.getSessionFactoryOptions().isCommentsEnabled() ) {
		select.setComment( getLockMode() + " lock " + getLockable().getEntityName() );
	}
	return select.toStatementString();
}
 
源代码5 项目: lams   文件: AbstractEntityPersister.java
/**
 * Generate the SQL that selects the version number by id
 */
protected String generateSelectVersionString() {
	SimpleSelect select = new SimpleSelect( getFactory().getDialect() )
			.setTableName( getVersionedTableName() );
	if ( isVersioned() ) {
		select.addColumn( versionColumnName );
	}
	else {
		select.addColumns( rootTableKeyColumnNames );
	}
	if ( getFactory().getSessionFactoryOptions().isCommentsEnabled() ) {
		select.setComment( "get version " + getEntityName() );
	}
	return select.addCondition( rootTableKeyColumnNames, "=?" ).toStatementString();
}
 
源代码6 项目: lams   文件: AbstractEntityPersister.java
public String getSelectByUniqueKeyString(String propertyName) {
	return new SimpleSelect( getFactory().getDialect() )
			.setTableName( getTableName( 0 ) )
			.addColumns( getKeyColumns( 0 ) )
			.addCondition( getPropertyColumnNames( propertyName ), "=?" )
			.toStatementString();
}
 
源代码7 项目: lams   文件: UnionSubclassEntityPersister.java
/**
 * Generate the SQL that selects a row by id
 */
protected String generateSelectString(LockMode lockMode) {
	SimpleSelect select = new SimpleSelect( getFactory().getDialect() )
			.setLockMode( lockMode )
			.setTableName( getTableName() )
			.addColumns( getIdentifierColumnNames() )
			.addColumns(
					getSubclassColumnClosure(),
					getSubclassColumnAliasClosure(),
					getSubclassColumnLazyiness()
			)
			.addColumns(
					getSubclassFormulaClosure(),
					getSubclassFormulaAliasClosure(),
					getSubclassFormulaLazyiness()
			);
	//TODO: include the rowids!!!!
	if ( hasSubclasses() ) {
		if ( isDiscriminatorFormula() ) {
			select.addColumn( getDiscriminatorFormula(), getDiscriminatorAlias() );
		}
		else {
			select.addColumn( getDiscriminatorColumnName(), getDiscriminatorAlias() );
		}
	}
	if ( getFactory().getSettings().isCommentsEnabled() ) {
		select.setComment( "load " + getEntityName() );
	}
	return select.addCondition( getIdentifierColumnNames(), "=?" ).toStatementString();
}
 
源代码8 项目: lams   文件: AbstractCollectionPersister.java
protected String generateSelectSizeString(boolean isIntegerIndexed) {
	String selectValue = isIntegerIndexed ?
			"max(" + getIndexColumnNames()[0] + ") + 1" : // lists, arrays
			"count(" + getElementColumnNames()[0] + ")"; // sets, maps, bags
	return new SimpleSelect( dialect )
			.setTableName( getTableName() )
			.addCondition( getKeyColumnNames(), "=?" )
			.addWhereToken( sqlWhereString )
			.addColumn( selectValue )
			.toStatementString();
}
 
源代码9 项目: lams   文件: AbstractCollectionPersister.java
protected String generateDetectRowByIndexString() {
	if ( !hasIndex() ) {
		return null;
	}
	return new SimpleSelect( dialect )
			.setTableName( getTableName() )
			.addCondition( getKeyColumnNames(), "=?" )
			.addCondition( getIndexColumnNames(), "=?" )
			.addCondition( indexFormulas, "=?" )
			.addWhereToken( sqlWhereString )
			.addColumn( "1" )
			.toStatementString();
}
 
源代码10 项目: lams   文件: AbstractCollectionPersister.java
protected String generateSelectRowByIndexString() {
	if ( !hasIndex() ) {
		return null;
	}
	return new SimpleSelect( dialect )
			.setTableName( getTableName() )
			.addCondition( getKeyColumnNames(), "=?" )
			.addCondition( getIndexColumnNames(), "=?" )
			.addCondition( indexFormulas, "=?" )
			.addWhereToken( sqlWhereString )
			.addColumns( getElementColumnNames(), elementColumnAliases )
			.addColumns( indexFormulas, indexColumnAliases )
			.toStatementString();
}
 
源代码11 项目: lams   文件: AbstractCollectionPersister.java
protected String generateDetectRowByElementString() {
	return new SimpleSelect( dialect )
			.setTableName( getTableName() )
			.addCondition( getKeyColumnNames(), "=?" )
			.addCondition( getElementColumnNames(), "=?" )
			.addCondition( elementFormulas, "=?" )
			.addWhereToken( sqlWhereString )
			.addColumn( "1" )
			.toStatementString();
}
 
源代码12 项目: cacheonix-core   文件: AbstractEntityPersister.java
/**
 * Generate the SQL that selects the version number by id
 */
protected String generateSelectVersionString() {
	SimpleSelect select = new SimpleSelect( getFactory().getDialect() )
			.setTableName( getVersionedTableName() );
	if ( isVersioned() ) {
		select.addColumn( versionColumnName );
	}
	else {
		select.addColumns( rootTableKeyColumnNames );
	}
	if ( getFactory().getSettings().isCommentsEnabled() ) {
		select.setComment( "get version " + getEntityName() );
	}
	return select.addCondition( rootTableKeyColumnNames, "=?" ).toStatementString();
}
 
源代码13 项目: cacheonix-core   文件: AbstractEntityPersister.java
public String getSelectByUniqueKeyString(String propertyName) {
	return new SimpleSelect( getFactory().getDialect() )
		.setTableName( getTableName(0) )
		.addColumns( getKeyColumns(0) )
		.addCondition( getPropertyColumnNames(propertyName), "=?" )
		.toStatementString();
}
 
/**
 * Generate the SQL that selects a row by id
 */
protected String generateSelectString(LockMode lockMode) {
	SimpleSelect select = new SimpleSelect( getFactory().getDialect() )
		.setLockMode(lockMode)
		.setTableName( getTableName() )
		.addColumns( getIdentifierColumnNames() )
		.addColumns( 
				getSubclassColumnClosure(), 
				getSubclassColumnAliasClosure(),
				getSubclassColumnLazyiness()
		)
		.addColumns( 
				getSubclassFormulaClosure(), 
				getSubclassFormulaAliasClosure(),
				getSubclassFormulaLazyiness()
		);
	//TODO: include the rowids!!!!
	if ( hasSubclasses() ) {
		if ( isDiscriminatorFormula() ) {
			select.addColumn( getDiscriminatorFormula(), getDiscriminatorAlias() );
		}
		else {
			select.addColumn( getDiscriminatorColumnName(), getDiscriminatorAlias() );
		}
	}
	if ( getFactory().getSettings().isCommentsEnabled() ) {
		select.setComment( "load " + getEntityName() );
	}
	return select.addCondition( getIdentifierColumnNames(), "=?" ).toStatementString();
}
 
protected String generateSelectSizeString(boolean isIntegerIndexed) {
	String selectValue = isIntegerIndexed ? 
		"max(" + getIndexColumnNames()[0] + ") + 1": //lists, arrays
		"count(" + getElementColumnNames()[0] + ")"; //sets, maps, bags
	return new SimpleSelect(dialect)
			.setTableName( getTableName() )
			.addCondition( getKeyColumnNames(), "=?" )
			.addColumn(selectValue)
			.toStatementString();
}
 
protected String generateDetectRowByIndexString() {
	if ( !hasIndex() ) {
		return null;
	}
	return new SimpleSelect(dialect)
			.setTableName( getTableName() )
			.addCondition( getKeyColumnNames(), "=?" )
			.addCondition( getIndexColumnNames(), "=?" )
			.addCondition( indexFormulas, "=?" )
			.addColumn("1")
			.toStatementString();
}
 
protected String generateSelectRowByIndexString() {
	if ( !hasIndex() ) {
		return null;
	}
	return new SimpleSelect(dialect)
			.setTableName( getTableName() )
			.addCondition( getKeyColumnNames(), "=?" )
			.addCondition( getIndexColumnNames(), "=?" )
			.addCondition( indexFormulas, "=?" )
			.addColumns( getElementColumnNames(), elementColumnAliases )
			.addColumns( indexFormulas, indexColumnAliases )
			.toStatementString();
}
 
protected String generateDetectRowByElementString() {
	return new SimpleSelect(dialect)
			.setTableName( getTableName() )
			.addCondition( getKeyColumnNames(), "=?" )
			.addCondition( getElementColumnNames(), "=?" )
			.addCondition( elementFormulas, "=?" )
			.addColumn("1")
			.toStatementString();
}
 
源代码19 项目: cacheonix-core   文件: SelectLockingStrategy.java
protected String generateLockString() {
	SessionFactoryImplementor factory = lockable.getFactory();
	SimpleSelect select = new SimpleSelect( factory.getDialect() )
			.setLockMode( lockMode )
			.setTableName( lockable.getRootTableName() )
			.addColumn( lockable.getRootTableIdentifierColumnNames()[0] )
			.addCondition( lockable.getRootTableIdentifierColumnNames(), "=?" );
	if ( lockable.isVersioned() ) {
		select.addCondition( lockable.getVersionColumnName(), "=?" );
	}
	if ( factory.getSettings().isCommentsEnabled() ) {
		select.setComment( lockMode + " lock " + lockable.getEntityName() );
	}
	return select.toStatementString();
}
 
 类所在包
 同包方法