Не могу понять как реализовать связь в MVP + Room.
На примере приложения "Заметки":
Я создал БД с использованием Room.
@Database(entities = {Note.class}, version = 1, exportSchema = false)
public abstract class NotesDatabase extends RoomDatabase {
private static NotesDatabase database;
private static final String DB_NAME = "notes.db";
private static final Object LOCK = new Object();
public static NotesDatabase getInstance(Context context) {
synchronized (LOCK){
if (database == null) {
database = Room.databaseBuilder(context, NotesDatabase.class, DB_NAME)
.build();
}
}
return database;
}
public abstract NotesDao notesDao();
}
Создал Model, в которой находятся запросы к БД
public class MainModel{
private static NotesDatabase database;
private LiveData<List<Note>> notes;
public MainModel(Application application) {
database = NotesDatabase.getInstance(application);
notes = database.notesDao().getAllNotes();
}
public LiveData<List<Note>> getNotes() {
return notes;
}
public void deleteAllNote() {
new DeleteNotesTask().execute();
}
public void insertNote(Note note) {
new InsertTask().execute(note);
}
public void deleteNote(Note note){
new DeleteTask().execute(note);
}
public Note getNoteById(int id) {
try {
return new GetNoteTask().execute(id).get();
} catch (ExecutionException | InterruptedException e) {
e.printStackTrace();
}
return null;
}
public void updateNote(Note note) {
new UpdateTask().execute(note);
}
private static class DeleteTask extends AsyncTask<Note, Void, Void> {
@Override
protected Void doInBackground(Note... notes) {
if (notes != null && notes.length > 0) {
database.notesDao().deleteNote(notes[0]);
}
return null;
}
}
private static class DeleteNotesTask extends AsyncTask<Void, Void, Void> {
@Override
protected Void doInBackground(Void... voids) {
database.notesDao().deleteAllNote();
return null;
}
}
private static class InsertTask extends AsyncTask<Note, Void, Void> {
@Override
protected Void doInBackground(Note... notes) {
if (notes != null && notes.length > 0) {
database.notesDao().insertNote(notes[0]);
}
return null;
}
}
private static class GetNoteTask extends AsyncTask<Integer, Void, Note> {
@Override
protected Note doInBackground(Integer... integers) {
if (integers != null && integers.length > 0) {
return database.notesDao().getNoteById(integers[0]);
}
return null;
}
}
private static class UpdateTask extends AsyncTask<Note, Void, Void> {
@Override
protected Void doInBackground(Note... notes) {
if (notes != null && notes.length > 0) {
database.notesDao().updateNote(notes[0]);
}
return null;
}
}
}
И дальше совсем не понятно как это все связать между собой и к тому же со View and Presenter.
Пытался написать Presenter, но абсолютно нет понимания как это сделать правильно. Пример Presenter:
public class MainPresenter {
private MainModel model;
private NotesAdapter adapter;
private List<Note> notes = new ArrayList<>();
public void getData() {
LiveData<List<Note>> notesFromDb = model.getNotes();
notesFromDb.observe([что писать в качестве owner?], new Observer<List<Note>>() {
@Override
public void onChanged(List<Note> notesFromLiveData) {
notes.clear();
notes.addAll(notesFromLiveData);
adapter.notifyDataSetChanged();
}
});
}
}
Помогите, пожалуйста, разобраться с вопросом.