Hibernate/hibernate-orm
1
0
Fork 0
mirror of https://github.com/hibernate/hibernate-orm synced 2025-02-28 14:59:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

HHH-16900 Refactor integration tests

Browse Source
This commit is contained in:
Sanne Grinovero 2023-07-04 20:41:30 +01:00 committed by Sanne Grinovero
parent c1767adee7
commit 045f25511c
1 changed files with 36 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
hibernate-core/src/test/java/org/hibernate/orm/test/boot/database/qualfiedTableNaming/DefaultCatalogAndSchemaTest.java
View File

@ -47,6 +47,7 @@
import org.hibernate.query.sqm.mutation.internal.temptable.LocalTemporaryTableStrategy; import org.hibernate.query.sqm.mutation.internal.temptable.LocalTemporaryTableStrategy;
import org.hibernate.query.sqm.mutation.internal.temptable.PersistentTableStrategy; import org.hibernate.query.sqm.mutation.internal.temptable.PersistentTableStrategy;
import org.hibernate.service.spi.ServiceRegistryImplementor; import org.hibernate.service.spi.ServiceRegistryImplementor;
import org.hibernate.sql.model.MutationOperation;
import org.hibernate.sql.model.MutationOperationGroup; import org.hibernate.sql.model.MutationOperationGroup;
import org.hibernate.sql.model.PreparableMutationOperation; import org.hibernate.sql.model.PreparableMutationOperation;
import org.hibernate.tool.hbm2ddl.SchemaExport; import org.hibernate.tool.hbm2ddl.SchemaExport;
@ -408,38 +409,51 @@ private void verifyEntityPersisterQualifiers(Class<?> entityClass, ExpectedQuali
// This will include SQL generated by ID generators in some cases, which will be validated here // This will include SQL generated by ID generators in some cases, which will be validated here
// because ID generators table/sequence names are prefixed with the owning entity name. // because ID generators table/sequence names are prefixed with the owning entity name.
{
final MutationOperationGroup staticSqlInsertGroup = persister.getInsertCoordinator().getStaticInsertGroup(); final MutationOperationGroup staticSqlInsertGroup = persister.getInsertCoordinator().getStaticInsertGroup();
final String[] insertSqls = new String[staticSqlInsertGroup.getNumberOfOperations()]; final String[] insertSqls = new String[staticSqlInsertGroup.getNumberOfOperations()];
staticSqlInsertGroup.forEachOperation( (tablePosition, insertOperation) -> { for ( int tablePosition = 0;
tablePosition < staticSqlInsertGroup.getNumberOfOperations();
tablePosition++ ) {
final MutationOperation insertOperation = staticSqlInsertGroup.getOperation( tablePosition );
if ( insertOperation instanceof PreparableMutationOperation ) { if ( insertOperation instanceof PreparableMutationOperation ) {
insertSqls[tablePosition] = ( (PreparableMutationOperation) insertOperation ).getSqlString(); insertSqls[tablePosition] = ( (PreparableMutationOperation) insertOperation ).getSqlString();
} }
} ); }
verifyOnlyQualifier( insertSqls, SqlType.RUNTIME, jpaEntityName, expectedQualifier ); verifyOnlyQualifier( insertSqls, SqlType.RUNTIME, jpaEntityName, expectedQualifier );
}
String identitySelectString = persister.getIdentitySelectString(); String identitySelectString = persister.getIdentitySelectString();
if ( identitySelectString != null ) { if ( identitySelectString != null ) {
verifyOnlyQualifierOptional( identitySelectString, SqlType.RUNTIME, jpaEntityName, expectedQualifier ); verifyOnlyQualifierOptional( identitySelectString, SqlType.RUNTIME, jpaEntityName, expectedQualifier );
} }
{
final MutationOperationGroup staticSqlUpdateGroup = persister.getUpdateCoordinator().getStaticUpdateGroup(); final MutationOperationGroup staticSqlUpdateGroup = persister.getUpdateCoordinator().getStaticUpdateGroup();
final String[] sqlUpdateStrings = new String[staticSqlUpdateGroup.getNumberOfOperations()]; final String[] sqlUpdateStrings = new String[staticSqlUpdateGroup.getNumberOfOperations()];
staticSqlUpdateGroup.forEachOperation( (tablePosition, operation) -> { for ( int tablePosition = 0;
tablePosition < staticSqlUpdateGroup.getNumberOfOperations();
tablePosition++ ) {
final MutationOperation operation = staticSqlUpdateGroup.getOperation( tablePosition );
if ( operation instanceof PreparableMutationOperation ) { if ( operation instanceof PreparableMutationOperation ) {
sqlUpdateStrings[tablePosition] = ( (PreparableMutationOperation) operation ).getSqlString(); sqlUpdateStrings[tablePosition] = ( (PreparableMutationOperation) operation ).getSqlString();
} }
} ); }
verifyOnlyQualifier( sqlUpdateStrings, SqlType.RUNTIME, jpaEntityName, expectedQualifier ); verifyOnlyQualifier( sqlUpdateStrings, SqlType.RUNTIME, jpaEntityName, expectedQualifier );
}
{
final MutationOperationGroup staticDeleteGroup = persister.getDeleteCoordinator().getStaticDeleteGroup(); final MutationOperationGroup staticDeleteGroup = persister.getDeleteCoordinator().getStaticDeleteGroup();
final String[] sqlDeleteStrings = new String[staticDeleteGroup.getNumberOfOperations()]; final String[] sqlDeleteStrings = new String[staticDeleteGroup.getNumberOfOperations()];
staticDeleteGroup.forEachOperation( (tablePosition, operation) -> { for ( int tablePosition = 0; tablePosition < staticDeleteGroup.getNumberOfOperations(); tablePosition++ ) {
final MutationOperation operation = staticDeleteGroup.getOperation( tablePosition );
if ( operation instanceof PreparableMutationOperation ) { if ( operation instanceof PreparableMutationOperation ) {
sqlDeleteStrings[tablePosition] = ( (PreparableMutationOperation) operation ).getSqlString(); sqlDeleteStrings[tablePosition] = ( (PreparableMutationOperation) operation ).getSqlString();
} }
} ); }
verifyOnlyQualifier( sqlDeleteStrings, SqlType.RUNTIME, jpaEntityName, expectedQualifier ); verifyOnlyQualifier( sqlDeleteStrings, SqlType.RUNTIME, jpaEntityName, expectedQualifier );
}
// This is used in the "select" id generator in particular. // This is used in the "select" id generator in particular.
verifyOnlyQualifierOptional( persister.getSelectByUniqueKeyString( "basic" ), SqlType.RUNTIME, verifyOnlyQualifierOptional( persister.getSelectByUniqueKeyString( "basic" ), SqlType.RUNTIME,