litesoft
@ 947
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 |
// This Source Code is in the Public Domain per: http://unlicense.org package org.litesoft.bo.views; import org.litesoft.bo.views.caching.*; import org.litesoft.bo.views.communication.*; public abstract class TypedVoDataProvider<T extends IViewObject> extends VoDataProvider<T> implements CacheInvalidCallBack { protected TypedVoDataProvider( VoMetaData<T> pMetaData ) { super( pMetaData ); } protected CScomm getCScomm() { checkOnPolling(); return CScomm.getInstance(); } @Override public void requestTemporalTriggerPoll() { getCScomm().requestTemporalTriggerPoll(); } @Override public void requestRow( ObjectURL pObjectURL, FetchRowDataProviderCallBack<T> pCallBack ) { requestRow( null, pObjectURL, pCallBack ); } protected void requestRow( CacheID pCacheID, ObjectURL pObjectURL, FetchRowDataProviderCallBack<T> pCallBack ) { getCScomm().requestRowByObjectURL( this, pCacheID, new VOCSrequestRowByObjectURL( getForViewObjectRegisteredName(), pObjectURL ), pCallBack ); } @Override public void requestRows( ObjectURL[] pObjectURLs, FetchRowsDataProviderCallBack<T> pCallBack ) { requestRows( null, pObjectURLs, pCallBack ); } protected void requestRows( CacheID pCacheID, ObjectURL[] pObjectURLs, FetchRowsDataProviderCallBack<T> pCallBack ) { getCScomm().requestRowsByObjectURLs( this, pCacheID, new VOCSrequestRowsByObjectURLs( getForViewObjectRegisteredName(), pObjectURLs ), pCallBack ); } @Override public void requestRows( BoAccessorFilters pFilters, FetchRowsDataProviderCallBack<T> pCallBack ) { requestRows( null, pFilters, pCallBack ); } protected void requestRows( CacheID pCacheID, BoAccessorFilters pFilters, Integer pMaxToReturn, FetchRowsDataProviderCallBack<T> pCallBack ) { getCScomm().requestRowsByFilters( this, pCacheID, new VOCSrequestRowsByFilters( getForViewObjectRegisteredName(), pFilters, pMaxToReturn ), pCallBack ); } protected void requestRows( CacheID pCacheID, BoAccessorFilters pFilters, FetchRowsDataProviderCallBack<T> pCallBack ) { requestRows( pCacheID, pFilters, getMaxRowsToFetch(), pCallBack ); } protected Integer getMaxRowsToFetch() { return 100; } @Override public void requestAllRows( FetchRowsDataProviderCallBack<T> pCallBack ) { requestRows( null, (BoAccessorFilters) null, pCallBack ); } @Override public void commit( TransactionSet pTransactionSet, CommitCallBack<T> pCallBack, ObjectURL... pReturnOnSuccess ) { commit( null, pTransactionSet, pCallBack, pReturnOnSuccess ); } protected void commit( CacheID pCacheID, TransactionSet pTransactionSet, CommitCallBack<T> pCallBack, ObjectURL... pReturnOnSuccess ) { getCScomm().requestCommit( this, pCacheID, new VOCSrequestCommit( getForViewObjectRegisteredName(), pTransactionSet, pReturnOnSuccess ), pCallBack ); } @Override protected String getForViewObjectRegisteredName() { return mMetaData.getViewObjectClass().getName(); } } |