Невозможно добавить ответ от API в базу данных. - PullRequest
Новая
       9

Невозможно добавить ответ от API в базу данных.

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

У меня есть один запрос GET от API. С Retrofit и RxJava я получаю ответ. Теперь я хочу добавить свой ответ в базу данных Room. Но я не хочу использовать AsyncTask Я хочу использовать RxJava. Я подготовил метод в Дао insertAll. Как я могу использовать RxJava для асинхронного добавления моего списка в базу данных? Мой запрос на получение: 

@GET("contacts")
fun getContactModel(): Single<List<Contact>>

Мой Дао insertAll Метод: 

@Insert(onConflict = OnConflictStrategy.REPLACE)
fun insertAll(contact: List<Contact>?) : Completable

Мой запрос с использованием Rx Java: 

val disposable = CompositeDisposable()

disposable.add(contactsRepository.modelSingle()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribeWith(object : DisposableSingleObserver<List<Contact>>() {
            override fun onSuccess(t: List<Contact>) {
                // t - My List from Api
            }

            override fun onError(e: Throwable) {
            }
        })
)

Ответы [ 2 ]

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

Если contactsRepository.modelSingle() возвращает Single Наблюдаемое, тогда вы можете просто сделать 

disposable.add(contactsRepository.modelSingle()
                   .doOnSuccess { data -> saveToDb(data) } // this will be called on Schedulers.io
                   .subscribeOn(Schedulers.io())
                   .observeOn(AndroidSchedulers.mainThread())
                   .subscribeWith(object : DisposableSingleObserver<List<Contact>>() {
                       override fun onSuccess(t: List<Contact>) {
                           // t - My List from Api
                       }

                       override fun onError(e: Throwable) {
                       }
                   })
        )

Если это другое Наблюдаемое, тогда вы можете использовать flatMap

disposable.add(contactsRepository.modelSingle()
                   .flatMap { data ->
                       saveToDb(data)
                       Observable.just(data)
                   }
                   .subscribeOn(Schedulers.io())
                   .observeOn(AndroidSchedulers.mainThread())
                   .subscribe()
        )
0 голосов
/ 14 января 2020

В java это то, для чего я сначала буду использовать Retrofit с Rx Java и смогу получить наблюдаемый ответ из API следующим образом

В сервисе Retrofit Interface используйте следующий код 

    @GET("contacts")
    Observable<Contacts> getContactsFromAPI

в орудии @Dao Room Class 

 @Insert(onConflict = OnConflictStrategy.REPLACE)
 Completable insertContact(List<Contact> contact);

Для извлечения наблюдаемых элементов данных из API используйте следующий код 

    RetrofitService getContactService = RetroInstance.getService();
    Observable<Contact> apiData = 
     getContactService.getContactsFromAPI();

     compositeDisposable.add(apiData
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
               .subscribeWith(new DisposableObserver<Contact>() {
                @Override
                public void onNext(List<Contact> contact) {
                    newContact(contact)
                    Log.d(LOG_TAG, "The contacts are : "+ contact);
                }

                @Override
                public void onError(Throwable e) {
                    Log.d(LOG_TAG, "Error: "+ e.getMessage());
                }

                @Override
                public void onComplete() {                
                }
            }));

Чтобы добавить дополнение, извлечение из api к базе данных Room, затем создайте метод, который будет использоваться для вставки данных в базу данных Room, и этот метод был вызван для кода, написанного для получения данных из api 

 public void newContact(List<Contacts> contacts) {

 disposable.add(Completable.fromAction(new Action() {
        @Override
        public void run() throws Exception {
        rowIdInserted = 
    contactAppDatabase.userDao().insertContact(contacts);
        }
    }).subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribeWith(new DisposableCompletableObserver() {
            @Override
            public void onComplete() {
                Log.d(TAG, "inserted successful");
            }

            @Override
            public void onError(Throwable e) {
            Log.d(LOG_TAG, "tHE new error on create the new user is: " + 
        e.getMessage());
            }
        }));
     }

Я думаю, что справка

...