Raum aktualisieren (oder einfügen, falls nicht vorhanden) Zeilen und Anzahl geänderter Zeilen zurückgeben

Ich brauche ein Update und wenn nicht vorhanden, füge eine Zeile in ROOM DB ein.

Ich mache das: productRepository.updateProducts(productsResponse.getProductItems());

Und:

@Override
public void updateProducts(final List<ProductItem> products) {
    new Thread(() -> {
        for (ProductItem item : products) {
            Product product = createProduct(item);
            productDao.insert(product);
        }
    }).start();
}

Und im DAO:

@Insert
void insert(Product products);

Aber ich habe Methode

@Update
void update(Product product);

Und ich habe einige Fragen:

1. beide Methoden sind nichtig. Wie kann ich gespeicherte Produkte oder boolesche Flags oder eingefügte Zählwerte nach dem Einfügen zurückgeben?

2. wenn ich versuche anzurufen update und ich habe keine Zeile, wird sie eingefügt?

3. Wie kann ich die Zeile aktualisieren (wenn nicht – einfügen) und die Anzahl der aktualisierten oder eingefügten Zeilen zurückgeben?

Wie @Danail Alexiev sagte @Insert kann zurückgeben a long. @Update kann ein zurückgeben int.

Aber zu welchem ​​Zweck verwenden Sie Update? Wenn Sie nur möchten, dass das gesamte Objekt durch das neue ersetzt wird, geben Sie einfach die an OnConflictStrategy

@Insert(onConflict = OnConflictStrategy.REPLACE)
void insert(Product products);

Das Ergebnis wird sein: nicht vorhandene Elemente werden hinzugefügt, bereits vorhandene Elemente werden durch die neuen ersetzt.

Im Bedarfsfall aktualisiere nur einen Parameter (wie Menge zum Beispiel) können Sie so etwas tun

  @Insert(onConflict = OnConflictStrategy.REPLACE)
  void insert(Product products);

  @Query("SELECT * from item WHERE id= :id")
  List<Product> getItemById(int id);

  @Query("UPDATE item SET quantity = quantity + 1 WHERE id = :id")
  void updateQuantity(int id)

  void insertOrUpdate(Product item) {
                List<Product> itemsFromDB = getItemById(item.getId())
                if (itemsFromDB.isEmpty())
                    insert(item)
                else
                    updateQuantity(item.getId())   
            }
        }

Das Ergebnis wird sein: Versuchen Sie, das Element in der Datenbank nachzuschlagen, wenn Sie es finden, aktualisieren Sie eine Eigenschaft, wenn nicht, fügen Sie einfach ein neues Element ein. Sie müssen also nur eine Methode aufrufen insertOrUpdate von Ihrem DAO.

1. Eine Methode, kommentiert mit @Insert kann zurückgeben a long. Dies ist die neu generierte ID für die eingefügte Zeile. Eine Methode, kommentiert mit @Update kann ein zurückgeben int. Dies ist die Anzahl der aktualisierten Zeilen.

2. update versucht, alle Ihre Felder mit dem Wert des Primärschlüssels in a zu aktualisieren where Klausel. Wenn Ihre Entität noch nicht in der Datenbank gespeichert ist, wird die update Abfrage kann keine Zeile finden und aktualisiert nichts.

3. Sie können verwenden @Insert(onConflict = OnConflictStrategy.REPLACE). Dadurch wird versucht, die Entität einzufügen, und wenn es eine vorhandene Zeile mit demselben ID-Wert gibt, wird sie gelöscht und durch die Entität ersetzt, die Sie einfügen möchten. Beachten Sie, dass bei Verwendung automatisch generierter IDs die resultierende Zeile eine andere ID hat als das Original, das ersetzt wurde. Wenn Sie die ID beibehalten möchten, müssen Sie sich eine benutzerdefinierte Methode dafür einfallen lassen.

Sie können Ihre Datenbank überprüfen, ob es bereits Artikel mit einem bestimmten Feld gibt, zum Beispiel:

@Query("SELECT id FROM items WHERE id = :id LIMIT 1")
fun getItemId(id: String): String?

@Insert
fun insert(item: Item): Long

@Update(onConflict = OnConflictStrategy.REPLACE)
fun update(item: Item): Int

Item ist Ihr Objekt und in Ihrem Code:

 fun insertOrUpdate(item: Item) {
            database.runInTransaction {
                val id = getItemDao().getItemId(item.id)

                if(id == null)
                    getItemDao().insert(item)
                else
                    getItemDao().update(item)
            }
        }

Sie können die folgende Methode insertModel() überprüfen, wo Sie die Methoden onComplete() und onError() abrufen können:

    val db: AppDatabase = Room.databaseBuilder(mCtx, AppDatabase::class.java, "db_nam.sqlite").build()

    companion object {
        @SuppressLint("StaticFieldLeak")
        private var mInstance: DatabaseClient? = null

        @Synchronized
        fun getInstance(mCtx: Context): DatabaseClient {
            if (mInstance == null) {
                mInstance = DatabaseClient(mCtx)
            }
            return mInstance as DatabaseClient
        }
    }

    // SEE HERE FOR INSERTING DATA SUCCESSFULLY AND ERROR CODE  
    private fun insertModel(rss_Model: RSS_Model) {
        Completable.fromAction {

            db.database_dao().insertRSS(rss_Model)

        }.observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(Schedulers.io()).subscribe(object : CompletableObserver {
                    override fun onSubscribe(d: Disposable) {}

                    override fun onComplete() {
                        // Log.e("onComplete","GET SUCCESS HERE")
                    }

                    override fun onError(e: Throwable) {
                        // Log.e("onError","onError")
                    }
                })
    }

Danke an @Ashwini für die tolle Idee.

@Dao
interface SendDao {
    @Insert(onConflict = OnConflictStrategy.IGNORE)
    suspend fun insert(model: DataModel): Long

    @Update
    suspend fun update(model: DataModel): Int

    @Transaction
    suspend fun insertOrUpdate(model: DataModel): Long {
        val id = insert(model)
        return if (id==-1L) {
            update(model)
            model.id
        } else {
            id
        }
    }
}

Wir sollten also anrufen: database.sendDao().insertOrUpdate(DataModel(...))

@Query("SELECT * FROM pojo WHERE pojo.id = :id")
Maybe<POJO> checkPOJO(String id);

Sie können InsertOrUpdate wie folgt ausführen:

checkPOJO(id).toSingle().concatMapCompletable(pojo->update(pojo))
   .onErrorResumeNext(t -> t instanceof NoSuchElementException ? 
   insert(...): Completable.error

Sie können auch überprüfen, ob der Eintrag in der Datenbank vorhanden ist oder nicht, Sie können Ihre Logik entsprechend erstellen

Kotlin

@Query("SELECT * FROM Product WHERE productId == :id")
fun isProductExist(id: Int): Boolean

Java

@Query("SELECT * FROM Product WHERE productId == :id")
public boolean isExist(int id);