ContentProvider 浅析


概况

定义:contentProvider是android中提供专门进行不同程序数据共享的方式,其底层实现是Binder,contentProvider以表格的形式组织数据,而且包含多个表。
作用:访问系统预置的ContentProvider,如通讯录,自定义contentProvider暴露给外界,方便调用。

ContentProvider的工作过程

首先给一张大图(反应了ContentProvider的工作流程)


ContentProvider工作流程
ContentProvider工作流程

简单介绍:

  • 一个应用启动入口方法是ActivityThread的main方法,main方法中会创建ActivityThread的实例和主线程的消息队列,然后通过attch方法远程调用远程的Ams的attachApplication,并把ApplicationThread对象给Ams。ams的attachApplication方法会调用ApplicationThread的bindApplication,经过handler传回ActivityThread中处理,即交给handleBindApplication方法,此方法会创建Application对象,和加载ContentProvider。
  • 所以Application的onCreate的执行在加载ContentProvider之后。
  • ApplicationThread是Binder对象,它的Binder接口是IApplicationThread,主要用于Ams和ActivityThread的之间通信。

聊聊之后发生的事:

  • contentProvider开始后,外界无法直接访问,必须通过AMS根据uri获取对应的ContentProvider的binder接口(IcontentProvider),来访问数据。
  • 通过android:multiprocess设置ContentProvider是单实例还是多实例。
  • 访问ContentProvider通过ContentResolver,实际上就是ApplicationContentProvider,第一次触发ContentProvider方法,伴随着启动其所在进程。

选query方法,来仔细介绍:(具体参见开发艺术探索)

1、首先获取IContentProvider对象,(通过acquireProvider方法获取ContentProvider)。
2、发送一个进程间请求给AMS让其启动目标ContentProvider,最后通过installProvider修改引用次数。
3、AMS首先启动进程,然后启动ContentProvider,具体启动进程的方法是startProcessLocked方法,内部通过Process的start方法完成进程的启动。
4、ActivityThread的attach方法会将Application对象通过AMS的attachApplication方法跨进程传递给AMS,最终会完成ContentProvider创建过程。
5、一个流程:
attachApplication(ams)--》 attachApplicationLocked(ams)--》 bindApplication(ApplicationThread) -(发送消息)-》Handler--》handleBindApplication
6、四个步骤:

  • 创建ContextImpl和Instrumentation
  • 创建Application对象
  • 启动当前进程的ContentProvider并调用其OnCreate
  • 调用Application的onCreate方法

上例子

首先是读取系统的一些信息:

package com.example.contentprovider;

import android.Manifest;
import android.content.ContentProvider;
import android.content.ContentProviderOperation;
import android.content.ContentResolver;
import android.content.ContentValues;
import android.content.Intent;
import android.content.OperationApplicationException;
import android.content.pm.PackageManager;
import android.database.Cursor;
import android.net.Uri;
import android.os.RemoteException;
import android.provider.ContactsContract;
import android.support.annotation.NonNull;
import android.support.v4.app.ActivityCompat;
import android.support.v4.content.ContextCompat;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import android.widget.Toast;

import java.util.ArrayList;

