Realm and Threading

#java #android #многопоточность #realm #realm_android

Пишу проект. В качестве БД использую Realm. Это первый опыт с этой бд, поэтому за
вопрос прошу не линчевать.
Итак, к примеру, в качестве модели бд есть класс (все упрощенно, так как хочу передать
суть вопроса как можно яснее):

public class QuoteText extends RealmObject {
    private long id;
    private String quoteText;
    ...
}


Для изолирования слоя работы с этой бд я решила применить обобщенный вариант паттерна
Repository. Написала интерфейс:

public interface QuoteRepository {
    List getListOfQuoteText();
}


И класс, реализующий этот интерфейс:

public class QuoteDataRepository implements QuoteRepository {
    private final Realm realm;  
    @Override
    public List getListOfQuoteText() {
        return realm.where(QuoteText.class).findAll();
    }
}


Соответственно во фрагменте для получения списка QuoteText из бд:

QuoteDataRepository quoteDataRepository = new QuoteDataRepository();
List quoteTexts = quoteDataRepository.getListOfQuoteText();


Все бы ничего, но хотелось бы все эти запросы делать не в UI потоке. Как засунуть
это все в другой поток? (Особенно интересно: можно ли совместить способы асинхронных
запросов предлагаемые Realm (назнчаение слушателей, или запрос с использованием onSuccess(),
onError() и прочее) и изоляцию слоя работы с бд). 

Спасибо за помощь!

Правка: важен момент именно абстракции кода работы с бд и реализации асинхронных
запросов.
    

Ответы

Ответ 1

Красивее всего получится если вы будете соединять Realm + RxJava + Retrolambda.

Например вот такое может получиться:

public Observable> getFeedVkPostsSortedAsync(String field, Sort order) {
    return mRealm.where(VkPost.class)
            .equalTo(VkPost.FIELD_IS_IN_FEED, true)
            .equalTo(VkPost.FIELD_IS_IN_FAVORITES, true)
            .findAllSortedAsync(field, order)
            .asObservable()
            .filter(RealmResults::isLoaded)
            .filter(RealmResults::isValid)
            //опционально и на всякий случай отвязываем объекты от реалма и
            //возвращаем обычные объекты в обычном листе
            .flatMap(realmResults -> Observable.just(mRealm.copyFromRealm(realmResults)));
}


Данный Observable, запущенный из основного потока выполнит запрос в БД асинхронно,
отсеет объекты не удовлетворяющие двум условиям значений полей объектов (VkPost.FIELD_IS_IN_FEED,
VkPost.FIELD_IS_IN_FAVORITES) и проверит что объекты возвращаемые полностью готовы
для использования. И будет эмитить новую выборку при каждом изменении в ней.


Ответ 2

У Realm есть возможность создавать асинхронные запросы. Для этого нужно вместо findAll()
вызывать findAllAsync().

Поправлю Ваш интерфейс, потому что оба этих метода возвращают не List, а RealmResults
- это объект стандарта Future:

public interface QuoteRepository {
    RealmResults getListOfQuoteTextAsync();
}


Для того, чтобы получить уведомление об окончании загрузки нужно добавить подписку
на экземпляр RealmResults:

RealmResults result = quoteDataRepository.getListOfQuoteTextAsync();
result.addChangeListener(new RealmChangeListener() {
    @Override
    public void onChange(RealmResults results) {
        // метод будет вызван, когда запрос будет выполнен или при обновлении данных
    }
});


Помимо этого, можно убедиться в завершении загрузки вызвав метод isLoaded():

if (result.isLoaded()) {
    // данные загружены
}


Получение результата

Для работы с результатами запросов (в том числе асинхронными) Realm предоставляет
специализированные адаптеры, которые нужно добавить в зависимости в build.gradle:

dependencies {
    compile 'io.realm:android-adapters:1.4.0'
}


После этого нужно создать наследника от RealmRecyclerViewAdapter, который будет работать
с Вашим ViewHolder. Продемонстрирую использование на примере из документации

public class MyFragment extends Fragment {
    private Realm realm;
    private RecyclerView recyclerView;

    @Override
    public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle
savedInstanceState) {
        realm = Realm.getDefaultInstance();

        View root = inflater.inflate(R.layout.fragment_view, container, false);

        recyclerView = (RecyclerView) root.findViewById(R.id.recycler_view);
        // установка Вашего адаптера для RecyclerView
        recyclerView.setAdapter(new MyRecyclerViewAdapter(getActivity(), 
                                    // установка результата асинхронного запроса
                                    quoteDataRepository.getListOfQuoteTextAsync()));

        // ...

        return root;
    }

    @Override
    public void onDestroyView() {
        super.onDestroyView();
        realm.close();
    }
}


В общем случае для получения (и отображения) результата внутри Fragment/Activity
нужно осуществить подписку на RealmResults. Сделать это нужно именно в вызывающем коде
для возможности отписаться от уведомлений (так как никто кроме вызывающего кода не
знает, когда запрос для него уже неактуален). Этот вариант будет выглядеть так:

public class MyFragment extends Fragment {
    private Realm realm;
    private RealmResults results;

    @Override
    public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle
savedInstanceState) {
        realm = Realm.getDefaultInstance();

        View root = inflater.inflate(R.layout.fragment_view, container, false);
        results = quoteDataRepository.getListOfQuoteTextAsync();
        // добавление подписки на получение результата
        results.addChangeListener(new RealmChangeListener() {
             @Override
             public void onChange(RealmResults results) {
                 // метод будет вызван, когда запрос будет выполнен или при обновлении
данных
                 // здесь можно обновлять экран или делать другой полезный код
             }
        });

        return root;
    }

    @Override
    public void onDestroyView() {
        super.onDestroyView();
        // при уничтожении фрагмента нужно отписаться от уведомлений
        results.removeChangeListeners(); 
        realm.close();
    }
}


Ответ 3

Вот эта статья(-и) дала(-и) ответы на все мои вопросы! Спасибо автору!


  https://medium.com/@Viraj.Tank/realm-integration-in-android-best-practices-449919d25f2f#.9735g4ojc