You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by jg...@apache.org on 2019/06/14 15:44:22 UTC
[tomee] branch master updated (ea1a433 -> 44e37ab)
This is an automated email from the ASF dual-hosted git repository.
jgallimore pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/tomee.git.
from ea1a433 Merge pull request #485 from doychin/list-ordered-set-for-thread-context-listeners
new e3c3fc9 Reinstating example
new 79c5117 Correct the config so the Derby database is picked up
new 8952bd7 Add example
new 44e37ab Merge branch 'TOMEE-2541'
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
examples/pom.xml | 1 +
examples/xa-datasource/README.md | 217 +++++++++++++++++++++
.../pom.xml | 43 ++--
.../java/org/superbiz/injection/jpa/Movie.java | 4 +-
.../java/org/superbiz/injection/jpa/Movies.java | 18 +-
.../org/superbiz/injection/jpa/MoviesDirect.java} | 53 +++--
.../java/org/superbiz/injection/jpa/MoviesXA.java | 193 ++++++++++++++++++
.../src/main/resources/META-INF/persistence.xml | 0
.../org/superbiz/injection/jpa/MoviesTest.java | 98 ++++++++++
.../org/superbiz/injection/jpa/MoviesXATest.java | 167 ++++++++++++++++
10 files changed, 737 insertions(+), 57 deletions(-)
create mode 100644 examples/xa-datasource/README.md
copy examples/{rest-applicationcomposer-mockito => xa-datasource}/pom.xml (80%)
copy examples/{injection-of-entitymanager => xa-datasource}/src/main/java/org/superbiz/injection/jpa/Movie.java (99%)
copy examples/{injection-of-entitymanager => xa-datasource}/src/main/java/org/superbiz/injection/jpa/Movies.java (80%)
copy examples/{ejb-examples/src/main/java/org/superbiz/servlet/AnnotatedEJB.java => xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesDirect.java} (50%)
create mode 100644 examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesXA.java
copy examples/{injection-of-entitymanager => xa-datasource}/src/main/resources/META-INF/persistence.xml (100%)
create mode 100644 examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesTest.java
create mode 100644 examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesXATest.java
[tomee] 01/04: Reinstating example
Posted by jg...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jgallimore pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tomee.git
commit e3c3fc95dfa6aefc956eb4308596958c80a92877
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Fri Jun 14 15:10:47 2019 +0100
Reinstating example
---
examples/xa-datasource/README.md | 217 +++++++++++++++++++++
examples/xa-datasource/pom.xml | 113 +++++++++++
.../java/org/superbiz/injection/jpa/Movie.java | 76 ++++++++
.../java/org/superbiz/injection/jpa/Movies.java | 54 +++++
.../org/superbiz/injection/jpa/MoviesDirect.java | 47 +++++
.../java/org/superbiz/injection/jpa/MoviesXA.java | 189 ++++++++++++++++++
.../src/main/resources/META-INF/persistence.xml | 32 +++
.../org/superbiz/injection/jpa/MoviesTest.java | 98 ++++++++++
.../org/superbiz/injection/jpa/MoviesXATest.java | 169 ++++++++++++++++
9 files changed, 995 insertions(+)
diff --git a/examples/xa-datasource/README.md b/examples/xa-datasource/README.md
new file mode 100644
index 0000000..5128f0c
--- /dev/null
+++ b/examples/xa-datasource/README.md
@@ -0,0 +1,217 @@
+Title: Injection Of Entitymanager
+
+This example shows use of `@PersistenceContext` to have an `EntityManager` with an
+`EXTENDED` persistence context injected into a `@Stateful bean`. A JPA
+`@Entity` bean is used with the `EntityManager` to create, persist and merge
+data to a database.
+
+## Creating the JPA Entity
+
+The entity itself is simply a pojo annotated with `@Entity`. We create one called `Movie` which we can use to hold movie records.
+
+ package org.superbiz.injection.jpa;
+
+ import javax.persistence.Entity;
+
+ @Entity
+ public class Movie {
+
+ @Id @GeneratedValue
+ private long id;
+
+ private String director;
+ private String title;
+ private int year;
+
+ public Movie() {
+ }
+
+ public long getId() {
+ return id;
+ }
+
+ public void setId(long id) {
+ this.id = id;
+ }
+
+ public Movie(String director, String title, int year) {
+ this.director = director;
+ this.title = title;
+ this.year = year;
+ }
+
+ public String getDirector() {
+ return director;
+ }
+
+ public void setDirector(String director) {
+ this.director = director;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+
+ public int getYear() {
+ return year;
+ }
+
+ public void setYear(int year) {
+ this.year = year;
+ }
+ }
+
+## Configure the EntityManager via a persistence.xml file
+
+The above `Movie` entity can be created, removed, updated or deleted via an `EntityManager` object. The `EntityManager` itself is
+configured via a `META-INF/persistence.xml` file that is placed in the same jar as the `Movie` entity.
+
+ <persistence xmlns="http://java.sun.com/xml/ns/persistence" version="1.0">
+
+ <persistence-unit name="movie-unit">
+ <jta-data-source>movieDatabase</jta-data-source>
+ <non-jta-data-source>movieDatabaseUnmanaged</non-jta-data-source>
+ <class>org.superbiz.injection.jpa.Movie</class>
+
+ <properties>
+ <property name="openjpa.jdbc.SynchronizeMappings" value="buildSchema(ForeignKeys=true)"/>
+ </properties>
+ </persistence-unit>
+ </persistence>
+
+Notice that the `Movie` entity is listed via a `<class>` element. This is not required, but can help when testing or when the
+`Movie` class is located in a different jar than the jar containing the `persistence.xml` file.
+
+## Injection via @PersistenceContext
+
+The `EntityManager` itself is created by the container using the information in the `persistence.xml`, so to use it at
+runtime, we simply need to request it be injected into one of our components. We do this via `@PersistenceContext`
+
+The `@PersistenceContext` annotation can be used on any CDI bean, EJB, Servlet, Servlet Listener, Servlet Filter, or JSF ManagedBean. If you don't use an EJB you will need to use a `UserTransaction` begin and commit transactions manually. A transaction is required for any of the create, update or delete methods of the EntityManager to work.
+
+ package org.superbiz.injection.jpa;
+
+ import javax.ejb.Stateful;
+ import javax.persistence.EntityManager;
+ import javax.persistence.PersistenceContext;
+ import javax.persistence.PersistenceContextType;
+ import javax.persistence.Query;
+ import java.util.List;
+
+ @Stateful
+ public class Movies {
+
+ @PersistenceContext(unitName = "movie-unit", type = PersistenceContextType.EXTENDED)
+ private EntityManager entityManager;
+
+ public void addMovie(Movie movie) throws Exception {
+ entityManager.persist(movie);
+ }
+
+ public void deleteMovie(Movie movie) throws Exception {
+ entityManager.remove(movie);
+ }
+
+ public List<Movie> getMovies() throws Exception {
+ Query query = entityManager.createQuery("SELECT m from Movie as m");
+ return query.getResultList();
+ }
+ }
+
+This particular `EntityManager` is injected as an `EXTENDED` persistence context, which simply means that the `EntityManager`
+is created when the `@Stateful` bean is created and destroyed when the `@Stateful` bean is destroyed. Simply put, the
+data in the `EntityManager` is cached for the lifetime of the `@Stateful` bean.
+
+The use of `EXTENDED` persistence contexts is **only** available to `@Stateful` beans. See the [JPA Concepts](../../jpa-concepts.html) page for an high level explanation of what a "persistence context" really is and how it is significant to JPA.
+
+## MoviesTest
+
+Testing JPA is quite easy, we can simply use the `EJBContainer` API to create a container in our test case.
+
+ package org.superbiz.injection.jpa;
+
+ import junit.framework.TestCase;
+
+ import javax.ejb.embeddable.EJBContainer;
+ import javax.naming.Context;
+ import java.util.List;
+ import java.util.Properties;
+
+ //START SNIPPET: code
+ public class MoviesTest extends TestCase {
+
+ public void test() throws Exception {
+
+ final Properties p = new Properties();
+ p.put("movieDatabase", "new://Resource?type=DataSource");
+ p.put("movieDatabase.JdbcDriver", "org.hsqldb.jdbcDriver");
+ p.put("movieDatabase.JdbcUrl", "jdbc:hsqldb:mem:moviedb");
+
+ final Context context = EJBContainer.createEJBContainer(p).getContext();
+
+ Movies movies = (Movies) context.lookup("java:global/injection-of-entitymanager/Movies");
+
+ movies.addMovie(new Movie("Quentin Tarantino", "Reservoir Dogs", 1992));
+ movies.addMovie(new Movie("Joel Coen", "Fargo", 1996));
+ movies.addMovie(new Movie("Joel Coen", "The Big Lebowski", 1998));
+
+ List<Movie> list = movies.getMovies();
+ assertEquals("List.size()", 3, list.size());
+
+ for (Movie movie : list) {
+ movies.deleteMovie(movie);
+ }
+
+ assertEquals("Movies.getMovies()", 0, movies.getMovies().size());
+ }
+ }
+
+# Running
+
+When we run our test case we should see output similar to the following.
+
+ -------------------------------------------------------
+ T E S T S
+ -------------------------------------------------------
+ Running org.superbiz.injection.jpa.MoviesTest
+ Apache OpenEJB 4.0.0-beta-1 build: 20111002-04:06
+ http://tomee.apache.org/
+ INFO - openejb.home = /Users/dblevins/examples/injection-of-entitymanager
+ INFO - openejb.base = /Users/dblevins/examples/injection-of-entitymanager
+ INFO - Using 'javax.ejb.embeddable.EJBContainer=true'
+ INFO - Configuring Service(id=Default Security Service, type=SecurityService, provider-id=Default Security Service)
+ INFO - Configuring Service(id=Default Transaction Manager, type=TransactionManager, provider-id=Default Transaction Manager)
+ INFO - Configuring Service(id=movieDatabase, type=Resource, provider-id=Default JDBC Database)
+ INFO - Found EjbModule in classpath: /Users/dblevins/examples/injection-of-entitymanager/target/classes
+ INFO - Beginning load: /Users/dblevins/examples/injection-of-entitymanager/target/classes
+ INFO - Configuring enterprise application: /Users/dblevins/examples/injection-of-entitymanager
+ INFO - Configuring Service(id=Default Stateful Container, type=Container, provider-id=Default Stateful Container)
+ INFO - Auto-creating a container for bean Movies: Container(type=STATEFUL, id=Default Stateful Container)
+ INFO - Configuring Service(id=Default Managed Container, type=Container, provider-id=Default Managed Container)
+ INFO - Auto-creating a container for bean org.superbiz.injection.jpa.MoviesTest: Container(type=MANAGED, id=Default Managed Container)
+ INFO - Configuring PersistenceUnit(name=movie-unit)
+ INFO - Auto-creating a Resource with id 'movieDatabaseNonJta' of type 'DataSource for 'movie-unit'.
+ INFO - Configuring Service(id=movieDatabaseNonJta, type=Resource, provider-id=movieDatabase)
+ INFO - Adjusting PersistenceUnit movie-unit <non-jta-data-source> to Resource ID 'movieDatabaseNonJta' from 'movieDatabaseUnmanaged'
+ INFO - Enterprise application "/Users/dblevins/examples/injection-of-entitymanager" loaded.
+ INFO - Assembling app: /Users/dblevins/examples/injection-of-entitymanager
+ INFO - PersistenceUnit(name=movie-unit, provider=org.apache.openjpa.persistence.PersistenceProviderImpl) - provider time 462ms
+ INFO - Jndi(name="java:global/injection-of-entitymanager/Movies!org.superbiz.injection.jpa.Movies")
+ INFO - Jndi(name="java:global/injection-of-entitymanager/Movies")
+ INFO - Jndi(name="java:global/EjbModule1461341140/org.superbiz.injection.jpa.MoviesTest!org.superbiz.injection.jpa.MoviesTest")
+ INFO - Jndi(name="java:global/EjbModule1461341140/org.superbiz.injection.jpa.MoviesTest")
+ INFO - Created Ejb(deployment-id=Movies, ejb-name=Movies, container=Default Stateful Container)
+ INFO - Created Ejb(deployment-id=org.superbiz.injection.jpa.MoviesTest, ejb-name=org.superbiz.injection.jpa.MoviesTest, container=Default Managed Container)
+ INFO - Started Ejb(deployment-id=Movies, ejb-name=Movies, container=Default Stateful Container)
+ INFO - Started Ejb(deployment-id=org.superbiz.injection.jpa.MoviesTest, ejb-name=org.superbiz.injection.jpa.MoviesTest, container=Default Managed Container)
+ INFO - Deployed Application(path=/Users/dblevins/examples/injection-of-entitymanager)
+ Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.301 sec
+
+ Results :
+
+ Tests run: 1, Failures: 0, Errors: 0, Skipped: 0
+
diff --git a/examples/xa-datasource/pom.xml b/examples/xa-datasource/pom.xml
new file mode 100644
index 0000000..efe0e54
--- /dev/null
+++ b/examples/xa-datasource/pom.xml
@@ -0,0 +1,113 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+<!-- $Rev$ $Date$ -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <groupId>org.superbiz</groupId>
+ <artifactId>xa-datasource</artifactId>
+ <packaging>jar</packaging>
+ <version>8.0.0-SNAPSHOT</version>
+ <name>OpenEJB :: Examples :: XA Datasource configuration and usage</name>
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+ <derby.version>10.12.1.1</derby.version>
+ </properties>
+ <build>
+ <defaultGoal>install</defaultGoal>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <version>3.5.1</version>
+ <configuration>
+ <source>1.8</source>
+ <target>1.8</target>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+ <repositories>
+ <repository>
+ <id>apache-m2-snapshot</id>
+ <name>Apache Snapshot Repository</name>
+ <url>https://repository.apache.org/content/groups/snapshots</url>
+ </repository>
+ </repositories>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.tomee</groupId>
+ <artifactId>javaee-api</artifactId>
+ <version>8.0</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.12</version>
+ <scope>test</scope>
+ </dependency>
+ <!--
+ The <scope>test</scope> guarantees that non of your runtime
+ code is dependent on any OpenEJB classes.
+ -->
+ <dependency>
+ <groupId>org.apache.tomee</groupId>
+ <artifactId>openejb-core</artifactId>
+ <version>8.0.0-SNAPSHOT</version>
+ <scope>test</scope>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.derby</groupId>
+ <artifactId>derby</artifactId>
+ <version>${derby.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.derby</groupId>
+ <artifactId>derbynet</artifactId>
+ <version>${derby.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.derby</groupId>
+ <artifactId>derbyclient</artifactId>
+ <version>${derby.version}</version>
+ </dependency>
+
+ </dependencies>
+ <!--
+ This section allows you to configure where to publish libraries for sharing.
+ It is not required and may be deleted. For more information see:
+ http://maven.apache.org/plugins/maven-deploy-plugin/
+ -->
+ <distributionManagement>
+ <repository>
+ <id>localhost</id>
+ <url>file://${basedir}/target/repo/</url>
+ </repository>
+ <snapshotRepository>
+ <id>localhost</id>
+ <url>file://${basedir}/target/snapshot-repo/</url>
+ </snapshotRepository>
+ </distributionManagement>
+</project>
diff --git a/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movie.java b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movie.java
new file mode 100644
index 0000000..1bc65eb
--- /dev/null
+++ b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movie.java
@@ -0,0 +1,76 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.superbiz.injection.jpa;
+//START SNIPPET: code
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+
+@Entity
+public class Movie {
+
+ @Id
+ @GeneratedValue
+ private long id;
+
+ private String director;
+ private String title;
+ private int year;
+
+ public Movie() {
+ }
+
+ public long getId() {
+ return id;
+ }
+
+ public void setId(long id) {
+ this.id = id;
+ }
+
+ public Movie(String director, String title, int year) {
+ this.director = director;
+ this.title = title;
+ this.year = year;
+ }
+
+ public String getDirector() {
+ return director;
+ }
+
+ public void setDirector(String director) {
+ this.director = director;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+
+ public int getYear() {
+ return year;
+ }
+
+ public void setYear(int year) {
+ this.year = year;
+ }
+}
+//END SNIPPET: code
diff --git a/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movies.java b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movies.java
new file mode 100644
index 0000000..4e136aa
--- /dev/null
+++ b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movies.java
@@ -0,0 +1,54 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.superbiz.injection.jpa;
+
+//START SNIPPET: code
+
+import javax.ejb.Singleton;
+import javax.persistence.EntityManager;
+import javax.persistence.PersistenceContext;
+import javax.persistence.PersistenceContextType;
+import javax.persistence.Query;
+import java.util.List;
+
+@Singleton
+public class Movies {
+
+ @PersistenceContext(unitName = "movie-unit", type = PersistenceContextType.TRANSACTION)
+ private EntityManager entityManager;
+
+ public void addMovie(Movie movie) throws Exception {
+ entityManager.persist(movie);
+ }
+
+ public void deleteMovie(Movie movie) throws Exception {
+ final Movie storedMovie = entityManager.find(Movie.class, movie.getId());
+ entityManager.remove(storedMovie);
+ }
+
+ public List<Movie> getMovies() throws Exception {
+ Query query = entityManager.createQuery("SELECT m from Movie as m");
+ return query.getResultList();
+ }
+
+ public void deleteAll() throws Exception {
+ Query query = entityManager.createQuery("DELETE from Movie");
+ query.executeUpdate();
+ }
+
+}
+//END SNIPPET: code
diff --git a/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesDirect.java b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesDirect.java
new file mode 100644
index 0000000..22646b0
--- /dev/null
+++ b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesDirect.java
@@ -0,0 +1,47 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.superbiz.injection.jpa;
+
+import javax.annotation.Resource;
+import javax.ejb.Singleton;
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+
+@Singleton
+public class MoviesDirect {
+
+ @Resource(name="moviesDatabaseUnmanaged")
+ private DataSource ds;
+
+ public int count() {
+ try (final Connection connection = ds.getConnection()) {
+ try (final PreparedStatement ps = connection.prepareStatement("select count(1) from movie")) {
+ try (final ResultSet rs = ps.executeQuery()) {
+ if (rs != null && rs.next()) {
+ return rs.getInt(1);
+ } else {
+ return 0;
+ }
+ }
+ }
+ } catch (final Exception e) {
+ throw new RuntimeException("Unable to execute query against the database");
+ }
+ }
+}
diff --git a/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesXA.java b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesXA.java
new file mode 100644
index 0000000..05a384d
--- /dev/null
+++ b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesXA.java
@@ -0,0 +1,189 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.superbiz.injection.jpa;
+
+import javax.annotation.Resource;
+import javax.ejb.Singleton;
+import javax.persistence.EntityManager;
+import javax.persistence.PersistenceContext;
+import javax.transaction.RollbackException;
+import javax.transaction.SystemException;
+import javax.transaction.TransactionManager;
+import javax.transaction.xa.XAException;
+import javax.transaction.xa.XAResource;
+import javax.transaction.xa.Xid;
+
+@Singleton
+public class MoviesXA {
+ private static int XA_STATE_INITIAL = 0;
+ private static int XA_STATE_STARTED = 1;
+ private static int XA_STATE_ENDED = 2;
+ private static int XA_STATE_PREPARED = 3;
+ private static int XA_STATE_DISPOSED = 4;
+
+ @PersistenceContext
+ private EntityManager em;
+
+ @Resource
+ private TransactionManager transactionManager;
+
+ private volatile boolean fail = false;
+ private volatile boolean before = false;
+
+ public void run(Movie movie) {
+ if (before) {
+ addXaResource();
+ }
+
+ em.persist(movie);
+
+ if (!before) {
+ addXaResource();
+ }
+ }
+
+ private void addXaResource() {
+ try {
+ transactionManager.getTransaction().enlistResource(new XAResource() {
+ private int state = XA_STATE_INITIAL;
+ private Xid xid = null;
+
+ private void validateXid(final Xid xid) throws XAException {
+ if (xid == null) {
+ throw new XAException("Null Xid");
+ }
+ if (this.xid == null) {
+ throw new XAException("There is no live transaction for this XAResource");
+ }
+ if (!xid.equals(this.xid)) {
+ throw new XAException("Given Xid is not that associated with this XAResource object");
+ }
+ }
+
+ @Override public void commit(final Xid xid, final boolean onePhase) throws XAException {
+ if (onePhase && state == XA_STATE_PREPARED) {
+ throw new XAException("Transaction is in a 2-phase state when 1-phase is requested");
+ }
+
+ if ((!onePhase) && state != XA_STATE_PREPARED) {
+ throw new XAException("Attempt to do a 2-phase commit when " + "transaction is not prepared");
+ }
+
+ dispose();
+ }
+
+ private void dispose() throws XAException {
+ state = XA_STATE_DISPOSED;
+ xid = null;
+ }
+
+ @Override public void end(final Xid xid, final int flags) throws XAException {
+
+ validateXid(xid);
+
+ if (state != XA_STATE_STARTED) {
+ throw new XAException("Invalid XAResource state");
+ }
+
+ state = XA_STATE_ENDED;
+ }
+
+ @Override public void forget(Xid xid) throws XAException {
+ validateXid(xid);
+
+ if (state != XA_STATE_PREPARED) {
+ throw new XAException("Attempted to forget a XAResource that " + "is not in a heuristically completed state");
+ }
+
+ dispose();
+
+ state = XA_STATE_INITIAL;
+ }
+
+ @Override public int getTransactionTimeout() throws XAException {
+ throw new XAException("Transaction timeouts not implemented yet");
+ }
+
+ @Override public boolean isSameRM(final XAResource xares) throws XAException {
+ return xares == this;
+ }
+
+ @Override public int prepare(final Xid xid) throws XAException {
+ if (state != XA_STATE_ENDED) {
+ throw new XAException("Invalid XAResource state");
+ }
+
+ state = XA_STATE_PREPARED;
+
+ if (fail) {
+ throw new XAException("oops");
+ }
+
+ return XA_OK;
+ }
+
+ @Override public Xid[] recover(final int flag) throws XAException {
+ return new Xid[0];
+ }
+
+ @Override public void rollback(Xid xid) throws XAException {
+ if (state != XA_STATE_PREPARED && state != XA_STATE_ENDED) {
+ throw new XAException("Invalid XAResource state");
+ }
+ dispose();
+ }
+
+ @Override public boolean setTransactionTimeout(final int seconds) throws XAException {
+ return false;
+ }
+
+ @Override public void start(final Xid xid, final int flags) throws XAException {
+ if (state != XA_STATE_INITIAL && state != XA_STATE_DISPOSED) {
+ throw new XAException("Invalid XAResource state");
+ }
+
+ if (xid == null) {
+ throw new XAException("Null Xid");
+ }
+
+ this.xid = xid;
+ state = XA_STATE_STARTED;
+ }
+ });
+ } catch (final RollbackException | SystemException e) {
+ throw new IllegalStateException(e);
+ }
+ }
+
+ public Movie find() {
+ return em.createQuery("select e from Movie e", Movie.class).getResultList().iterator().next();
+ }
+
+ public void fail() {
+ fail = true;
+ }
+
+ public void reset() {
+ fail = false;
+ before = false;
+ }
+
+ public void before() {
+ before = true;
+ }
+}
diff --git a/examples/xa-datasource/src/main/resources/META-INF/persistence.xml b/examples/xa-datasource/src/main/resources/META-INF/persistence.xml
new file mode 100644
index 0000000..798f6a9
--- /dev/null
+++ b/examples/xa-datasource/src/main/resources/META-INF/persistence.xml
@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+<!-- START SNIPPET: code -->
+<persistence xmlns="http://java.sun.com/xml/ns/persistence" version="1.0">
+
+ <persistence-unit name="movie-unit">
+ <jta-data-source>movieDatabase</jta-data-source>
+ <non-jta-data-source>movieDatabaseUnmanaged</non-jta-data-source>
+ <class>org.superbiz.injection.jpa.Movie</class>
+
+ <properties>
+ <property name="openjpa.jdbc.SynchronizeMappings" value="buildSchema(ForeignKeys=true)"/>
+ </properties>
+ </persistence-unit>
+</persistence>
+ <!-- END SNIPPET: code -->
diff --git a/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesTest.java b/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesTest.java
new file mode 100644
index 0000000..48771ce
--- /dev/null
+++ b/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesTest.java
@@ -0,0 +1,98 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.superbiz.injection.jpa;
+
+import junit.framework.TestCase;
+
+import javax.ejb.embeddable.EJBContainer;
+import javax.naming.Context;
+import java.util.List;
+import java.util.Properties;
+
+//START SNIPPET: code
+public class MoviesTest extends TestCase {
+
+ public void test() throws Exception {
+
+ final Properties p = new Properties();
+ p.put("movieDatabaseXA", "new://Resource?type=javax.sql.XADataSource&class-name=org.apache.derby.jdbc.EmbeddedXADataSource");
+ p.put("movieDatabaseXA.DatabaseName", "test");
+ p.put("movieDatabaseXA.CreateDatabase", "create");
+
+ p.put("movieDatabase", "new://Resource?type=DataSource");
+ p.put("movieDatabase.DataSourceCreator", "dbcp");
+ p.put("movieDatabase.XaDataSource", "movieDatabaseXA");
+ p.put("movieDatabase.JtaManaged", "true");
+ p.put("movieDatabase.UserName", "admin");
+ p.put("movieDatabase.Password", "admin");
+ p.put("movieDatabase.MaxActive", "128");
+ p.put("movieDatabase.MaxIdle", "25");
+ p.put("movieDatabase.MinIdle", "10");
+ p.put("movieDatabase.AccessToUnderlyingConnectionAllowed", "true");
+ p.put("movieDatabase.TestOnBorrow", "false");
+ p.put("movieDatabase.TestWhileIdle", "true");
+ p.put("movieDatabase.TimeBetweenEvictionRuns", "1 minute");
+ p.put("movieDatabase.MaxWaitTime", "0 seconds");
+ p.put("movieDatabase.PoolPreparedStatements", "true");
+ p.put("movieDatabase.MaxOpenPreparedStatements", "1024");
+ p.put("movieDatabase.ValidationQuery", "values 1");
+
+ p.put("movieDatabaseUnmanaged", "new://Resource?type=DataSource");
+ p.put("movieDatabaseUnmanaged.DataSourceCreator", "dbcp");
+ p.put("movieDatabaseUnmanaged.JdbcDriver", "org.apache.derby.jdbc.EmbeddedDriver");
+ p.put("movieDatabaseUnmanaged.JdbcUrl", "jdbc:derby:test;create=true");
+ p.put("movieDatabaseUnmanaged.UserName", "admin");
+ p.put("movieDatabaseUnmanaged.Password", "admin");
+ p.put("movieDatabaseUnmanaged.JtaManaged", "false");
+ p.put("movieDatabaseUnmanaged.MaxActive", "128");
+ p.put("movieDatabaseUnmanaged.MaxIdle", "25");
+ p.put("movieDatabaseUnmanaged.MinIdle", "10");
+ p.put("movieDatabaseUnmanaged.AccessToUnderlyingConnectionAllowed", "true");
+ p.put("movieDatabaseUnmanaged.TestOnBorrow", "false");
+ p.put("movieDatabaseUnmanaged.TestWhileIdle", "true");
+ p.put("movieDatabaseUnmanaged.TimeBetweenEvictionRuns", "1 minute");
+ p.put("movieDatabaseUnmanaged.MaxWaitTime", "0 seconds");
+ p.put("movieDatabaseUnmanaged.PoolPreparedStatements", "true");
+ p.put("movieDatabaseUnmanaged.MaxOpenPreparedStatements", "1024");
+ p.put("movieDatabaseUnmanaged.ValidationQuery", "values 1");
+
+ EJBContainer container = EJBContainer.createEJBContainer(p);
+ final Context context = container.getContext();
+
+ Movies movies = (Movies) context.lookup("java:global/xa-datasource/Movies");
+ MoviesDirect moviesDirect = (MoviesDirect) context.lookup("java:global/xa-datasource/MoviesDirect");
+
+ movies.addMovie(new Movie("Quentin Tarantino", "Reservoir Dogs", 1992));
+ movies.addMovie(new Movie("Joel Coen", "Fargo", 1996));
+ movies.addMovie(new Movie("Joel Coen", "The Big Lebowski", 1998));
+
+ List<Movie> list = movies.getMovies();
+ assertEquals("List.size()", 3, list.size());
+ assertEquals(3, moviesDirect.count());
+
+
+ for (Movie movie : list) {
+ movies.deleteMovie(movie);
+ }
+
+ assertEquals("Movies.getMovies()", 0, movies.getMovies().size());
+ assertEquals(0, moviesDirect.count());
+
+ container.close();
+ }
+}
+//END SNIPPET: code
diff --git a/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesXATest.java b/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesXATest.java
new file mode 100644
index 0000000..56ee0c6
--- /dev/null
+++ b/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesXATest.java
@@ -0,0 +1,169 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.superbiz.injection.jpa;
+
+import org.apache.openejb.jee.EjbJar;
+import org.apache.openejb.jee.jpa.unit.PersistenceUnit;
+import org.apache.openejb.junit.ApplicationComposer;
+import org.apache.openejb.loader.Files;
+import org.apache.openejb.testing.Classes;
+import org.apache.openejb.testing.Configuration;
+import org.apache.openejb.testing.Module;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import javax.ejb.EJB;
+import javax.ejb.EJBException;
+import java.io.File;
+import java.util.Properties;
+
+import static java.lang.Math.abs;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+
+@RunWith(ApplicationComposer.class)
+public class MoviesXATest {
+ @Module
+ @Classes(value = { MoviesXA.class, Movies.class, MoviesDirect.class })
+ public EjbJar app() {
+ return new EjbJar();
+ }
+
+ @Module
+ public PersistenceUnit jpa() {
+ final PersistenceUnit unit = new PersistenceUnit("movie-unit");
+ unit.setJtaDataSource("movieDatabase");
+ unit.setNonJtaDataSource("movieDatabaseUnmanaged");
+ unit.setProperty("openjpa.jdbc.SynchronizeMappings", "buildSchema(foreignKeys=true,schemaAction='dropDB,add')");
+ unit.addClass(Movie.class);
+ return unit;
+ }
+
+ @Configuration
+ public Properties config() {
+ final String db = "target/test + " + abs(System.nanoTime());
+ Files.deleteOnExit(new File(db));
+
+ final Properties p = new Properties();
+
+ p.put("movieDatabaseXA", "new://Resource?type=javax.sql.XADataSource&class-name=org.apache.derby.jdbc.EmbeddedXADataSource");
+ p.put("movieDatabaseXA.DatabaseName", db);
+ p.put("movieDatabaseXA.CreateDatabase", "create");
+
+ p.put("movieDatabase", "new://Resource?type=DataSource");
+ p.put("movieDatabase.XaDataSource", "movieDatabaseXA");
+ p.put("movieDatabase.JtaManaged", "true");
+ p.put("movieDatabase.UserName", "admin");
+ p.put("movieDatabase.Password", "admin");
+ p.put("movieDatabase.MaxActive", "128");
+ p.put("movieDatabase.InitialSize", "2");
+ p.put("movieDatabase.MaxIdle", "25");
+ p.put("movieDatabase.MinIdle", "10");
+ p.put("movieDatabase.AccessToUnderlyingConnectionAllowed", "true");
+ p.put("movieDatabase.TestOnBorrow", "false");
+ p.put("movieDatabase.TestWhileIdle", "true");
+ p.put("movieDatabase.TimeBetweenEvictionRuns", "1 minute");
+ p.put("movieDatabase.MaxWaitTime", "0 seconds");
+ p.put("movieDatabase.PoolPreparedStatements", "true");
+ p.put("movieDatabase.MaxOpenPreparedStatements", "1024");
+ p.put("movieDatabase.ValidationQuery", "values 1");
+
+ p.put("movieDatabaseUnmanaged", "new://Resource?type=DataSource");
+ p.put("movieDatabaseUnmanaged.LogSql", "true");
+ p.put("movieDatabaseUnmanaged.JdbcDriver", "org.apache.derby.jdbc.EmbeddedDriver");
+ p.put("movieDatabaseUnmanaged.JdbcUrl", "jdbc:derby:" + db + ";create=true");
+ p.put("movieDatabaseUnmanaged.UserName", "admin");
+ p.put("movieDatabaseUnmanaged.Password", "admin");
+ p.put("movieDatabaseUnmanaged.JtaManaged", "false");
+ p.put("movieDatabaseUnmanaged.InitialSize", "2");
+ p.put("movieDatabaseUnmanaged.MaxActive", "128");
+ p.put("movieDatabaseUnmanaged.MaxIdle", "25");
+ p.put("movieDatabaseUnmanaged.MinIdle", "10");
+ p.put("movieDatabaseUnmanaged.AccessToUnderlyingConnectionAllowed", "true");
+ p.put("movieDatabaseUnmanaged.TestOnBorrow", "false");
+ p.put("movieDatabaseUnmanaged.TestWhileIdle", "true");
+ p.put("movieDatabaseUnmanaged.TimeBetweenEvictionRuns", "1 minute");
+ p.put("movieDatabaseUnmanaged.MaxWaitTime", "0 seconds");
+ p.put("movieDatabaseUnmanaged.PoolPreparedStatements", "true");
+ p.put("movieDatabaseUnmanaged.MaxOpenPreparedStatements", "1024");
+ p.put("movieDatabaseUnmanaged.ValidationQuery", "values 1");
+
+ System.out.println("Using db: " + db);
+
+ return p;
+ }
+
+ @EJB
+ private Movies movies;
+
+ @EJB
+ private MoviesDirect moviesDirect;
+
+ @EJB
+ private MoviesXA runner;
+
+ @Test
+ public void run() throws Exception {
+ movies.deleteAll();
+
+ runner.reset();
+
+ final Movie movie = new Movie();
+ movie.setTitle("Bad Boys");
+ movie.setDirector("Michael Bay");
+ movie.setYear(1995);
+
+ runner.run(movie);
+ assertEquals(1, moviesDirect.count());
+
+ final Movie storedMovie = runner.find();
+ assertNotNull(storedMovie);
+ }
+
+ @Test
+ public void failBefore() {
+ runner.before();
+ doFail();
+ }
+
+ @Test
+ public void failAfter() {
+ doFail();
+ }
+
+ private void doFail() {
+ runner.fail();
+ try {
+ final Movie movie = new Movie();
+ movie.setTitle("Bad Boys");
+ movie.setDirector("Michael Bay");
+ movie.setYear(1995);
+
+ runner.run(movie);
+ } catch (final EJBException ee) {
+ System.out.flush();
+ System.err.flush();
+ System.out.println("Exception ->");
+ ee.printStackTrace();
+ System.out.println();
+ System.out.flush();
+ System.err.flush();
+ }
+
+ assertEquals(0, moviesDirect.count());
+ }
+}
[tomee] 03/04: Add example
Posted by jg...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jgallimore pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tomee.git
commit 8952bd738d1b4abbe0191f18e849ba729de658b4
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Fri Jun 14 16:38:58 2019 +0100
Add example
---
examples/pom.xml | 1 +
1 file changed, 1 insertion(+)
diff --git a/examples/pom.xml b/examples/pom.xml
index 999c9df..0b3a4e5 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -205,6 +205,7 @@
<module>vaadin-vxx-simple</module>
<module>cloud-tomee-azure</module>
<module>mp-faulttolerance-timeout</module>
+ <module>xa-datasource</module>
</modules>
<dependencies>
[tomee] 02/04: Correct the config so the Derby database is picked up
Posted by jg...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jgallimore pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tomee.git
commit 79c51174f2de0fb86534dcd3674dd077b23375ad
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Fri Jun 14 16:35:12 2019 +0100
Correct the config so the Derby database is picked up
---
.../src/main/java/org/superbiz/injection/jpa/MoviesXA.java | 4 ++++
.../src/test/java/org/superbiz/injection/jpa/MoviesXATest.java | 8 +++-----
2 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesXA.java b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesXA.java
index 05a384d..7c2be21 100644
--- a/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesXA.java
+++ b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesXA.java
@@ -21,6 +21,7 @@ import javax.annotation.Resource;
import javax.ejb.Singleton;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
+import javax.sql.DataSource;
import javax.transaction.RollbackException;
import javax.transaction.SystemException;
import javax.transaction.TransactionManager;
@@ -39,6 +40,9 @@ public class MoviesXA {
@PersistenceContext
private EntityManager em;
+ @Resource(name = "movieDatabase")
+ private DataSource ds;
+
@Resource
private TransactionManager transactionManager;
diff --git a/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesXATest.java b/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesXATest.java
index 56ee0c6..afad529 100644
--- a/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesXATest.java
+++ b/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesXATest.java
@@ -60,12 +60,8 @@ public class MoviesXATest {
final Properties p = new Properties();
- p.put("movieDatabaseXA", "new://Resource?type=javax.sql.XADataSource&class-name=org.apache.derby.jdbc.EmbeddedXADataSource");
- p.put("movieDatabaseXA.DatabaseName", db);
- p.put("movieDatabaseXA.CreateDatabase", "create");
-
p.put("movieDatabase", "new://Resource?type=DataSource");
- p.put("movieDatabase.XaDataSource", "movieDatabaseXA");
+ p.put("movieDatabase.JdbcDriver", "org.apache.derby.jdbc.EmbeddedXADataSource");
p.put("movieDatabase.JtaManaged", "true");
p.put("movieDatabase.UserName", "admin");
p.put("movieDatabase.Password", "admin");
@@ -81,6 +77,8 @@ public class MoviesXATest {
p.put("movieDatabase.PoolPreparedStatements", "true");
p.put("movieDatabase.MaxOpenPreparedStatements", "1024");
p.put("movieDatabase.ValidationQuery", "values 1");
+ p.put("movieDatabase.DatabaseName", db);
+ p.put("movieDatabase.CreateDatabase", "create");
p.put("movieDatabaseUnmanaged", "new://Resource?type=DataSource");
p.put("movieDatabaseUnmanaged.LogSql", "true");
[tomee] 04/04: Merge branch 'TOMEE-2541'
Posted by jg...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jgallimore pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tomee.git
commit 44e37ab6dcc1478a87666afed784d0e2d0ebef92
Merge: ea1a433 8952bd7
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Fri Jun 14 16:43:14 2019 +0100
Merge branch 'TOMEE-2541'
examples/pom.xml | 1 +
examples/xa-datasource/README.md | 217 +++++++++++++++++++++
examples/xa-datasource/pom.xml | 113 +++++++++++
.../java/org/superbiz/injection/jpa/Movie.java | 76 ++++++++
.../java/org/superbiz/injection/jpa/Movies.java | 54 +++++
.../org/superbiz/injection/jpa/MoviesDirect.java | 47 +++++
.../java/org/superbiz/injection/jpa/MoviesXA.java | 193 ++++++++++++++++++
.../src/main/resources/META-INF/persistence.xml | 32 +++
.../org/superbiz/injection/jpa/MoviesTest.java | 98 ++++++++++
.../org/superbiz/injection/jpa/MoviesXATest.java | 167 ++++++++++++++++
10 files changed, 998 insertions(+)