Search code examples
javaspringjpaentitymanager

Spring JPA: entityManager remove not working


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();
        }
    }
}

Solution

  • 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.