GreenDao与ReactiveX的完美搭配

BAT 批处理程序 2017-04-16

作为Android开发者，一定不会对 GreenDao 和 ReactiveX 陌生。

GreenDao   号称Android最快的关系型数据库

GreenDao与ReactiveX的完美搭配

ReactiveX    Rx是一个编程模型,目标是提供一致的编程接口,帮助开发者更方便的处理异步数据流。

GreenDao与ReactiveX的完美搭配

下面我们就通过一个实例，来讲解有无Rx支持的时候GreenDao应该怎么用，实现增删操作。

GreenDao与ReactiveX的完美搭配

首先导入需要的库(本文针对的 GreenDao 是 3.x 版本， Rx 是 1.x 版本)

GreenDao导入需求库的说明: https://github.com/greenrobot/greenDAO/

在 build.gradle(Project:Xxx) 下，添加：

buildscript {
    repositories {
        ...
        mavenCentral()
        ...
    }
    dependencies {
        ...
        classpath 'org.greenrobot:greendao-gradle-plugin:3.2.2'
        ...
    }
}

在 build.gradle(Module:Xxx) 下，添加：

...
apply plugin: 'org.greenrobot.greendao'
...
dependencies {
    ...
    compile 'org.greenrobot:greendao:3.2.2'
    ...
}

Rx导入需求库的说明: https://github.com/ReactiveX/RxJava/tree/1.x

在 build.gradle(Module:Xxx) 下，添加：

dependencies {
    ...
    compile 'io.reactivex:rxjava:1.2.9'
    compile 'io.reactivex:rxandroid:1.2.1'
    ...
}

需求库添加完之后就可以进入正题了

1.参考GreenDao官方文档，添加必要的类 Note 、 NotesAdapter 、 NoteType 、 NoteTypeConverter

Note :

/**
 * Entity mapped to table "NOTE".
 */
@Entity(indexes = {
        @Index(value = "text, date DESC", unique = true)
})
public class Note {

    @Id
    private Long id;

    @NotNull
    private String text;
    private String comment;
    private java.util.Date date;

    @Convert(converter = NoteTypeConverter.class, columnType = String.class)
    private NoteType type;

    @Generated(hash = 1272611929)
    public Note() {
    }

    public Note(Long id) {
        this.id = id;
    }

    @Generated(hash = 1686394253)
    public Note(Long id, @NotNull String text, String comment, java.util.Date date, NoteType type) {
        this.id = id;
        this.text = text;
        this.comment = comment;
        this.date = date;
        this.type = type;
    }

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    @NotNull
    public String getText() {
        return text;
    }

    /**
     * Not-null value; ensure this value is available before it is saved to the database.
     */
    public void setText(@NotNull String text) {
        this.text = text;
    }

    public String getComment() {
        return comment;
    }

    public void setComment(String comment) {
        this.comment = comment;
    }

    public java.util.Date getDate() {
        return date;
    }

    public void setDate(java.util.Date date) {
        this.date = date;
    }

    public NoteType getType() {
        return type;
    }

    public void setType(NoteType type) {
        this.type = type;
    }

}

NotesAdapter :

public class NotesAdapter extends RecyclerView.Adapter<NotesAdapter.NoteViewHolder> {

    private NoteClickListener clickListener;
    private List<Note> dataset;

    public interface NoteClickListener {
        void onNoteClick(int position);
    }

    static class NoteViewHolder extends RecyclerView.ViewHolder {

        public TextView text;
        public TextView comment;

        public NoteViewHolder(View itemView, final NoteClickListener clickListener) {
            super(itemView);
            text = (TextView) itemView.findViewById(R.id.textViewNoteText);
            comment = (TextView) itemView.findViewById(R.id.textViewNoteComment);
            itemView.setOnClickListener(new View.OnClickListener() {
                @Override
                public void onClick(View view) {
                    if (clickListener != null) {
                        clickListener.onNoteClick(getAdapterPosition());
                    }
                }
            });
        }
    }

    public NotesAdapter(NoteClickListener clickListener) {
        this.clickListener = clickListener;
        this.dataset = new ArrayList<Note>();
    }

    public void setNotes(@NonNull List<Note> notes) {
        dataset = notes;
        notifyDataSetChanged();
    }

    public Note getNote(int position) {
        return dataset.get(position);
    }

