From 25a4129e5085c97d0f28ddb18b967108e0120875 Mon Sep 17 00:00:00 2001 From: kbachl Date: Thu, 26 Feb 2015 11:35:47 +0100 Subject: [PATCH 1/3] OLINGO-580 #only missing correction is for the tests as some assertions failed; Works in our project for CRUD via OData --- .../jpa/processor/api/ODataJPAContext.java | 5 ++ .../processor/api/ODataJPAServiceFactory.java | 30 ++++++++++- .../api/ODataJPATransactionContext.java | 51 ++++++++++++++++++ .../processor/core/ODataJPAContextImpl.java | 6 +++ .../core/ODataJPAProcessorDefault.java | 8 +-- .../processor/core/access/data/JPALink.java | 11 ++-- .../core/access/data/JPAProcessorImpl.java | 14 ++--- ...DataJPATransactionLocalDefaultContext.java | 54 +++++++++++++++++++ .../ref/web/JPAReferenceServiceFactory.java | 6 +++ 9 files changed, 169 insertions(+), 16 deletions(-) create mode 100644 odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPATransactionContext.java create mode 100644 odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefaultContext.java diff --git a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAContext.java b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAContext.java index 9a57bf345..899ce244f 100644 --- a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAContext.java +++ b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAContext.java @@ -227,4 +227,9 @@ public interface ODataJPAContext { * @return an instance of type {@link org.apache.olingo.odata2.jpa.processor.api.access.JPAPaging} */ public JPAPaging getPaging(); + + /** + * The transaction context + */ + public ODataJPATransactionContext getODataJpaTransactionContext(); } diff --git a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java index 709a048a9..75cf920ed 100644 --- a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java +++ b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java @@ -81,6 +81,7 @@ public abstract class ODataJPAServiceFactory extends ODataServiceFactory { private ODataContext oDataContext; private boolean setDetailErrors = false; private OnJPAWriteContent onJPAWriteContent = null; + private ODataJPATransactionContext oDataJPATransactionContext = null; /** * Creates an OData Service based on the values set in @@ -201,7 +202,34 @@ public T getCallback(final Class responses = new ArrayList(); try { - oDataJPAContext.getEntityManager().getTransaction().begin(); + oDataJPAContext.getODataJpaTransactionContext().beginTransaction(); for (ODataRequest request : requests) { oDataJPAContext.setODataContext(getContext()); ODataResponse response = handler.handleRequest(request); if (response.getStatus().getStatusCode() >= HttpStatusCodes.BAD_REQUEST.getStatusCode()) { // Rollback - oDataJPAContext.getEntityManager().getTransaction().rollback(); + oDataJPAContext.getODataJpaTransactionContext().rollbackTransaction(); List errorResponses = new ArrayList(1); errorResponses.add(response); return BatchResponsePart.responses(errorResponses).changeSet(false).build(); } responses.add(response); } - oDataJPAContext.getEntityManager().getTransaction().commit(); + oDataJPAContext.getODataJpaTransactionContext().commitTransaction(); + return BatchResponsePart.responses(responses).changeSet(true).build(); } catch (Exception e) { diff --git a/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPALink.java b/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPALink.java index 64bf56cfd..a2fed2056 100644 --- a/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPALink.java +++ b/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPALink.java @@ -44,6 +44,8 @@ import org.apache.olingo.odata2.api.uri.info.PostUriInfo; import org.apache.olingo.odata2.api.uri.info.PutMergePatchUriInfo; import org.apache.olingo.odata2.jpa.processor.api.ODataJPAContext; +import org.apache.olingo.odata2.jpa.processor.api.ODataJPAServiceFactory; +import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransactionContext; import org.apache.olingo.odata2.jpa.processor.api.access.JPAProcessor; import org.apache.olingo.odata2.jpa.processor.api.exception.ODataJPAModelException; import org.apache.olingo.odata2.jpa.processor.api.exception.ODataJPARuntimeException; @@ -149,10 +151,9 @@ public void delete(final DeleteUriInfo uriInfo) throws ODataJPARuntimeException public void save() { EntityManager em = context.getEntityManager(); - EntityTransaction tx = em.getTransaction(); - - if (!tx.isActive()) { - em.getTransaction().begin(); + ODataJPATransactionContext tx = context.getODataJpaTransactionContext(); + if (!tx.transactionIsActive()) { + tx.beginTransaction(); if (sourceJPAEntity != null) { em.persist(sourceJPAEntity); } @@ -160,7 +161,7 @@ public void save() { em.persist(targetJPAEntity); em.flush(); } - em.getTransaction().commit(); + tx.commitTransaction(); } } diff --git a/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPAProcessorImpl.java b/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPAProcessorImpl.java index d926daf3e..f71965890 100644 --- a/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPAProcessorImpl.java +++ b/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPAProcessorImpl.java @@ -26,7 +26,6 @@ import java.util.Map; import javax.persistence.EntityManager; -import javax.persistence.EntityTransaction; import javax.persistence.Query; import org.apache.olingo.odata2.api.commons.InlineCount; @@ -50,6 +49,7 @@ import org.apache.olingo.odata2.jpa.processor.api.ODataJPAContext; import org.apache.olingo.odata2.jpa.processor.api.ODataJPATombstoneContext; import org.apache.olingo.odata2.jpa.processor.api.ODataJPATombstoneEntityListener; +import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransactionContext; import org.apache.olingo.odata2.jpa.processor.api.access.JPAFunction; import org.apache.olingo.odata2.jpa.processor.api.access.JPAMethodContext; import org.apache.olingo.odata2.jpa.processor.api.access.JPAProcessor; @@ -355,7 +355,7 @@ public Object process(DeleteUriInfo uriParserResultView, final String contentTyp em.remove(selectedObject); em.flush(); if (isLocalTransaction) { - em.getTransaction().commit(); + oDataJPAContext.getODataJpaTransactionContext().commitTransaction(); } } catch (Exception e) { @@ -456,7 +456,7 @@ private Object processCreate(final PostUriInfo createView, final InputStream con em.persist(jpaEntity); if (em.contains(jpaEntity)) { if (isLocalTransaction) { - em.getTransaction().commit(); + oDataJPAContext.getODataJpaTransactionContext().commitTransaction(); } return jpaEntity; } @@ -507,7 +507,7 @@ private Object processUpdate(PutMergePatchUriInfo updateView, } em.flush(); if (isLocalTransaction) { - em.getTransaction().commit(); + oDataJPAContext.getODataJpaTransactionContext().commitTransaction(); } } catch (Exception e) { throw ODataJPARuntimeException.throwException( @@ -572,9 +572,9 @@ private List handlePaging(final Query query, final GetEntitySetUriInfo u } private boolean setTransaction() { - final EntityTransaction transaction = em.getTransaction(); - if (!transaction.isActive()) { - em.getTransaction().begin(); + ODataJPATransactionContext transactionContext = oDataJPAContext.getODataJpaTransactionContext(); + if (!transactionContext.transactionIsActive()) { + transactionContext.beginTransaction(); return true; } diff --git a/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefaultContext.java b/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefaultContext.java new file mode 100644 index 000000000..dc26a7d32 --- /dev/null +++ b/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefaultContext.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 + * + * 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. + ******************************************************************************/ +package org.apache.olingo.odata2.jpa.processor.ref.extension; + + +import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransactionContext; + +import javax.persistence.EntityManager; +import javax.persistence.EntityTransaction; + +public class ODataJPATransactionLocalDefaultContext implements ODataJPATransactionContext { + + EntityTransaction tx = null; + + public ODataJPATransactionLocalDefaultContext(EntityManager em) { + this.tx = em.getTransaction(); + } + + @Override + public void beginTransaction() { + tx.begin(); + } + + @Override + public void commitTransaction() { + tx.commit(); + } + + @Override + public void rollbackTransaction() { + tx.rollback(); + } + + @Override + public boolean transactionIsActive() { + return tx.isActive(); + } +} diff --git a/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/web/JPAReferenceServiceFactory.java b/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/web/JPAReferenceServiceFactory.java index 256ffdd50..906223ab8 100644 --- a/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/web/JPAReferenceServiceFactory.java +++ b/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/web/JPAReferenceServiceFactory.java @@ -25,6 +25,7 @@ import org.apache.olingo.odata2.jpa.processor.api.OnJPAWriteContent; import org.apache.olingo.odata2.jpa.processor.api.exception.ODataJPARuntimeException; import org.apache.olingo.odata2.jpa.processor.api.model.JPAEdmExtension; +import org.apache.olingo.odata2.jpa.processor.ref.extension.ODataJPATransactionLocalDefaultContext; import org.apache.olingo.odata2.jpa.processor.ref.extension.OnDBWriteContent; import org.apache.olingo.odata2.jpa.processor.ref.extension.SalesOrderProcessingExtension; import org.apache.olingo.odata2.jpa.processor.ref.factory.JPAEntityManagerFactory; @@ -50,6 +51,11 @@ public ODataJPAContext initializeODataJPAContext() oDataJPAContext.setDefaultNaming(false); setErrorLevel(); setOnWriteJPAContent(onDBWriteContent); + if(getoDataJPATransactionContext() == null) { + setODataJPATransactionContext( + new ODataJPATransactionLocalDefaultContext(getODataJPAContext().getEntityManager())); + } + return oDataJPAContext; } From 28c662bc70000faa0c331c90d50a63f7f21c4c11 Mon Sep 17 00:00:00 2001 From: kbachl Date: Thu, 26 Feb 2015 13:06:03 +0100 Subject: [PATCH 2/3] OLINGO-580 #2 #renaming according to wishes --- .../jpa/processor/api/ODataJPAContext.java | 2 +- .../processor/api/ODataJPAServiceFactory.java | 22 +++++++++---------- ...nContext.java => ODataJPATransaction.java} | 10 ++++----- .../processor/core/ODataJPAContextImpl.java | 6 ++--- .../core/ODataJPAProcessorDefault.java | 7 +++--- .../processor/core/access/data/JPALink.java | 12 +++++----- .../core/access/data/JPAProcessorImpl.java | 14 ++++++------ ...a => ODataJPATransactionLocalDefault.java} | 14 ++++++------ .../ref/web/JPAReferenceServiceFactory.java | 6 ++--- 9 files changed, 45 insertions(+), 48 deletions(-) rename odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/{ODataJPATransactionContext.java => ODataJPATransaction.java} (87%) rename odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/{ODataJPATransactionLocalDefaultContext.java => ODataJPATransactionLocalDefault.java} (81%) diff --git a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAContext.java b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAContext.java index 899ce244f..bcb27fcd0 100644 --- a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAContext.java +++ b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAContext.java @@ -231,5 +231,5 @@ public interface ODataJPAContext { /** * The transaction context */ - public ODataJPATransactionContext getODataJpaTransactionContext(); + public ODataJPATransaction getODataJpaTransactionContext(); } diff --git a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java index 75cf920ed..1fd6c023e 100644 --- a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java +++ b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java @@ -81,7 +81,7 @@ public abstract class ODataJPAServiceFactory extends ODataServiceFactory { private ODataContext oDataContext; private boolean setDetailErrors = false; private OnJPAWriteContent onJPAWriteContent = null; - private ODataJPATransactionContext oDataJPATransactionContext = null; + private ODataJPATransaction oDataJPATransaction = null; /** * Creates an OData Service based on the values set in @@ -203,9 +203,9 @@ public T getCallback(final Class T getCallback(final Class responses = new ArrayList(); try { - oDataJPAContext.getODataJpaTransactionContext().beginTransaction(); + oDataJPAContext.getODataJpaTransactionContext().begin(); for (ODataRequest request : requests) { oDataJPAContext.setODataContext(getContext()); ODataResponse response = handler.handleRequest(request); if (response.getStatus().getStatusCode() >= HttpStatusCodes.BAD_REQUEST.getStatusCode()) { // Rollback - oDataJPAContext.getODataJpaTransactionContext().rollbackTransaction(); + oDataJPAContext.getODataJpaTransactionContext().rollback(); List errorResponses = new ArrayList(1); errorResponses.add(response); return BatchResponsePart.responses(errorResponses).changeSet(false).build(); } responses.add(response); } - oDataJPAContext.getODataJpaTransactionContext().commitTransaction(); + oDataJPAContext.getODataJpaTransactionContext().commit(); return BatchResponsePart.responses(responses).changeSet(true).build(); diff --git a/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPALink.java b/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPALink.java index a2fed2056..54666a4bb 100644 --- a/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPALink.java +++ b/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPALink.java @@ -27,7 +27,6 @@ import java.util.List; import javax.persistence.EntityManager; -import javax.persistence.EntityTransaction; import org.apache.olingo.odata2.api.edm.EdmEntitySet; import org.apache.olingo.odata2.api.edm.EdmException; @@ -44,8 +43,7 @@ import org.apache.olingo.odata2.api.uri.info.PostUriInfo; import org.apache.olingo.odata2.api.uri.info.PutMergePatchUriInfo; import org.apache.olingo.odata2.jpa.processor.api.ODataJPAContext; -import org.apache.olingo.odata2.jpa.processor.api.ODataJPAServiceFactory; -import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransactionContext; +import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransaction; import org.apache.olingo.odata2.jpa.processor.api.access.JPAProcessor; import org.apache.olingo.odata2.jpa.processor.api.exception.ODataJPAModelException; import org.apache.olingo.odata2.jpa.processor.api.exception.ODataJPARuntimeException; @@ -151,9 +149,9 @@ public void delete(final DeleteUriInfo uriInfo) throws ODataJPARuntimeException public void save() { EntityManager em = context.getEntityManager(); - ODataJPATransactionContext tx = context.getODataJpaTransactionContext(); - if (!tx.transactionIsActive()) { - tx.beginTransaction(); + ODataJPATransaction tx = context.getODataJpaTransactionContext(); + if (!tx.isActive()) { + tx.begin(); if (sourceJPAEntity != null) { em.persist(sourceJPAEntity); } @@ -161,7 +159,7 @@ public void save() { em.persist(targetJPAEntity); em.flush(); } - tx.commitTransaction(); + tx.commit(); } } diff --git a/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPAProcessorImpl.java b/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPAProcessorImpl.java index f71965890..f478b00a0 100644 --- a/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPAProcessorImpl.java +++ b/odata2-jpa-processor/jpa-core/src/main/java/org/apache/olingo/odata2/jpa/processor/core/access/data/JPAProcessorImpl.java @@ -49,7 +49,7 @@ import org.apache.olingo.odata2.jpa.processor.api.ODataJPAContext; import org.apache.olingo.odata2.jpa.processor.api.ODataJPATombstoneContext; import org.apache.olingo.odata2.jpa.processor.api.ODataJPATombstoneEntityListener; -import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransactionContext; +import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransaction; import org.apache.olingo.odata2.jpa.processor.api.access.JPAFunction; import org.apache.olingo.odata2.jpa.processor.api.access.JPAMethodContext; import org.apache.olingo.odata2.jpa.processor.api.access.JPAProcessor; @@ -355,7 +355,7 @@ public Object process(DeleteUriInfo uriParserResultView, final String contentTyp em.remove(selectedObject); em.flush(); if (isLocalTransaction) { - oDataJPAContext.getODataJpaTransactionContext().commitTransaction(); + oDataJPAContext.getODataJpaTransactionContext().commit(); } } catch (Exception e) { @@ -456,7 +456,7 @@ private Object processCreate(final PostUriInfo createView, final InputStream con em.persist(jpaEntity); if (em.contains(jpaEntity)) { if (isLocalTransaction) { - oDataJPAContext.getODataJpaTransactionContext().commitTransaction(); + oDataJPAContext.getODataJpaTransactionContext().commit(); } return jpaEntity; } @@ -507,7 +507,7 @@ private Object processUpdate(PutMergePatchUriInfo updateView, } em.flush(); if (isLocalTransaction) { - oDataJPAContext.getODataJpaTransactionContext().commitTransaction(); + oDataJPAContext.getODataJpaTransactionContext().commit(); } } catch (Exception e) { throw ODataJPARuntimeException.throwException( @@ -572,9 +572,9 @@ private List handlePaging(final Query query, final GetEntitySetUriInfo u } private boolean setTransaction() { - ODataJPATransactionContext transactionContext = oDataJPAContext.getODataJpaTransactionContext(); - if (!transactionContext.transactionIsActive()) { - transactionContext.beginTransaction(); + ODataJPATransaction transactionContext = oDataJPAContext.getODataJpaTransactionContext(); + if (!transactionContext.isActive()) { + transactionContext.begin(); return true; } diff --git a/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefaultContext.java b/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefault.java similarity index 81% rename from odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefaultContext.java rename to odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefault.java index dc26a7d32..3ee63b79f 100644 --- a/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefaultContext.java +++ b/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/extension/ODataJPATransactionLocalDefault.java @@ -19,36 +19,36 @@ package org.apache.olingo.odata2.jpa.processor.ref.extension; -import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransactionContext; +import org.apache.olingo.odata2.jpa.processor.api.ODataJPATransaction; import javax.persistence.EntityManager; import javax.persistence.EntityTransaction; -public class ODataJPATransactionLocalDefaultContext implements ODataJPATransactionContext { +public class ODataJPATransactionLocalDefault implements ODataJPATransaction { EntityTransaction tx = null; - public ODataJPATransactionLocalDefaultContext(EntityManager em) { + public ODataJPATransactionLocalDefault(EntityManager em) { this.tx = em.getTransaction(); } @Override - public void beginTransaction() { + public void begin() { tx.begin(); } @Override - public void commitTransaction() { + public void commit() { tx.commit(); } @Override - public void rollbackTransaction() { + public void rollback() { tx.rollback(); } @Override - public boolean transactionIsActive() { + public boolean isActive() { return tx.isActive(); } } diff --git a/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/web/JPAReferenceServiceFactory.java b/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/web/JPAReferenceServiceFactory.java index 906223ab8..c1584dc53 100644 --- a/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/web/JPAReferenceServiceFactory.java +++ b/odata2-jpa-processor/jpa-web/src/main/java/org/apache/olingo/odata2/jpa/processor/ref/web/JPAReferenceServiceFactory.java @@ -25,7 +25,7 @@ import org.apache.olingo.odata2.jpa.processor.api.OnJPAWriteContent; import org.apache.olingo.odata2.jpa.processor.api.exception.ODataJPARuntimeException; import org.apache.olingo.odata2.jpa.processor.api.model.JPAEdmExtension; -import org.apache.olingo.odata2.jpa.processor.ref.extension.ODataJPATransactionLocalDefaultContext; +import org.apache.olingo.odata2.jpa.processor.ref.extension.ODataJPATransactionLocalDefault; import org.apache.olingo.odata2.jpa.processor.ref.extension.OnDBWriteContent; import org.apache.olingo.odata2.jpa.processor.ref.extension.SalesOrderProcessingExtension; import org.apache.olingo.odata2.jpa.processor.ref.factory.JPAEntityManagerFactory; @@ -51,9 +51,9 @@ public ODataJPAContext initializeODataJPAContext() oDataJPAContext.setDefaultNaming(false); setErrorLevel(); setOnWriteJPAContent(onDBWriteContent); - if(getoDataJPATransactionContext() == null) { + if(getoDataJPATransaction() == null) { setODataJPATransactionContext( - new ODataJPATransactionLocalDefaultContext(getODataJPAContext().getEntityManager())); + new ODataJPATransactionLocalDefault(getODataJPAContext().getEntityManager())); } From 7418c39724e098720bccf9d134f86de0af113b25 Mon Sep 17 00:00:00 2001 From: kbachl Date: Thu, 26 Feb 2015 13:11:22 +0100 Subject: [PATCH 3/3] OLINGO-580 #3 #renaming according to wishes - little one missed --- .../odata2/jpa/processor/api/ODataJPAServiceFactory.java | 4 ++-- .../jpa/processor/ref/web/JPAReferenceServiceFactory.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java index 1fd6c023e..900ea1494 100644 --- a/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java +++ b/odata2-jpa-processor/jpa-api/src/main/java/org/apache/olingo/odata2/jpa/processor/api/ODataJPAServiceFactory.java @@ -218,9 +218,9 @@ public T getCallback(final Class