spring Sping Boot Hibernate加载但不保存来自事件日志的数据

mrfwxfqh  于 2024-01-05  发布在  Spring
关注(0)|答案(1)|浏览(101)

我在从事件侦听器内部保存数据时遇到问题。
目前我正在侦听AuthenticationEvent，并且该事件正在按预期调用（使用记录器检查）。
我希望能够在事件中使用JPA存储库，并在事件被触发时保存数据。
仓库正在初始化，数据从数据库加载，只有userRepository.save（）不起作用。我在保存过程中也没有得到任何异常。保存（）方法在其他RestController中工作没有任何问题。
（数据库为MySQL）
这是实现ApplicationServer接口的侦听器类：

  1. @Component
  2. @Transactional
  3. public class AuthenticationListener implements ApplicationListener<AuthenticationSuccessEvent> {
  5. @Autowired
  6. private UserRepository userRepository;
  8. private final Logger logger = LoggerFactory.getLogger(this.getClass());
  10. @Override
  11. public void onApplicationEvent(AuthenticationSuccessEvent event) {
  12.     logger.info(userRepository.toString());
  13.     String username = event.getAuthentication().getName();
  14.     LoggedUser loggedUser = (LoggedUser) event.getAuthentication().getPrincipal();
  15.     logger.info("Logged user: " + loggedUser);
  17.     if (userRepository.existsByUsername(event.getAuthentication().getName())) {
  18.         logger.info("Existing user: " + event.getAuthentication().getName());
  19.         User user = userRepository.findByUsername(username);
  20.         user.setFirstname(loggedUser.getFirstName());
  21.         user.setLastname(loggedUser.getLastName());
  22.         logger.info("Saved: " + userRepository.save(user).toString());
  23.     } else {
  24.         logger.info("Not existing user: " + event.getAuthentication().getName());
  25.         User user = new User(loggedUser.getFirstName(), loggedUser.getLastName(), "", username);
  26.         logger.info(user.toString());
  27.         logger.info("Saved: " + userRepository.save(user).toString());
  28.     }
  29.   }
  30. }

字符串
UserRepository.java:

  1. @Repository
  2. public interface UserRepository extends JpaRepository<User, Long>{
  4.   List<User> findAll();
  6.   List<User> findByFirstname(String firstname);
  7.   List<User> findByLastname(String lastname);
  8.   List<User> findByFirstnameAndLastnameAndEmail(String firstname, String lastname, String email);
  10.   User findByEmail(String email);   
  11.   User findByUsername(String username);
  13.   @Query("SELECT CASE WHEN COUNT(u) > 0 THEN true ELSE false END FROM User u WHERE u.email = :email")
  14.   boolean existsByEmail(@Param("email") String email);
  16.   @Query("SELECT CASE WHEN COUNT(u) > 0 THEN true ELSE false END FROM User u WHERE u.username = :username")
  17.   boolean existsByUsername(@Param("username") String username);
  19. }