    @Override
    public NotesAdapter.NoteViewHolder onCreateViewHolder(ViewGroup parent, int viewType) {
        View view = LayoutInflater.from(parent.getContext())
                .inflate(R.layout.item_note, parent, false);
        return new NoteViewHolder(view, clickListener);
    }

    @Override
    public void onBindViewHolder(NotesAdapter.NoteViewHolder holder, int position) {
        Note note = dataset.get(position);
        holder.text.setText(note.getText());
        holder.comment.setText(note.getComment());
    }

    @Override
    public int getItemCount() {
        return dataset.size();
    }
}

NoteType :

public enum NoteType {
    TEXT, LIST, PICTURE
}

NoteTypeConverter :

public class NoteTypeConverter implements PropertyConverter<NoteType, String> {
    @Override
    public NoteType convertToEntityProperty(String databaseValue) {
        return NoteType.valueOf(databaseValue);
    }

    @Override
    public String convertToDatabaseValue(NoteType entityProperty) {
        return entityProperty.name();
    }
}

必要的类添加之后，接下来就是重头戏：

用代码说话，横向比较 GreenDao 在有无 Rx 的支持下应该如何书写

1.初始化类

无 Rx 写法                                                

private NoteDao noteDao;
private Query<Note> notesQuery;

 有 Rx 写法

private RxDao<Note, Long> noteDao;
private RxQuery<Note> notesQuery;

2.将记录保存到DAO里

无 Rx 写法 

DaoSession daoSession = ((BaseApplication) getApplication()).getDaoSession();
noteDao = daoSession.getNoteDao();

有 Rx 写法

DaoSession daoSession = ((BaseApplication) getApplication()).getDaoSession();
noteDao = daoSession.getNoteDao().rx();

3.查询所有记录，按A-Z分类

无 Rx 写法

notesQuery = noteDao.queryBuilder().orderAsc(NoteDao.Properties.Text).build();

有 Rx 写法

notesQuery = daoSession.getNoteDao().queryBuilder().orderAsc(NoteDao.Properties.Text).rx();

4.初始化View

无 Rx 写法

protected void setUpViews() {
        RecyclerView recyclerView = (RecyclerView) findViewById(R.id.recyclerViewNotes);
        //noinspection ConstantConditions
        recyclerView.setHasFixedSize(true);
        recyclerView.setLayoutManager(new LinearLayoutManager(this));

        notesAdapter = new NotesAdapter(noteClickListener);
        recyclerView.setAdapter(notesAdapter);

        addNoteButton = findViewById(R.id.buttonAdd);
        //noinspection ConstantConditions
        addNoteButton.setEnabled(false);

        editText = (EditText) findViewById(R.id.editTextNote);
        editText.setOnEditorActionListener(new TextView.OnEditorActionListener() {

            @Override
            public boolean onEditorAction(TextView v, int actionId, KeyEvent event) {
                if (actionId == EditorInfo.IME_ACTION_DONE) {
                    addNote();
                    return true;
                }
                return false;
            }
        });
        editText.addTextChangedListener(new TextWatcher() {

            @Override
            public void onTextChanged(CharSequence s, int start, int before, int count) {
                boolean enable = s.length() != 0;
                addNoteButton.setEnabled(enable);
            }

            @Override
            public void beforeTextChanged(CharSequence s, int start, int count, int after) {
            }

            @Override
            public void afterTextChanged(Editable s) {
            }
        });
    }

有 Rx 写法

protected void setUpViews() {
        RecyclerView recyclerView = (RecyclerView) findViewById(R.id.recyclerViewNotes);
        //noinspection ConstantConditions
        recyclerView.setHasFixedSize(true);
        recyclerView.setLayoutManager(new LinearLayoutManager(this));

        notesAdapter = new NotesAdapter(noteClickListener);
        recyclerView.setAdapter(notesAdapter);

        addNoteButton = findViewById(R.id.buttonAdd);

        editText = (EditText) findViewById(R.id.editTextNote);
        //noinspection ConstantConditions
        RxTextView.editorActions(editText).observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<Integer>() {
                    @Override
                    public void call(Integer actionId) {
                        if (actionId == EditorInfo.IME_ACTION_DONE) {
                            addNote();
                        }
                    }
                });
        RxTextView.afterTextChangeEvents(editText).observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<TextViewAfterTextChangeEvent>() {
                    @Override
                    public void call(TextViewAfterTextChangeEvent textViewAfterTextChangeEvent) {
                        boolean enable = textViewAfterTextChangeEvent.editable().length() > 0;
                        addNoteButton.setEnabled(enable);
                    }
                });
    }

