android常用的数据保存方式有文件、sharepreferences、数据库、网络、contentprovider集中方式。

文件存储方式，经常使用在缓存整个页面数据，比如电子书内容、html数据等。

sharepreferrences存储方式，实质也就是xml文件存储的封装，常用于存储配置参数数据。当然也可以用文件存储+Properties来存储参数数据。

网络，就是将数据存储在网络空间上。

contentprovider主要作用是统一数据存储方式，实现数据共享，以后有机会仔细分析下。

数据库的方式，常用在存储一系列的结构复杂的数据，轻量级的数据库SQlit使用起来还是比较简单，但是总想能像hibernate似的框架可以进行下封装，实现orm并且可以实现简单的rcud。这里就介绍下一个分装过程，源码下载在后面。

一、封装数据库的类结构

结构比较简单：BaseBean.java--实体类的基类

DBConfig.java---数据库的参数，包括数据库名、要创建的表列表、数据库版本等

IssContentProvider.java--继承了ContentProvider，定义了数据库的初始化和操作

DBFactory--数据库工厂类

Table.java----定义Table的annotation

TableColumn.java--定义表的列的annotation和属性

TableUtil.java--书库操作工具类，主要是获得表和根据标签拼装sql语句

二、封装数据库的使用过程

由于封装后的数据库使用比较简单，就跟配置好hibernate之后使用似的，所以咱们先看下咱们使用，不理解的地方，等分析了整个实现过程后就行清晰了。

1、要实现orm，肯定要定义带标签的实体类，当然是继承BaseBean类。

2、要将数据库参数传递给DBConfig，并初始化。

3、数据库操作类，通过contentprovideder实现crud。

用例子看下
1，定义实体类

[java] view plain copy

1. publicclassSmartDownloadBeanextendsBaseBean<SmartDownloadBean>{
3. @TableColumn(type=TableColumn.Types.TEXT,isIndex=true,isNotNull=true)
4. publicStringdownpath;
6. @TableColumn(type=TableColumn.Types.INTEGER)
7. publicintthreadid;
9. @TableColumn(type=TableColumn.Types.INTEGER)
10. publicintdownlength;
12. @Override
13. publicSmartDownloadBeanparseJSON(JSONObjectjsonObj){
14. returnnull;
15. }
17. @Override
18. publicJSONObjecttoJSON(){
19. //TODOAuto-generatedmethodstub
20. returnnull;
21. }
23. @Override
24. publicSmartDownloadBeancursorToBean(Cursorcursor){
25. this.downpath=cursor.getString(cursor.getColumnIndex("downpath"));
26. this.threadid=cursor.getInt(cursor.getColumnIndex("threadid"));
27. this.downlength=cursor.getInt(cursor.getColumnIndex("downlength"));
28. returnthis;
29. }
31. @Override
32. publicContentValuesbeanToValues(){
33. ContentValuesvalues=newContentValues();
34. if(!TextUtils.isEmpty(downpath)){
35. values.put("downpath",downpath);
36. }
37. if(!TextUtils.isEmpty(threadid+"")){
38. values.put("threadid",threadid);
39. }
40. if(!TextUtils.isEmpty(downlength+"")){
41. values.put("downlength",downlength);
42. }
43. returnvalues;
44. }
46. }

实体类通过标签，定义了对应表的列名、及列的属性

2、定义要创建的表、数据名等参数

[java] view plain copy

1. /**
2. *数据库配置
3. **/
4. publicclassSssProviderextendsIssContentProvider{
6. @Override
7. publicvoidinit(){
9. //数据库相关参数设置
10. DBConfigconfig=newDBConfig.Builder()
11. .addTatble(SmartDownloadBean.class)
12. .setName("sss.db").setVersion(2)
13. .setAuthority("com.sss").build();
15. IssDBFactory.init(getContext(),config);
16. }
21. }

要定义都个表的话，再addTatble(Bean.class)即可。

3、调用数据库的工具类

[java] view plain copy

