Android ContentProvider基础应用详解

2022-07-16,,,,

一、适用场景

1、contentprovider为存储和读取数据提供了统一的接口

2、 使用contentprovider,应用程序可以实现数据共享

3、 android内置的许多数据都是使用contentprovider形式,供开发者调用的(如视频,音频,图片,通讯录等)

二、概念介绍

1、contentprovider简介

当应用继承contentprovider类,并重写该类用于提供数据和存储数据的方法,就可以向其他应用共享其数据。虽然使用其他方法也可以对外共享数据,但数据访问方式会因数据存储的方式而不同,如:采用文件方式对外共享数据,需要进行文件操作读写数据;采用sharedpreferences共享数据,需要使用sharedpreferences api读写数据。而使用contentprovider共享数据的好处是统一了数据访问方式。

2、uri类简介

uri uri = uri.parse("content://com.changcheng.provider.contactprovider/contact")

在content provider中使用的查询字符串有别于标准的sql查询。很多诸如select, add, delete, modify等操作我们都使用一种特殊的uri来进行,这种uri由3个部分组成, “content://”, 代表数据的路径,和一个可选的标识数据的id。以下是一些示例uri:

content://media/internal/images  这个uri将返回设备上存储的所有图片

content://contacts/people/  这个uri将返回设备上的所有联系人信息

content://contacts/people/45 这个uri返回单个结果(联系人信息中id为45的联系人记录)

尽管这种查询字符串格式很常见,但是它看起来还是有点令人迷惑。为此,android提供一系列的帮助类(在android.provider包下),里面包含了很多以类变量形式给出的查询字符串,这种方式更容易让我们理解一点,因此,如上面content://contacts/people/45这个uri就可以写成如下形式:uri person = contenturis.withappendedid(people.content_uri,  45)。

三、使用步骤

1、首先创建一个继承自contentprovider的类,并实现其6个方法:

此6个方法只有oncreate方法运行在ui线程中,这里在oncreate方法中进行一些数据的初始化工作,初始了sqlite数据库【这里拿封装数据库操作举例,也可以是其他】,创建了两张表book、user 并分别默认插入了两本书,和两个管理员。

package com.hongri.androidipc.contentprovider;
 
/**
 * @author zhongyao
 * @date 2018/6/11
 *
 * oncreate方法运行在主线程(main)中
 * 其他方法运行在binder线程池中
 *
 */
 
public class mycontentprovider extends contentprovider {
    private static final string tag = mycontentprovider.class.getsimplename() + " ";
    /**
     * 唯一标识
     */
    public static final string authorities = "com.hongri.androidipc.contentprovider.provider";
 
    public static final uri book_content_uri = uri.parse("content://" + authorities + "/book");
 
    public static final uri user_content_uri = uri.parse("content://" + authorities + "/user");
 
    public static final int book_uri_code = 0;
 
    public static final int user_uri_code = 1;
 
    private dbopenhelper mdbhelper;
 
    private sqlitedatabase mdb;
 
    private context mcontext;
 
    private static final urimatcher murimatcher = new urimatcher(urimatcher.no_match);
 
    static {
        murimatcher.adduri(authorities, "book", book_uri_code);
        murimatcher.adduri(authorities, "user", user_uri_code);
    }
 
    /**
     * contentprovider的创建:做一些初始化的工作
     * oncreate方法 运行在主线程,其他方法运行在工作线程
     * @return
     */
    @override
    public boolean oncreate() {
        string currentthreadname = thread.currentthread().getname();
        logger.d(tag + "oncreate--" + "currentthreadname:" + currentthreadname);
 
        mcontext = getcontext();
 
        mdbhelper = new dbopenhelper(getcontext(), "", null, 1);
        mdb = mdbhelper.getwritabledatabase();
        mdb.execsql("delete from " + dbopenhelper.book_table_name);
        mdb.execsql("delete from " + dbopenhelper.user_table_name);
        mdb.execsql("insert into book values('1','android',234);");
        mdb.execsql("insert into book values('2','java',348);");
        mdb.execsql("insert into user values('1','hongri',1);");
        mdb.execsql("insert into user values('2','huyin',1);");
        return true;
    }
 
    private string gettablename(uri uri) {
        switch (murimatcher.match(uri)) {
            case book_uri_code:
                return dbopenhelper.book_table_name;
            case user_uri_code:
                return dbopenhelper.user_table_name;
            default:
                break;
        }
        return "";
    }
 
