美文网首页
Android随笔之Realm

Android随笔之Realm

作者: 圈圈猫 | 来源:发表于2016-11-10 16:11 被阅读1477次

           在Android中数据的存储无非就这么几种,数据库、sharedpreference、文件、内存、网络、内容提供者也算一个。sharedpreference结构是类似XML键值对方式存储的,然后和文件一样,如果用于查找数据就明显是鸡肋了。这个时候就需要使用sqlite,sqlite可以满足大部分用于的查询要求,但使用它的病垢就是代码量太多了。

    因此在这样的环境下realm就诞生了,realm可以和当下流行的网络框架retrofit和异步框架rxjava配合使用。

    接下来看使用方法:

    一、在projeect的gradle文件中添加这样一句。注意:是工程的gradle,不是app的gradle。

    二、在到app下的gradle头部添加

    三、写一个java实体类。继承RealmObject,对于主键可以添加注解@PrimaryKey,,对于@Required是必填的意思。@Ignore即是忽略的。

    /**

    * Created by hmh on 2016/11/7.

    *实体类、属性类似于字段

    */

    public classUserextendsRealmObject{

    @PrimaryKey

    private intid;//主键

    @Required

    privateStringuserName;//用户名,不能为空

    private intuserAge;//年龄

    privateStringuserAdress;//地址

    privateStringuserWork;//工作

    privateStringuserSex;//性别

    @Ignore//忽略

    private booleanisHasFriend;//是否有男女朋友

    publicUser(){}

    publicUser(intid, String userName,intuserAge, String userAdress, String userWork, String userSex,booleanisHasFriend) {

    this.id= id;

    this.userName= userName;

    this.userAge= userAge;

    this.userAdress= userAdress;

    this.userWork= userWork;

    this.userSex= userSex;

    this.isHasFriend= isHasFriend;

    }

    public intgetId() {

    returnid;

    }

    public voidsetId(intid) {

    this.id= id;

    }

    publicString getUserName() {

    returnuserName;

    }

    public voidsetUserName(String userName) {

    this.userName= userName;

    }

    public intgetUserAge() {

    returnuserAge;

    }

    public voidsetUserAge(intuserAge) {

    this.userAge= userAge;

    }

    publicString getUserAdress() {

    returnuserAdress;

    }

    public voidsetUserAdress(String userAdress) {

    this.userAdress= userAdress;

    }

    publicString getUserWork() {

    returnuserWork;

    }

    public voidsetUserWork(String userWork) {

    this.userWork= userWork;

    }

    publicString getUserSex() {

    returnuserSex;

    }

    public voidsetUserSex(String userSex) {

    this.userSex= userSex;

    }

    public booleanisHasFriend() {

    returnisHasFriend;

    }

    public voidsetHasFriend(booleanhasFriend) {

    isHasFriend= hasFriend;

    }

    }

    四、初始化,写成了一个工具类RealmUtils工具类

    /**

    * Created by hmh on 2016/11/7.

    *配置数据库,也可以在application的onCreate配置

    */

    public classRealmUtils {

    privateContextcontext;

    private staticRealmUtilsmInstance;

    privateStringrealName="myRealm.realm";

    publicRealmUtils(Context context){

    this.context= context;

    }

    /**单例方式*/

    public staticRealmUtils getInstance(Context context){

    if(mInstance==null){

    synchronized(RealmUtils.class){

    if(mInstance==null){

    mInstance=newRealmUtils(context);

    }

    }

    }

    returnmInstance;

    }

    /***获得realm对象*/

    publicRealm getRealm(){

    returnRealm.getInstance(newRealmConfiguration.Builder(context).name(realName).build());

    }

    }

    五、在看基本操作,先写一个Dao接口,将需要操作的方式,用方法的方式,注释已经写的很清楚了

    /**

    * Created by hmh on 2016/11/7.

    *操作数据库接口的Dao

    *

    */

    public interfaceUserDao {

    /**插入一个用户

    *@paramuser需要插入的用户对象

    * */

    voidinsert(User user)throwsSQLException;

    /**

    *获得所有的用户

    *

    * */

    List getAllUser()throwsSQLException;

    /**

    *更新一个用户

    *@paramuser需要更新的用户类

    *@return跟新后的对象

    * */

    User updateUser(User user)throwsSQLException;

    /***

    *根据姓名修改新姓名

    *@paramname1老名字

    *@paramname2新名字

    *@throwsSQLException

    * */

    voidupdateUser(String name1, String name2)throwsSQLException;

    /***

    *根据id删除用户

    *@paramid用户主键id

    * */

    voiddeleteUser(intid)throwsSQLException;

    /**

    *异步添加用户

    *@paramuser需要添加的用户

    *@throwsSQLException

    * */

    voidinsertUserAsync(User user)throwsSQLException;

    /***

    *按名字或者年龄查找第一个User

    *@paramname1用户名字

    *@paramage1用户年龄

    * */

    User findByNameOrAge(String name1,intage1)throwsSQLException;

    /***

    *清除所有用户

    * */

    voiddeleteAll()throwsSQLException;

    /**关闭事务*/

    voidcloseRealm();

    }

    六、写一个类,继承上面的Dao的接口;

    /**

    * Created by hmh on 2016/11/7.

    */

    public classUserDaoImplimplementsUserDao {

    privateContextcontext;

    privateRealmmRealms;

    publicUserDaoImpl(Context context){

    //取得数据库对象

    mRealms= RealmUtils.getInstance(context).getRealm();

    }

    /**同步插入用户*/

    @Override

    public voidinsert(User user)throwsSQLException {

    mRealms.beginTransaction();//必须先开启事务

    //        User user1 = mRealms.copyFromRealm(user);  //吧User对象复制到realm

    User user1 =mRealms.copyToRealm(user);

    mRealms.commitTransaction();//提交事务

    //        mRealms.close();        //必须关闭,否则容易造成内存泄漏

    }

    /**返回所有的User对象,并按照名字的首字母排序*/

    @Override

    publicList getAllUser()throwsSQLException {

    List list =null;

    RealmResults results =mRealms.where(User.class).findAll();

    //        results.sort("userName", Sort.DESCENDING); //针对字符串的排序,但目前并不是支持所有字符集

    list = results;

    //        mRealms.close();    //关闭

    returnresults;

    }

    /***更新一个User*/

    @Override

    publicUser updateUser(User user)throwsSQLException {

    mRealms.beginTransaction();//开启事务

    User user1 =mRealms.copyToRealmOrUpdate(user);//用户信息更新到realm

    mRealms.commitTransaction();//提交事务

    //        mRealms.close();        //关闭事务

    returnuser1;

    }

    /**根据姓名修改姓名*/

    @Override

    public voidupdateUser(String name1, String name2)throwsSQLException {

    //1、开启事务

    mRealms.beginTransaction();

    //2、执行,查询出name和name的User对象对比

    mRealms.where(User.class).equalTo("userName", name1)

    .findFirst()

    .setUserName(name2);//吧新名字和查处的名字替换

    //3、提交事务

    mRealms.commitTransaction();

    //4、关闭事务

    //        mRealms.close();

    }

    /**根据用户的id删除一个用户*/

    @Override

    public voiddeleteUser(intid)throwsSQLException {

    User id1 =mRealms.where(User.class).equalTo("userId", id).findFirst();

    //开启事务

    mRealms.beginTransaction();

    id1.deleteFromRealm();//从数据库中删除

    //提交事务

    mRealms.commitTransaction();

    //        mRealms.close();

    }

    /**异步插入User

    *注意:  一个Realm只能在同一个线程访问,在子线程中进行数据库操作必须重新

    *获取realm对象。

    *

    * */

    @Override

    public voidinsertUserAsync(finalUser user)throwsSQLException {

    mRealms.executeTransaction(newRealm.Transaction() {

    @Override

    public voidexecute(Realm realm) {

    //开启事务

    mRealms.beginTransaction();

    User user1 =mRealms.copyToRealm(user);

    //提交事务

    mRealms.commitTransaction();

    mRealms.close();//关闭事务

    }

    });

    //外部也需要关闭事务。

    //        mRealms.close();

    }

    /**返回第一个指定名字或者年龄的对象*/

    @Override

    publicUser findByNameOrAge(String name1,intage1)throwsSQLException {

    User user =mRealms.where(User.class)

    .equalTo("userName", name1)//相当于where name = name1

    .or()//或。连接查询条件,没有这个方法时会默认是&连接

    .equalTo("userAge", age1)//相当于where age = age1;

    .findFirst();

    //整体相当于select * from(表明) where name = name1 or age = age1 limit 1;

    //关闭数据库

    //        mRealms.close();

    returnuser;

    }

    /***删除所有*/

    @Override

    public voiddeleteAll()throwsSQLException {

    //开启事务

    mRealms.beginTransaction();

    mRealms.where(User.class).findAll().deleteAllFromRealm();

    //提交事务iu

    mRealms.commitTransaction();

    //        mRealms.close();

    }

    @Override

    public voidcloseRealm() {

    mRealms.close();

    }

    }

    注意:close是必须调用的,不然容易造成内存泄漏。

    七、简单的调用:

    public classMainActivityextendsAppCompatActivity {

    privateUserDaouserDao;

    privateTextViewmMsg;

    private booleans=false;

    private static final intTYPE_SHOW=1;//显示加减

    private static final intTYPE_HIDE=2;//隐藏加减

    private intcurrentStatic=TYPE_HIDE;//默认隐藏

    @Override

    protected voidonCreate(Bundle savedInstanceState) {

    super.onCreate(savedInstanceState);

    setContentView(R.layout.activity_main);

    mMsg= (TextView) findViewById(R.id.addAll);

    mMsg.setOnClickListener(newView.OnClickListener() {

    @Override

    public voidonClick(View view) {

    if(s){

    //显示加减

    s=false;

    }else{

    //隐藏加减

    s=true;

    }

    }

    });

    //获取对象

    userDao=newUserDaoImpl(this);

    try{

    //删除所有

    userDao.deleteAll();

    User user =newUser();

    user.setId(10);

    user.setUserName("王尼玛");

    user.setUserAge(22);

    user.setUserAdress("广州");

    user.setUserSex("男");

    user.setUserWork("嫖妓");

    user.setHasFriend(true);

    userDao.insert(user);

    for(inti =0; i <5; i++){

    userDao.insert(newUser(i,"屌丝",11,"水利","工程","男",false));

    }

    Log.e("123",userDao.getAllUser().toString());

    mMsg.setText(""+userDao.getAllUser().toString());

    Log.e("123",userDao.findByNameOrAge("王尼玛",66)+"查询一");

    Log.e("123","查询二:"+userDao.findByNameOrAge("狗子",11));

    userDao.updateUser("屌丝","二狗子");

    Log.e("123",userDao.getAllUser()+"//");

    }catch(SQLException e) {

    e.printStackTrace();

    }

    }

    }

    总结:

    1)、修改,插入和删除操作均必须在一个完整的事务中,在更新操作中,我们可以通过copyToRealmOrUpdate来做,但是官方更推荐我们用先查询出来后更新的方法,上面代码也有提到。

    2)、该事务确保多个实例(在多个线程中)可以在一个一致的状态和保证事务在ACID前提下,访问相同的对象。

    3)、当一个Realm实例操作完成后,一定一定要记住调用close()方法,否则导致了本地资源无法释放。

    4)、Realm实例不能不在不同的线程间访问操作,所以在异步插入里面打开了一个新的实例,当然也得关掉它!

    5)、对于UI线程来说。打开和关闭Realm实例,应当放在onCreate/onDestory或者onPause/onStop方法中。

    6)、在不同的线程间,Realm实例使用Handler机制来调整它的状态。也就是说,Realm实例在线程中,如果没有Looper,是不能收到更新通知的。除非手动调用waitForChange方法。

    7)、重点注意:Realm数据库的主键字段不是自动增长的,并且不支持设置数据的自增。需要自己设置,做添加的时候如果不给id字段值,默认为是0。后面再添加的话会报错说id为0的字段已经存在。尤其是批量添加的时候要注意,当心出现只添加了一条记录的悲剧!

    8)、数据自动更新。可以通过调用addChangeListener(context)来做。当数据库的数据有变化时,系统会自动回调此方法

    注:文章出处来自:http://www.cnblogs.com/liushilin/p/5752099.html,支持原创。

    在此附上源码:https://github.com/huaminghui/DefineDemo/tree/master

    相关文章

      网友评论

          本文标题:Android随笔之Realm

          本文链接:https://www.haomeiwen.com/subject/meatpttx.html