App-Engine JDO nhất quán đọc không hoạt động, có thể bộ nhớ đệm?

Question

Hôm nay, đây là lần đầu tiên tôi sử dụng GWT và JDO. Tôi đang chạy nó với Eclipse trong chế độ gỡ lỗi cục bộ.

tôi làm những điều sau đây:

public Collection<MyObject> add(MyObject o) { 
PersistenceManager pm = PMF.get().getPersistenceManager(); 
try { 
    pm.makePersistent(o); 
    Query query = pm.newQuery(MyObject.class);// fetch all objects incl. o. But o only sometimes comes... 
List<MyObject> rs = (List<MyObject>) query.execute(); 
ArrayList<MyObject> list= new ArrayList<MyObject>(); 
for (MyObject r : rs) { 
    list.add(r); 
} 
return list; 
} finally { 
    pm.close(); 
} 
} 

tôi đã thiết lập <property name="datanucleus.appengine.datastoreReadConsistency" value="STRONG" /> trong jdoconfig.xml tôi. Tôi có phải đặt một số giao dịch khác trong cấu hình không? Có ai đó đã làm việc jdoconfig.xml? Hay là vấn đề ở đâu đó khác? Một số bộ nhớ đệm inbetween?

EDIT: Những điều tôi đã cố gắng:

• Thiết NontransactionalRead/Viết false
• Sử dụng cùng/A khác nhau PersistenceManager dù gọi PMF.get().getPersistenceManager() nhiều lần
• Sử dụng giao dịch
• ignoreCache = đúng trên PersistenceManager
• gọi flush và checkConsistency

Các jdoconfig:

<persistence-manager-factory name="transactions-optional"> 
<property name="datanucleus.appengine.datastoreReadConsistency" value="STRONG" /> 
    <property name="javax.jdo.PersistenceManagerFactoryClass" 
     value="org.datanucleus.store.appengine.jdo.DatastoreJDOPersistenceManagerFactory"/> 
    <property name="javax.jdo.option.ConnectionURL" value="appengine"/> 
    <property name="javax.jdo.option.NontransactionalRead" value="true"/> 
    <property name="javax.jdo.option.NontransactionalWrite" value="true"/> 
    <property name="javax.jdo.option.RetainValues" value="true"/> 
    <property name="datanucleus.appengine.autoCreateDatastoreTxns" value="true"/> 
</persistence-manager-factory> 

tôi phải mất một cái gì đó trung tâm ở đây bởi vì tất cả các cách tiếp cận thất bại ...

EDIT2: Khi tôi chia công việc thành hai giao dịch các bản ghi nói rằng giao dịch ghi được đánh bắt và sau đó giao dịch đọc bắt đầu. Nhưng nó không tìm thấy đối tượng vừa bị thuyết phục. Nó luôn luôn nói Level 1 Cache of type "weak" initialised là tốt. Tuần xấu hay tốt?

Có khoảng 30% yêu cầu bị lỗi ... Tôi có thể gặp vấn đề tải truy vấn lười biếng không?

Answer 1

Franz, tính nhất quán đọc mặc định trong Cấu hình JDO là STRONG. vì vậy nếu bạn đang cố gắng tiếp cận nó theo hướng đó, nó sẽ không dẫn bạn đến bất cứ đâu

Kiểm tra điều này vì tôi nghĩ nó đề cập đến một điều gì đó tương tự như kịch bản bạn đang gặp phải, với dữ liệu đã cam kết không được trả về trong truy vấn. Nó không đồng thời như đã đề cập, nhưng nó giải thích quy trình cam kết.

http://code.google.com/appengine/articles/transaction_isolation.html

Ngoài ra, cách tiếp cận khác sẽ được truy vấn sử dụng Extents và tìm hiểu xem có thể giải quyết các trường hợp sử dụng cụ thể bạn đang nhìn vào, kể từ khi tôi tin rằng bạn đang kéo ra tất cả các bản ghi trong bảng.

EDIT:

Vì trong đoạn mã mà bạn đã đề cập, nó sẽ truy vấn toàn bộ bảng. Và nếu đó là những gì bạn cần, bạn có thể sử dụng một Mức độ ... Cách sử dụng nó là bằng cách gọi

Extent ext = getExtent(<Entity Class name>)

trên đối tượng singleton persistenceManager. Sau đó, bạn có thể lặp lại thông qua các tài liệu Extent

Kiểm tra tài liệu và tìm kiếm các phần Mở rộng trên trang tại đây. http://code.google.com/appengine/docs/java/datastore/jdo/queries.html

Answer 2

