在春季启动中使用交易型

Question

我在Spring Boot应用程序中使用Hibernate时会遇到错误 我使用以下配置类：

import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
import org.springframework.context.annotation.Bean;
import org.springframework.transaction.annotation.EnableTransactionManagement;

@org.springframework.context.annotation.Configuration
@EnableTransactionManagement
public class Config {
    @Bean
    public SessionFactory sessionFactory() {

        Configuration configuration = new Configuration();
        configuration.configure();
        configuration.addAnnotatedClass(Ct.class);
        configuration.addAnnotatedClass(St.class);

        SessionFactory sessionFactory = configuration.buildSessionFactory();
        return sessionFactory;
    }

}  
@RestController
public class RestAPIController {
 @Autowired
    private SessionFactory sessionFactory;

 @PutMapping("/addS")
    @Transactional
    public void addSt(@RequestParam("cc") String cc,@RequestParam("st") String st) {
        CC cc1= new CC();
        CC.setCode(cc);
        State state = new State(cc,st);
        sessionFactory.getCurrentSession().save(state);
    }
}
}  

我在Addst方法中添加@transactional的主要原因是由于错误：当数据库期间发生异常时，事务仍然是一个活动。 因此，我转向使用Spring Boot来管理交易。我不确定在这里做什么。

----------------------------------------------------------------------------

@Repository
public interface StateRepository extends CrudRepository<State, String> {}


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import java.util.ArrayList;
import java.util.List;

@Service
@Transactional
public class StateService {

    @Autowired
    private StateRepository stateRepository;

    public void save(State state) {
        stateRepository.save(state);
    }

    public List<State> findAll() {
        List<State> states = new ArrayList<>();
        stateRepository.findAll().forEach(states::add);
        return states;
    }
}

Answer 1

对于初学者来说，使用适当的图层并写下服务并使用JPA代替普通的Hibernate。如果您想要session可以始终使用entitymanager.unwrap获得基础session。

@Service
@Transactional
public StateService {

  @PersistenceContext
  private EntityManager em;

  public void save(State state) {
    em.persist(state);
  }

在控制器中使用此服务，而不是SessionFactory。

@RestController
public class RestAPIController {

    private final StateService stateService;

    RestAPIController(StateService stateService) {
      this.stateService=stateService;
    }

    @PutMapping("/addS")
    public void addSt(@RequestParam("cc") String cc, @RequestParam("st") String st) {
        CC cc1= new CC();
        CC.setCode(cc);
        State state = new State(cc,st);
        stateService.save(state);
    }
}

现在，将您的config类放置，然后重新启动应用程序。

Note

使用Spring Data JPA时，它甚至更容易，定义一个存储库扩展crudrepository并将其注入服务，而不是EntityManager。 （我假设long是您定义的主键的类型）。

public interface StateRepository extends CrudRepository<State, Long> {}

@Service
@Transactional
public StateService {

  private final StateRepository states;

  public StateService(StateRepository states) {
    this.states=states;
  }

  public void save(State state) {
    states.save(state);
  }
}