1. /**
2. *操作数据库的utils
3. *
4. *@authordllik2013-11-23
5. */
6. publicclassDBUtils{
8. publicstaticUriURI_SMARTDOWNLOAD=IssContentProvider.buildUri(SmartDownloadBean.class);
12. /**
13. *获取每条线程已经下载的文件长度
14. *
15. *@paramcontext
16. *@paramdownpath
17. *@return
18. */
19. publicstaticMap<Integer,Integer>querySmartDownData(Contextcontext,Stringdownpath){
20. ContentResolvermResolver=context.getContentResolver();
21. Cursorcursor=mResolver.query(URI_SMARTDOWNLOAD,null,"downpath=?",newString[]{
22. downpath
23. },null);
24. Map<Integer,Integer>data=newHashMap<Integer,Integer>();
25. while(cursor.moveToNext()){
26. SmartDownloadBeanbean=newSmartDownloadBean();
27. bean.cursorToBean(cursor);
28. data.put(bean.threadid,bean.downlength);
29. }
30. cursor.close();
31. returndata;
32. }
34. /**
35. *保存每条线程已经下载的文件长度
36. *
37. *@paramcontext
38. *@parampath
39. *@parammap
40. */
41. publicstaticvoidinsertSmartDown(Contextcontext,Stringpath,Map<Integer,Integer>map){
42. ContentResolvermResolver=context.getContentResolver();
43. for(Map.Entry<Integer,Integer>entry:map.entrySet()){
44. SmartDownloadBeanbean=newSmartDownloadBean();
45. bean.downpath=path;
46. bean.downlength=entry.getValue();
47. bean.threadid=entry.getKey();
48. mResolver.insert(URI_SMARTDOWNLOAD,bean.beanToValues());
49. }
50. }
52. /**
53. *实时更新每条线程已经下载的文件长度
54. *
55. *@paramcontext
56. *@parampath
57. *@parammap
58. */
59. publicstaticvoidupdateSmartDown(Contextcontext,Stringpath,Map<Integer,Integer>map){
60. ContentResolvermResolver=context.getContentResolver();
61. for(Map.Entry<Integer,Integer>entry:map.entrySet()){
62. SmartDownloadBeanbean=newSmartDownloadBean();
63. bean.downpath=path;
64. bean.downlength=entry.getValue();
65. bean.threadid=entry.getKey();
66. mResolver.update(URI_SMARTDOWNLOAD,bean.beanToValues(),"downpath=?andthreadid=?",
67. newString[]{
68. bean.downpath,bean.threadid+""
69. });
70. }
71. }
73. /**
74. *当文件下载完成后，删除对应的下载记录
75. *
76. *@paramcontext
77. *@parampath
78. */
79. publicstaticvoiddeleteSmartDown(Contextcontext,Stringpath){
80. ContentResolvermResolver=context.getContentResolver();
81. mResolver.delete(URI_SMARTDOWNLOAD,"downpath=?",newString[]{
82. path
83. });
84. }
88. }

三、数据库的封装过程

看下实体类的基类

[java] view plain copy

1. publicabstractclassBaseBean<T>implementsSerializable{
2. privatestaticfinallongserialVersionUID=-804757173578073135L;
4. @TableColumn(type=TableColumn.Types.INTEGER,isPrimary=true)
5. publicstaticfinalString_ID="_id";
7. /**
8. *将json对象转化为Bean实例
9. *
10. *@paramjsonObj
11. *@return
12. */
13. publicabstractTparseJSON(JSONObjectjsonObj);
15. /**
16. *将Bean实例转化为json对象
17. *
18. *@return
19. */
20. publicabstractJSONObjecttoJSON();
22. /**
23. *将数据库的cursor转化为Bean实例（如果对象涉及在数据库存取，需实现此方法）
24. *
25. *@paramcursor
26. *@return
27. */
28. publicabstractTcursorToBean(Cursorcursor);
30. /**
31. *将Bean实例转化为一个ContentValues实例，供存入数据库使用（如果对象涉及在数据库存取，需实现此方法）
32. *
33. *@return
34. */
35. publicabstractContentValuesbeanToValues();
37. @SuppressWarnings("unchecked")
38. publicTparseJSON(Gsongson,Stringjson){
39. return(T)gson.fromJson(json,this.getClass());
40. }
42. publicContentValuestoValues(){
43. ContentValuesvalues=newContentValues();
44. try{
45. Class<?>c=getClass();
46. Field[]fields=c.getFields();
47. for(Fieldf:fields){
48. f.setAccessible(true);
49. finalTableColumntableColumnAnnotation=f.getAnnotation(TableColumn.class);
50. if(tableColumnAnnotation!=null){
51. if(tableColumnAnnotation.type()==TableColumn.Types.INTEGER){
52. values.put(f.getName(),f.getInt(this));
53. }elseif(tableColumnAnnotation.type()==TableColumn.Types.BLOB){
54. values.put(f.getName(),(byte[])f.get(this));
55. }elseif(tableColumnAnnotation.type()==TableColumn.Types.TEXT){
56. values.put(f.getName(),f.get(this).toString());
57. }else{
58. values.put(f.getName(),f.get(this).toString());
59. }
60. }
61. }
62. }catch(IllegalArgumentExceptione){
63. e.printStackTrace();
64. }catch(IllegalAccessExceptione){
65. e.printStackTrace();
66. }
67. returnvalues;
68. }
71. }