    /**
     * 用来返回一个mime类型(媒体类型)
     *
     * @param uri
     * @return
     */
    @nullable
    @override
    public string gettype(@nonnull uri uri) {
        return null;
    }
 
    /**
     * 增
     *
     * @param uri
     * @param values
     * @return
     */
    @nullable
    @override
    public uri insert(@nonnull uri uri, @nullable contentvalues values) {
        string tablename = gettablename(uri);
        mdb.insert(tablename, null, values);
        mcontext.getcontentresolver().notifychange(uri, null);
        return uri;
    }
 
    /**
     * 删
     *
     * @param uri
     * @param selection
     * @param selectionargs
     * @return
     */
    @override
    public int delete(@nonnull uri uri, @nullable string selection, @nullable string[] selectionargs) {
        string tablename = gettablename(uri);
        int count = mdb.delete(tablename, selection, selectionargs);
        if (count > 0) {
            mcontext.getcontentresolver().notifychange(uri, null);
        }
        return count;
    }
 
    /**
     * 查
     *
     * @param uri
     * @param projection
     * @param selection
     * @param selectionargs
     * @param sortorder
     * @return
     */
    @nullable
    @override
    public cursor query(@nonnull uri uri, @nullable string[] projection, @nullable string selection,
                        @nullable string[] selectionargs, @nullable string sortorder) {
        string currentthreadname = thread.currentthread().getname();
        logger.d(tag + "query: currentthreadname:" + currentthreadname + " uri:" + uri);
 
        string tablename = gettablename(uri);
 
        return mdb.query(tablename, projection, selection, selectionargs, null, null, sortorder, null);
    }
 
    /**
     * 改
     *
     * @param uri
     * @param values
     * @param selection
     * @param selectionargs
     * @return
     */
    @override
    public int update(@nonnull uri uri, @nullable contentvalues values, @nullable string selection,
                      @nullable string[] selectionargs) {
        string tablename = gettablename(uri);
        if (tablename == null) {
            return 0;
        }
        int row = mdb.update(tablename, values, selection, selectionargs);
        if (row > 0) {
            mcontext.getcontentresolver().notifychange(uri, null);
        }
        return row;
    }
}

上面封装的 dbopenhelper 代码如下:

package com.hongri.androidipc.db;
 
/**
 * @author zhongyao
 * @date 2018/6/11
 */
 
public class dbopenhelper extends sqliteopenhelper {
    public static final string book_table_name = "book";
    public static final string user_table_name = "user";
 
    public static final string db_name = "library";
    public static final int db_version = 1;
 
    private string book_sql;
    private string user_sql;
 
    public dbopenhelper(context context, string name,
                        cursorfactory factory, int version) {
        super(context, db_name, factory, db_version);
 
        book_sql = "create table if not exists " + book_table_name + "(_id integer primary key," + "name text,"
            + "page int)";
        user_sql = "create table if not exists " + user_table_name + "(_id integer primary key," + "name text,"
            + "sex int)";
 
    }
 
    @override
    public void oncreate(sqlitedatabase db) {
        db.execsql(book_sql);
        db.execsql(user_sql);
    }
 
    @override
    public void onupgrade(sqlitedatabase db, int oldversion, int newversion) {
 
    }
}

2、在manifest文件中注册这个contentprovider:

    <provider
         android:name="com.hongri.androidipc.contentprovider.mycontentprovider"
         android:authorities="com.hongri.androidipc.contentprovider.provider"
         android:permission="com.hongri.androidipc.provider"
         android:process=":provider" />

3、在外部应用中访问它:

        <activity
            android:name=".contentprovideractivity"
            android:process=":remoteprocess">
            <intent-filter>
                <action android:name="android.intent.action.main"/>
                <category android:name="android.intent.category.launcher"/>
            </intent-filter>
        </activity>

这里单独开启了一个进程 remoteprocess 用来模拟第三方app。

该activity页面如下,点击相关按钮可以进行基础的增、删、查、改操作,可通过log查看调用结果。

这里注意如果希望监听数据更新,那么需要注册内容观察者 contentobserver,增、删、改动的时候,会有回调通知,前提是在自定义的contentprovider类方法中,调用getcontentresolver().notifychange(uri, null);方法即可。

package com.hongri.androidipc;
 
 
/**
 * @author hongri
 */
public class contentprovideractivity extends appcompatactivity implements view.onclicklistener {
 
    //book uri
    private final uri bookuri = mycontentprovider.book_content_uri;
    //user uri
    private final uri useruri = mycontentprovider.user_content_uri;
    private button btninsert, btnquery, btnquerybyuser, btnmodify, btndelete;
    private handler mhandler = new handler();
 
