Возврат автоматически сгенерированного идентификатора из Room с использованием AsyncTask и onPostExecute с использованием MVVM - PullRequest
Новая
       7

Возврат автоматически сгенерированного идентификатора из Room с использованием AsyncTask и onPostExecute с использованием MVVM

0 голосов
/ 22 января 2020

Я пытаюсь получить автоматически сгенерированный идентификатор из базы данных Room, но пытаюсь решить, как реализовать использование MVVM со всеми слоями. Я новичок в Android программировании. Я считаю, что onPostExecute является ключом, но я не знаю, как я могу вернуть идентификатор в пользовательский интерфейс.

У меня есть этот класс: 

@Entity
public class Scenario {

    @PrimaryKey (autoGenerate = true)
    private int id;
    private String name;

    public Scenario(String name) {this.name = name;}

    public void setId(@NonNull int id) {this.id = id;}
    @NonNull
    public int getId() {return id;}
    public String getName() {return name;}
}

И этот DAO (только показывает код, связанный с вставкой ): 

@Dao
public interface ScenarioDao {

    @Insert
    Long insert(Scenario scenario);

}

С этим репозиторием (только показывает код, связанный со вставкой): 

public class ScenarioRepository {

    private ScenarioDao scenarioDao;
    private LiveData<List<Scenario>> allScenarios;


    public ScenarioRepository(Application application) {

        AppDatabase database = AppDatabase.getInstance(application);
        scenarioDao = database.scenarioDao();
        allScenarios = scenarioDao.getAllScenarios();
    }


    public void insert (Scenario scenario) {
        new InsertScenarioAsyncTask(scenarioDao).execute(scenario);
    }

    private static class InsertScenarioAsyncTask extends AsyncTask<Scenario, Void, Long> {
        private ScenarioDao scenarioDao;

        private InsertScenarioAsyncTask (ScenarioDao scenarioDao) {
            this.scenarioDao = scenarioDao;
        }

        //protected Void doInBackground(Scenario... scenarios) {
        @Override
        protected Long doInBackground(Scenario... scenarios) {
            return scenarioDao.insert(scenarios[0]);
        }

       //protected void onPostExecute(Void aVoid) {
        @Override
        protected void onPostExecute(Long insertId) {
            super.onPostExecute(insertId);
            //onScenarioInserted(insertId, scenario);
        }
    }
}

И эта модель представления: 

public class ScenarioDetailViewModel extends AndroidViewModel {

    private ScenarioRepository repository;

    public ScenarioDetailViewModel(@NonNull Application application) {
        super(application);
        repository = new ScenarioRepository(application);
    }

    public void insert(Scenario scenario) {
        repository.insert(scenario);
    }
}

Вызывается этой функцией в фрагмент, который вызывается кнопкой OnClickListener: 

private void saveScenario() {

    String name = editTextName.getText().toString();

    if (name.isEmpty()) {
        Toast.makeText(getActivity(), "Please enter scenario name.", Toast.LENGTH_SHORT).show();
        return;
    }

    Scenario scenario = new Scenario(name);
    scenarioDetailViewModel.insert(scenario);

}

ОБНОВЛЕНО Благодаря комментариям ниже. 

    public class ScenarioRepository {

    private ScenarioDao scenarioDao;
    private LiveData<List<Scenario>> allScenarios;


    public ScenarioRepository(Application application) {

        AppDatabase database = AppDatabase.getInstance(application);
        scenarioDao = database.scenarioDao();
        allScenarios = scenarioDao.getAllScenarios();
    }


    public void insert (MutableLiveData<Long> id, Scenario scenario) {
        new InsertScenarioAsyncTask(scenarioDao).execute(id, scenario);
    }

    private static class InsertScenarioAsyncTask extends AsyncTask<Scenario, Void, Long> {
        private ScenarioDao scenarioDao;
    private MutableLiveData<Long> id;

        private InsertScenarioAsyncTask (MutableLiveData<Long> id, ScenarioDao scenarioDao) {
            this.scenarioDao = scenarioDao;
    this.id=id;
        }

        //protected Void doInBackground(Scenario... scenarios) {
        @Override
        protected Long doInBackground(Scenario... scenarios) {
            return scenarioDao.insert(scenarios[0]);
        }

       //protected void onPostExecute(Void aVoid) {
        @Override
        protected void onPostExecute(Long insertId) {
    id.postValue(insertId);
            super.onPostExecute(insertId);
        }

        @Override
        protected void onCancelled() {
            id.postValue(new Long(0));
            super.onCancelled();
        }
    }
}

и во фрагменте: 

    scenarioDetailViewModel = ViewModelProviders.of(this).get(ScenarioDetailViewModel.class);

    final Observer<Long> scenarioIdObserver = new Observer<Long>() {
        @Override
        public void onChanged(Long aLong) {
            Log.d(TAG, "onChanged, scenarioId is " + aLong);
        }
    };

    scenarioDetailViewModel.getCurrentScenarioId().observe(getActivity(),scenarioIdObserver);

И это во ViewModel: 

public class ScenarioDetailViewModel extends AndroidViewModel {

    private static final String TAG="ScenarioDetailViewModel";
    private ScenarioRepository repository;
    private MutableLiveData<Long> currentId;

    public ScenarioDetailViewModel(@NonNull Application application) {
        super(application);
        currentId = new MutableLiveData<Long>();
        repository = new ScenarioRepository(application);
    }

    public MutableLiveData<Long> getCurrentId() {
        return currentId;
    }

    public void insert(Scenario scenario) {
        Log.d(TAG,"inserting scenario " + scenario.getName());
        repository.insert(currentId,scenario);
    }

    public void update(Scenario scenario) {
        repository.update(scenario);
    }

    public void delete(Scenario scenario) {
        repository.delete(scenario);
    }
}

1 Ответ

1 голос
/ 22 января 2020

Вы можете использовать LiveData внутри AsyncTask
ScenarioRepository будет выглядеть следующим образом: 

public MutableLiveData<Long> insert (Scenario scenario) {
        MutableLiveData<Long> liveData = new MutableLiveData()
        new InsertScenarioAsyncTask(liveData, scenarioDao).execute(scenario);
        return liveData ;
}

ِ Ваш InsertScenarioAsyncTask: 

private static class InsertScenarioAsyncTask extends AsyncTask<Scenario, Void, Long> {
        private ScenarioDao scenarioDao;
        private MutableLiveData<Long> liveData;

        private InsertScenarioAsyncTask (MutableLiveData<Long> liveData, ScenarioDao scenarioDao) {
            this.liveData = liveData;
            this.scenarioDao = scenarioDao;
        }

        //protected Void doInBackground(Scenario... scenarios) {
        @Override
        protected Long doInBackground(Scenario... scenarios) {
            return scenarioDao.insert(scenarios[0]);
        }

       //protected void onPostExecute(Void aVoid) {
        @Override
        protected void onPostExecute(Long insertId) {
            liveData.postValue(insertId);
            super.onPostExecute(insertId);
            //onScenarioInserted(insertId, scenario);
        }

         @Override
         protected void onCancelled() {
            liveData.postValue(0);
            super.onCancelled();
         }
    }

в вашем фрагменте: 

liveData.observe(this, insertedId -> {
// insertedId is the id of the inserted scenario
// if value is 0 then the task was cancelled
    if(insertedId == 0){

    }else{

    }
});
...