如何在spring数据存储库中钩住所有成功的插入、更新和删除

kmb7vmvb 于 2021-07-24 发布在 Java

关注(0)|答案(1)|浏览(247)

我当前正在尝试构建钩子，以获取存储库中所有成功提交的实体更改的列表：

@Entity data class User(@Id val id: Long, val name: String)

interface extends JpaRepository<User, Long>

@Service
class UserService(val userRepository:UserRepository){

    @Transactional
    fun someProcess(){
        val newUser = User()
        newUser.name = "newUser"
        userRepository.save(newUser)

        val userToUpdate = userRepository.findById(1).get()
        userToUpdate.name = "updatedUser"

        val userToDelete = userRepository.findById(2).get()
        userRepository.delete(userToDelete)
    }

    // TODO implement hooks 
    fun hookAllInserts(inserts :List<User>){
        // list is expected to contain newUser
    }

    fun hookAllUpdates(updates: List<User>) {
        // list is expected to contain the latest state of updatedUser
    }

    fun hookAllDeletions(deletions: List<User>){
        // list is expected to contain the deletedUser
    }
}

钩子只能在成功提交后触发，因此不会传播回滚的更改。
如何使用spring数据实现这一点？

spring spring-boot spring-data-jpa spring-data

来源：https://stackoverflow.com/questions/65883282/how-to-hook-all-successfull-inserts-updates-and-deletions-in-a-spring-data-repo

1条答案

按热度按时间

f87krz0w1#

我还没有找到一个适用于所有spring数据存储库的通用解决方案，但是当结合使用spring数据和hibernate时，有一个解决方案：

@Component
class ChangeListener(
    private val entityManagerFactory: EntityManagerFactory,
) : PostUpdateEventListener, PostInsertEventListener, PostDeleteEventListener {

    @PostConstruct
    private fun init() {
        val sessionFactory = entityManagerFactory.unwrap(SessionFactoryImpl::class.java)
        val registry = sessionFactory.serviceRegistry.getService(EventListenerRegistry::class.java)
        registry.getEventListenerGroup(EventType.POST_COMMIT_UPDATE).appendListener(this)
        registry.getEventListenerGroup(EventType.POST_COMMIT_INSERT).appendListener(this)
        registry.getEventListenerGroup(EventType.POST_COMMIT_DELETE).appendListener(this)
    }

    override fun requiresPostCommitHanding(persister: EntityPersister): Boolean {
        return true
    }

    override fun onPostUpdate(event: PostUpdateEvent) {
        // event.entity contains the latest state of the entity
    }

    override fun onPostDelete(event: PostDeleteEvent) {
        // event.entity contains the latest state of the entity
    }

    override fun onPostInsert(event: PostInsertEvent) {
        // event.entity contains the last state of the entity
    }

}

它基于hibernate eventlisteners
另请参见此处。
弗拉德·米哈尔恰的博客上也有一篇不错的帖子

赞(0）回复(0）举报 2021-07-24

我来回答

如何在spring数据存储库中钩住所有成功的插入、更新和删除

1条答案

相关问题

热门标签

最新问答