跳至主要內容

Room 数据库完全指南

2026/9/14大约 8 分钟

Room 数据库完全指南

面试高频指数：极高 Room 是 Android 官方 ORM，面试必问，实际项目几乎必用。

1. Room 是什么

Room 是 Jetpack 的 SQLite 抽象层，在 SQLite 之上提供：

  • 编译期 SQL 校验（写错 SQL 直接编译失败）。
  • 协程/Flow 集成（响应式查询）。
  • Migration 机制（数据库升级管理）。
  • 减少样板代码（自动生成 DAO 实现）。
Room ← 抽象层 → SQLite ← 存储

1. Room 是什么

Room 是 Jetpack 的 SQLite 抽象层，在 SQLite 之上提供：

  • 编译期 SQL 校验（写错 SQL 直接编译失败）。
  • 协程/Flow 集成（响应式查询）。
  • Migration 机制（数据库升级管理）。
  • 减少样板代码（自动生成 DAO 实现）。

一句话理解它的定位：你写 SQL 和数据结构，Room 负责在编译期帮你校验、运行时帮你执行：

Room ← 抽象层 → SQLite ← 存储

2. 三要素

2.1 @Entity（表）

@Entity 把普通类映射成数据库表：类名/字段名即表名/列名，可用 @ColumnInfo 改名，@PrimaryKey 声明主键，@Index 建索引。唯一索引能保证 email 不重复：

Java
@Entity(
    tableName = "user",
    indices = {@Index(value = {"email"}, unique = true)}  // 唯一索引
)
public class User {
    @PrimaryKey(autoGenerate = true)
    public long id;               // 默认 0

    @ColumnInfo(name = "email")
    public String email;          // 自定义列名

    public String name;
    public Integer age;           // 可空列

    public User(String name, String email, Integer age) {
        this.name = name;
        this.email = email;
        this.age = age;
    }
}

多对多关系需要一张"关系表"：联合主键 + 外键，onDelete = CASCADE 让主表删记录时自动清理关联数据：

Java
@Entity(
    tableName = "user_book",
    primaryKeys = {"userId", "bookId"},   // 联合主键
    foreignKeys = @ForeignKey(
        entity = User.class,
        parentColumns = {"id"},
        childColumns = {"userId"},
        onDelete = ForeignKey.CASCADE
    )
)
public class UserBook {
    public long userId;
    public long bookId;

    public UserBook(long userId, long bookId) {
        this.userId = userId;
        this.bookId = bookId;
    }
}

2.2 @Dao（数据访问）

@Dao 定义所有数据操作：@Insert/@Update/@Delete 处理常规增删改，@Query 写自定义 SQL。返回 Flow 的方法具备响应式能力——表数据一变，UI 自动刷新：

Java
@Dao
public interface UserDao {

    // 同步查询
    @Query("SELECT * FROM user")
    List<User> getAll();

    // 响应式查询（数据变化自动推送）
    @Query("SELECT * FROM user")
    Flow<List<User>> observeAll();

    // 条件查询
    @Query("SELECT * FROM user WHERE age >= :minAge ORDER BY age DESC")
    List<User> getByAge(int minAge);

    // 插入：冲突策略（suspend → Java 中同步执行或包一层 Executor）
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    void insert(User user);

    @Update
    void update(User user);

    @Delete
    void delete(User user);

    // 自定义 SQL 更新
    @Query("UPDATE user SET name = :name WHERE id = :id")
    void rename(long id, String name);
}

2.3 @Database（数据库）

@Database 把实体和 DAO 组装成一个数据库入口：声明 entities、version，并提供单例 + 迁移注册。数据库升级必须写 Migration，否则版本不匹配会崩：

Java
@Database(
    entities = {User.class, Book.class},
    version = 2,                       // 当前版本
    exportSchema = true                // 导出 schema 用于迁移测试
)
public abstract class AppDatabase extends RoomDatabase {

    public abstract UserDao userDao();

    private static volatile AppDatabase INSTANCE;

    public static AppDatabase getInstance(Context context) {
        if (INSTANCE == null) {
            synchronized (AppDatabase.class) {
                if (INSTANCE == null) {
                    INSTANCE = Room.databaseBuilder(
                            context.getApplicationContext(),
                            AppDatabase.class,
                            "app.db"
                    )
                    .addMigrations(MIGRATION_1_2)   // 注册迁移
                    .build();
                }
            }
        }
        return INSTANCE;
    }

    // 数据库升级迁移（object 匿名对象 → 静态单例）
    public static final Migration MIGRATION_1_2 = new Migration(1, 2) {
        @Override
        public void migrate(SupportSQLiteDatabase db) {
            db.execSQL(
                "ALTER TABLE user ADD COLUMN avatar TEXT NOT NULL DEFAULT ''"
            );
        }
    };
}

3. 响应式查询：Flow

Room 对 Flow 的支持是最大亮点：DAO 方法返回 Flow/LiveData 后，任何表变化都会自动重新查询并推送，UI 侧只管订阅，不用手动刷新：

Java
// DAO 返回 LiveData（Java 中更常用；Kotlin 侧对应 Flow）
@Query("SELECT * FROM user WHERE id = :id")
LiveData<User> observeUser(long id);

// ViewModel 中使用（对应 stateIn：LiveData 自带缓存最新值 + 生命周期感知）
public class UserViewModel extends ViewModel {
    private final LiveData<User> user;

