文档章节

ContentProvider+ContentResolver+ContentObserver

 小牛仔
发布于 2015/02/16 11:32
字数 1185
阅读 814
收藏 1
点赞 0
评论 0
/**
 * 自定义MyContentProvider提供了对外共享本地数据一种机制
 * 在AndroidManifest.xml中注册MyContentProvider:
 * <provider android:name="com.test.provider.MyContentProvider"
 *              android:authorities="com.test.provider.MyContentProvider"
 *              android:exported="true" />
 * name,为自定义Provider类的路径名
 * authorities,为类中定义的常量AUTHORITY,是Provider的唯一标示,一般定义为Provider类的路径名
 * exported="true",表示允许其他应用访问
 * */
public class MyContentProvider extends ContentProvider{
    
    // 定义AndroidManifest.xml中<provider>标签的android:authorities的属性值
    public static final String AUTHORITY="com.test.provider.MyContentProvider";
    
    private static final String DATABASE_DIR = "database_dir"; //数据库的目录名
    private static final String DATABASE_NAME = "database.db"; //数据库的文件名,一个数据库文件可以关联多张表
    public static final String SIMPLE_TABLE_NAME = "simple_list_data";//数据库的表名
    
    // 定义数据库中simple_list_data表的基本字段
    public static final class SimpleListData implements BaseColumns{
        // Data数据只有两个字段:_id,content
        public static final String ID = "_id";//_id字段
        public static final String CONTENT = "content";//content字段
        
        // 定义Uri:scheme + authority + path
        // 1. scheme必须以content://开头,这是Android规定的。
        // 2. authority用于来唯一标示一个ContentProvider,一般定义为ContentProvider的包路径。
        // 3. path也是字符串,表示要操作的数据。可根据自己的实现逻辑来指定:
        //    content://com.test.provider.MyContentProvider/simple_list_data
        //    表示要操作simple_list_data表
        //
        //    content://com.test.provider.MyContentProvider/simple_list_data/#
        //    表示要操作simple_list_data表中特定id的行(记录).注意#匹配一个数字字符串
        //
        //    content://com.test.provider.MyContentProvider/simple_list_data/10/content
        //    表示要操作simple_list_data表中id为10的行的content字段。
        //
        //    content://com.test.provider.MyContentProvider/simple_list_data/*
        //    表示操作simple_list_data表中的所有字段。注意*匹配一个文本字符串。
        public static final Uri DATA_URI = Uri.parse("content://" + AUTHORITY + "/" + SIMPLE_TABLE_NAME);
                
        // 如果要处理的对象是一个新的数据类型,需要定义MIME类型,在getType(Uri)中返回定义类型值
        // 定义遵循3条原则:
        // 1. 必须以"vnd"开头
        // 2. 如果Uri对应的数据有多条,必须是"vnd.android.cursor.dir/开头"
        // 3. 如果Uri对应的数据只有一条,必须是"vnd.android.cursor.item/开头"
        public static final String TYPE = "vnd.android.cursor.dir/vnd.dir";
        public static final String ITEM_TYPE = "vnd.android.cursor.item/vnd.item";
    }
    
    // 使用静态代码块初始化UriMatch
    // 可以注册多个Uri,每个Uri代表一种操作
    // 在使用UriMatch。match(uri)方法匹配相应的URI,就可以返回相应的code,比如:
    // "content://com.test.provider.MyContentProvider/simple_list_data"匹配返回1
    // "content://com.test.provider.MyContentProvider/simple_list_data/#"匹配返回2
    public static final UriMatcher mUriMatcher;
    static {
        mUriMatcher = new UriMatcher(UriMatcher.NO_MATCH);
        mUriMatcher.addURI(AUTHORITY, SIMPLE_TABLE_NAME, 1); //URI表示返回所有数据
        mUriMatcher.addURI(AUTHORITY, SIMPLE_TABLE_NAME+"/#", 2); //URI表示返回某一条数据
    }
    
    // 定义SQLite数据库接口
    private class SQLiteHelper extends SQLiteOpenHelper {
        public SQLiteHelper(Context context, String name,
                CursorFactory factory, int version) {
            super(context, name, factory, version);
        }

        public void onCreate(SQLiteDatabase db) {
        }

