#30 - Started Updating Camel JPA-JTA Example

karaf/camel-jpa_jta/src/main/resources/scripts/deploy.karaf → karaf/jpa_jta/README.md

@@ -1,10 +1,15 @@
-# important! "connector" feature required to have rollback to work
-features:install jndi jpa hibernate camel-jpa transaction connector
+Build Application
 
-install -s wrap:mvn:org.postgresql/postgresql/9.3-1102-jdbc41
+Start Fuse
 
-install -s blueprint:mvn:com.redhat.consulting.fusequickstarts.karaf/camel-jpa-jta/6.2.1/xml/postgres
-install -s mvn:com.redhat.consulting.fusequickstarts.karaf/camel-jpa-jta/6.2.1
+Install Dependencies
+````
+features:install jndi jpa hibernate camel-jpa transaction connector
+install -s mvn:com.h2database/h2/1.3.163
+install -s blueprint:mvn:com.redhat.consulting.fusequickstarts.karaf/camel-jpa-jta/6.2.1/xml/h2
+````
 
-la -l | tail
-echo JPA Example installed.
+Install Application
+````
+install -s mvn:com.redhat.consulting.fusequickstarts.karaf/camel-jpa-jta/6.2.1
+````

karaf/camel-jpa_jta/pom.xml → karaf/jpa_jta/pom.xml

@@ -11,7 +11,7 @@
 		<relativePath>../parent/pom.xml</relativePath>
 	</parent>
 
-  <artifactId>camel-jpa-jta</artifactId>
+  <artifactId>jpa-jta</artifactId>
   <packaging>bundle</packaging>
   <name>Fuse Quickstart :: Karaf :: Blueprint :: Camel JPA w/ Hibernate and JTA</name>
 
@@ -96,20 +96,6 @@
                 <type>xml</type>
                 <classifier>h2</classifier>
               </artifact>
-              <artifact>
-                <file>target/classes/datasources/postgresql-ds.xml</file>
-                <type>xml</type>
-                <classifier>postgres</classifier>
-              </artifact>
-              <artifact>
-                <file>target/classes/datasources/oracle-ds.xml</file>
-                <type>xml</type>
-                <classifier>oracle</classifier>
-              </artifact>
-              <artifact>
-                <file>target/classes/scripts/deploy.karaf</file>
-                <type>karaf</type>
-              </artifact>
             </artifacts>
           </configuration>
         </execution>

karaf/camel-jpa_jta/src/main/java/org/redhat/consulting/fusequickstarts/karaf/jpa/model/Person.java → karaf/jpa_jta/src/main/java/org/redhat/consulting/fusequickstarts/karaf/jpa/model/Person.java

