12.4 DrySister看妹子应用(第一版)——4.添加数据缓存(加入SQLite)
1.一些BB 上节已经给DrySister搭好了一个异步图片加载缓存框架——SisterLoader(妹子加载器)，图片从网络拉取成功后，会同时缓存到磁盘和内存里。这样一来，就算后来把网络断掉，之前看过的图片照样还能打开。不过这里还有个挺现实的问题：APP是在有网时进入的，图片相关信息比如URL，也
1.一些BB
上节已经给DrySister搭好了一个异步图片加载缓存框架——SisterLoader(妹子加载器)，图片从网络拉取成功后，会同时缓存到磁盘和内存里。这样一来，就算后来把网络断掉，之前看过的图片照样还能打开。不过这里还有个挺现实的问题：APP是在有网时进入的，图片相关信息比如URL，也是那时候从接口拿到的；一旦退出应用、再断网重进，图片反而加载不出来了。原因并不复杂——图片文件虽然还在缓存里，但图片对应的URL信息没留下来，这套缓存能力就多少有点“使不上劲”。所以，后台接口返回的数据也得一并存起来。更准确地说，就是每次加载时，把返回的数据同步落到本地；等到无网状态下，再直接读取本地数据来完成展示。也正因为如此，这一节要给DrySister补上SQLite，用来存储这些相关数据。目标很明确，直接开干。
2.开始编写程序
在develop上开辟一个新的db分支，来完成本节相关代码的编写。
首先，我们添加一个用来判断网络状态的工具类：NetworkUtils.ja va， 就一个简单的判断网络是否可用的方法~这里我们还需要在AndroidManifest.xml 里加一个权限：android.permission.ACCESSNETWORKSTATE"的权限！
public class NetworkUtils {
/** 获取网络信息 */
private static NetworkInfo getActiveNetworkInfo(Context context) {
ConnectivityManager cm = (ConnectivityManager) context
.getSystemService(Context.CONNECTIVITY_SERVICE);
return cm.getActiveNetworkInfo();
}
/** 判断网络是否可用 */
public static boolean isA vailable(Context context) {
NetworkInfo info = getActiveNetworkInfo(context);
return info != null && info.isA vailable();
}
}接着定义一个数据库字段常量的类：TableDefine.ja va， 在里面把数据库名，字段写上：
public class TableDefine {
public static final String TABLE_FULI = "fuli";
public static final String COLUMN_ID = "id";
public static final String COLUMN_FULI_ID = "_id";
public static final String COLUMN_FULI_CREATEAT = "createAt";
public static final String COLUMN_FULI_DESC = "desc";
public static final String COLUMN_FULI_PUBLISHEDAT = "publishedAt";
public static final String COLUMN_FULI_SOURCE = "source";
public static final String COLUMN_FULI_TYPE = "type";
public static final String COLUMN_FULI_URL = "url";
public static final String COLUMN_FULI_USED = "used";
public static final String COLUMN_FULI_WHO = "who";
}再接着编写数据库的创建类：SisterOpenHelper.ja va，在里面完成数据库的创建
public class SisterOpenHelper extends SQLiteOpenHelper{
private static final String DB_NAME = "sister.db"; //数据库名
private static final int DB_VERSION = 1; //数据库版本号
public SisterOpenHelper(Context context) {
super(context, DB_NAME, null, DB_VERSION);
}
@Override
public void onCreate(SQLiteDatabase db) {
String createTableSql = "CREATE TABLE IF NOT EXISTS " + TableDefine.TABLE_FULI + " ("
+ TableDefine.COLUMN_ID + " INTEGER PRIMARY KEY AUTOINCREMENT, "
+ TableDefine.COLUMN_FULI_ID + " TEXT, "
+ TableDefine.COLUMN_FULI_CREATEAT + " TEXT, "
+ TableDefine.COLUMN_FULI_DESC + " TEXT, "
+ TableDefine.COLUMN_FULI_PUBLISHEDAT + " TEXT, "
+ TableDefine.COLUMN_FULI_SOURCE + " TEXT, "
+ TableDefine.COLUMN_FULI_TYPE + " TEXT, "
+ TableDefine.COLUMN_FULI_URL + " TEXT, "
+ TableDefine.COLUMN_FULI_USED + " BOOLEAN, "
+ TableDefine.COLUMN_FULI_WHO + " TEXT"
+ ")";
db.execSQL(createTableSql);
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { }
}再接着，我们需要编写一个数据库的操作类，就是做增删改查，分页查询等操作的类， 这里我们把这个类写成单例的：SisterDBHelper.ja va，里面的编写的方法有这些：
具体代码：
public class SisterDBHelper {
private static final String TAG = "SisterDBHelper";
private static SisterDBHelper dbHelper;
private SisterOpenHelper sqlHelper;
private SQLiteDatabase db;
private SisterDBHelper() {
sqlHelper = new SisterOpenHelper(DrySisterApp.getContext());
}
/** 单例 */
public static SisterDBHelper getInstance() {
if(dbHelper == null) {
synchronized (SisterDBHelper.class) {
if(dbHelper == null) {
dbHelper = new SisterDBHelper();
}
}
}
return dbHelper;
}
/** 插入一个妹子 */
public void insertSister(Sister sister) {
db = getWritableDB();
ContentValues contentValues = new ContentValues();
contentValues.put(TableDefine.COLUMN_FULI_ID,sister.get_id());
contentValues.put(TableDefine.COLUMN_FULI_CREATEAT,sister.getCreateAt());
contentValues.put(TableDefine.COLUMN_FULI_DESC,sister.getDesc());
contentValues.put(TableDefine.COLUMN_FULI_PUBLISHEDAT,sister.getPublishedAt());
contentValues.put(TableDefine.COLUMN_FULI_SOURCE,sister.getSource());
contentValues.put(TableDefine.COLUMN_FULI_TYPE,sister.getType());
contentValues.put(TableDefine.COLUMN_FULI_URL,sister.getUrl());
contentValues.put(TableDefine.COLUMN_FULI_USED,sister.getUsed());
contentValues.put(TableDefine.COLUMN_FULI_WHO,sister.getWho());
db.insert(TableDefine.TABLE_FULI,null,contentValues);
closeIO(null);
}
/** 插入一堆妹子(使用事务) */
public void insertSisters(ArrayList sisters) {
db = getWritableDB();
db.beginTransaction();
try{
for (Sister sister: sisters) {
ContentValues contentValues = new ContentValues();
contentValues.put(TableDefine.COLUMN_FULI_ID,sister.get_id());
contentValues.put(TableDefine.COLUMN_FULI_CREATEAT,sister.getCreateAt());
contentValues.put(TableDefine.COLUMN_FULI_DESC,sister.getDesc());
contentValues.put(TableDefine.COLUMN_FULI_PUBLISHEDAT,sister.getPublishedAt());
contentValues.put(TableDefine.COLUMN_FULI_SOURCE,sister.getSource());
contentValues.put(TableDefine.COLUMN_FULI_TYPE,sister.getType());
contentValues.put(TableDefine.COLUMN_FULI_URL,sister.getUrl());
contentValues.put(TableDefine.COLUMN_FULI_USED,sister.getUsed());
contentValues.put(TableDefine.COLUMN_FULI_WHO,sister.getWho());
db.insert(TableDefine.TABLE_FULI,null,contentValues);
}
db.setTransactionSuccessful();
} finally {
if(db != null && db.isOpen()) {
db.endTransaction();
closeIO(null);
}
}
}
/** 删除妹子(根据_id) */
public void deleteSister(String _id) {
db = getWritableDB();
db.delete(TableDefine.TABLE_FULI,"_id =?",new String[]{_id});
closeIO(null);
}
/** 删除所有妹子 */
public void deleteAllSisters() {
db = getWritableDB();
db.delete(TableDefine.TABLE_FULI,null,null);
closeIO(null);
}
/** 更新妹子信息(根据_id) */
public void deleteSister(String _id,Sister sister) {
db = getWritableDB();
ContentValues contentValues = new ContentValues();
contentValues.put(TableDefine.COLUMN_FULI_ID,sister.get_id());
contentValues.put(TableDefine.COLUMN_FULI_CREATEAT,sister.getCreateAt());
contentValues.put(TableDefine.COLUMN_FULI_DESC,sister.getDesc());
contentValues.put(TableDefine.COLUMN_FULI_PUBLISHEDAT,sister.getPublishedAt());
contentValues.put(TableDefine.COLUMN_FULI_SOURCE,sister.getSource());
contentValues.put(TableDefine.COLUMN_FULI_TYPE,sister.getType());
contentValues.put(TableDefine.COLUMN_FULI_URL,sister.getUrl());
contentValues.put(TableDefine.COLUMN_FULI_USED,sister.getUsed());
contentValues.put(TableDefine.COLUMN_FULI_WHO,sister.getWho());
db.update(TableDefine.TABLE_FULI,contentValues,"_id =?",new String[]{_id});
closeIO(null);
}
/** 查询当前表中有多少个妹子 */
public int getSistersCount() {
db = getReadableDB();
Cursor cursor = db.rawQuery("SELECT COUNT (*) FROM " + TableDefine.TABLE_FULI,null);
cursor.moveToFirst();
int count = cursor.getInt(0);
Log.v(TAG,"count：" + count);
closeIO(cursor);
return count;
}
/** 分页查询妹子，参数为当前页和每一个的数量，页数从0开始算 */
public List getSistersLimit(int curPage,int limit) {
db = getReadableDB();
List sisters = new ArrayList<>();
String startPos = String.valueOf(curPage * limit); //数据开始位置
if(db != null) {
Cursor cursor = db.query(TableDefine.TABLE_FULI,new String[] {
TableDefine.COLUMN_FULI_ID, TableDefine.COLUMN_FULI_CREATEAT,
TableDefine.COLUMN_FULI_DESC, TableDefine.COLUMN_FULI_PUBLISHEDAT,
TableDefine.COLUMN_FULI_SOURCE, TableDefine.COLUMN_FULI_TYPE,
TableDefine.COLUMN_FULI_URL, TableDefine.COLUMN_FULI_USED,
TableDefine.COLUMN_FULI_WHO,
},null,null,null,null,TableDefine.COLUMN_ID,startPos + "," + limit);
while (cursor.moveToNext()) {
Sister sister = new Sister();
sister.set_id(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_ID)));
sister.setCreateAt(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_CREATEAT)));
sister.setDesc(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_DESC)));
sister.setPublishedAt(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_PUBLISHEDAT)));
sister.setSource(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_SOURCE)));
sister.setType(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_TYPE)));
sister.setUrl(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_URL)));
sister.setUsed(cursor.getInt(cursor.getColumnIndex(TableDefine.COLUMN_FULI_USED)));
sisters.add(sister);
}
closeIO(cursor);
}
return sisters;
}
/** 查询所有妹子 */
public List getAllSisters() {
db = getReadableDB();
List sisters = new ArrayList<>();
Cursor cursor = db.rawQuery("SELECT * FROM "+TableDefine.TABLE_FULI,null);
cursor.moveToFirst();
while (cursor.moveToNext()) {
Sister sister = new Sister();
sister.set_id(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_ID)));
sister.setCreateAt(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_CREATEAT)));
sister.setDesc(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_DESC)));
sister.setPublishedAt(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_PUBLISHEDAT)));
sister.setSource(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_SOURCE)));
sister.setType(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_TYPE)));
sister.setUrl(cursor.getString(cursor.getColumnIndex(TableDefine.COLUMN_FULI_URL)));
sister.setUsed(cursor.getInt(cursor.getColumnIndex(TableDefine.COLUMN_FULI_USED)));
sisters.add(sister);
}
closeIO(cursor);
return sisters;
}
/** 获得可写数据库的方法 */
private SQLiteDatabase getWritableDB() {
return sqlHelper.getWritableDatabase();
}
/** 获得可读数据库的方法 */
private SQLiteDatabase getReadableDB() {
return sqlHelper.getReadableDatabase();
}
/** 关闭cursor和数据库的方法 */
private void closeIO(Cursor cursor) {
if(cursor != null) {
cursor.close();
}
if(db != null) {
db.close();
}
}
} 嗯，还是蛮简单的，都是一些SQLite的方法调用而已，接着我们对布局做一下更改， 把activity_main.xml改成下面的代码，就是换成上一个和下一个这样：
最后就是对MainActivity.ja va的一些逻辑更改了，核心的要点如下：
- 1.curPos和page的控制以及处理逻辑
- 2.根据网络是否可用加载网络还是数据库数据
- 3.加载网络数据时存储到数据库需要避免重复插入 等等。
代码实现：
public class MainActivity extends AppCompatActivity implements View.OnClickListener {
private Button previousBtn;
private Button nextBtn;
private ImageView showImg;
private ArrayList data;
private int curPos = 0; //当前显示的是哪一张
private int page = 1; //当前页数
private PictureLoader loader;
private SisterApi sisterApi;
private SisterTask sisterTask;
private SisterLoader mLoader;
private SisterDBHelper mDbHelper;
@Override
protected void onCreate(Bundle sa vedInstanceState) {
super.onCreate(sa vedInstanceState);
setContentView(R.layout.activity_main);
sisterApi = new SisterApi();
loader = new PictureLoader();
mLoader = SisterLoader.getInstance(MainActivity.this);
mDbHelper = SisterDBHelper.getInstance();
initData();
initUI();
}
private void initData() {
data = new ArrayList<>();
sisterTask = new SisterTask();
sisterTask.execute();
}
private void initUI() {
previousBtn = (Button) findViewById(R.id.btn_previous);
nextBtn = (Button) findViewById(R.id.btn_next);
showImg = (ImageView) findViewById(R.id.img_show);
previousBtn.setOnClickListener(this);
nextBtn.setOnClickListener(this);
}
@Override
public void onClick(View v) {
switch (v.getId()) {
case R.id.btn_previous:
--curPos;
if (curPos == 0) {
previousBtn.setVisibility(View.INVISIBLE);
}
if (curPos == data.size() - 1) {
sisterTask = new SisterTask();
sisterTask.execute();
} else if(curPos < data.size()) {
mLoader.bindBitmap(data.get(curPos).getUrl(), showImg, 400, 400);
}
break;
case R.id.btn_next:
previousBtn.setVisibility(View.VISIBLE);
if(curPos < data.size()) {
++curPos;
}
if (curPos > data.size() - 1) {
sisterTask = new SisterTask();
sisterTask.execute();
} else if(curPos < data.size()){
mLoader.bindBitmap(data.get(curPos).getUrl(), showImg, 400, 400);
}
break;
}
}
private class SisterTask extends AsyncTask> {
public SisterTask() {
}
@Override
protected ArrayList doInBackground(Void... params) {
ArrayList result = new ArrayList<>();
if (page < (curPos + 1) / 10 + 1) {
++page;
}
//判断是否有网络
if (NetworkUtils.isA vailable(getApplicationContext())) {
result = sisterApi.fetchSister(10, page);
//查询数据库里有多少个妹子，避免重复插入
if(mDbHelper.getSistersCount() / 10 < page) {
mDbHelper.insertSisters(result);
}
} else {
result.clear();
result.addAll(mDbHelper.getSistersLimit(page - 1, 10));
}
return result;
}
@Override
protected void onPostExecute(ArrayList sisters) {
super.onPostExecute(sisters);
data.addAll(sisters);
if (data.size() > 0 && curPos + 1 < data.size()) {
mLoader.bindBitmap(data.get(curPos).getUrl(), showImg, 400, 400);
}
}
@Override
protected void onCancelled() {
super.onCancelled();
sisterTask = null;
}
}
@Override
protected void onDestroy() {
super.onDestroy();
if (sisterTask != null) {
sisterTask.cancel(true);
}
}
} 3.运行效果图
操作步骤：
把项目跑起来后，一直按下一页下一页缓存一堆图片，接着断开网络，进入DrySister， Duang~，神奇的发现，有妹子出现了，按下一页或者上一页也可以切换图片，妈妈再也 不用担心我在没网的时候不可以看DrySister了！
运行截图：
4.小结
这一步是在上一节的基础上，进一步补上了 SQLite，用来把后台数据落到本地。这样一来，即使在没有网络的情况下，妹子图片照样可以正常查看。整体上，代码层面的主要调整和前面提到的一致，另外还有一些零散的小改动，细节直接看代码会更清楚。最后，再把 db 分支的代码合并到 develop 分支，随后删除 db 分支，并将更新后的 develop 分支推送到 Github。
代码下载：
https://github.com/coder-pig/DrySister/tree/develop 欢迎follow，star，觉得有什么想加进来的可以提下issues！
WPS Office是一款面向macOS用户的综合办公套件，将文字处理、电子表格、演示文稿、PDF工具、模板与云协作整合在同一应用中。它兼容常见Microsoft Office格式，支持Intel及Apple芯片Mac，基础功能可免费使用，
Shapr3D是一款面向工业设计、机械工程、建筑概念和三维打印工作流的CAD软件。Mac版采用Parasolid建模内核，支持草图约束、实体建模、工程图、可视化渲染及常见CAD格式交换，并可通过账户在多台设备之间同步项目。
REAPER是Cockos开发的数字音频工作站，提供多轨音频与MIDI录制、剪辑、处理、混音和母带制作工具。Mac版兼容Intel与Apple芯片，支持AU、VST、VST3、CLAP等插件格式，并提供高度可定制的工作流程。
Ableton Live 是面向音乐制作人与现场表演者的数字音频工作站，提供编曲视图、独具特色的现场视图、音频录制、MIDI创作、实时变速、乐器及效果器。Mac版原生支持Apple芯片，并可连接音频接口、MIDI控制器和第三方插件。
Adobe After Effects 是面向动态图形、影视特效与视频合成的专业创作软件。它提供关键帧动画、遮罩抠像、运动跟踪、三维空间、文字动画和表达式等工具，并可与 Premiere Pro、Photoshop、Illustrator
Adobe Audition 是面向播客、影视后期、音乐制作及内容创作者的专业音频工作站，提供波形精修、多轨录制与混音、频谱编辑、降噪修复、响度匹配和效果处理工具，并可与 Adobe Premiere 协同完成视频声音制作。
Adobe Bridge 是面向摄影师、设计师及内容团队的免费数字资产管理工具，可集中预览照片、视频和 Adobe 项目文件，并利用评级、标签、关键词、元数据、筛选与收藏集完成分类检索。它还支持批量重命名、格式导出、相机导入及 Camera
Adobe Illustrator 是 Adobe 推出的专业矢量图形设计软件，适合在 Mac 上制作标志、图标、插画、包装、信息图及印刷版面。它以路径和锚点构建可无损缩放的图形，并提供钢笔、形状、文字、图像描摹、渐变、画板及生成式功能。
Adobe InDesign 是面向印刷品与数字出版物的专业版面设计软件，可在 Mac 上制作书籍、杂志、宣传册、海报、报告及交互式文档。它提供精细的文字样式、网格、母版、长文档管理和印前输出能力。
Adobe Lightroom Classic 是面向桌面摄影工作流的照片管理与后期处理软件，可将原始照片保存在本地硬盘，通过目录、关键词、评分和收藏夹高效整理图库，并提供 RAW 冲印、蒙版、镜头校正、批量同步及多格式导出等功能。
Adobe Media Encoder 是 Adobe 推出的专业音视频编码与转码工具，可通过队列、预设和监视文件夹批量完成格式转换、代理文件创建及多平台成片输出，并与 Premiere Pro、After Effects 等软件紧密协作。
Adobe Photoshop 是面向摄影师、设计师和内容创作者的专业图像处理软件，提供图层、蒙版、选区、修复、调色、文字排版、智能对象及生成式编辑等能力。Mac 版支持 Intel 与 Apple Silicon 处理器。
AutoCAD 是 Autodesk 推出的专业计算机辅助设计软件，Windows 版支持精确二维绘图、三维实体与曲面建模、图纸标注、布局发布和任务自动化，并包含多套行业专业化工具组合，适用于建筑、机械、电气、工程建设及制造设计人员。
SketchUp Pro 是面向建筑、室内、景观、施工和产品设计等专业场景的三维建模工具，提供桌面建模、LayOut 二维文档、模型资源库、扩展程序及云端协作能力。其操作逻辑直观，适合从概念推敲、空间规划到图纸表达和方案汇报的完整工作流程。
AutoCAD LT 是 Autodesk 推出的专业二维 CAD 软件，适合建筑师、工程师、施工人员和设计师完成精确绘图、标注及文档编制。它支持 DWG 工作流、智能块、图形比较、计数、表格和 AutoLISP 自动化，
Rhino 3D 是 McNeel 推出的专业三维建模工具，可创建、编辑和分析 NURBS 曲线曲面、实体、网格、SubD 与点云。Windows 版支持精确造型、工程制图、渲染、文件转换及 Grasshopper 参数化设计，
Autodesk Fusion 是面向产品设计与制造的云连接开发平台，在统一环境中整合三维 CAD、CAM、CAE、PCB、工程图、数据管理和团队协作功能，适合产品设计师、机械工程师、电子工程师及加工制造团队完成从概念建模、验证分析到生产交
Archicad 是 Graphisoft 面向建筑师、设计师、工程师及 BIM 团队开发的建筑信息模型平台。它把三维建筑建模、施工文档、数据管理、专业协调、实时协作和可视化集中在统一项目环境中，适合从概念方案到施工交付的完整建筑设计流程。
Vectorworks Architect 是面向建筑师、室内设计师和建筑顾问的综合设计与BIM平台，覆盖概念草图、二维制图、三维建模、施工文档、数据报表、可视化及开放式协作。它强调自由造型与数据化建筑对象并存，
Shapr3D 是一款基于 Siemens Parasolid 几何内核的专业三维CAD软件，可在 Windows 电脑和平板设备上完成草图绘制、实体建模、参数化修改、模型可视化及技术图纸制作。软件提供免费基础方案，
FreeCAD 是面向机械设计、产品开发、建筑建模和创客项目的免费开源参数化三维 CAD 工具。它可在 Windows 上完成约束草图、实体零件、装配、工程图、BIM、有限元分析及 CAM 等任务，
Twinmotion 是 Epic Games 推出的实时三维可视化工具，可导入常见 CAD、BIM 与三维模型，通过材质、环境、植被、灯光及动画资源快速构建场景，并输出图片、视频、全景图和交互演示。
BricsCAD 是以 DWG 为核心格式的专业 CAD 平台，可用于二维制图、三维建模、工程文档与设计协作。产品按 Lite、Pro、BIM、Mechanical 和 Ultimate 等层级提供不同工具，
Ableton Live 是面向音乐创作、录音、编曲、声音设计、混音与现场演出的数字音频工作站。它将适合即兴触发素材的 Session 视图与传统时间线编曲结合，并提供音频变速、MIDI工具、软件乐器、效果器和声音资源，