    @override
    protected void oncreate(bundle savedinstancestate) {
        super.oncreate(savedinstancestate);
        setcontentview(r.layout.activity_content_provider);
 
        btninsert = (button) findviewbyid(r.id.btninsert);
        btnquery = (button) findviewbyid(r.id.btnquery);
        btnquerybyuser = (button) findviewbyid(r.id.btnquerybyuser);
        btnmodify = (button) findviewbyid(r.id.btnmodify);
        btndelete = (button) findviewbyid(r.id.btndelete);
 
        btninsert.setonclicklistener(this);
        btnquery.setonclicklistener(this);
        btnquerybyuser.setonclicklistener(this);
        btnmodify.setonclicklistener(this);
        btndelete.setonclicklistener(this);
 
        getcontentresolver().registercontentobserver(bookuri, true, mcontentobserver);
        getcontentresolver().registercontentobserver(useruri, true, mcontentobserver);
    }
 
    /**
     * 定义一个内容观察者【数据有更新时会调用】
     */
    private contentobserver mcontentobserver = new contentobserver(mhandler) {
        @override
        public void onchange(boolean selfchange) {
            super.onchange(selfchange);
            //这里selfchange都是返回false的,不用理会这个参数
            logger.d("onchange调用 --- 数据有更新");
        }
    };
 
 
    /**
     * 向 bookuri 中插入一本书
     */
    private void doinsert() {
        contentvalues values = new contentvalues();
        values.put("name", "android框架");
        values.put("page", "1213");
        uri uri = getcontentresolver().insert(bookuri, values);
        logger.d("插入成功 ---> uri:" + uri.tostring());
    }
 
    /**
     * 根据 bookuri 查询所有书籍
     */
    private void doquery() {
        cursor bookcursor = getcontentresolver().query(bookuri, new string[]{"_id", "name", "page"}, null, null, null);
        while (bookcursor.movetonext()) {
            book book = new book();
            book.set_id(bookcursor.getint(0));
            book.setname(bookcursor.getstring(1));
            book.setpage(bookcursor.getint(2));
            logger.d("book:" + book.tostring());
        }
        bookcursor.close();
    }
 
    /**
     * 查询 useruri 所有图书员
     */
    private void doqueryuser() {
        cursor usercursor = getcontentresolver().query(useruri, new string[]{"_id", "name", "sex"}, null, null, null);
        while (usercursor.movetonext()) {
            user user = new user();
            user.set_id(usercursor.getint(0));
            user.setname(usercursor.getstring(1));
            user.setsex(usercursor.getint(2));
            logger.d("user:" + user.tostring());
        }
        usercursor.close();
    }
 
    /**
     * 更新书籍【android底层开发】
     */
    private void doupdate() {
        contentvalues updatevalues = new contentvalues();
        updatevalues.put("name", "android底层开发");
        updatevalues.put("page", 3345);
        int row = getcontentresolver().update(bookuri, updatevalues, "name=?", new string[]{"android框架"});
        if (row > 0) {
            logger.d("book:已修改");
        }
    }
 
    /**
     * 删除 名为"java" 这本书
     */
    private void dodelete() {
        int count = getcontentresolver().delete(bookuri, "name=?", new string[]{"java"});
        if (count > 0) {
            logger.d("book:已进行删除操作");
        }
    }
 
    @suppresslint("nonconstantresourceid")
    @override
    public void onclick(view v) {
        int id = v.getid();
        switch (id) {
            case r.id.btninsert:
                /**
                 * 增
                 */
                doinsert();
                break;
 
            case r.id.btnquery:
                /**
                 * 查
                 */
                doquery();
                break;
 
            case r.id.btnquerybyuser:
                /**
                 * 查
                 */
                doqueryuser();
                break;
 
            case r.id.btnmodify:
                /**
                 * 改
                 */
                doupdate();
                doquery();
                break;
 
            case r.id.btndelete:
                /**
                 * 删
                 */
                dodelete();
                doquery();
                break;
 
            default:
                break;
        }
    }
 
    @override
    protected void ondestroy() {
        super.ondestroy();
        getcontentresolver().unregistercontentobserver(mcontentobserver);
    }
}

以上便是contentprovider的基础应用。

源码地址:androidipc 

到此这篇关于android contentprovider基础应用详解的文章就介绍到这了,更多相关android contentprovider内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!

《Android ContentProvider基础应用详解.doc》

下载本文的Word格式文档,以方便收藏与打印。