@@ -2,13 +2,13 @@
 
 import javax.persistence.Entity;
 import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
 import javax.persistence.Id;
 
 @Entity
 public class Person {
 
     @Id
-    @GeneratedValue
     private long id;
 
     private String name;
@@ -17,7 +17,8 @@ public Person(){
 
     }
 
-    public Person(String pName){
+    public Person(long pId, String pName){
+        this.id = pId;
         this.name = pName;
     }
 

karaf/jpa_jta/src/main/java/org/redhat/consulting/fusequickstarts/karaf/jpa/route/JpaRoutes.java

@@ -0,0 +1,37 @@
+package org.redhat.consulting.fusequickstarts.karaf.jpa.route;
+
+import org.redhat.consulting.fusequickstarts.karaf.jpa.model.Person;
+import org.apache.camel.builder.RouteBuilder;
+import org.redhat.consulting.fusequickstarts.karaf.jpa.processor.ExceptionProcessor;
+
+public class JpaRoutes extends RouteBuilder {
+
+  @Override
+  public void configure() throws Exception {
+    from("timer://jpaTimer?fixedRate=true&period=5000&repeatCount=1")
+        .routeId("Success Route")
+        .transacted()
+        .log(">>> Generating New Person")
+        .setBody(constant(new Person(1, Person.generateName())))
+        .log(">>> Saving Person")
+        .to("jpa://org.redhat.consulting.fusequickstarts.karaf.jpa.model.Person")
+        .log(">>> Saved Person: ${body}!");
+
+    from("jpa://org.redhat.consulting.fusequickstarts.karaf.jpa.model.Person")
+        .routeId("JPA Poll")
+        .log("Retrieved Person: ${body}");
+
+    /*from("timer://jpaTimer?fixedRate=true&period=5000&repeatCount=1")
+        .routeId("Failure Route")
+        .transacted()
+        .log(">>> Generating New Person")
+        .setBody(constant(new Person(2, "Rolled_Back_" + Person.generateName())))
+        .log(">>> Saving Person")
+        .to("jpa://org.redhat.consulting.fusequickstarts.karaf.jpa.model.Person")
+        .log(">>> Saved Person: ${body}!")
+        .beanRef("dummy","crash")
+        .log(">>> Rolled back");*/
+
+  }
+
+}

karaf/camel-jpa_jta/src/main/resources/META-INF/persistence.xml → karaf/jpa_jta/src/main/resources/META-INF/persistence.xml

@@ -7,16 +7,13 @@
       <jta-data-source>osgi:service/javax.sql.DataSource/(osgi.jndi.service.name=jdbc/h2ds)</jta-data-source>
         <properties>
 
-            <property name="hibernate.connection.driver_class" value="org.postgresql.Driver"/>
-            <property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQLDialect"/>
-
-            <!-- <property name="hibernate.connection.driver_class" value="org.h2.Driver"/>
-            <property name="hibernate.dialect" value="org.hibernate.dialect.H2Dialect"/> -->
+            <property name="hibernate.connection.driver_class" value="org.h2.Driver"/>
+            <property name="hibernate.dialect" value="org.hibernate.dialect.H2Dialect"/>
 
             <property name="hibernate.hbm2ddl.auto" value="create-drop"/>
             <property name="hibernate.archive.autodetection" value="class"/>
-            <!-- <property name="hibernate.show_sql" value="true" /> -->
-            <!-- <property name="hibernate.format_sql" value="true" /> -->
+            <property name="hibernate.show_sql" value="true" />
+            <property name="hibernate.format_sql" value="true" />
         </properties>
     </persistence-unit>
 </persistence>

karaf/jpa_jta/src/main/resources/OSGI-INF/blueprint/blueprint.xml

@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jpa="http://aries.apache.org/xmlns/jpa/v1.0.0"
+	xmlns:tx="http://aries.apache.org/xmlns/transactions/v1.1.0"
+	xmlns:camel="http://camel.apache.org/schema/blueprint"
+	xsi:schemaLocation="
+           http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
+
+	<reference id="transactionManager"
+		interface="org.springframework.transaction.PlatformTransactionManager" />
+	<reference id="entityManagerFactory" interface="javax.persistence.EntityManagerFactory" />
+
+	<bean id="jpa" class="org.apache.camel.component.jpa.JpaComponent">
+		<jpa:unit unitname="camelJpaContainer" property="entityManagerFactory" />
+		<property name="transactionManager" ref="transactionManager" />
+	</bean>
+
+	<bean id="PROPAGATION_REQUIRED" class="org.apache.camel.spring.spi.SpringTransactionPolicy">
+		<property name="transactionManager" ref="transactionManager" />
+	</bean>
+
+	<bean id="dummy" class="org.redhat.consulting.fusequickstarts.karaf.jpa.Dummy" />
+
+	<camel:camelContext id="camel"
+		xmlns="http://camel.apache.org/schema/blueprint">
+		<packageScan>
+			<package>org.redhat.consulting.fusequickstarts.karaf.jpa.route</package>
+		</packageScan>
+	</camel:camelContext>
+</blueprint>

karaf/camel-jpa_jta/src/main/resources/datasources/h2-ds.xml → karaf/jpa_jta/src/main/resources/datasources/h2-ds.xml

@@ -8,7 +8,6 @@
 <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0">
 
 	<bean id="dataSource" class="org.h2.jdbcx.JdbcDataSource">
-		<!-- <property name="URL" value="jdbc:h2:/tmp/myapp;AUTO_SERVER=TRUE" /> -->
 		<property name="URL" value="jdbc:h2:/tmp/myapp;AUTO_SERVER=TRUE;AUTOCOMMIT=FALSE" />
 		<property name="user" value="sa" />
 		<property name="password" value="" />