Android相关

Realm详解

2020-12-25  本文已影响0人  Topone

介绍

Realm 是一个 MVCC (多版本并发控制)数据库,由Y Combinator公司在2014年7月发布一款支持运行在手机、平板和可穿戴设备上的嵌入式数据库,目标是取代SQLite。
Realm 本质上是一个嵌入式数据库,他并不是基于SQLite所构建的。它拥有自己的数据库存储引擎,可以高效且快速地完成数据库的构建操作。和SQLite不同,它允许你在持久层直接和数据对象工作。在它之上是一个函数式风格的查询api,众多的努力让它比传统的SQLite 操作更快 。

优势

条件

使用

buildscript {
    repositories {
        jcenter()
    }
    dependencies {
        classpath "io.realm:realm-gradle-plugin:2.2.1"
    }
}

在module中加入

apply plugin: 'realm-android'

Realm从v1.0.0后,不支持Ecilpse,我们推荐使用Android Studio

创建model

创建一个User类,需要继承RealmObject。支持public, protected和 private的类以及方法

public class Favorites extends RealmObject {
    private String pic;
    private String name;
    private String price;
    private String title;

    public String getPic() {
        return pic;
    }

    public void setPic(String pic) {
        this.pic = pic;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPrice() {
        return price;
    }

    public void setPrice(String price) {
        this.price = price;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }
}

除了直接继承于RealmObject来声明 Realm 数据模型之外,还可以通过实现 RealmModel接口并添加 @RealmClass修饰符来声明。

@RealmClass
public class User implements RealmModel {
    ...
}
@PrimaryKey
private String id;
@Required
private String name;
@Ignore
private String name;
 > **注意**:如果你创建Model并运行过,然后修改了Model。那么就需要升级数据库,否则会抛异常。升级方式后面会提到

### **初始化**
使用默认配置
```java
        Realm.init(this);
        Realm mRealm = Realm.getDefaultInstance();

这时候会创建一个叫做 default.realm的Realm文件,一般来说,这个文件位于/data/data/包名/files/。通过realm.getPath()来获得该Realm的绝对路径。

注意:模拟器上运行时,Realm.getDefaultInstance()抛出异常,真机上没问题(不止何故)

当然,我们还可以使用RealmConfiguration来配置Realm

RealmConfiguration config = new RealmConfiguration.Builder() 
            .name("myrealm.realm") //文件名
            .schemaVersion(0) //版本号
            .build();
Realm realm = Realm.getInstance(config);

创建非持久化的Realm,也就是保持在内存中,应用关闭后就清除了。

RealmConfiguration myConfig = new RealmConfiguration.Builder(context) 
            .name("myrealm.realm")//保存在内存中
            .inMemory() .build();

RealmConfiguration支持的方法:

关闭Realm

记得使用完后,在onDestroy中关闭Realm

@Override 
protected void onDestroy() { 
    super.onDestroy();
    // Close the Realm instance. 
    realm.close(); 
}

在execute方法中执行插入操作

注意:如果在UI线程中插入过多的数据,可能会导致主线程拥塞。

final User user = new User();
        user.setName("Jack");
        user.setId("2");
        mRealm.executeTransaction(new Realm.Transaction() {
            @Override
            public void execute(Realm realm) {
                realm.copyToRealmOrUpdate(user);
            }
        });
public class User2 extends RealmObject {
      public String name;
      public int age;
}

就这样写

     mRealm.executeTransaction(new Realm.Transaction() {
            @Override
            public void execute(Realm realm) {
                User2 user = realm.createObject(User2.class);
                user.name = "Micheal";
                user.age = 30;
            }
        });
public class Dog extends RealmObject {
      private String name;
      private int age;
      //getters and setters
}

对应的User属性中加入Dog类

public class User extends RealmObject {
      private String name;
      private int age;
      private Dog dog;
      //getters and setters
}

如果你养了不止一只,你养了二哈、阿拉撕家...那你就要用到RealmList了。在User中加入该属性

private RealmList<Dog> dogs;

插入数据

    Realms.getRealm(CarActivity.this).executeTransaction(new Realm.Transaction() {
                    @Override
                    public void execute(Realm realm) {
                        Favorites favorites = realm.createObject(Favorites.class);
                        favorites.setName(info.getName());
                        favorites.setPic(info.getList_pic_url());
                        favorites.setPrice(info.getRetail_price());
                        favorites.setTitle(info.getGoods_brief());

                        Log.e("TAG", "execute: "+info.getName()+info.getList_pic_url() );
                    }
                });
mRealm.beginTransaction();//开启事务
User user = mRealm.createObject(User.class);
user.setName("Gavin");
user.setId("3");
mRealm.commitTransaction();//提交事务

在插入前,先调用beginTransaction(),完成后调用commitTransaction()即可。

注意:在UI和后台线程同时开启创建write的事务,可能会导致ANR错误。为了避免该问题,可以使用executeTransactionAsync来实现。

RealmAsyncTask transaction = mRealm.executeTransactionAsync(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
        User user = realm.createObject(User.class);
        user.setName("Eric");
        user.setId("4");
      }
});

还可以加入监听

RealmAsyncTask transaction =  mRealm.executeTransactionAsync(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
        User user = realm.createObject(User.class);
        user.setName("Eric");
        user.setId("4");
      }
}, new Realm.Transaction.OnSuccess() {
    @Override
    public void onSuccess() {
        //成功回调
      }
}, new Realm.Transaction.OnError() {
    @Override
    public void onError(Throwable error) {
        //失败回调
      }
});

注意:如果当Acitivity或Fragment被销毁时,在OnSuccess或OnError中执行UI操作,将导致程序奔溃 。用RealmAsyncTask .cancel();可以取消事务
在onStop中调用,避免crash

public void onStop () {
    if (transaction != null && !transaction.isCancelled()) {
        transaction.cancel();
      }
}
// 一个city model
public class City extends RealmObject {
    private String city;
    private int id;
    // getters and setters left out ...
}
// 使用Json字符串插入数据
realm.executeTransaction(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
        realm.createObjectFromJson(City.class, "{ city: \"Copenhagen\", id: 1 }");
    }
});
// 使用InputStream插入数据
realm.executeTransaction(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
        try {
            InputStream is = new FileInputStream(new File("path_to_file"));
            realm.createAllFromJson(City.class, is);
        } catch (IOException e) {
            throw new RuntimeException();
        }
    }
});

Realm 解析 JSON 时遵循如下规则:

查找操作就比插入方便多了,并不需在事务中操作,直接查询即可。

RealmResults<User> userList = mRealm.where(User.class).findAll();

这里使用RealmResults来接受查询到的结果,突然出现的RealmResults可能会让人懵逼。看看他的源码,发现RealmResults继承了AbstractList,而AbstractList又实现了List接口。好吧,原来实现了我们熟悉的List接口。

public final class RealmResults<E extends RealmModel> extends AbstractList<E>

public abstract class AbstractList<E> extends AbstractCollection<E> implements List<E>

@Override
@Deprecated
public boolen add(E element){
           throw new UnsupportedoperationException(NOT_SUPPORTED_MESSAGE);
}

注意:RealmResults虽然实现了List接口,不过有很多方法是不能用的。比如add、addAll、remove、clear等,调用后会直接抛异常。不过也不用当心误用这些方法,因为它们都被标记为@Deprecated了。

        RealmResults<User> userList = mRealm.where(User.class)
                .equalTo("name", "Gavin")
                .findAllAsync();

值得注意的是,这里并不会马上查到数据,是有一定延时的。也就是说,你马上使用userList的时候,里面是没有数据的。可以注册RealmChangeListener监听器,或者使用isLoaded()方法,判断是否查询完成

if (result.isLoaded()) {
     // 完成查询
}
User user2 = mRealm.where(User.class).findFirst();
RealmResults<User> userList = mRealm.where(User.class)
            .equalTo("name", "Gavin").findAll();

如果User中还有Dog属性,希望根据Dog的条件来获取用户:
例:查询dogs.name为二哈的User

RealmResults<User> userList = mRealm.where(User.class)
             .equalTo("dogs.name", "二哈").findAll();

得到有养有dogs.name为"二哈"的用户列表(这里的dogs是User表中的属性名)

RealmResults<User> userList = mRealm.where(User.class)
            .equalTo("name", "Gavin").findAll();
RealmResults<User> userList = user5.where()
            .equalTo("dogs.name", "二哈").findAll();

上面先找到name为“Gavin”的User列表,然后再得到的结果中查询dogs.name为“二哈”
觉得这样写太麻烦?我也是这样想的,所以还可以这样写

RealmResults<User> userList = mRealm.where(User.class)
            .equalTo("name", "Gavin")
            .equalTo("dogs.name", "二哈")
            .findAll();
RealmQuery<User> query = mRealm.where(User.class);
query.equalTo("name", "Gavin");
query.or().equalTo("name", "Eric");
RealmResults<User> userList = query.findAll();

这种情况下就要用到or()方法
这么一大串,你又觉得麻烦了?没事,继续简化。

RealmResults<User> userList = mRealm.where(User.class)
            .equalTo("name", "Gavin")
            .or().equalTo("name", "Eric")
            .findAll();

Tip:查询的时候你不用当心得到的RealmResults为null。如果查询的结果为空,那么RealmResults的size为0

RealmResults<User> userList = mRealm.where(User.class) .findAll();
userList = result.sort("age"); //根据age,正序排列
userList = result.sort("age", Sort.DESCENDING);//逆序排列
RealmResults<User> results = realm.where(User.class).findAll();
long   sum     = results.sum("age").longValue();
long   min     = results.min("age").longValue();
long   max     = results.max("age").longValue();
double average = results.average("age");
long   matches = results.size();

mRealm.executeTransaction(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
        //先查找后得到User对象
        User user = mRealm.where(User.class).findFirst();
        user.setAge(26);
    }
});

修改也是需要在事务中操作。
使用查询语句得到数据,然后将内容改了即可。

//先查找到数据
final RealmResults<User> userList = mRealm.where(User.class).findAll();
mRealm.executeTransaction(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
        userList.get(0).deleteFromRealm();
    }
});
mRealm.executeTransaction(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
        userList.deleteFromRealm(0);
    }
});

-更多方法:

userList.deleteFirstFromRealm(); //删除user表的第一条数据
userList.deleteLastFromRealm();//删除user表的最后一条数据
results.deleteAllFromRealm();//删除user表的全部数据

版本升级

当数据结构发生变化是,需要升级数据库。对于Realm来说,数据库升级就是迁移操作,把原来的数据库迁移到新结构的数据库。(体验:略麻烦)

例1:User类发生变化,移除age,新增个@Required的id字段。
User版本:version 0

String name;
int    age;

创建迁移类CustomMigration,需要实现RealmMigration接口。执行版本升级时的处理:

 /**
     * 升级数据库
     */
    class CustomMigration implements RealmMigration {
        @Override
        public void migrate(DynamicRealm realm, long oldVersion, long newVersion) {
            RealmSchema schema = realm.getSchema();
            if (oldVersion == 0 && newVersion == 1) {
                RealmObjectSchema personSchema = schema.get("User");
                //新增@Required的id
                personSchema
                        .addField("id", String.class, FieldAttribute.REQUIRED)
                        .transform(new RealmObjectSchema.Function() {
                            @Override
                            public void apply(DynamicReal
mObject obj) {
                                obj.set("id", "1");//为id设置值
                            }
                        })
                        .removeField("age");//移除age属性
                oldVersion++;
            }
        }
    }

使用Builder.migration升级数据库,将版本号改为1(原版本号:0)。当Realm发现新旧版本号不一致时,会自动使用该迁移类完成迁移操作。

RealmConfiguration config = new RealmConfiguration.Builder() 
            .name("myrealm.realm") //文件名
            .schemaVersion(1) 
            .migration(new CustomMigration())//升级数据库
            .build();

例2:加入Dog类,User中加入Dog集合。
User版本:version 1

@Required
String    id;
String name;

User版本:version 2

@Required
private String id;
private String name;
private RealmList<Dog> dogs;

Dog类

public class Dog extends RealmObject {
        private String name;
        private int age;
}

在迁移类CustomMigration中,继续添加处理方法。

  if (oldVersion == 1 && newVersion == 2) {
                //创建Dog表
                RealmObjectSchema dogSchema = schema.create("Dog");
                dogSchema.addField("name", String.class);
                dogSchema.addField("age", int.class);

                //User中添加dogs属性
                schema.get("User")
                        .addRealmListField("dogs", dogSchema)
                        .transform(new RealmObjectSchema.Function() {
                            @Override
                            public void apply(DynamicRealmObject obj) {
                                //为已存在的数据设置dogs数据
                                DynamicRealmObject dog = realm.createObject("Dog");
                                dog.set("name", "二哈");
                                dog.set("age", 2);
                                obj.getList("dogs").add(dog);
                            }
                        });
                oldVersion++;
            }

更多用法——RealmObjectSchema
例:取消id必填:

personSchema.setNullable("id", true):

例:移除id字段

personSchema.removeField("id");

例:重命名

personSchema..renameField("id", "userId");

personSchema..renameField("id", "userId");
更多用法——DynamicRealmObject
例:获取id

String id = obj.getString("id");

例:为字段设置值

obj.setString("name", "Gavin");
obj.setInt("id", 1);
obj.setLong("id", 1);
上一篇 下一篇

猜你喜欢

热点阅读