文档章节

ContentProvider+ContentResolver+ContentObserver

 小牛仔
发布于 2015/02/16 11:32
字数 1185
阅读 842
收藏 1
/**
 * 自定义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
博文 34
码字总数 35169
作品 0
成都

暂无文章

OSChina 周日乱弹 —— 恨不得给你买张飞机挂票

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @开源中国首席灵魂师:分享张希/曹方的单曲《认真地老去》 来不及认真的年轻过,就认真的老去! 《认真地老去》- 张希/曹方 手机党少年们想听...

小小编辑
9分钟前
8
3
如何实现靠谱的分布式锁?

分布式锁,是用来控制分布式系统中互斥访问共享资源的一种手段,从而避免并行导致的结果不可控。基本的实现原理和单进程锁是一致的,通过一个共享标识来确定唯一性,对共享标识进行修改时能够...

郑加威
58分钟前
0
0
Mac OS X下Maven的安装与配置

Mac OS X 安装Maven: 下载 Maven, 并解压到某个目录。例如/Users/robbie/apache-maven-3.3.3 打开Terminal,输入以下命令,设置Maven classpath $ vi ~/.bash_profile 添加下列两行代码,之后...

TonyStarkSir
今天
3
0
关于编程,你的练习是不是有效的?

最近由于工作及Solution项目的影响,我在重新学习DDD和领域建模的一些知识。然后,我突然就想到了这个问题,以及我是怎么做的? 对于我来说,提升技能的项目会有四种: 纯兴趣驱动的项目。即...

问题终结者
今天
4
0
打开eclipse出现an error has occurred see the log file

解决方法: 1,打开eclipse安装目录下的eclipse.ini文件; 2,打开的文本文件最后添加一行 --add-modules=ALL-SYSTEM 3,保存重新打开Eclipse。...

任梁荣
昨天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部