java Hibernate不会在选择之前刷新持久性上下文
我正在尝试使用spring事务支持用户休眠。我已经将会话工厂配置为bean(见下文),并创建了一个DAO类。我还使用spring测试支持——运行带有@Transactional注释的测试类,据我所知,这应该允许我在一个事务中调用多个dao操作。我读到hibernate应该在提交之后或在执行select之前刷新其持久性上下文。我对后者抱有希望。但是我的大多数测试都失败了,因为(根据日志)hibernate在插入之后和选择之前没有刷新它的持久性上下文
以下是弹簧配置的弹簧部分:
@Configuration
@PropertySource("/db.properties")
@EnableTransactionManagement
@ComponentScan(basePackages = "repository")
public class DataAccessConfiguration {
@Bean
public SessionFactory sessionFactory() throws IOException {
LocalSessionFactoryBean sessionFactoryBean = new LocalSessionFactoryBean();
sessionFactoryBean.setDataSource(pool());
sessionFactoryBean.setPackagesToScan("domain");
sessionFactoryBean.setHibernateProperties(hibernateProperties());
sessionFactoryBean.afterPropertiesSet();
return sessionFactoryBean.getObject();
}
private Properties hibernateProperties() {
Properties hibernateProp = new Properties();
hibernateProp.put("hibernate.dialect", "org.hibernate.dialect.PostgreSQLDialect");
hibernateProp.put("hibernate.format_sql", true);
hibernateProp.put("hibernate.use_sql_comments", true);
hibernateProp.put("hibernate.show_sql", true);
hibernateProp.put("hibernate.max_fetch_depth", 3);
hibernateProp.put("hibernate.jdbc.batch_size", 10);
hibernateProp.put("hibernate.jdbc.fetch_size", 50);
hibernateProp.put("hibernate.hbm2ddl.auto", "update");
return hibernateProp;
}
@Bean
@Profile("hibernate")
public PlatformTransactionManager transactionManager() throws IOException {
HibernateTransactionManager manager = new HibernateTransactionManager(sessionFactory());
manager.setDataSource(pool());
return manager;
}
@Bean
@Profile("jdbc")
PlatformTransactionManager jdbcTransactionManager(){
DataSourceTransactionManager manager = new DataSourceTransactionManager();
manager.setDataSource(pool());
return manager;
}
}
我使用两个平台事务管理器——一个用于jdbc,另一个用于hibernate。我尝试删除jdbc管理器,只留下hibernate(不起作用)
以下是dao类:
@Repository
@Profile("hibernate")
public class UserDaoHibernate implements UserDao {
private final SessionFactory sessionFactory;
public UserDaoHibernate(SessionFactory sessionFactory) {
this.sessionFactory = sessionFactory;
}
@Override
public void insert(User user) {
sessionFactory.getCurrentSession().save(user);
}
@Override
public void addRole(User user, Role role) {
NativeQuery addRoleQuery = sessionFactory.getCurrentSession()
.createNativeQuery("INSERT INTO roles(user_name, user_role) VALUES(:user_name,:user_role)");
addRoleQuery.setParameter("user_name",user.getUsername());
addRoleQuery.setParameter("user_role", role.toString().toUpperCase());
addRoleQuery.executeUpdate();
}
@Override
public boolean hasRole(User user, Role role) {
NativeQuery hasRoleQuery = sessionFactory.getCurrentSession()
.createSQLQuery("SELECT * FROM roles WHERE user_name = :user_name AND user_role = :user_role");
hasRoleQuery.setParameter("user_name", user.getUsername());
hasRoleQuery.setParameter("user_role", role.toString().toUpperCase());
return hasRoleQuery.getResultList().size() == 1;
}
}
测试类失败的测试代码如下:
@ContextConfiguration(classes = {DataAccessConfiguration.class})
@Rollback
@ExtendWith(SpringExtension.class)
@ActiveProfiles("hibernate")
@Transactional
public class UserDaoTest {
@Autowired
private UserDao sut;
private User user = new User("NEW_USERNAME123", "NEW_PASSWORD123", LocalDate.now().minusYears(20),
"FIRST_NAME", "LAST_NAME");
@Test
public void shouldAddNewRoleToUser(){
sut.insert(user);
assertFalse(sut.hasRole(user,Role.MEMBER));
sut.addRole(user, Role.MEMBER);
assertTrue(sut.hasRole(user,Role.MEMBER));
}
}
下面是我在运行测试方法后得到的输出(不包括事务注释):
Hibernate:
select
nextval ('USER_ID_SEQUENCE')
Hibernate:
/* dynamic native SQL query */ SELECT
*
FROM
roles
WHERE
user_name = ?
AND user_role = ?
Hibernate:
/* dynamic native SQL query */ INSERT
INTO
roles
(user_name, user_role)
VALUES
(?,?)
Nov 13, 2019 3:05:31 AM org.hibernate.engine.jdbc.spi.SqlExceptionHelper logExceptions
WARN: SQL Error: 0, SQLState: 23503
Nov 13, 2019 3:05:31 AM org.hibernate.engine.jdbc.spi.SqlExceptionHelper logExceptions
ERROR: ERROR: insert or update on table "roles" violates foreign key constraint "fk_roles_user_id"
Detail: Key (user_name)=(NEW_USERNAME123) is not present in table "users_table".
当我以编程方式提交会话时 会话工厂。getCurrentSession()。getTransaction()。提交();在插入结束时,一切正常
# 1 楼答案
到目前为止,关于我的问题,我唯一发现的是这里How does AUTO flush strategy works
显然,自动刷新模式不能保证在每次查询之前刷新(至少在hibernate自己的API中是这样)。我不能百分之百确定这是否是我的情况,我会努力找出答案
# 2 楼答案
尝试使insert方法@Transactional或使用sessionFactory。getCurrentSession()。刷新()
# 3 楼答案
您应该使用@Transactional注释“shouldAddNewRoleToUser()”方法,并检查是否在应用程序中为事务配置了spring会话上下文