這篇文章給大家分享的是有關Spring Data MongoDB中如何實現(xiàn)自定義級聯(lián)的內(nèi)容。小編覺得挺實用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。
創(chuàng)新互聯(lián)建站是專業(yè)的上黨網(wǎng)站建設公司,上黨接單;提供成都網(wǎng)站建設、網(wǎng)站制作,網(wǎng)頁設計,網(wǎng)站設計,建網(wǎng)站,PHP網(wǎng)站建設等專業(yè)做網(wǎng)站服務;采用PHP框架,可快速的進行上黨網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團隊,希望更多企業(yè)前來合作!
前言
Spring Data MongoDB 項目提供與MongoDB文檔數(shù)據(jù)庫的集成,Spring與Hibernate集成時,Spring提供了org.springframework.orm.hibernate3.HibernateTemplate
實現(xiàn)了對數(shù)據(jù)的CRUD操作, Spring Data MongoDB提供了org.springframework.data.mongodb.core.MongoTemplate
對MongoDB的CRUD的操作,包括對集成的對象映射文件和POJO之間的CRUD的操作。
在使用Spring Data操作MongoDB中:
在保存一個實體的時候,如果被@DBRef標識的類只傳入Id,保存后返回的結果并沒有全部的引用類內(nèi)容,只有Id。
保存實體,不能保存引用實體。
例如:我們有一個實體Person,有一個實體EmailAddress。
@Document(collection = "test_person") public class Person { private String name; @DBRef private EmailAddress emailAddress; ... getter setter 方法 }
@Document(collection = "test_email") public class EmailAddress { @Id private String id; private String value; ... getter setter 方法 }
當我們調(diào)用保存方法的時候:
public Person test() { Person person = new Person(); person.setName("test"); EmailAddress emailAddress = new EmailAddress(); emailAddress.setId("5a05108d4dcc5dece03c9e69"); person.setEmailAddress(emailAddress); testRepository.save(person); return person; }
上述的代碼中,返回的person只有id,沒有emailAddress的其他值。
public Person test() { Person person = new Person(); person.setName("test"); EmailAddress emailAddress = new EmailAddress(); emailAddress.setName("afafa"); person.setEmailAddress(emailAddress); testRepository.save(person); return person; }
上述的代碼中,emailAddress不能被保存。
解決
生命周期事件
Spring Data MongoDB中存在一些生命周期事件,如:onBeforeConvert, onBeforeSave, onAfterSave, onAfterLoad and onAfterConvert等。我們可以繼承AbstractMappingEventListener,然后重寫這些方法,即可以實現(xiàn)。
代碼
/** * MongoDB級聯(lián)控制 * Created by guanzhenxing on 2017/11/9. */ public class CascadeControlMongoEventListener extends AbstractMongoEventListener
/** * 級聯(lián)控制的回調(diào) * Created by guanzhenxing on 2017/11/10. */ public class CascadeAfterSaveCallback implements ReflectionUtils.FieldCallback { private Object source; private MongoOperations mongoOperations; public CascadeAfterSaveCallback(final Object source, final MongoOperations mongoOperations) { this.source = source; this.mongoOperations = mongoOperations; } @Override public void doWith(final Field field) throws IllegalArgumentException, IllegalAccessException { ReflectionUtils.makeAccessible(field); if (field.isAnnotationPresent(DBRef.class)) { final Object fieldValue = field.get(source); //獲得值 if (fieldValue != null) { doCascadeLoad(field); } } } /** * 級聯(lián)查詢 * * @param field */ private void doCascadeLoad(Field field) throws IllegalAccessException { Object fieldValue = field.get(source); ListidFields = ReflectionUtil.getAnnotationField(fieldValue, Id.class); //該方法是為了獲得所有的被@Id注解的屬性 if (idFields.size() == 1) { //只處理一個Id Object idValue = ReflectionUtil.getFieldValue(fieldValue, idFields.get(0).getName()); Object value = mongoOperations.findById(idValue, fieldValue.getClass()); //查詢獲得值 ReflectionUtil.setFieldValue(source, field.getName(), value); } } }
public class CascadeBeforeConvertCallback implements ReflectionUtils.FieldCallback { private Object source; private MongoOperations mongoOperations; public CascadeBeforeConvertCallback(Object source, MongoOperations mongoOperations) { this.source = source; this.mongoOperations = mongoOperations; } @Override public void doWith(Field field) throws IllegalArgumentException, IllegalAccessException { ReflectionUtils.makeAccessible(field); if (field.isAnnotationPresent(DBRef.class)) { final Object fieldValue = field.get(source); //獲得值 if (fieldValue != null) { doCascadeSave(field); } } } /** * 級聯(lián)保存 * * @param field * @throws IllegalAccessException */ private void doCascadeSave(Field field) throws IllegalAccessException { if (field.isAnnotationPresent(CascadeSave.class)) { //如果有標識@CascadeSave注解 Object fieldValue = field.get(source); ListidFields = ReflectionUtil.getAnnotationField(fieldValue, Id.class); if (idFields.size() == 1) { mongoOperations.save(fieldValue); } } } }
@Retention(RetentionPolicy.RUNTIME) @Target(ElementType.FIELD) public @interface CascadeSave { }
@Configuration public class MongoConfig { @Bean public CascadeControlMongoEventListener userCascadingMongoEventListener() { return new CascadeControlMongoEventListener(); } }
感謝各位的閱讀!關于“Spring Data MongoDB中如何實現(xiàn)自定義級聯(lián)”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!