Android开发中RxJava-SQLBrite实时刷新UI

淡淡的烟草味﹌ 2022-06-16 08:45 105阅读 0赞

android实现数据库实时刷新的方式：

*  ContentProvider+CursorLoaders+SQlite实现数据自动观察者模式
 *  Rxjava+SQLBrite+SQLite实现数据自动观察者模式

本篇，这里介绍RxJava+SQLBrite组合方式。

引入RxJava,RxAndroid,SQLBrite库，项目的gradle配置如下：

dependencies {
        .......
        compile 'com.squareup.sqlbrite:sqlbrite:1.1.1'
        compile 'io.reactivex:rxjava:1.3.0'
        compile 'io.reactivex:rxandroid:1.2.1'
    }

### 1.创建数据库： ###

创建BaseColumn的实现类，存放数据库需要用到的常量配置：

public final class Data implements BaseColumns { 
        /** * 数据库信息 */
        public static final String SQLITE_NAME="sqlitePrcactice.db";
        public static final int SQLITE_VERSON=1;
        /** * 信息表，及其字段 */
        public static final String TABLE_NAME="message";
        public static final String COLUMN_CONTENT="content";
        public static final String COLUMN_DATE="date";
        /** * 时间字段的格式 */
        public static final String DATE_FORMAT="YYYY-MM-DD";
        /** * 时间字段的降序，采用date函数比较 */
        public static final String ORDER_BY="date("+COLUMN_DATE+") desc";
    
    }

创建数据库的代码如下：

public class DataHelper extends SQLiteOpenHelper { 
        public static final String CREATE_MESSAGE="create table "+
                Data.TABLE_NAME+"("+
                Data._ID+" integer primary key autoincrement,"+
                Data.COLUMN_CONTENT+" text,"+
                Data.COLUMN_DATE+" text"
                +")";
    
        public DataHelper(Context context) {
            super(context, Data.SQLITE_NAME, null, Data.SQLITE_VERSON);
        }
        @Override
        public void onCreate(SQLiteDatabase db) {
            db.execSQL(CREATE_MESSAGE);
        }
        @Override
        public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        }
    }

### 2. 使用SQLBrite： ###

若是，不熟悉SQLBrite，可以阅读[SQLBrite教程][SQLBrite]。

先创建一个SQLBrite的管理类：

public class SqlBriteProvider { 
        private SqlBrite sqlBrite;
        private BriteDatabase briteDatabase;
        public SqlBriteProvider(Context context){
            this.sqlBrite=providerSqlBrite();
            this.briteDatabase=createDatabase(this.sqlBrite,providerOpenHelper(context));
        }
        /** * 创建SQLiteOpenHelper对象 * @param context * @return */
        private SQLiteOpenHelper providerOpenHelper(Context context){
            return  new DataHelper(context);
        }
    
        /** * * 创建SqlBrite对象 * * @return */
        private SqlBrite providerSqlBrite(){
            return  new SqlBrite.Builder().build();
        }
        /** * 通过SQLBrite对象和SQLiteOpenHel对象 * @param sqlBrite * @param sqLiteOpenHelper * @return */
        public BriteDatabase createDatabase(SqlBrite sqlBrite,SQLiteOpenHelper sqLiteOpenHelper){
            BriteDatabase db=sqlBrite.wrapDatabaseHelper(sqLiteOpenHelper, Schedulers.io());
            return db;
        }
        /** * 获取到SQLBrite中数据库对象 * @return */
        public BriteDatabase getBriteDatabase() {
            return briteDatabase;
        }
    }

接下，来通过BriteDataBase对象来进行SQL操作。

**1. 长时间订阅信息，类似CursorLoader**：

创建一个长时间订阅的查询，返回一个QueryObservable对象。

private BriteDatabase db;
    
       private Subscription suscription;
    
        /** * 长时间订阅查询 */
       private void excuteQuery() {
            //Observable<SqlBrite.Query> observable
             QueryObservable observable = this.db.createQuery(Data.TABLE_NAME, "select * from message ORDER BY "+Data.ORDER_BY, null);
            suscription = observable.subscribe(new Action1<SqlBrite.Query>() {
                @Override
                public void call(SqlBrite.Query query) {
                    Cursor cursor = query.run();
                   //进行解析操作
                }
            });
        }

