add read method in DB layer to get favourite workflow
Project: http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/commit/c4698a80 Tree: http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/tree/c4698a80 Diff: http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/diff/c4698a80 Branch: refs/heads/master Commit: c4698a8072df5860e085b77932e477cbddaea89e Parents: 1e66e3b Author: Sagar <[email protected]> Authored: Sat Jul 9 23:25:54 2016 +0530 Committer: Sagar <[email protected]> Committed: Sat Jul 9 23:25:54 2016 +0530 ---------------------------------------------------------------------- .../taverna/mobile/data/local/DBHelper.java | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/blob/c4698a80/app/src/main/java/org/apache/taverna/mobile/data/local/DBHelper.java ---------------------------------------------------------------------- diff --git a/app/src/main/java/org/apache/taverna/mobile/data/local/DBHelper.java b/app/src/main/java/org/apache/taverna/mobile/data/local/DBHelper.java index ee27a3f..f81f88e 100644 --- a/app/src/main/java/org/apache/taverna/mobile/data/local/DBHelper.java +++ b/app/src/main/java/org/apache/taverna/mobile/data/local/DBHelper.java @@ -27,6 +27,8 @@ import org.apache.taverna.mobile.data.model.Workflows; import android.support.annotation.Nullable; +import java.util.List; + import rx.Observable; import rx.Subscriber; @@ -184,6 +186,24 @@ public class DBHelper { return false; } + public Observable<List<Workflow>> getFavouriteWorkflow() { + return Observable.create(new Observable.OnSubscribe<List<Workflow>>() { + @Override + public void call(Subscriber<? super List<Workflow>> subscriber) { + if (subscriber.isUnsubscribed()) return; + List<Workflow> workflows = SQLite.select() + .from(Workflow.class) + .where(Workflow_Table.favourite.eq(true)) + .queryList(); + + subscriber.onNext(workflows); + subscriber.onCompleted(); + + } + }); + + } + }
