Skip to main content

Notice: this Wiki will be going read only early in 2024 and edits will no longer be possible. Please see: https://gitlab.eclipse.org/eclipsefdn/helpdesk/-/wikis/Wiki-shutdown-plan for the plan.

Jump to: navigation, search

Difference between revisions of "EclipseLink/DesignDocs/328404 new"

(Config files)
(Config files)
Line 108: Line 108:
 
</source>
 
</source>
  
* ContainedPU may specify that it can't be used as an independent persistence unit:
+
* ContainedPU may specify in persistence.xml that it can't be used as an independent persistence unit:
 
<source lang="java">
 
<source lang="java">
 
/**
 
/**

Revision as of 15:22, 6 April 2011

Design Specification: Persistence Unit Composition

This feature adds support for persistence units being composed. This means a user can define multiple persistence units with a unique set of entity types and expose them through a composite persistence unit which combines the set of classes across multiple data sources to expose a single persistence context.

ER 328404

Document History

Date committer description
2011/04/06 Andrei Ilitchev Initial New Version

Project overview

The goal is to combine several persistence units into a single one.

em.persist(new A(..));
em.persist(new Z(..));
// insert A into db1; insert Z into db2:
// the two different data bases possibly from different vendors
em.flush();

Concepts

Terminology

  • Data Source: For the purposes of this discussion a data-source will include JTA and non-JTA data sources as well as EclipseLink's native JDBC connection pools.
  • Broker PU (or Container PU or Aggregate PU - need to choose the name): Refers to a PU which combines 2 or more Contained PUs to provide a persistence context which allows queries and transactions (with limitations) across the combined set of entity types.


Requirements

# Description
1 Add support for a single persistence context accessing entities stored in different data sources (schemas/table-space/database) where application developers can perform queries and transactions across the complete set of entities transparently.
2 Support mapping relationships between entities in different data sources.
3 Provide easy to use JPA configuration.
4 Clearly capture usage limitations and exceptions expected in Java Docs and user documentation. The most basic example of this is the ability to join across tables in different data sources. This limitation effects mapping and query execution and optimizations. These issues need to be identified and documented.
5 Support container managed and application bootstrap JPA usage with dynamic, static, and no weaving.

User Bugs

The following potentially related bugs should be taken into consideration in this feature work.

  • JPA enhancement requests.
    • bug 260258 - Add JPA EntityManagerFactoryBroker support
  • Core bugs
    • bug 269213 - SessionBroker handling of ExceptionHandler broken because stale copy/paste
    • bug 281569 - Integration of JPA using transaction-type="JTA" but without EJB container, set-up incomplete commit cleanup
    • bug 326649 - DatabaseSessionImpl.finalize() leads to ClassCastException
    • bug 329185 - SessionBroker: ClassCastException in Cursor.buildAndRegisterObject between ServerSession and UnitOfWorkImpl
    • bug 332581 - SessionBroker session event issues to consider and resolve when implementing JPA Session Broker


Design Constraints

Design / Functionality

Testing

API

Tooling

The Dali team should be made aware of this feature work and track an enhancement request to uptake it.

Config files

  • BrokerPU must be configured in persistence.xml using property:
/**
* Indicates if it's a broker persistence unit ("true").
* The property must be specified in persistence.xml of a broker persistence unit.
* The property passed to createEntityManagerFactory method or in system properties is ignored.
* Broker persistence unit would contain all persistence units found in jar files specified by <jar-file> elements in persistence.xml. 
*    <jar-file>contained1.jar</jar-file>
*    <jar-file>contained2.jar</jar-file>
*    <properties>
*        <property name="eclipselink.is-broker-persistence-unit" value="true"/>
*    </properties>
* Currently broker persistence unit cannot itself be contained in another broker persistence unit.
* Contained persistence units could be independent or contained-only.
* @see #IS_CONTAINED_PERSISTENCE_UNIT_ONLY
* @see #CONTAINED_PERSISTENCE_UNITS_PROPERTIES
*/
public static final String IS_BROKER_PERSISTENCE_UNIT = "eclipselink.is-broker-persistence-unit";
  • ContainedPU may specify in persistence.xml that it can't be used as an independent persistence unit:
