跳至主要内容

Data crossstore between Mongo and JPA


Data crossstore between Mongo and JPA

Spring Data Mongo provides another attractive feature, when you mix to use Mongo and JPA in your projects, you can unite the models of Mongo and JPA.

Model

The Conference and Signup are still used as example models,Conference is JPA entity class and Signup is a Mongo Document.
@Entity
public class Conference {
 @Id
 @GeneratedValue(strategy = GenerationType.AUTO)
 @Column(name = "id")
 private Long id;

 
 @RelatedDocument
 private Signup signup;
}
The Signup Document is defined as the following.
@Document
public class Signup {

 @Id
 private String id;

}
@RelatedDocument annotation indicates the signup property of Conference is a reference of Signup Mongo Document. This annotation will be processed by a AspectJ aspect which provided in Spring Data Mongo.
You have to add some code fragments to Spring configuration.
<!-- Mongo cross-store aspect config -->
<bean
 class="org.springframework.data.mongodb.crossstore.MongoDocumentBacking"
 factory-method="aspectOf">
 <property name="changeSetPersister" ref="mongoChangeSetPersister" />
</bean>
 
<bean id="mongoChangeSetPersister"
 class="org.springframework.data.mongodb.crossstore.MongoChangeSetPersister">
 <property name="mongoTemplate" ref="mongoTemplate" />
 <property name="entityManagerFactory" ref="entityManagerFactory" />
</bean>
Firstly, this aspect will mark this property as @Transient and prevent JPA recognize it as a persistent property.
Then register a transaction synchronization to entity lifecycle events of the host JPA Entity( Conference ) to synchronize the@RelatedDocument data into Mongo Document.
We also use Junit @Before to initialize the data.
@Before
public void beforeTestCase() {
 log.debug("==================before test case=========================");
 conferenceRepository.save(newConference());
}
The newConference() method is use for create a new Conference object, we also create a new Singup as the value of signup property.
@Test
public void retrieveConference() {
 log.debug("==================enter retrieveConference=========================");

 assertTrue(null != id);

 Conference conf = em.find(Conference.class, id);

 log.debug("conf@@@" + conf);
 assertTrue(null != conf);
 assertTrue(null == conf.getSignup());
}
When you run this Test, pass!
Everything is OK?
Spring Data Mongo provides a LoggingEventListener to tracking the Mongo events.
<bean class="org.springframework.data.mongodb.core.mapping.event.LoggingEventListener" />
After you enable this listener, you should see the Mongo log info about saving Conference. But we run this Test again, we can not see it at all.
Add another line code in the first line of the test method.
em.clear();
Run the Test, failed.
No doubt the Signup was not stored in Mongo when saving Conference object.
As motioned before, the crosssotre synchronization is fired by the entity lifecycle events. If JPA event @PostPersist is not fired in a transaction, the Mongo event will not be fired.
@Before
// @Transactional(propagation = Propagation.REQUIRED)
public void beforeTestCase() {
 log.debug("==================before test case=========================");
 transactionTemplate = new TransactionTemplate(transactionManager);
 transactionTemplate.execute(new TransactionCallback<Void>() {

  @Override
  public Void doInTransaction(TransactionStatus status) {
  }
 }
}
Alternatively, we change the initial codes slightly, and use aTranscationTemplate to process the Conference saving action as an unit of work.
Run this test again, pass.

More ...

If possible store a Collection of data into Mongo like this,
@RelatedDocument
private List<Signup> signups;

Unfortunately, it does not work.
But you wrap the List into standalone Document like.
@Document
public class SignupInfo {

 @Id
 private String id;

 @DBRef
 private List<Signup> signups = new ArrayList<Signup>();
}
And change the relation to SignupInfo.
@RelatedDocument
private SignupInfo signupinfo;
But you have to save the Signup objects in Mongo firstly, because Spring Data Mongo does not support Cascade saving feature like JPA.
I have some wishes for the crossstore.
  1. Store reverse when store a Document.
Update to now, there is no way to do the work reverse. When you store a Mongo Document it does not support to store the related JPA entity into database.
2. Query cross different data storage. Obviously, it is impossible to execute query cross different stores.

Summary

Personally, I think the Mongo and JPA crossstore is only a toy, and the provided feature is too weak. I hope it can be improved in future, and provides seamless integration between different data stores as I expected.

评论

此博客中的热门博文

Build a Reactive application with Angular 5 and Spring Boot 2.0

I have created a post to describe Reactive programming supports in Spring 5 and its subprojects, all codes of this article are updated the latest Spring 5 RELEASE, check spring-reactive-sample under my Github account.
In this post, I will create a simple blog system, including:
A user can sign in and sign out.An authenticated user can create a post.An authenticated user can update a post.Only the user who has ADMIN role can delete a post.All users(including anonymous users) can view post list and post details.An authenticated user can add his comments to a certain post. The backend will be built with the latest Spring 5 reactive stack, including:
Spring Boot 2.0, at the moment the latest version is 2.0.0.M7Spring Data MongoDB supports reactive operations for MongoDBSpring Session adds reactive support for WebSessionSpring Security 5 aligns with Spring 5 reactive stack The frontend is an Angular based SPA and it will be generated by Angular CLI.
The source code is hosted on Github, …

Activating CDI in JSF 2.3

Activating CDI in JSF 2.3 When I upgraed my Java EE 7 sample to the newest Java EE 8, the first thing confused me is the CDI beans are not recoganized in Facelects template in a JSF 2.3 based web applicaiton, which is working in the development version, but in the final release version, they are always resolved as null. I filed an issue on Mojarra and discussed it with the developers from communities and the JSF experts.
According to the content of README, In a JSF 2.3 application, to activate CDI support, declaring a 2.3 versioned faces-config.xml and adding javax.faces.ENABLE_CDI_RESOLVER_CHAIN in web.xml is not enough, you have to declare @FacesConfig annotated class to enable CDI.
Here is the steps I created a workable JSF 2.3 applicatoin in Java EE 8.
Create a Java web application, this can be done easily by NetBeans IDE, or generated by Maven archetype, for exmaple.
$ mvn archetype:generate -DgroupId=com.example -DartifactId=demo -DarchetypeArtifactId=maven-archetype-w…

JSF 2.3:Websocket support

Websocket support One of the most attractive features is JSF 2.3 added native websocket support, it means you can write real-time applications with JSF and no need extra effort.
To enable websocket support, you have to add javax.faces.ENABLE_WEBSOCKET_ENDPOINT in web.xml.
<context-param> <param-name>javax.faces.ENABLE_WEBSOCKET_ENDPOINT</param-name> <param-value>true</param-value> </context-param> Hello Websocket Let's start with a simple example.
@ViewScoped@Named("helloBean") publicclassHelloBeanimplementsSerializable { privatestaticfinalLoggerLOG=Logger.getLogger(HelloBean.class.getName()); @Inject@PushPushContext helloChannel; String message; publicvoidsendMessage() { LOG.log(Level.INFO, "send push message"); this.sendPushMessage("hello"); } privatevoidsendPushMessage(Objectmessage) { helloChannel.send(""+ message +" at &…