Android Room的使用

Room其实就是一个orm，抽象了SQLite的使用，原生支持LiveData和Rxjava嵌套使用。

Room有3个主要组件

Database ：数据库
Entity : 代表数据库一个表结构
Dao : 包含访问数据库的方法

简单使用

添加依赖

dependencies {// Roomimplementation "android.arch.persistence.room:runtime:1.0.0"annotationProcessor "android.arch.persistence.room:compiler:1.0.0"
}

定义数据表实体类

当一个类用@Entity注解并且被@Database注解中的entities属性所引用，Room就会在数据库中为那个entity创建一张表。

Room默认把类名作为数据库的表名。如果你想用其它的名称，使用@Entity注解的tableName属性。

默认Room会为entity中定义的每一个field都创建一个column。和tableName属性类似，Room默认把field名称作为数据库表的column名。如果你想让column有不一样的名称，为field添加@ColumnInfo属性。如果一个entity中有你不想持久化的field，那么你可以使用@Ignore来注释它们。

要持久化一个field，Room必须有获取它的渠道。你可以把field写成public，也可以为它提供一个setter和getter。如果你使用setter和getter的方式，记住它们要基于Room的Java Bean规范。

每个entity必须至少定义一个field作为主键（primary key）。即使只有一个field，你也必须用@PrimaryKey注释这个field。如果你想让Room为entity设置自增ID，你可以设置@PrimaryKey的autoGenerate属性。如果你的entity有一个组合主键，你可以使用@Entity注解的primaryKeys属性。

@Entity(tableName = "tb_class")
public class ClassEntity {@PrimaryKeyprivate long id;
}

