import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
public void putCollections(LinkedHashMap<String, List<EpisodeBaseModel>> collections) {
    Log.d(TAG, "store collections into db");
    int i = 0;
    FlowQueryList<EpisodeBaseModel> query = new FlowQueryList<>(EpisodeBaseModel.class);
    query.beginTransaction();
    for (Map.Entry<String, List<EpisodeBaseModel>> collection : collections.entrySet()) {
        Log.d(TAG, "Adding collection: " + collection.getKey() + " => " + collection.getValue().size());
        updateProgress("Loading " + collection.getKey() + "...");
        for (EpisodeBaseModel ep : collection.getValue()) {
            EpisodeBaseModel model = new EpisodeBaseModel();
            model.merge(ep);
            model.DATA_TYPE = TYPE_COLLECTIONS;
            model.DATA_COLLECTION_KEY = collection.getKey();
            model.DATA_COLLECTION_INDEX = i++;
            model.save();
        }
    }
    query.endTransactionAndNotify();
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@Override
public Subscriber<? super FlowQueryList<TModel>> call(final Subscriber<? super FlowQueryList<TModel>> subscriber) {
    return new Subscriber<FlowQueryList<TModel>>() {
        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onNext(FlowQueryList<TModel> tModels) {
            for (int i = 0; i < mSubscribedClasses.size(); i++) {
                mFlowContentObserver.registerForContentChanges(FlowManager.getContext(), mSubscribedClasses.get(i));
            }
            mFlowContentObserver.addOnTableChangedListener(
                    new FlowContentObserver.OnTableChangedListener() {
                        @Override
                        public void onTableChanged(@Nullable Class<?> tableChanged, BaseModel.Action action) {

                            if (subscriber.isUnsubscribed()) {
                                mFlowContentObserver.unregisterForContentChanges(FlowManager.getContext());
                            } else {
                                subscriber.onNext(mBaseModelQueriable.flowQueryList());
                            }
                        }
                    });
            subscriber.onNext(tModels);
        }
    };

}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@Override
public void provideProvinces(final AddressReceiver<Province> addressReceiver) {
    final FlowQueryList<Province> provinceQueryList = SQLite.select()
            .from(Province.class)
            .flowQueryList();
    addressReceiver.send(new ArrayList<>(provinceQueryList));
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@Override
public void provideCitiesWith(int provinceId, final AddressReceiver<City> addressReceiver) {
    final FlowQueryList<City> cityQueryList = SQLite.select()
            .from(City.class)
            .where(City_Table.province_id.eq(provinceId))
            .flowQueryList();
    addressReceiver.send(new ArrayList<>(cityQueryList));
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@Override
public void provideCountiesWith(int cityId, final AddressReceiver<County> addressReceiver) {
    final FlowQueryList<County> countyQueryList = SQLite.select()
            .from(County.class)
            .where(County_Table.city_id.eq(cityId))
            .flowQueryList();
    addressReceiver.send(new ArrayList<>(countyQueryList));
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@Override
public void provideStreetsWith(int countyId, final AddressReceiver<Street> addressReceiver) {
    final FlowQueryList<Street> streetQueryList = SQLite.select()
            .from(Street.class)
            .where(Street_Table.county_id.eq(countyId))
            .flowQueryList();
    addressReceiver.send(new ArrayList<>(streetQueryList));
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
public void putShows(Collection<EpisodeBaseModel> shows) {
    Log.d(TAG, "store shows into db");
    FlowQueryList<EpisodeBaseModel> query = new FlowQueryList<>(EpisodeBaseModel.class);
    query.beginTransaction();
    for (EpisodeBaseModel ep : shows) {
        EpisodeBaseModel model = new EpisodeBaseModel();
        model.merge(ep);
        model.DATA_TYPE = TYPE_EPISODES;
        model.save();
    }
    query.endTransactionAndNotify();
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
public void putEpisodes(Collection<EpisodeBaseModel> episodes) {
    Log.d(TAG, "store episodes into db");
    FlowQueryList<EpisodeBaseModel> query = new FlowQueryList<>(EpisodeBaseModel.class);
    query.beginTransaction();
    for (EpisodeBaseModel ep : episodes) {
        EpisodeBaseModel model = new EpisodeBaseModel();
        model.merge(ep);
        model.DATA_TYPE = TYPE_SHOWS;
        model.save();
    }
    query.endTransactionAndNotify();
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
/**
 * 查询已下载或已发送纪录
 *
 * @param type 类型，{@link #TYPE_RECEIVED},{@link #TYPE_SENT}
 * @return 列表
 */
public static FlowQueryList<TransferRecord> query(int type) {

    return SQLite.select()
            .distinct()
            .from(TransferRecord.class)
            .where(TransferRecord_Table.type.eq(type))
            .orderBy(TransferRecord_Table.timestamp, false)
            .groupBy(TransferRecord_Table.uri, TransferRecord_Table.size)
            .flowQueryList();
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@NonNull
@Override
public FlowQueryList<TModel> flowQueryList() {
    return new FlowQueryList.Builder<>(getTable())
            .cacheModels(cachingEnabled)
            .modelQueriable(this)
            .build();
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@NonNull
@Override
public Single<FlowQueryList<T>> flowQueryList() {
    return fromCallable(new Callable<FlowQueryList<T>>() {
        @Override
        public FlowQueryList<T> call() throws Exception {
            return getInnerModelQueriable().flowQueryList();
        }
    });
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@Override
public DBFlowSingle<FlowQueryList<TModel>> asQueryListSingle() {
    return new DBFlowQueryListSingle<>(mRealModelQueriable.getTable(), mRealModelQueriable);
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
@Override
public FlowQueryList<TModel> run() {
    return mBaseModelQueriable.flowQueryList();
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public Observable<FlowQueryList<TModel>> asQueryListObservable() {
    return new DBFlowQueryListObservable<>(mRealModelQueriable.getTable(), mRealModelQueriable);
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
public void clearCache() {
    Log.d(TAG, "Clear db");
    FlowQueryList<EpisodeBaseModel> query = new FlowQueryList<>(EpisodeBaseModel.class);
    query.clear();
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
/**
 * Creates an Single that emits the results of a query as a FlowQueryList.
 *
 * @return An Single that emits a FlowQueryList
 */
DBFlowSingle<FlowQueryList<TModel>> asQueryListSingle();
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
/**
 * Creates an observable that emits the results of a query as a FlowQueryList.
 *
 * @return An observable that emits a FlowQueryList
 */
Observable<FlowQueryList<TModel>> asQueryListObservable();
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
/**
 * Observes changes on the current table, restarting the query on change and emits the updated
 * query results to any subscribers
 * @return An observable which observes any changes in the current table
 */
public Observable<FlowQueryList<TModel>> restartOnChange(){
    mSubscribedClasses.add(mModelClazz);
    return lift(new DBFlowOnChangeOperator());
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
/**
 * Forces onComplete to be called upon returning with a result, therefore automatically
 * unsubscribing the subscription. This should be used when you're only interested in a
 * single result i.e. not using {@link #restartOnChange()} or {@link #restartOnChange(Class[])}.
 * If this is not used, the subscriber will be responsible for unsubscribing
 * @return An observable which will call onComplete once the result has returned.
 */
public Observable<FlowQueryList<TModel>> completeOnResult(){
    return lift(new CompleteOnResultOperator<FlowQueryList<TModel>>());
}
 

import com.raizlabs.android.dbflow.list.FlowQueryList; //导入依赖的package包/类
/**
 * @return A cursor-backed {@link List} that handles conversion, retrieval, caching, content changes,
 * and more.
 */
@NonNull
FlowQueryList<TModel> flowQueryList();