说明几点：1、用到了泛型，因为定义的数据实体类有多个

2、实现序列化，实体类数据通过Intent进行传递

3、定义了一个主键id

数据库参数类

[java] view plain copy

1. publicclassDBConfig{
2. finalArrayList<Class<?extendsBaseBean<?>>>tableList;
4. finalStringdbName;
6. finalintdbVersion;
8. finalStringauthority;
10. finalArrayList<String>tableNameList;
12. privateDBConfig(finalBuilderbuilder){
13. tableList=builder.tableList;
14. dbName=builder.dbName;
15. dbVersion=builder.dbVersion;
16. authority=builder.authority;
18. tableNameList=newArrayList<String>();
19. for(Class<?extendsBaseBean<?>>c:tableList){
20. Stringname=TableUtil.getTableName(c);
21. tableNameList.add(name);
22. }
23. }
25. publicstaticclassBuilder{
26. privateArrayList<Class<?extendsBaseBean<?>>>tableList;
28. privateStringdbName;
30. privateintdbVersion;
32. privateStringauthority="com.iss.mobile";
34. publicBuilder(){
35. tableList=newArrayList<Class<?extendsBaseBean<?>>>();
36. }
38. publicBuildersetName(Stringname){
39. dbName=name;
40. returnthis;
41. }
43. publicBuildersetVersion(intversion){
44. dbVersion=version;
45. returnthis;
46. }
48. publicBuilderaddTatble(Class<?extendsBaseBean<?>>table){
49. tableList.add(table);
50. returnthis;
51. }
53. publicBuildersetAuthority(Stringauthority){
54. this.authority=authority;
55. returnthis;
56. }
58. publicDBConfigbuild(){
59. returnnewDBConfig(this);
60. }
61. }
63. }

通过该类，来设置数据库的参数，在初始化数据库的时候用到。

内容提供者类，初始化和操作数据库

[java] view plain copy

