Android数据库缓存

nintyuui

简单的数据库缓存实现，有不足的地方请指出~

使用示例：
    CacheHelper.init(this).setJson("url", "json");
    CacheHelper.init(this).getJson("url", new Handler(){
      @Override
      public void handleMessage(Message msg) {
        String json = (String) msg.obj;
      }
    });
    CacheHelper.init(this).clear();

1. import android.content.ContentValues;
   
2. import android.content.Context;
   
3. import android.database.Cursor;
   
4. import android.database.sqlite.SQLiteDatabase;
   
5. import android.database.sqlite.SQLiteOpenHelper;
   
6. import android.os.Handler;
   
7. import android.os.Message;
   
8. 
   
9. /**
   
10. * 缓存数据库
    
11. * @author lu
    
12. *
    
13. */
    
14. public class CacheHelper extends SQLiteOpenHelper {
    
15. 
    
16.     private static final String tableName = "JSONCACHE";
    
17.     private static final String URL = "URL";
    
18.     private static final String JSON = "JSON";
    
19.     private static final String DATE = "DATE";
    
20. 
    
21.     public CacheHelper(Context context) {
    
22.         super(context, "cache.db", null, 1);
    
23.     }
    
24. 
    
25.     @Override
    
26.     public void onCreate(SQLiteDatabase db) {
    
27.         //建表jsoncache，字段：请求地址url、缓存数据json、时间date
    
28.         db.execSQL("CREATE TABLE "+tableName+" (ID INTEGER PRIMARY KEY AUTOINCREMENT, "+URL+" TEXT NOT NULL, "+JSON+" TEXT NOT NULL, "+DATE+" INTEGER NOT NULL )");
    
29.     }
    
30. 
    
31.     @Override
    
32.     public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
    
33.     }
    
34.      
    
35.     private static CacheHelper helper = null;
    
36.     public static CacheHelper init(Context context){
    
37.         if (helper==null) {
    
38.             helper = new CacheHelper(context);
    
39.         }
    
40.         return helper;
    
41.     }
    
42.      
    
43.     /**储存缓存json*/
    
44.     public void setJson(final String url0,final String json){
    
45.         new Thread(){
    
46.             public void run() {
    
47.                 String url = urlEncode(url0);
    
48.                 ContentValues cv = new ContentValues();
    
49.                 cv.put(URL, url);
    
50.                 cv.put(JSON, json);
    
51.                 cv.put(DATE, System.currentTimeMillis());
    
52.                 helper.getReadableDatabase().delete(tableName, URL+"=?", new String[]{url});
    
53.                 helper.getReadableDatabase().insert(tableName, null, cv);
    
54.             }
    
55.         }.start();
    
56.     }
    
57.      
    
58.     /**获取缓存json，以handler的obj返回（懒得写监听器了）*/
    
59.     public void getJson(final String url0,final Handler handler){
    
60.         new Thread(){
    
61.             public void run() {
    
62.                 String url = urlEncode(url0);
    
63.                 String result = null;
    
64.                 Cursor c =
    
65.                 helper.getReadableDatabase().query(tableName,
    
66.                         null,
    
67.                         URL+"=?",
    
68.                         new String[]{url},
    
69.                         null,
    
70.                         null,
    
71.                         null);
    
72.                 if (c.moveToNext()) {
    
73.                     result = c.getString(c.getColumnIndex(JSON));
    
74.                 }
    
75.                 Message msg = Message.obtain();
    
76.                 msg.obj = result;
    
77.                 handler.sendMessage(msg);
    
78.             }
    
79.         }.start();
    
80.     }
    
81.      
    
82.     /**缓存需要定时清空*/
    
83.     public void clear(){
    
84.         new Thread(){
    
85.             public void run() {
    
86.                 helper.getReadableDatabase().delete(tableName, "ID>?", new String[]{"0"});
    
87.             }
    
88.         }.start();
    
89.     }
    
90.      
    
91.     /**url需要去掉token*/
    
92.     private String urlEncode(String url){
    
93.         String result = url.replaceAll("accessToken.*?\\&", "");
    
94.         if (result.contains("accessToken")) {//如果还没去掉，说明是在尾部
    
95.             result = result.replaceAll("\\&accessToken.*?$", "");
    
96.         }
    
97.         return result;
    
98.     }
    
99. 
    
100. }

复制代码