Adding sample for XA datasources
Project: http://git-wip-us.apache.org/repos/asf/tomee/repo Commit: http://git-wip-us.apache.org/repos/asf/tomee/commit/6345d7ac Tree: http://git-wip-us.apache.org/repos/asf/tomee/tree/6345d7ac Diff: http://git-wip-us.apache.org/repos/asf/tomee/diff/6345d7ac Branch: refs/heads/tomee-1.7.x Commit: 6345d7ac0292acdded9a49619036cba4298a3a70 Parents: 0977da5 Author: Jonathan Gallimore <[email protected]> Authored: Mon Jul 25 11:48:33 2016 +0200 Committer: Jonathan Gallimore <[email protected]> Committed: Tue Jul 26 18:55:58 2016 +0200 ---------------------------------------------------------------------- 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 | 49 +++++ .../superbiz/injection/jpa/MoviesDirect.java | 31 +++ .../src/main/resources/META-INF/persistence.xml | 32 +++ .../org/superbiz/injection/jpa/MoviesTest.java | 98 +++++++++ 8 files changed, 617 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tomee/blob/6345d7ac/examples/pom.xml ---------------------------------------------------------------------- diff --git a/examples/pom.xml b/examples/pom.xml index d71ea55..2346e0f 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -159,6 +159,7 @@ <module>moviefun-rest</module> <module>cdi-event-realm</module> <module>resources-jmx-example</module> + <module>xa-datasource</module> </modules> <dependencies> http://git-wip-us.apache.org/repos/asf/tomee/blob/6345d7ac/examples/xa-datasource/README.md ---------------------------------------------------------------------- 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 + http://git-wip-us.apache.org/repos/asf/tomee/blob/6345d7ac/examples/xa-datasource/pom.xml ---------------------------------------------------------------------- diff --git a/examples/xa-datasource/pom.xml b/examples/xa-datasource/pom.xml new file mode 100644 index 0000000..76c00e6 --- /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>1.1.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.7</source> + <target>1.7</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>7.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>7.0.2-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> http://git-wip-us.apache.org/repos/asf/tomee/blob/6345d7ac/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movie.java ---------------------------------------------------------------------- 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 http://git-wip-us.apache.org/repos/asf/tomee/blob/6345d7ac/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movies.java ---------------------------------------------------------------------- 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..a03baa0 --- /dev/null +++ b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/Movies.java @@ -0,0 +1,49 @@ +/** + * 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(); + } + +} +//END SNIPPET: code http://git-wip-us.apache.org/repos/asf/tomee/blob/6345d7ac/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesDirect.java ---------------------------------------------------------------------- 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..3d2a1b0 --- /dev/null +++ b/examples/xa-datasource/src/main/java/org/superbiz/injection/jpa/MoviesDirect.java @@ -0,0 +1,31 @@ +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"); + } + } +} http://git-wip-us.apache.org/repos/asf/tomee/blob/6345d7ac/examples/xa-datasource/src/main/resources/META-INF/persistence.xml ---------------------------------------------------------------------- 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 --> http://git-wip-us.apache.org/repos/asf/tomee/blob/6345d7ac/examples/xa-datasource/src/test/java/org/superbiz/injection/jpa/MoviesTest.java ---------------------------------------------------------------------- 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
