LiveData配合原生SQLite使用时数据库更新后UI未同步刷新问题

你当前实现的LiveData仅在首次调用loadAllMessagesOfThisChat()时执行一次数据库查询，原生SQLite没有内置的数据变更通知机制，后续数据库写入新数据后，LiveData无法感知变更，不会主动重新查询数据推送给观察者，只有重启Activity重新触发查询逻辑才能拿到新数据。

推荐通过自定义可感知数据库变化的LiveData实现自动更新，不需要依赖Room，实现逻辑如下：

步骤1：自定义监听SQLite变化的LiveData #

public class ChatMessageLiveData extends MutableLiveData<ArrayList<Message>> {
    private final MessagesDbHelper dbHelper;
    private final String receiverUID;
    // 自定义数据变更回调的监听器，无需依赖ContentProvider
    private final Runnable dataChangeListener = this::loadDataFromDB;

    public ChatMessageLiveData(MessagesDbHelper dbHelper, String receiverUID) {
        this.dbHelper = dbHelper;
        this.receiverUID = receiverUID;
    }

    @Override
    protected void onActive() {
        super.onActive();
        // 有活跃观察者时，注册数据变更监听+加载初始数据
        MessagesDbHelper.registerDataChangeListener(dataChangeListener);
        loadDataFromDB();
    }

    @Override
    protected void onInactive() {
        super.onInactive();
        // 无活跃观察者时注销监听，避免内存泄漏
        MessagesDbHelper.unregisterDataChangeListener(dataChangeListener);
    }

    private void loadDataFromDB() {
        // 原有数据库查询逻辑移动到这里
        ArrayList<Message> messagesArrayList = new ArrayList<>();
        SQLiteDatabase mDb = dbHelper.getReadableDatabase();
        String[] projection = {
                MessageDetails.COLUMN_SENDER_UID,
                MessageDetails.COLUMN_MESSAGE,
                MessageDetails.TIMESTAMP_ID,
                MessageDetails.COLUMN_IMAGE_URI
        };
        Cursor cursor = mDb.query("receiver" + receiverUID, projection, null, null, null, null, null);
        int messageColumnIndex = cursor.getColumnIndex(MessageDetails.COLUMN_MESSAGE);
        int timestampColumnIndex = cursor.getColumnIndex(MessageDetails.TIMESTAMP_ID);
        int imageURIColumnIndex = cursor.getColumnIndex(MessageDetails.COLUMN_IMAGE_URI);
        int senderUIDColumnIndex = cursor.getColumnIndex(MessageDetails.COLUMN_SENDER_UID);
        while (cursor.moveToNext()) {
            Message message = new Message();
            message.setMessage(cursor.getString(messageColumnIndex));
            message.setImageUrl(cursor.getString(imageURIColumnIndex));
            message.setTimestamp(String.valueOf(cursor.getInt(timestampColumnIndex)));
            message.setUserID(cursor.getString(senderUIDColumnIndex));
            messagesArrayList.add(message);
        }
        cursor.close();
        mDb.close();
        // 推送新数据触发Observer回调
        postValue(messagesArrayList);
    }
}

步骤2：在DbHelper中增加全局变更监听逻辑 #

在你的MessagesDbHelper类中添加静态的监听集合，每次完成数据库增删改操作后通知所有监听者：

public class MessagesDbHelper extends SQLiteOpenHelper {
    // 存储所有数据变更监听器
    private static final List<Runnable> dataChangeListeners = new CopyOnWriteArrayList<>();

    // 新增注册、注销监听的静态方法
    public static void registerDataChangeListener(Runnable listener) {
        if (listener != null && !dataChangeListeners.contains(listener)) {
            dataChangeListeners.add(listener);
        }
    }

    public static void unregisterDataChangeListener(Runnable listener) {
        dataChangeListeners.remove(listener);
    }

    // 新增数据变更通知方法，每次你执行插入、更新、删除消息的操作完成后调用该方法
    public static void notifyDataChanged() {
        for (Runnable listener : dataChangeListeners) {
            listener.run();
        }
    }

    // 原有DbHelper的其他逻辑不变...
}

步骤3：修改原有查询方法 #

private LiveData<ArrayList<Message>> loadAllMessagesOfThisChat() {
    return new ChatMessageLiveData(messagesDbHelper, receiverUID);
}

步骤4：数据库写入后触发通知 #

在你发送新消息、写入数据库的代码执行完成后，调用MessagesDbHelper.notifyDataChanged()即可，此时LiveData会自动重新查询数据，推送给观察者刷新UI。

如果不想修改现有架构，也可以在每次写入新消息后手动重新查询数据，更新已有的LiveData：

1. 将messages变量提升为Activity的全局变量
2. 写入新消息完成后执行如下代码：

// 重新查询数据，提前把原有查询逻辑复制出来单独封装成queryMessageList方法
ArrayList<Message> newMessages = queryMessageList();
messages.setValue(newMessages);

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