前言

Spring Data 通过钩子实现了在保存或修改数据前后执行指定的方法，即EntityCallback。本文示例EntityCallback在Spring Data Elasticsearch中的使用。

一、注册EntityCallback

package cn.jack.elasticsearchdemo.callback; import cn.jack.elasticsearchdemo.domain.Person; import lombok.extern.slf4j.Slf4j; import org.springframework.core.annotation.Order; import org.springframework.data.elasticsearch.core.document.Document; import org.springframework.data.elasticsearch.core.event.AfterConvertCallback; import org.springframework.data.elasticsearch.core.event.AfterSaveCallback; import org.springframework.data.elasticsearch.core.event.BeforeConvertCallback; import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates; import org.springframework.stereotype.Component; @Order(1) @Component @Slf4j public class PersonCallback implements BeforeConvertCallback<Person>, AfterConvertCallback<Person>, AfterSaveCallback<Person> { @Override public Person onBeforeConvert(Person entity, IndexCoordinates index) { log.info("onBeforeConvert, Person={}, index={}", entity, index); return entity; } @Override public Person onAfterConvert(Person entity, Document document, IndexCoordinates indexCoordinates) { log.info("onAfterConvert"); return entity; } @Override public Person onAfterSave(Person entity, IndexCoordinates index) { log.info("onAfterSave, Person={}, index={}", entity, index); return entity; } }

二、测试

使用junit进行测试，保存及修改Person数据，在保存数据前后，都执行了打印输出。

@Test public void testAuditing() { Person person = new Person(); person.setName("EntityCallback的使用"); this.personRepository.save(person); System.out.println(person); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } person.setHobbies(Arrays.asList("跳舞")); this.personRepository.save(person); System.out.println(person); } // 控制台输出 2020-10-06 22:39:29.903 INFO 1004 --- [ main] c.j.e.callback.PersonCallback : onBeforeConvert, Person=Person(id=null, name=EntityCallback的使用, gender=null, book=null, hobbies=null, abc=null, createdDate=null, createdBy=null, lastModifiedDate=null, lastModifiedBy=null), index=IndexCoordinates{indexNames=[jack_person], typeNames=[person]} 2020-10-06 22:39:29.968 INFO 1004 --- [ main] c.j.e.callback.PersonCallback : onAfterSave, Person=Person(id=ZTxa_nQBrwRoe5ExYNmj, name=EntityCallback的使用, gender=null, book=null, hobbies=null, abc=null, createdDate=2020-10-06T14:39:29.917001600Z, createdBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null], lastModifiedDate=2020-10-06T14:39:29.917001600Z, lastModifiedBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null]), index=IndexCoordinates{indexNames=[jack_person], typeNames=[person]} Person(id=ZTxa_nQBrwRoe5ExYNmj, name=EntityCallback的使用, gender=null, book=null, hobbies=null, abc=null, createdDate=2020-10-06T14:39:29.917001600Z, createdBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null], lastModifiedDate=2020-10-06T14:39:29.917001600Z, lastModifiedBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null]) 2020-10-06 22:39:31.007 INFO 1004 --- [ main] c.j.e.callback.PersonCallback : onBeforeConvert, Person=Person(id=ZTxa_nQBrwRoe5ExYNmj, name=EntityCallback的使用, gender=null, book=null, hobbies=[跳舞], abc=null, createdDate=2020-10-06T14:39:29.917001600Z, createdBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null], lastModifiedDate=2020-10-06T14:39:29.917001600Z, lastModifiedBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null]), index=IndexCoordinates{indexNames=[jack_person], typeNames=[person]} 2020-10-06 22:39:31.031 INFO 1004 --- [ main] c.j.e.callback.PersonCallback : onAfterSave, Person=Person(id=ZTxa_nQBrwRoe5ExYNmj, name=EntityCallback的使用, gender=null, book=null, hobbies=[跳舞], abc=null, createdDate=2020-10-06T14:39:29.917001600Z, createdBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null], lastModifiedDate=2020-10-06T14:39:31.008001600Z, lastModifiedBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null]), index=IndexCoordinates{indexNames=[jack_person], typeNames=[person]} Person(id=ZTxa_nQBrwRoe5ExYNmj, name=EntityCallback的使用, gender=null, book=null, hobbies=[跳舞], abc=null, createdDate=2020-10-06T14:39:29.917001600Z, createdBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null], lastModifiedDate=2020-10-06T14:39:31.008001600Z, lastModifiedBy=User[username=jack,roles=[ROLE_ADMIN],metadata={},fullName=null,email=null])