public class MainActivity extends AppCompatActivity {
    private TextView text_content;
    private Button change_text;
    private Button intent_second;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        init();
    }

    //初始化
    private void init(){
    //三组权限
        if (ContextCompat.checkSelfPermission(MainActivity.this, Manifest.permission.READ_CONTACTS) != PackageManager.PERMISSION_GRANTED) {
            //没有授权,则申请授权
            //ActivityCompat.requestPermissions() 参数一:context 参数二:申请的权限名数组 参数三:请求码,要求唯一值
            ActivityCompat.requestPermissions(MainActivity.this, new String[]{Manifest.permission.READ_CONTACTS}, 2);
        } else {
            getContacts();
        }
        if (ContextCompat.checkSelfPermission(MainActivity.this, Manifest.permission.WRITE_CONTACTS) != PackageManager.PERMISSION_GRANTED) {
           
            ActivityCompat.requestPermissions(MainActivity.this, new String[]{Manifest.permission.WRITE_CONTACTS}, 2);
        }
        if (ContextCompat.checkSelfPermission(MainActivity.this, Manifest.permission.READ_SMS) != PackageManager.PERMISSION_GRANTED) {
            ActivityCompat.requestPermissions(MainActivity.this, new String[]{Manifest.permission.READ_SMS}, 1);
        } else {
            getMsgs();
        }
//        insertMsg();
        initView();
    }


    //初始化页面和设置点击事件
    private void initView(){
        text_content = (TextView)findViewById(R.id.text_content);
        change_text = (Button)findViewById(R.id.add_contacts);
        intent_second = (Button)findViewById(R.id.intent_to_second);
        intent_second.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                Intent intent = new Intent();
                intent.setClass(MainActivity.this,SecondActivity.class);
                startActivity(intent);
            }
        });
        change_text.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                try{
                    //添加联系人,因为原方法抛出了异常,所以调用的时候需要try-catch语句
                    AddContact();
                }catch (Exception e){
                    e.printStackTrace();
                }

            }
        });
    }

    //查询短信一些信息
    private void getMsgs(){
    //短信的uri
        Uri uri = Uri.parse("content://sms/");
        ContentResolver resolver = getContentResolver();
        //获取的是哪些列的信息
        Cursor cursor = resolver.query(uri, new String[]{"address","date","type","body"}, null, null, null);
        while(cursor.moveToNext())
        {
            String address = cursor.getString(0);
            String date = cursor.getString(1);
            String type = cursor.getString(2);
            String body = cursor.getString(3);
            System.out.println("地址:" + address);
            System.out.println("时间:" + date);
            System.out.println("类型:" + type);
            System.out.println("内容:" + body);
            System.out.println("======================");
        }
        cursor.close();
    }

    //添加联系人
    private void AddContact() throws RemoteException,OperationApplicationException{
        Uri uri = Uri.parse("content://com.android.contacts/raw_contacts");
        Uri dataUri = Uri.parse("content://com.android.contacts/data");

        ContentResolver resolver = getContentResolver();
        ArrayList<ContentProviderOperation> operations = new ArrayList<>();
        ContentProviderOperation op1 = ContentProviderOperation.newInsert(uri)
                .withValue("account_name",null)
                .build();
        operations.add(op1);

        ContentProviderOperation op2 = ContentProviderOperation.newInsert(dataUri)
                .withValueBackReference("raw_contact_id",0)
                .withValue("mimetype","vnd.android.cursor.item/name")
                .withValue("data2","Coder_pig")
                .build();
        operations.add(op2);

        ContentProviderOperation op3 = ContentProviderOperation.newInsert(dataUri)
                .withValueBackReference("raw_contact_id", 0)
                .withValue("mimetype", "vnd.android.cursor.item/phone_v2")
                .withValue("data1", "13798988888")
                .withValue("data2", "2")
                .build();
        operations.add(op3);

        ContentProviderOperation op4 = ContentProviderOperation.newInsert(dataUri)
                .withValueBackReference("raw_contact_id", 0)
                .withValue("mimetype", "vnd.android.cursor.item/email_v2")
                .withValue("data1", "1825273284@qq.com")
                .withValue("data2", "2")
                .build();
        operations.add(op4);
        //将上述内容添加到手机联系人中~
        resolver.applyBatch("com.android.contacts", operations);
        Toast.makeText(getApplicationContext(), "添加成功", Toast.LENGTH_SHORT).show();
    }

    //获取联系人信息
    private void getContacts(){
        ContentResolver resolver = getContentResolver();
        Uri uri = ContactsContract.CommonDataKinds.Phone.CONTENT_URI;
        Cursor cursor = resolver.query(uri,null,null,null,null);
        while (cursor.moveToNext()){
            String cName = cursor.getString(cursor.getColumnIndex(ContactsContract.CommonDataKinds.Phone.DISPLAY_NAME));
            String cNum = cursor.getString(cursor.getColumnIndex(ContactsContract.CommonDataKinds.Phone.NUMBER));
            System.out.print("姓名:"+cName);
            System.out.println("号码:"+cNum);
            System.out.println("++++++++++++++++++++++");
        }
        cursor.close();
    }

    //动态权限申请
    @Override
    public void onRequestPermissionsResult(int requestCode, @NonNull String[] permissions, @NonNull int[] grantResults) {
        switch (requestCode) {
            case 1:
                if (grantResults.length > 0 && grantResults[0] == PackageManager.PERMISSION_GRANTED) {
                    getContacts();
                } else {
                    Toast.makeText(MainActivity.this, "read sms denied", Toast.LENGTH_SHORT).show();
                }
                break;
            case 2:
                if (grantResults.length > 0 && grantResults[0] == PackageManager.PERMISSION_GRANTED) {
                    getMsgs();
                } else {
                    Toast.makeText(MainActivity.this, "read call denied", Toast.LENGTH_SHORT).show();
                }
                break;

        }
    }
}

运行结果:


联系人
联系人
短信
短信
新添加的联系人
新添加的联系人

然后是自定义ContentProvider
目录结构:


目录结构
目录结构

DBOpenHelper是关于数据库的一个类:

package com.example.contentprovider.util;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;

public class DBOpenHelper extends SQLiteOpenHelper {

    final String CREATE_SQL = "CREATE TABLE test(_id INTEGER PRIMARY KEY AUTOINCREMENT,name)";

    public DBOpenHelper(Context context, String name, SQLiteDatabase.CursorFactory factory, int version){
        super(context,name,null,1);
    }
    @Override
    public void onCreate(SQLiteDatabase db) {
        db.execSQL(CREATE_SQL);
    }

    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {

    }

}

内容提供器:(ContentProvider)

package com.example.contentprovider.util;

