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:23 UTC
[tomee] 01/04: Reinstating example
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());
+ }
+}