型
编辑1（在保存点附近添加日志）：

  1. 10:58:52.351 [http-nio-8080-exec-4] DEBUG o.s.j.d.DriverManagerDataSource - Creating new JDBC DriverManager Connection to [jdbc:mysql://localhost:3306/airpng]
  2. 10:58:52.404 [http-nio-8080-exec-4] DEBUG org.hibernate.loader.Loader - Result set row: 0
  3. 10:58:52.405 [http-nio-8080-exec-4] DEBUG org.hibernate.loader.Loader - Result row: 
  4. 10:58:52.978 [http-nio-8080-exec-4] DEBUG o.s.o.jpa.EntityManagerFactoryUtils - Closing JPA EntityManager
  5. 10:58:52.979 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Initiating transaction commit
  6. 10:58:52.979 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Committing Hibernate transaction on Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=ExecutableList{size=0} updates=ExecutableList{size=0} deletions=ExecutableList{size=0} orphanRemovals=ExecutableList{size=0} collectionCreations=ExecutableList{size=0} collectionRemovals=ExecutableList{size=0} collectionUpdates=ExecutableList{size=0} collectionQueuedOps=ExecutableList{size=0} unresolvedInsertDependencies=null])]
  7. 10:58:52.980 [http-nio-8080-exec-4] DEBUG o.h.e.t.internal.TransactionImpl - committing
  8. 10:58:52.982 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Closing Hibernate Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=ExecutableList{size=0} updates=ExecutableList{size=0} deletions=ExecutableList{size=0} orphanRemovals=ExecutableList{size=0} collectionCreations=ExecutableList{size=0} collectionRemovals=ExecutableList{size=0} collectionUpdates=ExecutableList{size=0} collectionQueuedOps=ExecutableList{size=0} unresolvedInsertDependencies=null])] after transaction
  9. 10:59:03.767 [http-nio-8080-exec-4] INFO  a.p.a.shared.AuthenticationListener - Not existing user: bob
  10. 10:59:05.754 [http-nio-8080-exec-4] INFO  a.p.a.shared.AuthenticationListener -  Firstname: Bob | Lastname: Hamilton | E-Mail: 
  11. 10:59:07.172 [http-nio-8080-exec-4] DEBUG o.s.d.r.c.s.TransactionalRepositoryProxyPostProcessor$CustomAnnotationTransactionAttributeSource - Adding transactional method 'save' with attribute: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; ''
  12. 10:59:12.915 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Creating new transaction with name [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; ''
  13. 10:59:12.916 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Opened new Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=ExecutableList{size=0} updates=ExecutableList{size=0} deletions=ExecutableList{size=0} orphanRemovals=ExecutableList{size=0} collectionCreations=ExecutableList{size=0} collectionRemovals=ExecutableList{size=0} collectionUpdates=ExecutableList{size=0} collectionQueuedOps=ExecutableList{size=0} unresolvedInsertDependencies=null])] for Hibernate transaction
  14. 10:59:12.916 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Preparing JDBC Connection of Hibernate Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=ExecutableList{size=0} updates=ExecutableList{size=0} deletions=ExecutableList{size=0} orphanRemovals=ExecutableList{size=0} collectionCreations=ExecutableList{size=0} collectionRemovals=ExecutableList{size=0} collectionUpdates=ExecutableList{size=0} collectionQueuedOps=ExecutableList{size=0} unresolvedInsertDependencies=null])]
  15. 10:59:12.916 [http-nio-8080-exec-4] DEBUG o.s.j.d.DriverManagerDataSource - Creating new JDBC DriverManager Connection to [jdbc:mysql://localhost:3306/airpng]
  16. 10:59:12.932 [http-nio-8080-exec-4] DEBUG o.h.e.t.internal.TransactionImpl - begin
  17. 10:59:12.933 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Exposing Hibernate transaction as JDBC transaction [com.mysql.jdbc.JDBC4Connection@38ba8070]
  18. 10:59:17.963 [http-nio-8080-exec-4] DEBUG o.s.o.jpa.EntityManagerFactoryUtils - Opening JPA EntityManager
  19. 10:59:17.964 [http-nio-8080-exec-4] DEBUG o.s.o.jpa.EntityManagerFactoryUtils - Registering transaction synchronization for JPA EntityManager
  20. 10:59:26.892 [http-nio-8080-exec-4] DEBUG o.s.o.jpa.EntityManagerFactoryUtils - Closing JPA EntityManager
  21. 10:59:26.898 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Initiating transaction commit
  22. 10:59:26.898 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Committing Hibernate transaction on Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=ExecutableList{size=0} updates=ExecutableList{size=0} deletions=ExecutableList{size=0} orphanRemovals=ExecutableList{size=0} collectionCreations=ExecutableList{size=0} collectionRemovals=ExecutableList{size=0} collectionUpdates=ExecutableList{size=0} collectionQueuedOps=ExecutableList{size=0} unresolvedInsertDependencies=null])]
  23. 10:59:26.899 [http-nio-8080-exec-4] DEBUG o.h.e.t.internal.TransactionImpl - committing
  24. 10:59:26.900 [http-nio-8080-exec-4] DEBUG o.s.o.h.HibernateTransactionManager - Closing Hibernate Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=ExecutableList{size=0} updates=ExecutableList{size=0} deletions=ExecutableList{size=0} orphanRemovals=ExecutableList{size=0} collectionCreations=ExecutableList{size=0} collectionRemovals=ExecutableList{size=0} collectionUpdates=ExecutableList{size=0} collectionQueuedOps=ExecutableList{size=0} unresolvedInsertDependencies=null])] after transaction

