房间数据库：创建新的 RecyclerView 项目后两次获取 SELECT MAX()

Question

我有一个正常工作的 CardView 项目的 RecyclerView 列表。在创建插入数据库的新 CardView 后，我想触发一个 Toast，通知用户 CardView 已成功添加并显示 CardView 编号。 CardView 编号是插入数据库的 CardView 项的 Id。当用户单击触发 onClickSave() 的保存按钮时，数据将保存到数据库中。

我在 Dao 中设置了一个@Query 来获取 MAX(cardId)：

Dao
...
@Query("SELECT MAX(cardId) FROM cards")
LiveData<Integer> getMax();

@Insert
void insertCard(Card card);

问题是两个 Toast 正在触发。第一个 Toast 正在返回之前创建的 CardView 编号和，然后第二个 Toast 正在触发并显示刚刚添加的最新 CardView 编号。例如，Toast 将显示 CardView 编号 33，然后触发第二个 Toast，显示刚刚创建的预期 CardView 编号 34（我确认 CardViews 33 和 34 都在数据库中和两个最高的项目中，使用 DB Browser for SQLite 软件）。

AddorUpdateCardActivity
...
private int newMax = -1;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);

    mViewModel = new ViewModelProvider(this).get(cardViewModel.class);        
}

public void onClickSave(View v) {

    // set card data
    // then insert data in database
    mViewModel.insertCard(card1);     

    mViewModel.getMax().observe(this, value -> { newMax = value; Toast.makeText(AddorUpdateCardActivity.this, "card #" + newMax + " was saved to the list", Toast.LENGTH_LONG).show();});
}

ViewModel
...

public cardViewModel(Application application) {
    super(application);
    repository = new cardRepository(application);
    getMax = repository.getMax();
}

public LiveData<Integer> getMax() {
    return getMax;
}

public void insertCard(Card card) {
    repository.insertCard(card);
}

cardRepository

private CardDao cardDao;
private LiveData<Integer> getMax;


public cardRepository(Application application) {
    RoomDatabase db = RoomDatabase.getDatabase(application);
    cardDao = db.cardDao();
}

public LiveData<Integer> getMax() {
    return cardDao.getMax;  
}

public void insertCard(Quickcard newcard) {
    AsyncTask.execute(() -> cardDao.insertCard(newcard));

} 

我在这里缺少什么？如果卡片正确插入数据库，那么为什么 ViewModel 观察者不只返回这个新的 CardView 编号而不是两个 Toast？

作为参考，我展示了在 Room 和 ViewModel 之前使用的先前代码，它使用光标来获取最新和最高插入的 Id：

public class SQLiteDB extends SQLiteOpenHelper {

    ...
    public int getLastInsertId() {

    int index = 0;
    SQLiteDatabase sdb = getReadableDatabase();
    Cursor cursor = sdb.query(
            "sqlite_sequence",
            new String[]{"seq"},
            "name = ?",
            new String[]{TABLE_NAME},
            null,
            null,
            null,
            null
    );

    sdb.beginTransaction();
    try {
        if (cursor !=null) { 
            if (cursor.moveToLast()) {                    
                index = cursor.getInt(cursor.getColumnIndex("seq"));
            }
        }
    ...
    }         
    return index;
}      

Answer 1

您在onClickSave 中调用的视图模型操作是异步的：

public void onClickSave(View v) {
    mViewModel.insertCard(card1);
    mViewModel.getMax().observe(this, value -> { newMax = value; makeText(AddorUpdateCardActivity.this, "TEXT", .LENGTH_LONG).show();});
}

LiveData 的实现记录了数据版本以及观察者看到的最后一个版本。

因此，insertCard 开始在工作线程上运行，而您开始使用新创建的观察者从主线程观察 getMax。因此，您将收到当前值以及数据库更新后的新值。

相反，您只能在onCreate() 中观察一次，然后等待数据库触发的更新：

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    mViewModel = new ViewModelProvider(this).get(cardViewModel.class);
    mViewModel.getMax().observe(this, value -> { newMax = value; makeText(AddorUpdateCardActivity.this, "TEXT", .LENGTH_LONG).show();});
}

public void onClickSave(View v) {
    mViewModel.insertCard(card1);
}

Answer 2

AsyncTask 中的 Room Insert 操作需要一段时间才能更新 maxCount 变量。由于您在按钮单击中显示Toast，因此该消息会立即显示，而不会从LiveData 接收到更新的值。

将Toast 消息移动到obverve() 方法中，使其仅在LiveData 更改后触发。

mViewModel.getMax().observe(this, value -> {
        newMax = value;
        Toast.makeText(AddorUpdateCardActivity.this, "card #" + newMax + " was saved to the list", Toast.LENGTH_LONG).show();
    });

此时，代码应该可以运行，但您会为单个 Insert 获得多个 LiveData 事件。发生这种情况是因为您为 Insert 和 Query 操作使用了 2 个单独的 Dao 实例。

public cardRepository(Application application) {
    RoomDatabase db = RoomDatabase.getDatabase(application);
    cardDao = db.cardDao(); // <---------- Instance #1
    getMax = cardDao.getMax();
}

public LiveData<Integer> getMax() {
    return getMax;  
}

 public void insertCard(Card newcard) {
    new InsertAsyncTask(quickcardDao).execute(newcard);
}

private static class InsertAsyncTask extends AsyncTask<Card, Void, Integer> {

    private CardDao asyncTaskDao;

    InsertAsyncTask(CardDao dao) {
        asyncTaskDao = dao; // <---------- Instance #2
    }

    @Override
    protected Integer doInBackground(final Card... params) {

        asyncTaskDao.insertCard(params[0]);
        return null;
    }
}

要解决它，请在任何地方使用相同的 Dao 实例：

public cardRepository(Application application) {
        RoomDatabase db = RoomDatabase.getDatabase(application);
        cardDao = db.cardDao();
    }

    public LiveData<Integer> getMax() {
        return cardDao.getMax();  
    }

     public void insertCard(Card newcard) {
        AsyncTask.execute(() -> cardDao.insertCard(newcard));
    }

Answer 3

由于使用 AsyncTask 将卡片插入数据库，该功能需要一些时间才能完成，并且您会立即展示您的吐司！将您的活动更改为：

AddorUpdateCardActivity
...
private int newMax = -1;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);

    mViewModel = new ViewModelProvider(this).get(cardViewModel.class);

    mViewModel.getMax().observe(this, integer2 -> {
        newMax = integer2;
        Toast.makeText(AddorUpdateCardActivity.this, "card #" + newMax + " was saved to the list", Toast.LENGTH_LONG).show();
        hideProgressBar();
    });
}

public void onClickSave(View v) {

    //set card data
    // then insert data in database
    mViewModel.insertCard(card1);

    showProgressBar();
}