/**
* Indicates if the persistence unit must be contained in a broker persistence unit ("true"),
* can't be used as an independent persistence unit.
* That happens if contained persistence unit has dependencies on other contained persistence unit(s).
* The property may be specified in persistence.xml of contained persistence unit.
* The property passed to createEntityManagerFactory method or in system properties is ignored.
* Though EntityManagerFactory for contained-only persistence unit could be created,
* it can't be connected: an attempt to create entity manager would cause an exception.
* @see #IS_BROKER_PERSISTENCE_UNIT
* @see #CONTAINED_PERSISTENCE_UNITS_PROPERTIES
*/
public static final String IS_CONTAINED_PERSISTENCE_UNIT_ONLY = "eclipselink.is-contained-persistence-unit-only";
    • Properties extension usage and naming patterns.
// Property with set values
eclipselink.define.my-set-property.value1 -> ""
eclipselink.define.my-set-property.value2 -> ""
...
eclipselink.define.my-set-property.valueN -> ""
 
// Converted to a Set:
my-set-property = {value1, value2, ..., valueN};
 
// Suggested naming convention:
// let's use "eclipselink.define" prefix for these "value-less" properties.


  • The two main use cases:
    • Unify multiple persistence units (with independent from each other object models).

There are two predefine independent persistence units: puABC (that maps classes A, B, C) and puXYZ (that maps classes X, Y, Z). None of A, B, C classes references any of X, Y, Z classes and vise verse. Below are several examples of persistence.xml for SessionBroker persistence unit.

<!--Scenario 1 - simply use puABC and puXYZ exactly as they were originally defined-->
-<persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence persistence_1_0.xsd" version="1.0">
    <persistence-unit name="broker" transaction-type="RESOURCE_LOCAL">
        <provider>
            org.eclipse.persistence.jpa.PersistenceProvider
        </provider>
        <properties>
	    <!--Note that puABC must exist and be defined in the same jar file with this persistence.xml-->
	    <property name="eclipselink.define.add-contained-pu.puABC" value=""/>
	    <!--Note that puXYZ must exist and be defined in the same jar file with this persistence.xml-->
	    <property name="eclipselink.define.add-contained-pu.puXYZ" value=""/>
        </properties>
    </persistence-unit>
</persistence>

The result is SessionBroker persistence unit named "broker" that aggregates two ServerSessions - one maps classes A, B, C; another - X, Y, Z.

<!--Scenario 2 - override some of the properies of puABC and puXYZ -->
-<persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence persistence_1_0.xsd" version="1.0">
    <!-- note that there is no need to pass transaction type down to contained sessions - that will be done automatically -->
    <persistence-unit name="broker" transaction-type="JPA">
        <provider>
            org.eclipse.persistence.jpa.PersistenceProvider
        </provider>
        <properties>
            <!-- note that there is no need to pass server platform down to contained sessions - that will be done automatically -->
            <property name="eclipselink.target-server" value="WebLogic_10"/>
 
	    <!--Note that puABC must exist and be defined in the same jar file with this persistence.xml-->
	    <property name="eclipselink.define.add-contained-pu.puABC" value=""/>
	    <property name="javax.persistence.jtaDataSource.puABC" value="ElOracleJTA"/>
	    <property name="javax.persistence.nonjtaDataSource.puABC" value="ElOracle"/>
            <!-- Switching to data sources from user/password - have to remove user name-->
	    <property name="javax.persistence.jdbc.user.puABC" value=""/>
 
	    <!--Note that puXYZ must exist and be defined in the same jar file with this persistence.xml-->
	    <property name="eclipselink.define.add-contained-pu.puXYZ" value=""/>
	    <property name="javax.persistence.jtaDataSource.puXYZ" value="ElMySQLJTA"/>
	    <property name="javax.persistence.nonjtaDataSource.puXYZ" value="ElMySQL"/>
            <!-- Switching to data sources from user/password - have to remove user name-->
	    <property name="javax.persistence.jdbc.user.puXYZ" value=""/>
        </properties>
    </persistence-unit>