        public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        }
    }
    private static SQLiteHelper mDb;

    @Override
    public boolean onCreate() {
        if( mDb == null ){    
            StringBuffer path = new StringBuffer();
            if ( Environment.getExternalStorageState().equalsIgnoreCase(Environment.MEDIA_MOUNTED) ) {
                File file = Environment.getExternalStorageDirectory();
                path.append(file.getPath());
            } else {
                path.append(getContext().getFilesDir());
            }
            path.append(File.separator);
            path.append(DATABASE_DIR);
            String  databaseDirPath = path.toString();
            File dir = new File(databaseDirPath);
            if(!dir.exists()){
                dir.mkdir();
            }
            path.append(File.separator);
            path.append(DATABASE_NAME);
            String databaseFullPath = path.toString();
            File file = new File(databaseFullPath);
            if(!file.exists()){
                try {
                    file.createNewFile();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            mDb = new SQLiteHelper(getContext(),databaseFullPath,null,1);
            SQLiteDatabase db = mDb.getWritableDatabase();
            StringBuffer str = new StringBuffer();
            str.append("CREATE TABLE IF NOT EXISTS ");
            str.append(SIMPLE_TABLE_NAME);
            str.append(" (_id INTERGER PRIMARY KEY, content TEXT)");
            db.execSQL(str.toString());
            db.close();
        }
        return (mDb==null)?false:true;
    }

    @Override
    public Cursor query(Uri uri, String[] projection, String selection,
            String[] selectionArgs, String sortOrder) {
        SQLiteDatabase db = mDb.getReadableDatabase();
        Cursor c = null;
        switch(mUriMatcher.match(uri)){
            case 1:
                c = db.query(SIMPLE_TABLE_NAME, projection, selection, selectionArgs, null, null, sortOrder);
                break;
            case 2:
                long id = ContentUris.parseId(uri);
                StringBuffer where = new StringBuffer();
                where.append("_id=");
                where.append(id);
                if(selection!=null && !where.toString().equalsIgnoreCase(selection.trim())){
                    where.append(" and ");
                    where.append(selection);
                }
                c = db.query(SIMPLE_TABLE_NAME, projection, where.toString(), selectionArgs, null, null, sortOrder);
                break;
            default:
                break;
        }
        return c;
    }

    @Override
    public String getType(Uri uri) {
        String mimeType = null;
        switch(mUriMatcher.match(uri)){
            case 1://URI表示返回所有数据
                mimeType = SimpleListData.TYPE;
                break;
            case 2://URI表示返回某一条数据
                mimeType = SimpleListData.ITEM_TYPE;
                break;
            default:
                break;
        }
        return mimeType;
    }

    @Override
    public Uri insert(Uri uri, ContentValues values) {
        Uri insertedUri = null;
        SQLiteDatabase db = mDb.getWritableDatabase();
        if(mUriMatcher.match(uri)==1){
            //插入只能是向表插入
            long newid = db.insert(SIMPLE_TABLE_NAME, null, values);
            getContext().getContentResolver().notifyChange(uri, null);
            insertedUri = ContentUris.withAppendedId(uri, newid);
        }
        db.close();
        return insertedUri;
    }

    @Override
    public int delete(Uri uri, String selection, String[] selectionArgs) {
        int count = 0;
        SQLiteDatabase db = mDb.getWritableDatabase();
        switch(mUriMatcher.match(uri)){
            case 1://删除表
                count = db.delete(SIMPLE_TABLE_NAME, selection, selectionArgs);
                //向外界通知数据变化,以便ContentResolver作出相应
                getContext().getContentResolver().notifyChange(uri, null);
                break;
            case 2://删除表中的某一条数据
                long id = ContentUris.parseId(uri);
                StringBuffer where = new StringBuffer();
                where.append("_id=");
                where.append(id);
                if(selection!=null && !where.toString().equalsIgnoreCase(selection.trim())){
                    where.append(" and ");
                    where.append(selection);
                }
                count = db.delete(SIMPLE_TABLE_NAME, where.toString(), selectionArgs);
                //向外界通知数据变化,以便ContentResolver作出相应
                getContext().getContentResolver().notifyChange(uri, null);
                break;
            default:
                break;
        }
        db.close();
        return count;
    }

    @Override
    public int update(Uri uri, ContentValues values, String selection,
            String[] selectionArgs) {
        int count = 0;
        SQLiteDatabase db = mDb.getWritableDatabase();
        switch(mUriMatcher.match(uri)){
            case 1:
                count = db.update(SIMPLE_TABLE_NAME, values, selection, selectionArgs);
                getContext().getContentResolver().notifyChange(uri, null);
                break;
            case 2:
                long id = ContentUris.parseId(uri);
                StringBuffer where = new StringBuffer();
                where.append("_id=");
                where.append(id);
                if(selection!=null && !where.toString().equalsIgnoreCase(selection.trim())){
                    where.append(" and ");
                    where.append(selection);
                }
                count = db.update(SIMPLE_TABLE_NAME, values, where.toString(), selectionArgs);
                getContext().getContentResolver().notifyChange(uri, null);
                break;
            default:
                break;
        }
        db.close();
        return count;
    }
}

自定义ContentObserver来监听注册Uri数据的变化:

public class MyContentObserver extends ContentObserver{

    private Handler mHandler;
    public static final int DATA_CHANGED = 100;
    
    public MyContentObserver(Handler handler) {
        super(handler);
        mHandler = handler;
    }
    
    public void onChange(boolean selfChange) {
        mHandler.sendEmptyMessage(DATA_CHANGED);
    }
}

使用ContentResolver来获取ContentProvider提供的数据,同时注册ContentObserver监听Uri数据的变化:

//注册观察者
mContentObserver = new MyContentObserver(new Handler(){
    public void handleMessage(Message msg) {
        if(msg.what == MyContentObserver.DATA_CHANGED){
        }
    }
});    
mContentResolver = getContentResolver();
mContentResolver.registerContentObserver(MyContentProvider.SimpleListData.DATA_URI, true, mContentObserver);

//解除观察者
mContentResolver.unregisterContentObserver(mContentObserver);

© 著作权归作者所有

共有 人打赏支持
粉丝 0
博文 16
码字总数 35169
作品 0
成都

暂无相关文章

内存障碍: 软件黑客的硬件视图

此文为笔者近日有幸看到的一则关于计算机底层内存障碍的学术论文,并翻译(机译)而来[自认为翻译的还行],若读者想要英文原版的论文话,给我留言,我发给你。 内存障碍: 软件黑客的硬件视图...

Romane ⋅ 26分钟前 ⋅ 0

SpringCloud 微服务 (七) 服务通信 Feign

壹 继续第(六)篇RestTemplate篇 做到现在,本机上已经有注册中心: eureka, 服务:client、order、product 继续在order中实现通信向product服务,使用Feign方式 下面记录学习和遇到的问题 贰 or...

___大侠 ⋅ 43分钟前 ⋅ 0

001. 深入JVM学习—Java运行流程

1. Java运行流程图 2. Java运行时数据区 3. Java虚拟机栈 栈内存是线程私有的,其生命周期和线程相同; 虚拟机栈描述的是Java方法执行的内存模型:执行一个方法时会产生一个栈帧随后将其保存...

影狼 ⋅ 58分钟前 ⋅ 0

gitee、github上issue标签方案

目录 [TOC] issue生命周期 st=>start: 开始e=>end: 结束op0=>operation: 新建issueop1=>operation: 评审issueop2=>operation: 任务负责人执行任务cond1=>condition: 是否通过?op3=>o......

lovewinner ⋅ 今天 ⋅ 0

浅谈mysql的索引设计原则以及常见索引的区别

索引定义:是一个单独的,存储在磁盘上的数据库结构,其包含着对数据表里所有记录的引用指针. 数据库索引的设计原则: 为了使索引的使用效率更高,在创建索引时,必须考虑在哪些字段上创建索...

屌丝男神 ⋅ 今天 ⋅ 0

String,StringBuilder,StringBuffer三者的区别

这三个类之间的区别主要是在两个方面,即运行速度和线程安全这两方面。 首先说运行速度,或者说是, 1.执行速度 在这方面运行速度快慢为:StringBuilder(线程不安全,可变) > StringBuffer...

时刻在奔跑 ⋅ 今天 ⋅ 0

java以太坊开发 - web3j使用钱包进行转账

首先载入钱包,然后利用账户凭证操作受控交易Transfer进行转账: Web3j web3 = Web3j.build(new HttpService()); // defaults to http://localhost:8545/Credentials credentials = Wallet......

以太坊教程 ⋅ 今天 ⋅ 0

Oracle全文检索配置与实践

Oracle全文检索配置与实践

微小宝 ⋅ 今天 ⋅ 0

mysql的分区和分表

1,什么是mysql分表,分区 什么是分表,从表面意思上看呢,就是把一张表分成N多个小表,具体请看mysql分表的3种方法 什么是分区,分区呢就是把一张表的数据分成N多个区块,这些区块可以在同一...

梦梦阁 ⋅ 今天 ⋅ 0

exception.ZuulException: Forwarding error

错误日志 com.netflix.zuul.exception.ZuulException: Forwarding error Caused by: com.netflix.hystrix.exception.HystrixRuntimeException: xxx timed-out and no fallback available. Ca......

jack_peng ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部