从现在开始,多语种持久性一直是新闻。 从2011年底开始,在著名的Fowler帖子的推动下,我看到了更多更好的主意。 最新的一个是公司内部的学生项目,我们在其中使用Scala作为后端数据,将数据持久存储到MongoDB,Derby和Solar中。 我不是Scala的忠实拥护者,并且还记得EclipseLink对NoSQL数据库的日益增长的支持 。 鉴于我只需要尝试一下。
从哪儿开始?
最大的问题是缺少的示例。 您发现了很多有关如何使用EclipseLink更改数据容器(NoSQL或RDBMS)的知识,但是您找不到一个完全无缝地同时使用两种技术的数据容器。 感谢Shaun Smith和Gunnar Wagenkrnecht,我们在JavaOne上进行了关于Polyglot持久性的精彩演讲:EclipseLink JPA for NoSQL,Relational和Beyond正是在此进行了讨论。 不幸的是,消息来源仍然没有被推送到任何地方,我不得不从演讲中重新构建它,因此,功劳归功于Shaun和Gunnar。
神奇的解决方案称为持久性单元组成 。 每个数据容器都需要一个持久性单元。 看起来像下面的基本示例。 每个PU中都有几个实体,并且复合PU是保护伞。
我们走吧
在开始这个小教程示例之前,您应该已经安装了MongoDB 。 启动NetBeans并创建两个Java项目。 让我们称它们为polyglot-persistence-nosql-pu和polyglot-persistence-rational-pu。 将以下实体放入nosql-pu:客户,地址,订单和订单行。 (大部分取自
EclipseLink nosql示例 ),然后将Product实体放入Rational-pu。
单个产品进入Derby,而其他所有实体都保留在MongoDB中。 有趣的部分是,OrderLine与产品具有一对一关系:
@OneToOne(cascade = {CascadeType.REMOVE, CascadeType.PERSIST})
private Product product;
这是两个世界融合在一起的点。 以后再说。
两个PU都必须是transaction-type ='RESOURCE_LOCAL',并且需要在persistence.xml中包含以下行:
<property name='eclipselink.composite-unit.member' value='true'/>
不要忘记添加数据库特定的配置。 对于MongoDB,这是
<property name='eclipselink.nosql.property.mongo.port' value='27017'/>
<property name='eclipselink.nosql.property.mongo.host' value='localhost'/>
<property name='eclipselink.nosql.property.mongo.db' value='mydb'/>
对于德比,这是这样的:
<property name='javax.persistence.jdbc.url' value='jdbc:derby://localhost:1527/mydb'/>
<property name='javax.persistence.jdbc.password' value='sa'/>
<property name='javax.persistence.jdbc.driver' value='org.apache.derby.jdbc.ClientDriver'/>
<property name='javax.persistence.jdbc.user' value='sa'/>
现在,我们需要一些东西来将这两个PU链接在一起。 Combined-pu驻留在示例polyglot-persistence-web模块中,如下所示:
<persistence-unit name='composite-pu' transaction-type='RESOURCE_LOCAL'><provider>org.eclipse.persistence.jpa.PersistenceProvider</provider><jar-file>\lib\polyglot-persistence-rational-pu-1.0-SNAPSHOT.jar</jar-file><jar-file>\lib\polyglot-persistence-nosql-pu-1.0-SNAPSHOT.jar</jar-file><properties><property name='eclipselink.composite-unit' value='true'/></properties>
</persistence-unit>
</persistence>
注意jar文件的路径。 我们将其打包在一个战争存档中,因此,nosql-pu和有理-pu将进入WEB-INF / lib文件夹。 如您所见,我的示例是使用Maven构建的。 确保使用最新的EclipseLink依赖项。 甚至GlassFish 3.1.2.2仍附带较低版本。 从2.4开始增加了对MongoDB的支持。
<dependency><groupId>org.eclipse.persistence</groupId><artifactId>eclipselink</artifactId><version>2.4.1</version></dependency>
除此之外,还需要翻转GlassFish的类加载器:
<class-loader delegate='false'/>
不用担心细节。 我把一切都放在
github.com/myfear,因此,您稍后可能会自行研究完整的示例。
测试它
让我们用它做一些非常简短的测试。 创建一个不错的Demo servlet,然后将Composite-pu注入其中。 从中创建一个EntityManager并获取交易。 现在开始创建产品,客户,订单和单独的订单行。 所有普通的JPA。 这里没有进一步的魔术:
@PersistenceUnit(unitName = 'composite-pu')private EntityManagerFactory emf;protected void processRequest() // [...]{EntityManager em = emf.createEntityManager();em.getTransaction().begin();// Products go into RDBMSProduct installation = new Product('installation');em.persist(installation);Product shipping = new Product('shipping');em.persist(shipping);Product maschine = new Product('maschine');em.persist(maschine);// Customer into NoSQLCustomer customer = new Customer();customer.setName('myfear');em.persist(customer);// Order into NoSQLOrder order = new Order();order.setCustomer(customer);order.setDescription('Pinball maschine');// Order Lines mapping NoSQL --- RDBMSorder.addOrderLine(new OrderLine(maschine, 2999));order.addOrderLine(new OrderLine(shipping, 59));order.addOrderLine(new OrderLine(installation, 129));em.persist(order);em.getTransaction().commit();String orderId = order.getId();em.close();
如果将正确的日志记录属性放在适当的位置,您可以看到正在发生的情况:
将几个序列分配给创建的产品实体(GeneratedValue)。 客户实体通过MappedInteraction持久化到Mongo中。 实体映射到MongoDB中的集合。
FINE: Executing MappedInteraction()
spec => null
properties => {mongo.collection=CUSTOMER, mongo.operation=INSERT}
input => [DatabaseRecord(
CUSTOMER._id => 5098FF0C3D9F5D2CCB3CFECF
CUSTOMER.NAME => myfear)]
之后,您将看到产品被插入到Derby中,然后又被插入到MappedInteraction中,该订单将订单插入MongoDB中。 真正酷的部分在于OrderLines:
ORDER.ORDERLINES => [DatabaseRecord(LINENUMBER => 1COST => 2999.0PRODUCT_ID => 3), DatabaseRecord(LINENUMBER => 2COST => 59.0PRODUCT_ID => 2), DatabaseRecord(LINENUMBER => 3COST => 129.0PRODUCT_ID => 1)]
订单行具有一个对象,该对象具有为相关产品实体生成的product_id。 进一步,您还可以找到相关的订单并遍历产品并获得其描述:
Order order2 = em.find(Order.class, orderId);
for (OrderLine orderLine : order2.getOrderLines()) {String desc = orderLine.getProduct().getDescription();}
不错的小演示如下所示:
感谢Shaun,感谢Gunnar提供的这个好例子。 现在去github.com/myfear弄脏你的手:)
参考: Polyglot持久性: JCG合作伙伴 Markus Eisele在Java企业软件开发博客上的EclipseLink与MongoDB和Derby 。
翻译自: https://www.javacodegeeks.com/2012/11/polyglot-persistence-eclipselink-with-mongodb-and-derby.html