</persistence>

The result is SessionBroker persistence unit named "broker" that aggregates two ServerSessions - one maps classes A, B, C; another - X, Y, Z. The original connection parameters in both member sessions were substituted with the ones provided in SessionBroker properties.

    • Split single persistent unit.

There is a single predefined persistence unit: puABCXYZ (that maps classes A, B, C, X, Y, Z). There could be any sorts of references between the classes. Below is example that contains persistence.xml of the original persistence unit and for SessionBroker persistence unit.

<!--Original persistence unit -->
-<persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence persistence_1_0.xsd" version="1.0">
    <persistence-unit name="puABCXYZ" transaction-type="RESOURCE_LOCAL">
        <provider>
            org.eclipse.persistence.jpa.PersistenceProvider
        </provider>
        <exclude-unlisted-classes>false</exclude-unlisted-classes>
        <properties>
	    <property name="javax.persistence.jdbc.user" value="MyUser"/>
	    <property name="javax.persistence.jdbc.password" value="MyPassword"/>
            <property name="javax.persistence.jdbc.driver" value="oracle.jdbc.OracleDriver"/>
            <property name="javax.persistence.jdbc.url" value="jdbc:oracle:thin:@qaott11.ca.oracle.com:1521:toplink"/>
        </properties>
    </persistence-unit>
</persistence>
<!--SessionBroker persistence unit -->
-<persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence persistence_1_0.xsd" version="1.0">
    <persistence-unit name="puABCXYZ" transaction-type="RESOURCE_LOCAL">
        <provider>
            org.eclipse.persistence.jpa.PersistenceProvider
        </provider>
        <exclude-unlisted-classes>false</exclude-unlisted-classes>
        <properties>
	    <property name="javax.persistence.jdbc.user" value="MyUser"/>
	    <property name="javax.persistence.jdbc.password" value="MyPassword"/>
            <property name="javax.persistence.jdbc.driver" value="oracle.jdbc.OracleDriver"/>
            <property name="javax.persistence.jdbc.url" value="jdbc:oracle:thin:@qaott11.ca.oracle.com:1521:toplink"/>
 
	    <!--Note that puXYZ does not exist - it's used as an alias for the new ServerSession to be created-->
            <!--either provide full class name-->
	    <property name="eclipselink.split-contained-pu.package.X" value="puXYZ"/>
	    <property name="eclipselink.split-contained-pu.package.Y" value="puXYZ"/>
            <!--or entity name-->
	    <property name="eclipselink.split-contained-pu.Z" value="puXYZ"/>
	    <property name="javax.persistence.jdbc.user.puXYZ" value="MyUser2"/>
	    <property name="javax.persistence.jdbc.password.puXYZ" value="MyPassword2"/>
            <property name="javax.persistence.jdbc.driver.puXYZ" value="com.mysql.jdbc.Driver"/>
            <property name="javax.persistence.jdbc.url.puXYZ" value="jdbc:mysql://qaott51.ca.oracle.com:3306/MyUser2"/>
        </properties>
    </persistence-unit>
</persistence>

The result is SessionBroker persistence unit that aggregates two ServerSessions - one maps classes A, B, C; another - X, Y, Z. The ServerSession that maps classes X, Y, Z is created using all the properties defined in the persistence unit, overriding with the values designated to puXYZ. For all the remaining classes (in this case A, B, C) the ServerSession is created with all the original properties.

  • Mix the two main use cases.

Let's create a SessionBroker persistence unit from original puABC, by splitting class C and adding puXYZ. Below is example that contains persistence.xml of the original persistence unit and for SessionBroker persistence unit.

<!--Original persistence unit -->
-<persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence persistence_1_0.xsd" version="1.0">
    <persistence-unit name="puABC" transaction-type="RESOURCE_LOCAL">
        <provider>
            org.eclipse.persistence.jpa.PersistenceProvider
        </provider>
        <class>A</class>
        <class>B</class>
        <class>C</class>
        <properties>
	    <property name="javax.persistence.jdbc.user" value="MyUser"/>
	    <property name="javax.persistence.jdbc.password" value="MyPassword"/>
            <property name="javax.persistence.jdbc.driver" value="oracle.jdbc.OracleDriver"/>
            <property name="javax.persistence.jdbc.url" value="jdbc:oracle:thin:@qaott11.ca.oracle.com:1521:toplink"/>
        </properties>
    </persistence-unit>
