Android Room数据库如何获取最后更新时间戳？Pagination3实现疑问

首先明确：Room框架本身并没有提供lastUpdated()这个方法，官方文档里的这个方法是自定义的业务逻辑，用来追踪数据库数据的最后更新时间，从而判断是否需要触发RemoteMediator的初始刷新。

下面提供两种常用的实现方案：

方案1：创建元数据表单独存储更新时间 #

适合全局判断整个数据库的更新状态，步骤如下：

1. 定义元数据实体类 #

@Entity(tableName = "db_metadata")
data class DbMetadata(
    @PrimaryKey val id: Int = 1, // 固定id确保只有一条元数据记录
    val lastUpdated: Long = System.currentTimeMillis()
)

2. 编写元数据Dao接口 #

@Dao
interface DbMetadataDao {
    @Query("SELECT lastUpdated FROM db_metadata WHERE id = 1")
    suspend fun getLastUpdatedTime(): Long?

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    suspend fun saveOrUpdateMetadata(metadata: DbMetadata)
}

3. 在Room数据库类中封装方法 #

@Database(entities = [YourTargetEntity::class, DbMetadata::class], version = 1)
abstract class AppDatabase : RoomDatabase() {
    abstract fun yourTargetDao(): YourTargetDao
    abstract fun metadataDao(): DbMetadataDao

    // 对外暴露的lastUpdated方法
    suspend fun lastUpdated(): Long? {
        return metadataDao().getLastUpdatedTime()
    }

    // 更新最后时间的方法，网络数据插入成功后调用
    suspend fun markDatabaseUpdated() {
        metadataDao().saveOrUpdateMetadata(DbMetadata(lastUpdated = System.currentTimeMillis()))
    }
}

方案2：在目标表中添加更新时间字段 #

如果只需要判断某一张表的更新状态，可以直接在目标实体类中加字段：

1. 修改目标实体类 #

@Entity(tableName = "your_target_table")
data class YourTargetEntity(
    @PrimaryKey val id: String,
    val content: String,
    // 添加更新时间字段
    val lastUpdated: Long = System.currentTimeMillis()
)

2. 在目标Dao中添加查询最新时间的方法 #

@Dao
interface YourTargetDao {
    // 其他业务方法...

    @Query("SELECT MAX(lastUpdated) FROM your_target_table")
    suspend fun getLatestUpdatedTime(): Long?
}

3. 在RemoteMediator中直接调用 #

override suspend fun initialize(): InitializeAction {
    val cacheExpireTime = 60 * 60 * 1000 // 1小时缓存过期时间
    val lastUpdated = db.yourTargetDao().getLatestUpdatedTime() ?: 0
    return if (System.currentTimeMillis() - lastUpdated < cacheExpireTime) {
        InitializeAction.SKIP_INITIAL_REFRESH
    } else {
        InitializeAction.LAUNCH_INITIAL_REFRESH
    }
}

使用注意事项 #

• 首次启动时，lastUpdated()会返回null，建议默认视为需要触发初始刷新（即返回InitializeAction.LAUNCH_INITIAL_REFRESH）
• 每次从网络拉取数据并成功插入/更新数据库后，必须调用对应的更新方法（比如方案1的markDatabaseUpdated()，方案2则在插入数据时同步设置lastUpdated为当前时间）

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