5.更新记录

无 Rx 写法

private void updateNotes() {
    List<Note> notes = notesQuery.list();
    notesAdapter.setNotes(notes);
}

有 Rx 写法

private void updateNotes() {
    notesQuery.list()
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Action1<List<Note>>() {
                @Override
                public void call(List<Note> notes) {
                    notesAdapter.setNotes(notes);
                }
            });
}

6.添加记录

无 Rx 写法

private void addNote() {
        String noteText = editText.getText().toString();
        editText.setText("");

        final DateFormat df = DateFormat.getDateTimeInstance(DateFormat.MEDIUM, DateFormat.MEDIUM);
        String comment = "Added on " + df.format(new Date());

        Note note = new Note();
        note.setText(noteText);
        note.setComment(comment);
        note.setDate(new Date());
        note.setType(NoteType.TEXT);
        noteDao.insert(note);
        Log.d("DaoExample", "Inserted new note, ID: " + note.getId());

        updateNotes();
    }

有 Rx 写法

private void addNote() {
        String noteText = editText.getText().toString();
        editText.setText("");

        final DateFormat df = DateFormat.getDateTimeInstance(DateFormat.MEDIUM, DateFormat.MEDIUM);
        String comment = "Added on " + df.format(new Date());

        Note note = new Note(null, noteText, comment, new Date(), NoteType.TEXT);
        noteDao.insert(note)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<Note>() {
                    @Override
                    public void call(Note note) {
                        Log.d("DaoExample", "Inserted new note, ID: " + note.getId());
                        updateNotes();
                    }
                });
    }

7.删除记录

无 Rx 写法

NotesAdapter.NoteClickListener noteClickListener = new NotesAdapter.NoteClickListener() {
        @Override
        public void onNoteClick(int position) {
            Note note = notesAdapter.getNote(position);
            Long noteId = note.getId();

            noteDao.deleteByKey(noteId);
            Log.d("DaoExample", "Deleted note, ID: " + noteId);

            updateNotes();
        }
    };

有 Rx 写法

NotesAdapter.NoteClickListener noteClickListener = new NotesAdapter.NoteClickListener() {
        @Override
        public void onNoteClick(int position) {
            Note note = notesAdapter.getNote(position);
            final Long noteId = note.getId();

            noteDao.deleteByKey(noteId)
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Action1<Void>() {
                        @Override
                        public void call(Void aVoid) {
                            Log.d("DaoExample", "Deleted note, ID: " + noteId);
                            updateNotes();
                        }
                    });
        }
    };

最后别忘了新建一个Application类，并添加到Manifest中

public class BaseApplication extends Application {

    /**
     * A flag to show how easily you can switch from standard SQLite to the encrypted SQLCipher.
     */
    public static final boolean ENCRYPTED = true;

    private DaoSession daoSession;

    @Override
    public void onCreate() {
        super.onCreate();

        DaoMaster.DevOpenHelper helper = new DaoMaster.DevOpenHelper(                this, ENCRYPTED ? "notes-db-encrypted" : "notes-db");
        Database db = ENCRYPTED ? helper.getEncryptedWritableDb("super-secret") : helper.getWritableDb();
        daoSession = new DaoMaster(db).newSession();
    }

    public DaoSession getDaoSession() {
        return daoSession;
    }

}

文中额外可能会用到的库

compile 'com.jakewharton.rxbinding:rxbinding:1.0.1'
compile 'net.zetetic:android-database-sqlcipher:3.5.6'

关注我的新浪微博，获取更多Android开发资讯！关注科技评论家，领略科技、创新、教育以及最大化人类智慧与想象力！

BAT 批处理程序

BAT 批处理程序

相关推荐

greenDao基础用法(一)

daoPackage ‘com.xxx.database‘ // 你要存放greendao相关文件的包名。targetGenDir ‘src/main/java‘//设置生成的DaoMaster、DaoSession、Dao路径

Huawen / 0评论 2020-04-16

Android 高效的SQLite型数据库greenDAO使用

首先，新建datamodel包，用以包含DaoMaster、DaoSession、bean和beanDao等。在MainActivity.java中添加读写代码：public class MainActivity extends AppCompatActi

whyname / 0评论 2019-12-23

GreenDao数据库带你出坑