</persistence>
<!--SessionBroker persistence unit -->
-<persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence persistence_1_0.xsd" version="1.0">
    <persistence-unit name="puABCXYZ" transaction-type="RESOURCE_LOCAL">
        <provider>
            org.eclipse.persistence.jpa.PersistenceProvider
        </provider>
        <class>A</class>
        <class>B</class>
        <class>C</class>
        <properties>
	    <property name="javax.persistence.jdbc.user" value="MyUser"/>
	    <property name="javax.persistence.jdbc.password" value="MyPassword"/>
            <property name="javax.persistence.jdbc.driver" value="oracle.jdbc.OracleDriver"/>
            <property name="javax.persistence.jdbc.url" value="jdbc:oracle:thin:@qaott11.ca.oracle.com:1521:toplink"/>
 
	    <!--Note that puC does not exist - it's used as an alias for the new ServerSession to be created-->
            <!--either provide full class name or entity name-->
	    <property name="eclipselink.split-contained-pu.C" value="puC"/>
	    <property name="javax.persistence.jdbc.user.puC" value="MyUser2"/>
	    <property name="javax.persistence.jdbc.password.puC" value="MyPassword2"/>
            <property name="javax.persistence.jdbc.driver.puC" value="com.mysql.jdbc.Driver"/>
            <property name="javax.persistence.jdbc.url.puC" value="jdbc:mysql://qaott51.ca.oracle.com:3306/MyUser2"/>
 
	    <!--Note that puXYZ must exist and be defined in the same jar file with this persistence.xml-->
	    <property name="eclipselink.define.add-contained-pu.puXYZ" value=""/>
        </properties>
    </persistence-unit>
</persistence>

The result is SessionBroker persistence unit that aggregates three ServerSessions - one maps classes A, B; another - C; yet another - X, Y, Z. The ServerSession that maps classes X, Y, Z is created using puXYZ. The ServerSession that maps class C is created using all the properties defined in the persistence unit, overriding with the values designated to puC. For all the remaining classes (in this case A and B) the ServerSession is created with all the original properties.

Documentation

Open Issues

This section lists the open issues that are still pending that must be decided prior to fully implementing this project's requirements.

Issue # Description / Notes
1 Should this feature include both split and aggregated persistence units?
2 In the case of split persistence units where should the additional data sources be defined? PU properties in persistence.xml, eclipselink-orm.xml, both? Since it is possible for different data sources to be different database vendors or versions it should be possible to configure all JDBC/connection/pool level options on each data source.
3 Should this feature include support to customize additional datasources with persistence unit properties.
4 In the case of aggregate persistence units, should persistence units be usable on their own.

Decisions

This section lists decisions made. These are intended to document the resolution of open issues or constraints added to the project that are important.

Issue # Description / Notes Decision

Future Considerations

During the research for this project the following items were identified as out of scope but are captured here as potential future enhancements. If agreed upon during the review process these should be logged in the bug system.

1. It looks like this project is only considering of enabling the existing session broker support via JPA; i.e. enable the application to maintain different tables in different database instances. The concept overview or the requirements does not give any hint of enabling the application to define strategies for saving different sets of data in different database instances so that each databse instance contains the complete data matching a particular criteria. These days the more commonly practised database partitioning method is the latter one, popularly called sharding.

It would be better to consider providing support for this feature too since an attempt is being made to overhaul the sessionbroker support in eclipselink. In this method, every entity belongs to all the persistence units, however, eclipselink has to consult the defined criteria (range based or list based) while saving or retrieving the entities from any of the configured database instances.one of the complexities that may need to be addressed is how to handle the changes when a new databse instance is added to participate in the partitioning, especially if there needs to be a reorderig of the data across the database instances becasue the newly added instance falls in an intermediate range.

Back to the top