I can't deal with entityManager.remove() function.
When I try to delete object, I haven't got any errors and exceptions, but record is still in database.
Here is my EntityManager definition:
@Configuration
@EnableJpaRepositories
@ComponentScan("pl.lodz.p.admin")
@EnableTransactionManagement
class AdminDbConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource dataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "adminManager")
public EntityManagerFactory entityManagerFactory() {
HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
vendorAdapter.setGenerateDdl(true);
LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
factory.setJpaVendorAdapter(vendorAdapter);
factory.setPackagesToScan("pl.lodz.p.entities");
factory.setDataSource(dataSource());
factory.afterPropertiesSet();
return factory.getObject();
}
@Bean
public JpaTransactionManager transactionManager() {
JpaTransactionManager txManager = new JpaTransactionManager();
txManager.setEntityManagerFactory(entityManagerFactory());
return txManager;
}
}
Service:
@Service
@ComponentScan(basePackages = {"pl.lodz.p.admin.service"})
@Transactional(rollbackFor = AccountException.class, propagation = Propagation.REQUIRES_NEW)
public class AccountServiceImpl implements AccountService {
@Autowired
AccountRepository accountRepository;
@Override
public void deleteAccountByLogin(String login) {
Account account = accountRepository.findByLogin(login);
accountRepository.delete(account);
}
}
And repository:
@Repository("adminAccountRepository")
@Transactional(propagation = Propagation.MANDATORY)
public class AccountRepositoryImpl implements AccountRepository {
@PersistenceContext(unitName = "adminManager")
private EntityManager em;
@Override
public Account findByLogin(String login) {
Query query = em.createNamedQuery("Account.findByLogin");
query.setParameter("login", login);
Account account = (Account) query.getSingleResult();
return account;
}
@Override
public void delete(Account account) {
try {
em.remove(account);
} catch (Exception e) {
e.getCause();
}
}
}
Finally, I have resolved my problem.
In my EntityManager configuration, I've added
@Bean(name = "adminTransactionManager")
And in my AccountServiceImpl:
@Transactional(value = "adminTransactionManager", rollbackFor = AccountException.class, propagation = Propagation.REQUIRES_NEW)
public class AccountServiceImpl implements AccountService {
Thanks.