public class FirstProviderMetaData {
//这里的AUTHORTY为包的全名+ContentProvider子类的全名
public static final String AUTHORTY = "com.example.cptest.FirstContentProvider";
//数据库的名称
public static final String DATABASE_NAME = "FisrtProvider.db";
//数据库的版本号
public static final int DATABASE_VERSION = 1;
//数据库中的表名
public static final String USERS_TABLE_NAME = "users";
//表中的字表
public static final class UserTableMetaData implements BaseColumns{
//子表名
public static final String TABLE_NAME = "users";
//CONTENT_URI为常量Uri; parse是将文本转换成Uri
public static final Uri CONTENT_URI = Uri.parse("content://" + AUTHORTY + "/users");
//返回ContentProvider中表的数据类型
public static final String CONTENT_TYPE = "vnd.android.cursor.dir/vnd.firstprovider.user";
//返回ContentProvider表中item的数据类型
public static final String CONTENT_TYPE_ITEM = "vnd.android.cursor.item/vnd.firstprovider.user";
//子表列名
public static final String USER_NAME = "name";
//表中记录的默认排序算法,这里是降序排列
public static final String DEFAULT_SORT_ORDER = "_id desc";
}
}
FirstContentProvider.java:
package com.example.cptest;
import java.util.HashMap;
import android.content.ContentProvider;
import android.content.ContentUris;
import android.content.ContentValues;
import android.content.UriMatcher;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteQueryBuilder;
import android.net.Uri;
import android.text.TextUtils;
import com.example.cptest.FirstProviderMetaData.UserTableMetaData;
public class FirstContentProvider extends ContentProvider {
//定义一个UriMatcher类对象,用来匹配Uri的。
public static final UriMatcher uriMatcher;
//组时的ID
public static final int INCOMING_USER_COLLECTION = 1;
//单个时的ID
public static final int INCOMING_USER_SIGNAL = 2;
private DatabaseHelper dh;//定义一个DatabaseHelper对象
static{
uriMatcher = new UriMatcher(UriMatcher.NO_MATCH);//UriMatcher.NO_MATCH表示不匹配任何路径的返回码
uriMatcher.addURI(FirstProviderMetaData.AUTHORTY, "users", INCOMING_USER_COLLECTION);
uriMatcher.addURI(FirstProviderMetaData.AUTHORTY, "users/#", INCOMING_USER_SIGNAL);//后面加了#表示为单个
}
public static HashMap<String, String> userProjectionMap;//新建一个HashMap,后面执行插入操作时有用
static
{
userProjectionMap = new HashMap<String, String>();
//这里可以直接调用另外一个类的public变量,这里put里面的2个参数一样,
//是因为这里是给数据库表中的列取别名,因此取的是一样的名字
userProjectionMap.put(UserTableMetaData._ID, UserTableMetaData._ID);
userProjectionMap.put(UserTableMetaData.USER_NAME, UserTableMetaData.USER_NAME);
}
//得到ContentProvider的数据类型,返回的参数Uri所代表的数据类型
@Override
public String getType(Uri arg0) {
// TODO Auto-generated method stub
System.out.println("getType");
switch(uriMatcher.match(arg0)){
//matcher满足Uri的前2项(即协议+路径)为第1种情况时,switch语句的值为Uri的第3项,此处为INCOMING_USER_COLLECTION
case INCOMING_USER_COLLECTION:
return UserTableMetaData.CONTENT_TYPE;
case INCOMING_USER_SIGNAL://同上
return UserTableMetaData.CONTENT_TYPE_ITEM;
default:
throw new IllegalArgumentException("Unknown URI" + arg0);//throw是处理异常的,java中的语法
}
}
@Override
public int delete(Uri uri, String selection, String[] selectionArgs) {
// TODO Auto-generated method stub
System.out.println("delete");
return 0;
}
@Override
public int update(Uri uri, ContentValues values, String selection,
String[] selectionArgs) {
// TODO Auto-generated method stub
System.out.println("update");
return 0;
}
@Override
public Uri insert(Uri uri, ContentValues values) {
// TODO Auto-generated method stub
System.out.println("insert");
// dh = new DatabaseHelper(getContext(), FirstProviderMetaData.DATABASE_NAME);
SQLiteDatabase db = dh.getWritableDatabase();
long rowId = db.insert(UserTableMetaData.TABLE_NAME, null, values);
// System.out.println("insert OK");
// System.out.println("" + rowId);
if(rowId > 0){
//发出通知给监听器,说明数据已经改变
//ContentUris为工具类
Uri insertedUserUri = ContentUris.withAppendedId(UserTableMetaData.CONTENT_URI, rowId);
getContext().getContentResolver().notifyChange(insertedUserUri, null);
return insertedUserUri;
}
throw new SQLException("Failed to insert row into" + uri);
}
//回调函数,在ContentProvider创建的时候调用
@Override
public boolean onCreate() {
// TODO Auto-generated method stub
System.out.println("onCreate");
dh = new DatabaseHelper(getContext(), FirstProviderMetaData.DATABASE_NAME);//创建1个DatabaseHelper对象
return true;
}
@Override
public Cursor query(Uri uri, String[] projection, String selection,
String[] selectionArgs, String sortOrder) {
// TODO Auto-generated method stub
System.out.println("query");
SQLiteQueryBuilder qb = new SQLiteQueryBuilder();
switch(uriMatcher.match(uri)){
case INCOMING_USER_COLLECTION:
qb.setTables(UserTableMetaData.TABLE_NAME);//设置表的名称
qb.setProjectionMap(userProjectionMap);//其中userProjectionMap为上面建立好了的hashmap
break;
case INCOMING_USER_SIGNAL:
qb.setTables(UserTableMetaData.TABLE_NAME);//设置表的名称
qb.setProjectionMap(userProjectionMap);//其中userProjectionMap为上面建立好了的hashmap
//uri.getPathSegments()得到Path部分,即把uri的协议+authory部分去掉,把剩下的部分分段获取,这里取第
//一部分
qb.appendWhere(UserTableMetaData._ID + "=" +uri.getPathSegments().get(1));//设置where条件
break;
}
//排序
String orderBy;
if(TextUtils.isEmpty(sortOrder)){
orderBy = UserTableMetaData.DEFAULT_SORT_ORDER;//传入的排序参数为空的时候采用默认的排序
}
else{
orderBy = sortOrder;//不为空时用指定的排序方法进行排序
}
SQLiteDatabase db = dh.getWritableDatabase();
//采用传入的参数进行查询
Cursor c = qb.query(db, projection, selection, selectionArgs, null, null, sortOrder);
//发出通知
c.setNotificationUri(getContext().getContentResolver(), uri);
return c;
}
}
标签:SQLite
相关阅读 >>
c#使用dataset datatable更新数据库的三种实现方法
android之采用execsql与rawquery方法完成数据的添删改查操作详解
更多相关阅读请进入《Sqlite》频道 >>

数据库系统概念 第6版
本书主要讲述了数据模型、基于对象的数据库和XML、数据存储和查询、事务管理、体系结构等方面的内容。
相关推荐
评论
管理员已关闭评论功能...
- 欢迎访问木庄网络博客
- 可复制:代码框内的文字。
- 方法:Ctrl+C。