Sqlbrite并发插查返回空及多Fragment操作后ViewPager异常问题咨询

这两个问题都是Android数据库开发中非常典型的场景，我来逐一帮你分析解决：

背后的原因 #

Sqlbrite基于SQLite，而SQLite本身是单写多读的，但如果你的操作时机或方式不对，很容易出现查询拿不到最新数据的情况：

• 你可能在插入操作还没完成（比如异步写入未落地、事务未提交）就触发了查询，这时候查询只能拿到插入前的数据库快照。
• 如果是单次调用查询而非订阅Observable<Query>，Sqlbrite只会返回当前时刻的静态数据，插入操作在这之后完成的话，自然看不到新数据。
• 大量插入时没用到事务，导致写入分散、IO耗时增加，查询时部分数据还没真正写入数据库。

解决方案 #

• 串行化操作顺序：如果需要插入后立即拿到最新查询结果，用RxJava的操作符把插入和查询串起来，确保插入完成后再执行查询：

  // 先执行插入，完成后触发查询
  insertObservable
      .flatMapCompletable(result -> Completable.complete())
      .andThen(queryObservable)
      .subscribe(query -> {
          try (Cursor cursor = query.run()) {
              // 处理查询结果
          }
      }, error -> {
          // 处理异常
      });
  

• 订阅查询而非单次查询：如果需要实时感知数据变化，先订阅查询的Observable，再执行插入，这样插入完成后会自动推送最新的查询结果：

  // 先订阅，确保能收到后续数据更新
  Disposable queryDisposable = queryObservable.subscribe(query -> {
      try (Cursor cursor = query.run()) {
          // 更新UI或处理数据
      }
  });
  
  // 再执行插入操作
  insertObservable.subscribe();
  
  // 记得在生命周期结束时取消订阅，避免内存泄漏
  

• 用事务批量插入：大量插入/更新一定要包在事务里，既提升写入效率，又能保证数据原子性，避免部分写入的情况：

  Completable.fromAction(() -> {
      SQLiteDatabase db = dbHelper.getWritableDatabase();
      db.beginTransaction();
      try {
          // 循环执行插入/更新操作
          db.setTransactionSuccessful();
      } finally {
          db.endTransaction();
      }
  }).subscribeOn(Schedulers.io())
    .subscribe();
  

可能的诱因 #

这个问题本质上是数据库并发操作冲突加上UI线程阻塞/数据过时导致的：

• 大量未用事务的写操作会长时间占用SQLite的写锁，导致Fragment C的查询被阻塞，甚至抛出SQLiteException。
• Fragment C如果在UI线程执行查询，一旦被数据库锁阻塞，会导致UI卡顿、ANR，进而引发ViewPager页面加载异常。
• FragmentStatePagerAdapter的缓存机制可能让旧的Fragment实例没有刷新，显示过时数据；另外，Cursor未正确关闭会导致内存泄漏或CursorWindow异常。

解决方案 #

• 用事务包裹批量写操作：在Fragment A的后台任务里，把所有插入/更新放在一个事务中，大幅减少锁持有时间，降低对查询操作的影响：

  // 后台线程执行事务，避免阻塞UI
  Completable.fromAction(() -> {
      SQLiteDatabase db = dbHelper.getWritableDatabase();
      db.beginTransaction();
      try {
          // 执行所有批量插入/更新逻辑
          db.setTransactionSuccessful();
      } finally {
          db.endTransaction();
      }
  }).subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(() -> {
        // 操作完成后的UI提示
    }, error -> {
        // 处理错误
    });
  

• Fragment C的查询必须在后台线程：绝对不要在UI线程碰数据库查询，用RxJava把查询移到IO线程，拿到结果后再切回UI线程更新：

  // 在Fragment C的onViewCreated中执行
  Disposable queryDisposable = queryObservable
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(query -> {
          try (Cursor cursor = query.run()) {
              // 刷新页面UI
          }
      });
  
  // 在onDestroyView中取消订阅
  @Override
  public void onDestroyView() {
      super.onDestroyView();
      if (queryDisposable != null) {
          queryDisposable.dispose();
      }
  }
  

• 让Fragment C自动监听数据变化：用Sqlbrite的Observable<Query>订阅数据变化，数据库更新时自动刷新页面，避免显示过时数据：
  上面的代码已经包含了这个逻辑，只要保持订阅，数据变化时会自动收到新的查询结果，无需手动触发刷新。
• 优化ViewPager的Fragment管理：确保FragmentStatePagerAdapter的getItem()每次都返回新鲜的Fragment实例（或者在Fragment内部实现onResume时刷新数据的逻辑），避免缓存旧的状态。另外，检查setUserVisibleHint方法，当页面可见时可以主动触发一次数据刷新。
• 严格管理Cursor生命周期：用try-with-resources自动关闭Cursor，避免资源泄漏或CursorWindow已满的问题：

  try (Cursor cursor = query.run()) {
      // 遍历cursor处理数据
  } catch (Exception e) {
      Log.e(TAG, "Cursor处理异常", e);
  }
  

内容的提问来源于stack exchange，提问作者KpSt