QueryObservable类实际上是一个提供特定查询方便操作的Observable：

/** An { @link Observable} of { @link Query} which offers query-specific convenience operators. */
    public final class QueryObservable extends Observable<Query> { 
    
        .......
    
     public final <T> Observable<List<T>> mapToList(@NonNull Func1<Cursor, T> mapper) {
        return lift(Query.mapToList(mapper));
      }
    }

**2. 插入信息**：

通过BriteDataBase对象，插入一条数据：

Message message = new Message();
       message.setContent(content_editext.getText().toString());
       message.setDate(date_editext.getText().toString());
       this.db.insert(Data.TABLE_NAME, ValuesTransform.transformContentValues(message));

当插入成功后，将会通知订阅者，将会调用`Cursor cursor = query.run()`获取最新的数据源。

**3. 取消长时间的订阅**：

当Activity或Fragment的生命周期改变时候，需要取消订阅,释放资源。

@Override
      protected void onPause() {
            suscription.unsubscribe();
            super.onPause();
      }

### 3. 结合RxJava1.x使用： ###

BriteDataBase对象查询返回的是一个Observable对象，因此可以进行组合，过滤等操作符进行操作，最后切换到UI线程进行更新UI。

private Subscription suscription;
       /** * 长时间订阅查询 */
        private void excuteQuery() {
            //Observable<SqlBrite.Query> observable
            QueryObservable observable = this.db.createQuery(Data.TABLE_NAME, "select * from message ORDER BY "+Data.ORDER_BY, null);
            suscription = observable
            .observeOn(AndroidSchedulers.mainThread())//订阅者处理信息在UI线程中。
            .subscribe(new Action1<SqlBrite.Query>() {
                @Override
                public void call(SqlBrite.Query query) {
                    Cursor cursor = query.run();
                    loadDataToUI(cursor);
                }
            });
        }
    
        /** * 从Cursor获取数据加载到UI上 * * @param cursor */
        public void loadDataToUI(Cursor cursor) {
            try {
                if (cursor != null && cursor.moveToFirst()) {
                    List<Message> list = new ArrayList<>();
                    do {
                        list.add(ValuesTransform.transformMessage(cursor));
                    } while (cursor.moveToNext());
    
                    //更新UI
                    this.adapter.addData(list);
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                if (cursor != null) {
                    cursor.close();
                }
            }
        }

最后发现，RxJava+SQLBrite实现数据库观察者模式很简单，不需要配置自定义的ContentProvider.

若是，不习惯使用RxJava和SQLBrite,可以阅读上一篇[Android原生实现数据库观察者模式][Android]

项目效果图如下：

![这里写图片描述][SouthEast]

**项目代码Github上**：[https://github.com/13767004362/SQLitePractice][https_github.com_13767004362_SQLitePractice]

**资源参考**：

*  SQLBrite中文教程: [http://blog.csdn.net/hexingen/article/details/71598296][SQLBrite]
 *  SQLBrite： [https://github.com/square/sqlbrite][https_github.com_square_sqlbrite]
 *  RXJava: [https://github.com/ReactiveX/RxJava][https_github.com_ReactiveX_RxJava]
 *  RxAndroid: [https://github.com/ReactiveX/RxAndroid][https_github.com_ReactiveX_RxAndroid]

[SQLBrite]: http://blog.csdn.net/hexingen/article/details/71598296
[Android]: http://blog.csdn.net/hexingen/article/details/71597884
[SouthEast]: /images/20220616/adeebca549c5452c94eea51e8297c9e7.png
[https_github.com_13767004362_SQLitePractice]: https://github.com/13767004362/SQLitePractice
[https_github.com_square_sqlbrite]: https://github.com/square/sqlbrite
[https_github.com_ReactiveX_RxJava]: https://github.com/ReactiveX/RxJava
[https_github.com_ReactiveX_RxAndroid]: https://github.com/ReactiveX/RxAndroid