扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章给大家分享的是有关Spring Data MongoDB中如何实现自定义级联的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。
创新互联建站是专业的上党网站建设公司,上党接单;提供成都网站建设、网站制作,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行上党网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!
前言
Spring Data MongoDB 项目提供与MongoDB文档数据库的集成,Spring与Hibernate集成时,Spring提供了org.springframework.orm.hibernate3.HibernateTemplate
实现了对数据的CRUD操作, Spring Data MongoDB提供了org.springframework.data.mongodb.core.MongoTemplate
对MongoDB的CRUD的操作,包括对集成的对象映射文件和POJO之间的CRUD的操作。
在使用Spring Data操作MongoDB中:
在保存一个实体的时候,如果被@DBRef标识的类只传入Id,保存后返回的结果并没有全部的引用类内容,只有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 方法 }
当我们调用保存方法的时候:
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,然后重写这些方法,即可以实现。
代码
/** * MongoDB级联控制 * Created by guanzhenxing on 2017/11/9. */ public class CascadeControlMongoEventListener extends AbstractMongoEventListener
/** * 级联控制的回调 * 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); } } } /** * 级联查询 * * @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); } } } /** * 级联保存 * * @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中如何实现自定义级联”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流