//指示数据表实体类
@Entity(tableName = "tb_student",//定义表名indices = @Index(value = {"name", "sex"}, unique = true),//定义索引foreignKeys = {@ForeignKey(entity = ClassEntity.class,parentColumns = "id",childColumns = "class_id")})//定义外键
public class StudentEntity {@PrimaryKey //定义主键private long id;@ColumnInfo(name = "name")//定义数据表中的字段名private String name;@ColumnInfo(name = "sex")private int sex;@Ignore//指示Room需要忽略的字段或方法private String ignoreText;@ColumnInfo(name = "class_id")private String class_id;//setter and getter
}

Index索引注解可选参数

public @interface Index {//定义需要添加索引的字段String[] value();//定义索引的名称String name() default "";//true-设置唯一键，标识value数组中的索引字段必须是唯一的，不可重复boolean unique() default false;
}

ForeignKey外键注解可选参数

public @interface ForeignKey {//引用外键的表的实体Class entity();//要引用的外键列String[] parentColumns();//要关联的列String[] childColumns();//当父类实体(关联的外键表)从数据库中删除时执行的操作@Action int onDelete() default NO_ACTION;//当父类实体(关联的外键表)更新时执行的操作@Action int onUpdate() default NO_ACTION;//在事务完成之前，是否应该推迟外键约束boolean deferred() default false;//给onDelete，onUpdate定义的操作int NO_ACTION = 1;int RESTRICT = 2;int SET_NULL = 3;int SET_DEFAULT = 4;int CASCADE = 5;@IntDef({NO_ACTION, RESTRICT, SET_NULL, SET_DEFAULT, CASCADE})@interface Action {}
}

定义Dao类

@Dao
public interface StudentDao {@Query("SELECT * FROM StudentEntity")List<StudentEntity> getAll();@Query("SELECT * FROM StudentEntity WHERE id IN (:ids)")List<StudentEntity> getAllByIds(long[] ids);@Insertvoid insert(StudentEntity... entities);@Deletevoid delete(StudentEntity entity);@Updatevoid update(StudentEntity entity);
}

@insert， @Update都可以执行事务操作，定义在OnConflictStrategy注解类中

public @interface Insert {//定义处理冲突的操作@OnConflictStrategyint onConflict() default OnConflictStrategy.ABORT;
}

public @interface OnConflictStrategy {//策略冲突就替换旧数据int REPLACE = 1;//策略冲突就回滚事务int ROLLBACK = 2;//策略冲突就退出事务int ABORT = 3;//策略冲突就使事务失败 int FAIL = 4;//忽略冲突int IGNORE = 5;
}

定义数据库

@Database(entities = {StudentEntity.class}, version = 1)
public abstract class RoomDemoDatabase extends RoomDatabase {public abstract StudentDao studentDao();
}

生成数据库实例

RoomDemoDatabase database = Room.databaseBuilder(getApplicationContext(),RoomDemoDatabase.class, "database_name").build();

生成数据库实例的其他操作

Room.databaseBuilder(getApplicationContext(),RoomDemoDatabase.class, "database_name").addCallback(new RoomDatabase.Callback() {//第一次创建数据库时调用，但是在创建所有表之后调用的@Overridepublic void onCreate(@NonNull SupportSQLiteDatabase db) {super.onCreate(db);}//当数据库被打开时调用@Overridepublic void onOpen(@NonNull SupportSQLiteDatabase db) {super.onOpen(db);}}).allowMainThreadQueries()//允许在主线程查询数据.addMigrations()//迁移数据库使用，下面会单独拿出来讲.fallbackToDestructiveMigration()//迁移数据库如果发生错误，将会重新创建数据库，而不是发生崩溃.build();

数据库迁移(升级)

Room.databaseBuilder(getApplicationContext(), MyDb.class, "database-name").addMigrations(MIGRATION_1_2, MIGRATION_2_3).build();static final Migration MIGRATION_1_2 = new Migration(1, 2) {@Overridepublic void migrate(SupportSQLiteDatabase database) {database.execSQL("CREATE TABLE `Fruit` (`id` INTEGER, "+ "`name` TEXT, PRIMARY KEY(`id`))");}
};static final Migration MIGRATION_2_3 = new Migration(2, 3) {@Overridepublic void migrate(SupportSQLiteDatabase database) {database.execSQL("ALTER TABLE Book "+ " ADD COLUMN pub_year INTEGER");}
};

创建嵌套对象

有时，您希望将一个实体或普通的以前的Java对象(POJO)作为数据库逻辑中的一个完整的整体来表示，即使该对象包含几个字段。在这些情况下，您可以使用@Embedded来表示一个对象，您希望将其分解为表中的子字段。然后可以像对其他单个列一样查询嵌入式字段。

class Address {public String street;public String state;public String city;@ColumnInfo(name = "post_code")public int postCode;
}@Entity
class User {@PrimaryKeypublic int id;public String firstName;@Embeddedpublic Address address;
}

这样user表中的字段就包含了id, firstName, street, state, city, 和 post_code

注意：嵌入式字段还可以包含其他嵌入式字段

如果一个实体具有相同类型的多个内嵌字段，则可以通过设置前缀属性(prefix)使每个列保持惟一。然后将所提供的值添加到嵌入对象中每个列名的开头。

@Embedded(prefix = "foo_")Coordinates coordinates;

和`LiveData`一起使用

添加依赖

// ReactiveStreams support for LiveDataimplementation "android.arch.lifecycle:reactivestreams:1.0.0"

修改返回类型

@Dao
public interface MyDao {@Query("SELECT first_name, last_name FROM user WHERE region IN (:regions)")public LiveData<List<User>> loadUsersFromRegionsSync(List<String> regions);
}

和RxJava一起使用

添加依赖

// RxJava support for Roomimplementation "android.arch.persistence.room:rxjava2:1.0.0"

修改返回类型

@Dao
public interface MyDao {@Query("SELECT * from user where id = :id LIMIT 1")public Flowable<User> loadUserById(int id);
}

直接游标访问

@Dao
public interface MyDao {@Query("SELECT * FROM user WHERE age > :minAge LIMIT 5")public Cursor loadRawUsersOlderThan(int minAge);
}

类型转换

定义转换类，@TypeConverter注解定义转换的方法

public class Converters {@TypeConverterpublic static Date fromTimestamp(Long value) {return value == null ? null : new Date(value);}@TypeConverterpublic static Long dateToTimestamp(Date date) {return date == null ? null : date.getTime();}
}

@TypeConverters注解，告知数据库要依赖哪些转换类

@Database(entities = {User.class}, version = 1)
@TypeConverters({Converters.class})
public abstract class AppDatabase extends RoomDatabase {public abstract UserDao userDao();
}

使用这些转换器，您可以在其他查询中使用您的自定义类型，正如您将使用基本类型一样，如下代码所示

@Entity
public class User {...private Date birthday;
}

@Dao
public interface UserDao {...@Query("SELECT * FROM user WHERE birthday BETWEEN :from AND :to")List<User> findUsersBornBetweenDates(Date from, Date to);
}

输出模式

在编译时，将数据库的模式信息导出到JSON文件中，这样可有利于我们更好的调试和排错

build.gradle

android {...defaultConfig {...javaCompileOptions {annotationProcessorOptions {arguments = ["room.schemaLocation":"$projectDir/schemas".toString()]}}}
}

您应该将导出的JSON文件(表示数据库的模式历史记录)存储在您的版本控制系统中，因为它允许为测试目的创建您的数据库的旧版本