现在在Android中使用的数据库一般都是用的GreenDao,我们准备使用GreenDao的时候从网上看了很多文章，感觉很多技术点都不是我们关注的重点，经过实践以后觉得好多文章的内容都不太正确。我的这篇文章主要讲GreenDao的三个方面:1 Green

巨杉数据库 / 0评论 2019-06-29

Android之xUtils-3.0数据库框架详解

在Android 开发中,数据库模块是必不可少的.现在也有许多非常好用流行的数据库快速开发框架.今天主要介绍下xUtils下封装的数据库模块.Android 常用数据库开发框架在这里列一下Android开发中常用的数据库框架,有情趣的可以自行了解下,顺便储

xuweinet / 0评论 2019-06-28

GreenDao中一对多的处理

private Long cardId;//设计此字段，然后在Card中引用它，以便于Card来识别它

WillFlow / 0评论 2019-06-27

GreenDao使用-入门

GreenDao基本使用-入门GreenDao应该是一个很受欢迎的orm框架，很早以前使用过，现在已经是3.0了，这里做个记录。先看下官网上说的优点:性能最好简单易用GreenDao体积小数据库加密:支持SQLCipher强大的社区属性

Super简单 / 0评论 2019-06-26

greenDao基本搭建和使用

最近闲得发慌，研究下android框架，蛮早就听说过greendao，一直没接触，这会儿工夫来捯饬捯饬。作为一个菜鸟，不求所以然，先会用，再慢慢体会他设计的精妙在哪里。个人验证通过可行的方法。包： greendao-2.0.0.jar,greendao-g

道郭 / 0评论 2015-09-08

Android 笔记

keytool -list -keystore debug.keystore

Huawen / 0评论 2014-11-24

在Android Studio中使用GreenDao

3. 编写daogen moudle的gradle文件, 添加greendao-generator依赖

WillFlow / 0评论 2014-11-24

GitHub上最火的Android开源项目（完结篇）

摘要：截至目前，在GitHub“最受欢迎的开源项目”系列文章中我们已介绍了40个Android开源项目，对于如此众多的项目，你是Mark、和码友分享经验还是慨叹“活到老要学到老”？今天我们将继续介绍另外34个Android开源项目。此前，CSDN移动频道推

lxjhoney / 0评论 2013-05-22

一篇好文之Android数据库GreenDao的完全解析

之前在开发过程中，数据库基本上会使用 Litepal 和 SQlite 自己写，最近换新环境，公司原先使用的数据库就是 GreenDao，在各种情况的作用下，准备了解下 GreenDao，顺便写一篇文章记录下 GreenDao 的基本使用！大家在使用 Gr

wintershii / 0评论 2019-03-25

一篇好文之Android数据库GreenDao的完全解析

小米近日称，财政部此次公告的检查为2017年财政部会计监督检查，是针对2016年的会计信息质量进行的检查。公司存在部分费用摊销核算错误、对外赠送商品未作为视同销售行为申报缴税、报销发票管理不规范、费用管理制度不完善等问题。以上问题均已整改完成，并获得财政部

bluet00 / 0评论 2019-02-27

实现Android数据持久化的3种方法与优劣比较

近日，从事MobIM开发工作。在工作中需要实现本地数据持久化缓存的操作。查看了下当下流行的几款比较受欢迎的开源框架。选取了比较有代表性的进行实现和与原生的Sqlite框架进行实现和比较。集成方式十分便捷和简单。Javabean就是数据库对象，对JavaBe

jayronlou / 0评论 2017-12-21

greendao3.2.3配置时遇到的问题

点击OK 就成功解决掉了问题。希望这个配置问题解决方法对你们有用

BAT 批处理程序 / 0评论 2017-04-14

GreenDao 数据库：使用Raw文件夹下的数据库文件以及数据库升级

public static abstract class OpenHelper extends SQLiteOpenHelper {. Log.i;　　　　　　　//修改第二个参数为true. /** Creates underlying database

手机开发 / 0评论 2017-01-06

安卓GreenDao框架一些进阶用法整理

一些查询指令整理使用SQL语句进行特殊查询检测表字段是否存在数据库升级数据库表字段赋初始值一、查询指令整理 1.链式执行的指令。这时候用普通的查询指令就会非常麻烦了，需要使用SELECT DISTINCT指令查出某列名所有不重复的条目。

手机开发 / 0评论 2016-12-29