型
编辑2（添加用户实体）：

  1. @Entity
  2. @Table(name = "user")
  3. @JsonIgnoreProperties({ "hibernateLazyInitializer", "handler" })
  4. public class User {
  6. @Id
  7. @GeneratedValue(strategy = GenerationType.IDENTITY)
  8. @Column(name = "USER_ID")
  10. private long userId;
  11. @NotNull
  12. @Size(min = 1, max = 50)
  13. @Column(name = "USER_FIRSTNAME")
  14. private String firstname;
  16. @NotNull
  17. @Size(min = 1, max = 50)
  18. @Column(name = "USER_LASTNAME")
  19. private String lastname;
  21. @NotNull
  22. @Size(min = 1, max = 150)
  23. @Column(name = "USER_USERNAME")
  24. private String username;
  26. @NotNull
  27. @Size(min = 0, max = 150)
  28. @Column(name = "USER_EMAIL")
  29. private String email;
  31. @Column(name = "USER_ACTIVE", nullable = false)
  32. private boolean active;
  34. @Autowired
  35. @OneToMany(mappedBy = "user")
  36. @JsonBackReference
  37. private List<Ownership> ownerships;
  39. public User() {
  40. }
  42. public User(long userId) {
  43.     this.userId = userId;
  44. }
  46. public User(String firstname, String lastname, String email, String username) {
  47.     this.firstname = firstname;
  48.     this.lastname = lastname;
  49.     this.email = email;
  50.     this.username = username;
  51.     this.active = true;
  52. }
  54. public User(String firstname, String lastname, String email) {
  55.     this.firstname = firstname;
  56.     this.lastname = lastname;
  57.     this.email = email;
  58.     this.active = true;
  59. }
  62. public long getId() {
  63.     return userId;
  64. }
  66. public void setId(long Id) {
  67.     this.userId = Id;
  68. }
  70. public String getFirstname() {
  71.     return firstname;
  72. }
  74. public void setFirstname(String firstname) {
  75.     this.firstname = firstname;
  76. }
  78. public String getLastname() {
  79.     return lastname;
  80. }
  82. public void setLastname(String lastname) {
  83.     this.lastname = lastname;
  84. }
  86. public String getEmail() {
  87.     return email;
  88. }
  90. public void setEmail(String email) {
  91.     this.email = email;
  92. }
  94. public boolean isActive() {
  95.     return active;
  96. }
  98. public void setActive(boolean active) {
  99.     this.active = active;
  100. }
  102. public List<Ownership> getOwnerships() {
  103.     return ownerships;
  104. }
  106. public void setOwnerships(List<Ownership> ownerships) {
  107.     this.ownerships = ownerships;
  108. }
  110. public String getUsername() {
  111.     return username;
  112. }
  114. public void setUsername(String username) {
  115.     this.username = username;
  116. }
  118. @Override
  119. public String toString() {
  120.     return " Firstname: " + firstname + " | Lastname: " + lastname + " | E-Mail: " + email;
  121. }
  123. }

型

spring

1条答案

按热度按时间
wyyhbhjk

wyyhbhjk1#

问题在于事件侦听器在不同的线程中运行，并且看起来它需要一个显式的事务来保存实体。

  1. Just annotate your method with @Transactional(propagation = Propagation.REQUIRES_NEW)

字符串

赞(0）分享  回复(0）举报  2024-01-05
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com