    public UserViewModel(UserDao dao) {
        user = dao.observeUser(1L);
    }

    public LiveData<User> getUser() {
        return user;
    }
}

// UI 观察
public class UserFragment extends Fragment {
    @Override
    public void onViewCreated(View view, Bundle savedInstanceState) {
        UserViewModel vm = new ViewModelProvider(this).get(UserViewModel.class);
        vm.getUser().observe(getViewLifecycleOwner(), user -> {
            // 任何表数据变化都会自动刷新
            binding.nameText.setText(user != null ? user.getName() : null);
        });
    }
}

原理：Room 在查询时注册 InvalidationTracker 观察者，表数据变化时自动 重新查询并推送新结果（增量查询，性能优化）。

4. 复杂查询技巧

4.1 返回部分列（DTO）

不想把整个表字段都查出来时，用 DTO 只取需要的列：

Java
public class UserName {
    public long id;
    public String name;

    public UserName(long id, String name) {
        this.id = id;
        this.name = name;
    }
}

@Query("SELECT id, name FROM user")
Flow<List<UserName>> observeNames();

4.2 关联查询（JOIN）

@Embedded + @Relation 组合实现"一查多"：一次查询返回用户和他的书列表，@Transaction 保证一致性：

Java
public class UserWithBooks {
    @Embedded
    public User user;

    @Relation(parentColumn = "id", entityColumn = "userId")
    public List<Book> books;
}

@Transaction
@Query("SELECT * FROM user")
Flow<List<UserWithBooks>> observeUsersWithBooks();

4.3 原生查询

@RawQuery 用于编译期无法确定 SQL 的场景（如动态拼接搜索条件）：

Java
@RawQuery
List<User> search(SupportSQLiteQuery statement);

// 调用
String kw = "Tom";
dao.search(new SimpleSQLiteQuery(
    "SELECT * FROM user WHERE name LIKE ?",
    new Object[]{"%" + kw + "%"}
));

5. Migration 与升级

5.1 为什么不能 fallbackToDestructiveMigration

  • fallbackToDestructiveMigration() 在版本不匹配时删表重建，用户数据全部丢失。
  • 生产环境必须手写 Migration。

5.2 迁移测试

迁移代码一定要测——用 MigrationTestHelper 模拟"老版本数据库 + 真实数据 → 执行迁移 → 校验数据还在"：

Java
@RunWith(AndroidJUnit4.class)
public class MigrationTest {

    @Test
    public void migrate1To2() {
        MigrationTestHelper helper = new MigrationTestHelper(
            InstrumentationRegistry.getInstrumentation(),
            AppDatabase.class
        );

        // 创建版本 1 的数据库并插入数据
        SupportSQLiteDatabase db = helper.createDatabase(TEST_DB, 1);
        db.execSQL("INSERT INTO user (name) VALUES ('Tom')");

        // 执行迁移
        db = helper.runMigrationsAndValidate(
            TEST_DB, 2, true, AppDatabase.MIGRATION_1_2
        );

        // 验证数据仍在（buildList → ArrayList）
        List<String> users = new ArrayList<>();
        try (Cursor cursor = db.query("SELECT * FROM user")) {
            while (cursor.moveToNext()) users.add(cursor.getString(1));
        }
        assertTrue(users.contains("Tom"));
    }
}

6. Room vs 原生 SQLite vs 其他 ORM

选型时从"校验时机、响应式支持、迁移管理"三个维度对比：

维度原生 SQLiteRoomGreenDAO
SQL 校验运行时编译期编译期
协程/Flow手写内置需扩展
迁移管理手写Migration 机制手写
学习成本高中中
维护状态-官方维护已停更

7. 高频面试题

Q1：Room 的编译期校验是如何实现的？ A：通过 APT（Annotation Processing Tool） 在编译期生成代码。RoomProcessor 解析 @Entity/@Dao/@Database，用 SQLite 语法分析器校验 SQL 语句，错误直接 编译失败，还生成 UserDao_Impl、AppDatabase_Impl 等实现类。

Q2：Room 的 Flow 查询为什么能自动更新？ A：InvalidationTracker 维护表级观察者。DAO 的 Flow 查询会注册 invalidate 监听； 任何增删改触发 invalidate 后，Room 在协程中重新执行查询并下发新结果。 （Room 2.4+ 做了增量优化，只重算受影响的行。）

Q3：主线程能用 Room 吗？ A：默认禁止（IllegalStateException），除非 .allowMainThreadQueries()（仅测试用）。 suspend DAO 方法会自动切到 RoomDatabase.getQueryExecutor()（IO 线程池）执行。

Q4：如何设计数据库升级？ A：① 新表：CREATE TABLE；② 加列：ALTER TABLE ADD COLUMN（需默认值）； ③ 改列/复杂变更：CREATE 新表 → 拷贝数据 → DROP 旧表 → RENAME； ④ 加 Migration 并注册；⑤ 写 MigrationTest 验证数据无损。

Q5：@Transaction 什么时候用？ A：需要保证原子性的多步操作（如"插入订单+更新库存"）、以及 @Relation 关联查询 （避免 N+1 查询）时使用。

8. 小结

  • Room = Entity + DAO + Database，编译期校验 + Flow + Migration。
  • 响应式查询靠 InvalidationTracker，升级靠 Migration 且必须写测试。
  • 面试重点：APT 原理、InvalidationTracker、Migration 设计。
总访问量–|GitHub|MIT License
Copyright © 2026 WikiAndroid