1. publicabstractclassIssContentProviderextendsContentProvider{
2. publicstaticStringCONTENT_TYPE="vnd.android.cursor.dir/iss.db";
4. protectedSQLiteDatabasemDB;
6. publicstaticStringAUTHORITY="com.iss.mobile";
8. @Override
9. publicbooleanonCreate(){
10. init();
11. IssDBFactoryissDBFactory=IssDBFactory.getInstance();
12. DBConfigconfig=IssDBFactory.getInstance().getDBConfig();
13. if(config==null){
14. thrownewRuntimeException("dbfactorynotinit");
15. }
16. AUTHORITY=config.authority;
17. CONTENT_TYPE="vnd.android.cursor.dir/"+config.dbName;
18. mDB=issDBFactory.open();
19. returntrue;
20. }
22. publicabstractvoidinit();
24. publicstaticfinalStringSCHEME="content";
26. @Override
27. publicUriinsert(Uriuri,ContentValuesvalues){
28. StringtableName=getTableName(uri);
29. longresult=mDB.insert(tableName,null,values);
30. if(result!=-1){
31. getContext().getContentResolver().notifyChange(uri,null);
32. }
33. returnbuildResultUri(tableName,result);
34. }
36. @Override
37. publicintbulkInsert(Uriuri,ContentValues[]values){
38. mDB.beginTransaction();
39. StringtableName=getTableName(uri);
40. for(ContentValuesvalue:values){
41. mDB.insert(tableName,null,value);
42. }
43. mDB.setTransactionSuccessful();
44. mDB.endTransaction();
45. returnvalues.length;
46. }
48. @Override
49. publicCursorquery(Uriuri,String[]projection,Stringselection,String[]selectionArgs,
50. StringsortOrder){
51. StringtableName=getTableName(uri);
52. returnmDB.query(tableName,projection,selection,selectionArgs,null,null,sortOrder);
53. }
55. @Override
56. publicStringgetType(Uriuri){
57. returnCONTENT_TYPE;
58. }
60. @Override
61. publicintdelete(Uriuri,Stringselection,String[]selectionArgs){
62. StringtableName=getTableName(uri);
63. intresult=mDB.delete(tableName,selection,selectionArgs);
64. if(result!=0){
65. getContext().getContentResolver().notifyChange(uri,null);
66. }
67. returnresult;
68. }
70. @Override
71. publicintupdate(Uriuri,ContentValuesvalues,Stringselection,String[]selectionArgs){
72. StringtableName=getTableName(uri);
73. intresult=mDB.update(tableName,values,selection,selectionArgs);
74. if(result!=0){
75. getContext().getContentResolver().notifyChange(uri,null);
76. }
77. returnresult;
78. }
80. privateUribuildResultUri(StringtableName,longresult){
81. finalUri.Builderbuilder=newUri.Builder();
82. DBConfigconfig=IssDBFactory.getInstance().getDBConfig();
83. if(config==null){
84. thrownewRuntimeException("dbfactorynotinit");
85. }
86. builder.scheme(SCHEME);
87. builder.authority(config.authority);
88. builder.path(tableName);
89. builder.appendPath(String.valueOf(result));
90. returnbuilder.build();
91. }
93. privateStringgetTableName(Uriuri){
94. DBConfigconfig=IssDBFactory.getInstance().getDBConfig();
95. if(config==null){
96. thrownewRuntimeException("dbfactorynotinit");
97. }
98. Stringpath=uri.getLastPathSegment();
99. if(!config.tableNameList.contains(path)){
100. thrownewIllegalArgumentException("UnknownURI"+uri);
101. }
102. returnpath;
103. }
105. publicstaticUribuildUri(Stringpath,Stringid){
106. finalUri.Builderbuilder=newUri.Builder();
107. DBConfigconfig=IssDBFactory.getInstance().getDBConfig();
108. if(config==null){
109. thrownewRuntimeException("dbfactorynotinit");
110. }
111. builder.scheme(SCHEME);
112. builder.authority(config.authority);
113. builder.path(path);
114. builder.appendPath(id);
115. returnbuilder.build();
116. }
118. publicstaticUribuildUri(Stringpath){
119. finalUri.Builderbuilder=newUri.Builder();
120. DBConfigconfig=IssDBFactory.getInstance().getDBConfig();
121. if(config==null){
122. thrownewRuntimeException("dbfactorynotinit");
123. }
124. builder.scheme(SCHEME);
125. builder.authority(config.authority);
126. builder.path(path);
127. returnbuilder.build();
128. }
130. publicstaticUribuildUri(Class<?extendsBaseBean<?>>c){
131. finalStringtableName=TableUtil.getTableName(c);
132. returnbuildUri(tableName);
133. }
135. }

该内容提供者在创建的时候，先执行init()(将要数据库的参数设置好，再将参数传递给工厂类)，工厂类根据参数创建数据库mDB = issDBFactory.open();
数据库工厂类：

[java] view plain copy