Gọi phương thức makePersistent() không ghi vào kho dữ liệu; đóng PersistenceManager hoặc cam kết thay đổi của bạn. Vì bạn chưa thực hiện điều này khi bạn chạy truy vấn của mình, bạn sẽ nhận được tất cả các đối tượng từ kho dữ liệu mà chưa có, bao gồm đối tượng mà bạn vừa gọi là makePersistent.

Đọc về trạng thái đối tượng ở đây: http://db.apache.org/jdo/state_transition.html

Có hai cách này, bạn có thể đặt bên trong một giao dịch kể từ khi cam kết ghi vào kho dữ liệu (lưu ý GAE loại giới hạn/tổ chức 5 giao dịch về giao dịch) và cam kết trước khi chạy truy vấn của bạn; Ví dụ sử dụng giao dịch ...

public Collection<MyObject> add(MyObject o) { 
    PersistenceManager pm = PMF.get().getPersistenceManager(); 
    ArrayList<MyObject> list = null; 
    try { 
     Transaction tx=pm.currentTransaction(); 
     try { 
      tx.begin(); 
      pm.makePersistent(o); 
      tx.commit(); 
     } finally { 
      if (tx.isActive()) { 
       tx.rollback(); 
      } 
     } 

     Query query = pm.newQuery(MyObject.class); 
     List<MyObject> rs = (List<MyObject>) query.execute(); 
     ArrayList<MyObject> list = new ArrayList<MyObject>(); 
     for (MyObject r : rs) { 
      list.add(r); 
     } 
    } finally { 
     pm.close(); 
    } 

    return list; 
} 

hoặc bạn thể đóng người quản lý kiên trì sau khi gọi makePersistent trên o và rồi mở một số khác để chạy truy vấn của bạn trên.

// Note that this only works assuming the makePersistent call is successful 
public Collection<MyObject> add(MyObject o) { 
    PersistenceManager pm = PMF.get().getPersistenceManager(); 
    try { 
     pm.makePersistent(o); 
    } finally { 
     pm.close(); 
    } 

    pm = PMF.get().getPersistenceManager(); 
    ArrayList<MyObject> list = null; 
    try { 

     Query query = pm.newQuery(MyObject.class); 
     List<MyObject> rs = (List<MyObject>) query.execute(); 
     list= new ArrayList<MyObject>(); 
     for (MyObject r : rs) { 
      list.add(r); 
     } 

    } finally { 
     pm.close(); 
    } 

    return list; 
} 

LƯU Ý: tôi ban đầu cho biết bạn chỉ có thể thêm o vào danh sách kết quả trước khi trở về; nhưng đó không phải là một điều thông minh để làm vì trong trường hợp có một vấn đề bằng văn bản o đến kho dữ liệu; sau đó danh sách trả về sẽ không phản ánh dữ liệu thực tế trong kho dữ liệu.Làm những gì tôi có (cam kết một giao dịch hoặc đóng cửa pm và sau đó nhận được một cái khác) nên làm việc kể từ khi bạn có datastoreReadPolicy của bạn thiết lập để STRONG.

Answer 3

Tôi gặp phải vấn đề tương tự và điều này không hữu ích. Vì nó có vẻ là kết quả hàng đầu trên Google về "tính nhất quán của công cụ ứng dụng jdo trong nhật thực", tôi nghĩ rằng tôi sẽ chia sẻ bản sửa lỗi cho tôi!

Hóa ra tôi đã sử dụng nhiều phiên bản PersistenceManagerFactory dẫn đến một số hành vi kỳ quái. Việc sửa chữa là để có một singleton rằng mỗi phần của mã truy cập. Đây là thực tế documented correctly trên hướng dẫn GAE nhưng tôi nghĩ rằng tầm quan trọng của nó là understated.

Bắt một PersistenceManager Instance

Một ứng dụng tương tác với JDO sử dụng một thể hiện của lớp PersistenceManager . Bạn nhận được cá thể này bằng cách khởi tạo và gọi phương thức trên một cá thể của lớp PersistenceManagerFactory. Nhà máy sử dụng cấu hình JDO để tạo các cá thể PersistenceManager.

Vì một cá thể PersistenceManagerFactory cần thời gian để khởi tạo, một ứng dụng sẽ sử dụng lại một cá thể duy nhất. Một cách dễ dàng để quản lý các dụ PersistenceManagerFactory là tạo ra một singleton lớp wrapper với một trường hợp tĩnh, như sau:

PMF.java

import javax.jdo.JDOHelper; 
import javax.jdo.PersistenceManagerFactory; 

    public final class PMF { 
     private static final PersistenceManagerFactory pmfInstance = 
      JDOHelper.getPersistenceManagerFactory("transactions-optional"); 

     private PMF() {} 

     public static PersistenceManagerFactory get() { 
      return pmfInstance; 
     } 
    }