import android.content.ContentProvider;
import android.content.ContentUris;
import android.content.ContentValues;
import android.content.UriMatcher;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.net.Uri;

public class NameContentProvider extends ContentProvider {

    //初始化一些常量
    private static UriMatcher matcher = new UriMatcher(UriMatcher.NO_MATCH);
    private DBOpenHelper dbOpenHelper;

    static {
        matcher.addURI("com.example.contentprovider.myprovider","test",1);
    }

    @Override
    public boolean onCreate() {
        //实例化对象
        dbOpenHelper = new DBOpenHelper(this.getContext(),"test.db",null,1);
        return true;
    }

    @Override
    public Cursor query( Uri uri,String[] projection,String selection, String[] selectionArgs, String sortOrder) {
        return null;
    }


    @Override
    public String getType(Uri uri) {
        return null;
    }

    @Override
    public Uri insert(Uri uri , ContentValues values) {
        switch (matcher.match(uri)){
            //证明uri是否匹配成功
            case 1:
                SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
                long rowId = db.insert("test",null,values);
                if(rowId > 0){
                    // 在前面已有的uri后面追加id
                    Uri nameUri = ContentUris.withAppendedId(uri,rowId);
                    //通知内容提供器,内容发生改变了
                    getContext().getContentResolver().notifyChange(nameUri,null);;
                    return  nameUri;
                }
        }
        return null;
    }

    @Override
    public int delete(Uri uri, String selection,String[] selectionArgs) {
        return 0;
    }

    @Override
    public int update( Uri uri,  ContentValues values,  String selection, String[] selectionArgs) {
        return 0;
    }
}

AsyncTask(用于更新ui)

package com.example.contentprovider.util;

import android.os.AsyncTask;
import android.widget.TextView;

public class MyAsyncTask extends AsyncTask<Integer,Integer,String> {
    private TextView txt;
    private String str;
    public  MyAsyncTask(TextView txt,String str){
        super();
        this.txt = txt;
        this.str = str;
    }
    @Override
    protected String doInBackground(Integer... integers) {
        return null;
    }

    @Override
    protected void onPreExecute() {
        super.onPreExecute();
        txt.setText(str);
    }

    @Override
    protected void onProgressUpdate(Integer... values) {
        super.onProgressUpdate(values);
    }
}

SecondActivity:

package com.example.contentprovider;

import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.TextView;

import com.example.contentprovider.util.DBOpenHelper;
import com.example.contentprovider.util.MyAsyncTask;

public class SecondActivity extends AppCompatActivity {
    private DBOpenHelper dbOpenHelper;
    private String name = null;
    private TextView text_show;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_second);
        text_show = (TextView)findViewById(R.id.txt_show_data);
    }
    public void onClick(View view){
        if(view.getId() == R.id.cursor_data){
            watch();
        }
    }
    private void watch(){
        dbOpenHelper = new DBOpenHelper(this,"test.db",null,1);
        SQLiteDatabase sqLiteDatabase = dbOpenHelper.getReadableDatabase();
        Cursor cursor = sqLiteDatabase.query("test",new String[]{"name"},"name=?",new String[] { "测试" },null,null,null);
        while (cursor.moveToNext()) {
            name = cursor.getString(cursor.getColumnIndex("name"));
            //输出查询结果
            System.out.println("查询到的数据是:\n"+"name: "+name);

        }
        if(name != null){
            MyAsyncTask myAsyncTask = new MyAsyncTask(text_show,name);
            myAsyncTask.execute();
        }
        //关闭数据库
        sqLiteDatabase.close();
    }
}

在其他程序的调用:(ProviderTeminate的MainActivity)

package com.example.providerterminate;

import android.content.ContentResolver;
import android.content.ContentValues;
import android.net.Uri;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.Button;
import android.widget.Toast;

public class MainActivity extends AppCompatActivity {

    private Button btninsert;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        btninsert = (Button) findViewById(R.id.btn_insert);

        //读取contentprovider 数据
        final ContentResolver resolver = this.getContentResolver();


        btninsert.setOnClickListener(new View.OnClickListener() {

            @Override
            public void onClick(View v) {
                ContentValues values = new ContentValues();
                values.put("name", "测试");
                Uri uri = Uri.parse("content://com.example.contentprovider.myprovider/test");
                resolver.insert(uri, values);
                Toast.makeText(getApplicationContext(), "数据插入成功", Toast.LENGTH_SHORT).show();

            }
        });

    }
}

运行结果
运行结果

建立数据库和插入元素
建立数据库和插入元素
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 199,271评论 5 466
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 83,725评论 2 376
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 146,252评论 0 328
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 53,634评论 1 270
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,549评论 5 359
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 47,985评论 1 275
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,471评论 3 390
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,128评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,257评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,233评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,235评论 1 328
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,940评论 3 316
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,528评论 3 302
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,623评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,858评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,245评论 2 344
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 41,790评论 2 339

推荐阅读更多精彩内容