1. publicclassIssDBFactory{
2. privatestaticfinalStringTAG=IssDBFactory.class.getSimpleName();
4. privateDBConfigmConfig;
5. privateSQLiteDatabasemSQLiteDB;
7. privateIssDBOpenHelpermDBOpenHelper;
9. privatefinalContextmContext;
11. privatestaticIssDBFactoryinstance;
13. privateIssDBFactory(Contextcontext){
14. mContext=context;
15. }
17. publicstaticvoidinit(Contextcontext,DBConfigdbConfig){
18. if(instance==null){
19. instance=newIssDBFactory(context.getApplicationContext());
20. instance.setDBConfig(dbConfig);
21. }
22. }
24. publicstaticIssDBFactorygetInstance(){
25. returninstance;
26. }
29. publicvoidsetDBConfig(DBConfigdbConfig){
30. mConfig=dbConfig;
31. }
33. publicDBConfiggetDBConfig(){
34. returnmConfig;
35. }
37. publicSQLiteDatabaseopen(){
38. if(mSQLiteDB==null){
39. mDBOpenHelper=newIssDBOpenHelper(mContext,mConfig.dbName,null,mConfig.dbVersion);
40. mSQLiteDB=mDBOpenHelper.getWritableDatabase();
41. }
42. returnmSQLiteDB;
43. }
45. publicvoidclose(){
46. if(mDBOpenHelper!=null){
47. mDBOpenHelper.close();
48. }
49. }
51. publicvoidbeginTransaction(){
52. if(mSQLiteDB==null){
53. mSQLiteDB.beginTransaction();
54. }
55. }
57. publicvoidendTransaction(){
58. if(mSQLiteDB==null&&mSQLiteDB.inTransaction()){
59. mSQLiteDB.endTransaction();
60. }
61. }
63. publicvoidsetTransactionSuccessful(){
64. if(mSQLiteDB==null){
65. mSQLiteDB.setTransactionSuccessful();
66. }
67. }
69. privatefinalclassIssDBOpenHelperextendsSQLiteOpenHelper{
71. publicIssDBOpenHelper(Contextcontext,Stringname,CursorFactoryfactory,intversion){
72. super(context,name,factory,version);
73. }
75. @Override
76. publicvoidonCreate(SQLiteDatabasedb){
77. for(Class<?extendsBaseBean<?>>table:mConfig.tableList){
78. try{
79. for(Stringstatment:TableUtil.getCreateStatments(table)){
80. Log.d(TAG,statment);
81. db.execSQL(statment);
82. }
83. }catch(Throwablee){
84. Log.e(TAG,"Can'tcreatetable"+table.getSimpleName());
85. }
86. }
88. /**
89. *初始化数据
90. */
91. //initData();
93. }
95. @Override
96. publicvoidonUpgrade(SQLiteDatabasedb,intoldVersion,intnewVersion){
97. Log.d(TAG,"onUpgrade:"+oldVersion+">>"+newVersion);
98. for(Class<?extendsBaseBean<?>>table:mConfig.tableList){
99. try{
100. db.execSQL("DROPTABLEIFEXISTS"+TableUtil.getTableName(table));
101. }catch(Throwablee){
102. Log.e(TAG,"Can'tcreatetable"+table.getSimpleName());
103. }
104. }
105. onCreate(db);
106. }
108. }
110. publicvoidcleanTable(StringtableName,intmaxSize,intbatchSize){
111. Cursorcursor=mSQLiteDB.rawQuery("selectcount(_id)from"+tableName,null);
112. if(cursor.getCount()!=0&&cursor.moveToFirst()&&!cursor.isAfterLast()){
113. if(cursor.getInt(0)>=maxSize){
114. intdeleteSize=maxSize-batchSize;
115. mSQLiteDB.execSQL("deletefrom"+tableName+"where_idin("+"select_idfrom"+tableName
116. +"orderby_id"+"limit"+deleteSize+")");
117. }
118. }
119. cursor.close();
120. }

看到这用过数据库的就比较清晰了，用到了SQLiteOpenHelper是以内部类的形式实现的，在oncreat里创建了表，在onupgrade里实现了更新表。

其中用到TableUtil.getCreateStatments(table），

数据库工具类：

[java] view plain copy

1. publicclassTableUtil{
3. publicstaticStringgetTableName(Class<?extendsBaseBean<?>>c){
4. Stringname=null;
5. TabletableNameAnnotation=c.getAnnotation(Table.class);
6. if(tableNameAnnotation!=null){
7. name=tableNameAnnotation.name();
8. }
9. if(TextUtils.isEmpty(name)){
10. name=c.getSimpleName();
11. }
12. returnname;
13. }
15. /**
16. *拼装sql用的建表语句以及索引语句
17. *
18. *@paramc
19. *@return
20. */
21. publicfinalstaticList<String>getCreateStatments(Class<?extendsBaseBean<?>>c){
22. finalList<String>createStatments=newArrayList<String>();
23. finalList<String>indexStatments=newArrayList<String>();
25. finalStringBuilderbuilder=newStringBuilder();
26. finalStringtableName=getTableName(c);
27. builder.append("CREATETABLE");
28. builder.append(tableName);
29. builder.append("(");
30. intcolumnNum=0;
31. for(finalFieldf:c.getFields()){
32. f.setAccessible(true);
33. finalTableColumntableColumnAnnotation=f.getAnnotation(TableColumn.class);
34. if(tableColumnAnnotation!=null){
35. columnNum++;
36. StringcolumnName=f.getName();
37. builder.append(columnName);
38. builder.append("");
39. if(tableColumnAnnotation.type()==TableColumn.Types.INTEGER){
40. builder.append("INTEGER");
41. }elseif(tableColumnAnnotation.type()==TableColumn.Types.BLOB){
42. builder.append("BLOB");
43. }elseif(tableColumnAnnotation.type()==TableColumn.Types.TEXT){
44. builder.append("TEXT");
45. }else{
46. builder.append("DATETIME");
47. }
48. if(tableColumnAnnotation.isPrimary()){
49. builder.append("PRIMARYKEY");
50. }else{
51. if(tableColumnAnnotation.isNotNull()){
52. builder.append("NOTNULL");
53. }
54. if(tableColumnAnnotation.isUnique()){
55. builder.append("UNIQUE");
56. }
57. }
58. if(tableColumnAnnotation.isIndex()){
59. indexStatments.add("CREATEINDEXidx_"+columnName+"_"+tableName+"ON"
60. +tableName+"("+columnName+");");
61. }
62. builder.append(",");
63. }
64. }
65. builder.setLength(builder.length()-2);//removelast','
66. builder.append(");");
67. if(columnNum>0){
68. createStatments.add(builder.toString());
69. createStatments.addAll(indexStatments);
70. }
71. returncreateStatments;
72. }
74. }

就两个方法，获取表名，在更新表的时候用到，拼装sql在创建表时候用到。
最后两个标签类：

[java] view plain copy

1. @Retention(RetentionPolicy.RUNTIME)
2. public@interfaceTable{
3. Stringname();
4. }

[java] view plain copy

1. @Retention(RetentionPolicy.RUNTIME)
2. public@interfaceTableColumn{
3. publicenumTypes{
4. INTEGER,TEXT,BLOB,DATETIME
5. }
7. Typestype()defaultTypes.TEXT;
9. booleanisPrimary()defaultfalse;
11. booleanisIndex()defaultfalse;
13. booleanisNotNull()defaultfalse;
15. booleanisUnique()defaultfalse;
17. }

思路比较简单，就是注意先标签、过滤器、内容提供者的使用就行了。

最后是封装包代码，使用过程没有加，自己加入吧：http://download.csdn.net/detail/xiangxue336/7001299

更多相关文章

1. Android 与 JS 交互数据上限问题【Refusing to load URL as it e
2. 在 Android 应用中使用数据库
3. Android ListView 滚动条的设置详解及实例代码
4. android 数据传输之JSON
5. Android NDK c调用java代码
6. Android P 以及之后版本不支持同时从多个进程使用具有相同数据目
7. Android Sqlite数据库跨版本升级 保存之前数据

随机推荐

1. android开发实战！2021年Android技术下半场
2. Android自定义属性时TypedArray的使用方
3. Android历史版本
4. Android(安卓)R- CarAudioService之regis
5. git新建本地仓库关联远程仓库（无需移动本
6. Android之Activity概述
7. Android(安卓)事件分发
8. Android(安卓)中文API：Signing Your Appli
9. Android(安卓)6.0 7.0 8.0特性变更
10. Android学习笔记——蓝牙入门