交易在碼頭不堅持時間

Question

我繼承了一些代碼，當試圖添加一些功能時，不適合我。我不是Java網絡的專家，所以如果我需要任何額外的手持功能來爲您提供所需的信息，我很抱歉。

我正在開發一個GWT應用程序，它在後端使用Hibernate和Guice-Persist來堅持MySQL。不幸的是，我遇到了一個奇怪的問題，在這個問題中 - 在一臺服務器上 - put事務沒有及時保存到數據庫中，以便後續的get事務處理。 在任何版本的Jetty中嵌入GWT Eclipse插件（可能是6.1.11？）在Windows和Linux中的Tomcat6中都能正常工作，但是當我嘗試在Linux中使用jetty-maven-plugin版本8.1.0（也在8.1.5中只有兩個版本我試過），我遇到這個問題，交易沒有及時完成。（或者，我會很高興能找到一個解決方案，讓我可以在Maven中使用除Jetty以外的其他方法正確運行我的集成測試，從而避免了這個問題。已經嘗試過）。

下面是我用堅持一個對象的代碼：

public T put(T entity) { 
    EntityManager entityManager = entityManager(); 
    EntityTransaction transaction = entityManager.getTransaction();   
    transaction.begin(); 
    try { 
     entity = entityManager.merge(entity); 
     entityManager.persist(entity); 
     transaction.commit(); 

    } catch (Exception e) { 
     //do exception handling, including rollback 
    } 


    return entity; 
} 

的GET代碼：

public List<T> getAll() { 
    Query query = entityManager().createQuery("select c from " + clazz.getSimpleName() + " c"); 

    return (List<T>) query.getResultList(); 
} 

同樣，發生的事情是我做的（間接）調用getAll()以允許客戶端查看數據。然後，如果他們做出選擇，請從客戶端撥打電話put。然後，一旦我收到回覆，撥打getAll()即可更新顯示給用戶的數據。不幸的是，我從數據庫中得到的數據並不反映更新的數據，而是數據，因爲它存在於put()調用之前。數據庫最終會更新，當我自己檢查數據庫時，它似乎會立即更新。如果我重新加載數據幾次，Web應用程序也將最終更新以顯示正確的數據。所以我懷疑有些緩存層可能會響應我的getAll()請求而沒有真正檢查數據庫，但我真的不知道如何繼續 - Transactions和EntityManagers對我來說是相當新的。

我試過flush() ing和close() ing我的實體管理器，而不是提交我的交易，並沒有任何行爲改變。

我注射在構造函數中我的EntityManager提供者：

private final Class<T> clazz; 
private final Provider<EntityManager> entityManagerProvider; 

public BaseDao(final Class<T> clazz, final Provider<EntityManager> entityManagerProvider) { 
    this.clazz = clazz; 
    this.entityManagerProvider = entityManagerProvider; 
} 

，卻得到了實體管理器，像這樣：

protected EntityManager entityManager() { 
    return entityManagerProvider.get(); 
} 

謝謝！

爲後人的緣故，這裏是我的GuiceServletContextListener：

public class GuiceServletConfig extends GuiceServletContextListener { 
@Override 
protected Injector getInjector() { 
    DispatchServletModule dispatchServletModule = new DispatchServletModule(); 
    Injector injector = Guice.createInjector(new ServerModule(), new JpaPersistModule(getPersistenceUnit()), 
      dispatchServletModule); 

    PersistService persistService = injector.getInstance(PersistService.class); 
    persistService.start(); 

    BootStrapper bootStrapper = injector.getInstance(BootStrapper.class); 
    bootStrapper.init(); 



    return injector; 
} 

private String getPersistenceUnit() { 
    InputStream inputStream = getClass().getResourceAsStream("/database.properties"); 

    if (inputStream == null) { 
     throw new RuntimeException(); 
    } 

    try { 
     Properties properties = new Properties(); 
     properties.load(inputStream); 

     return properties.getProperty("persistenceUnit"); 
    } catch (IOException e) { 
     throw new RuntimeException(e); 
    } 
} 


} 

而且我的servlet：

public class DispatchServletModule extends ServletModule {  
    @Override 
    public void configureServlets() { 
    serve("/" + ActionImpl.DEFAULT_SERVICE_NAME + "*").with(DispatchServiceImpl.class); 
    } 
} 

我嘗試添加在configureServlets過濾器（），而在手動啓動的持續性會話嘗試使用session-per-http請求（每this page），但沒有運氣。

Answer 1

首先，您應該回滾catch塊中的交易，而不是忽略異常（至少記錄它）。但guice-persist支持@Transactional註釋，所以實際上你根本不需要手動進行事務管理。見Transactions - google-guice。

Answer 2

您是否希望關閉與交易相關的會話？

public T put(T entity) { 
    EntityManager entityManager = entityManager(); 
    EntityTransaction transaction = entityManager.getTransaction();   
    transaction.begin(); 
    try { 
     entity = entityManager.merge(entity); 
     entityManager.persist(entity); 
     transaction.commit(); 

    } catch (Exception e) { 
     //do exception handling, including rollback 
    } finally { 
     entityManager.close(); 
    } 

    return entity; 
} 

但你可以強制交易與沖洗同步：

public T put(T entity) { 
    EntityManager entityManager = entityManager(); 
    EntityTransaction transaction = entityManager.getTransaction();   
    transaction.begin(); 
    try { 
     entity = entityManager.merge(entity); 
     entityManager.persist(entity); 
     entityManager.flush(); 
     transaction.commit(); 

    } catch (Exception e) { 
     //do exception handling, including rollback 
    } 

    return entity; 
} 

問候，