相信小伙伴们在开发中或多或少都可能遇到过这样的问题:打开一个应用后,为了快速响应,先将数据库中的数据呈现给用户,然后再去网络上请求数据,请求成功之后将数据缓存至数据库,同时更新UI,但是我们经常会这样想,可不可以我只将数据缓存至数据库,当数据库中的数据发生改变时,UI会自动更新?这个当然可以实现,我们今天就来看看square公司推出的一个响应式数据库框架SQLBrite。
1.准备工作
SQLBrite项目地址:https://github.com/square/sqlbrite
将SQLBrite引入到我们的项目中:
compile 'com.squareup.sqlbrite:sqlbrite:0.7.0'
在处理线程问题时,由于要使用到RxAndorid中相关的类,所以我们还要引入RxAndroid:
compile 'io.reactivex:rxandroid:1.1.0'
另外:
SQLBrite的使用基于RxJava的使用,如果小伙伴们对RxJava的使用尚不熟悉,请移步这里RxAndroid结合Retrofit,看看谁才是最佳拍档!
2.开始使用
和以前一样,讲解代码之前我们先来看看效果图:
大家看到,当我添加数据时ListView会自动更新,删除数据或者修改数据时ListView一样会自动更新,就是这么简单一个效果,我们来看看实现方式。
2.1创建DBHelper
首先我们需要创建一个DBHelper,由于SQLBrite只是对数据的增删改查过程重新做了封装,其他的以前怎么写现在还是怎么写。DBHelper的创建和我们Sqlite中DBHelper的创建方式一模一样,假设我创建一个User表,如下:
public class DBHelper extends SQLiteOpenHelper { private static final String DBNAME = "sang.db"; private static final int CURRENTVERSION = 1; public static final String USERTABLE = "usertable"; public DBHelper(Context context) { super(context, DBNAME, null, CURRENTVERSION); } @Override public void onCreate(SQLiteDatabase db) { db.execSQL("CREATE TABLE IF NOT EXISTS " + USERTABLE + "(_id INTEGER PRIMARY KEY AUTOINCREMENT,USERNAME,NICKNAME);"); } @Override public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { } }
2.2初始化数据库,获取db对象
获取db对象只要三行代码,如下:
SqlBrite sqlBrite = SqlBrite.create(); DBHelper dbHelper = new DBHelper(this); db = sqlBrite.wrapDatabaseHelper(dbHelper, AndroidSchedulers.mainThread());
第一步先是获取一个SqlBrite对象,这个通过create方法直接获取即可,然后创建一个DBHelper的实例,最后通过sqlBrite类中的wrapDatabaseHelper方法来获取一个db实例,第一个参数不必说,第二个参数表示数据库的操作是在哪一个线程中进行的,AndroidSchedulers.mainThread()方法表示数据库的操作在主线程中执行。获取的db对象之后,后面的增删改查操作我们都要在这个db对象中进行。
2.3添加数据
ContentValues values = new ContentValues(); values.put("USERNAME", "ZHANGSAN"); values.put("NICKNAME", "张三"); long insert = db.insert(DBHelper.USERTABLE, values);
第一个参数表示要操作的表名,第二个参数表示要插入的数据。
2.4删除数据
db.delete(DBHelper.USERTABLE, "_id < ?", new String[]{5 + ""});
这里的参数都很简单,不多说。
2.5修改数据
ContentValues values = new ContentValues(); values.put("USERNAME", "LISI"); db.update(DBHelper.USERTABLE, values, "_id < ? and _id > ?", new String[]{20 + "", 10 + ""});
2.6查询数据
QueryObservable query = db.createQuery(DBHelper.USERTABLE, "SELECT * FROM " + DBHelper.USERTABLE, null); query.subscribe(new Action1<SqlBrite.Query>() { @Override public void call(SqlBrite.Query query) { Cursor cursor = query.run(); List<String> list = new ArrayList<String>(); while (cursor.moveToNext()) { String username = cursor.getString(cursor.getColumnIndex("USERNAME")); String id = cursor.getString(cursor.getColumnIndex("_id")); String nickname = cursor.getString(cursor.getColumnIndex("NICKNAME")); list.add(id + "--" + username + "--" + nickname); } cursor.close(); ArrayAdapter<String> adapter = new ArrayAdapter<String>(MainActivity.this, android.R.layout.simple_list_item_1, list); lv.setAdapter(adapter); } });
SQLBrite中可以直接通过SQL语句来查询数据,拿到Cursor对象之后剩下的就好说了。
2.7事务的使用
大批量进行数据插入操作的时候,我们可以使用事务,使用方式如下:
BriteDatabase.Transaction transaction = db.newTransaction(); try { ContentValues values = new ContentValues(); values.put("USERNAME", "ZHANGSAN"); values.put("NICKNAME", "张三"); long insert = db.insert(DBHelper.USERTABLE, values); transaction.markSuccessful(); } finally { transaction.end(); }
OK,这就是SQLBrite类的一个简单使用,很简单,整个源码也只有几百行。
Demo下载http://download.csdn.net/detail/u012702547/9633237
以上。