Android应用程序组件Content Provider在应用程序之间共享数据的原理分析(4)
Step 16. CursorWindow.native_init 这个函数定义在frameworks/base/core/jni/android_database_CursorWindow.cpp文件中,对应的函数为native_init_memory函数: staticJNINativeMethodsMethods[]= { ...... {"native_init","(Landroid/os/IBinder;)V",(void*)native_init_memory}, }; 函数native_init_memory的实现如下所示: staticvoidnative_init_memory(JNIEnv*env,jobjectobject,jobjectmemObj) { sp<IMemory>memory=interface_cast<IMemory>(ibinderForJavaObject(env,memObj)); ...... CursorWindow*window=newCursorWindow(); ...... if(!window->setMemory(memory)){ ...... } ...... SET_WINDOW(env,object,window); } 函数首先是将前面Step 15中传进来的Binder接口转换为IMemory接口,接着创建一个C++层的CursorWindow对象,再接着用这个IMemory接口来初始化这个C++层的CursorWindow对象,最后像前面的Step 8一样,通过宏SET_WINDOW把这个C++层的CursorWindow对象和前面在Step 15中创建的Java层CursorWindow对象关联起来。 下面我们就重点关注CursorWindow类的setMemory函数的实现,看看它是如何使用这个IMemory接口来初始化其内部的匿名共享内存对象的。 Step 17. CursorWindow.setMemory 这个函数定义在frameworks/base/core/jni/CursorWindow.cpp文件中: boolCursorWindow::setMemory(constsp<IMemory>&memory) { mMemory=memory; mData=(uint8_t*)memory->pointer(); ...... mHeader=(window_header_t*)mData; //Makethewindowread-only ssize_tsize=memory->size(); mSize=size; mMaxSize=size; mFreeOffset=size; ...... returntrue; } 从前面一篇文章 Android系统匿名共享内存(Anonymous Shared Memory)C++调用接口分析中,我们知道,这里得到的IMemory接口,实际上是一个Binder引用,它指向前面在Step 9中创建的MemoryBase对象,当我们第一次调用这个接口的pointer函数时,它便会通过Binder进程间通信机制去请求这个MemoryBase对象把它内部的匿名共享内存文件描述符返回来给它,而Binder驱动程序发现要传输的是一个文件描述符的时候,就会在目标进程中创建另外一个文件描述符,这个新建的文件描述符与要传输的文件描述符指向的是同一个文件,在我们这个情景中,这个文件就是我们前面创建的匿名共享内存文件了。因此,在目标进程中,即在Content Provider进程中,它可以通过这个新建的文件描述符来访问这块匿名共享内存,这也是匿名共享内存在进程间的共享原理,具体可以参考另外一篇文章Android系统匿名共享内存Ashmem(Anonymous Shared Memory)在进程间共享的原理分析 。 这样,在Content Provider这一侧,就可以把第三方应用程序请求的数据保存在这个匿名共享内存中了,回到前面的Step 14中,下一步要执行的函数便是bulkQuery了,它的作用为请求的数据制定好一个SQL数据库查询计划。这个bulkQuery函数是由一个实现了IContentProvider接口的Binder对象来实现的,具体可以参考前面一篇文章 Android应用程序组件Content Provider的启动过程源代码分析 中,这个Binder对象的实际类型是定义在ContentProivder类内部的Transport类。 Step 18. Transport.bulkQuery 这个函数定义在frameworks/base/core/java/android/content/ContentProvider.java文件中: publicabstractclassContentProviderimplementsComponentCallbacks{ ...... classTransportextendsContentProviderNative{ ...... publicIBulkCursorbulkQuery(Uriuri,String[]projection, Stringselection,String[]selectionArgs,StringsortOrder, IContentObserverobserver,CursorWindowwindow){ ...... Cursorcursor=ContentProvider.this.query(uri,projection, selection,selectionArgs,sortOrder); ...... returnnewCursorToBulkCursorAdaptor(cursor,observer, ContentProvider.this.getClass().getName(), hasWritePermission(uri),window); } ...... } ...... } 这个函数主要做了两件事情,一是调用ContentProvider的子类的query函数构造一个数据库查询计划,注意,从这个函数返回来的时候,还没有真正执行数据库查询的操作,而只是按照查询条件准备好了一个SQL语句,要等到第一次使用的时候才会去执行数据库查询操作;二是使用前面一步得到的Cursor接口以及传下来的参数window来创建一个CursorToBulkCursorAdaptor对象,这个对象实现了IBulkCursor接口,同时它也是一个Binder对象,是用来返回给第三方应用程序使用的,第三方应用程序必须通过这个接口来获取从ContentProvider中查询得到的数据,而这个CursorToBulkCursorAdaptor对象的功能就是利用前面获得的Cursor接口来执行数据库查询操作,然后把查询得到的结果保存在从参数传下来的window对象内部所引用的匿名共享内存中去。我们先来看ContentProvider的子类的query函数的实现,在我们这个情景中,这个子类就是ArticlesProvider了,然后再回过头来看看这个CursorToBulkCursorAdaptor对象是如何把数据库查询计划与匿名共享内存关联起来的。 Step 19. ArticlesProvider.query 这个函数定义在前面一篇文章 Android应用程序组件Content Provider应用实例 介绍的应用程序ArtilcesProvider源代码工程目录下,在文件packages/experimental/ArticlesProvider/src/shy/luo/providers/articles/ArticlesProvider.java中: publicclassArticlesProviderextendsContentProvider{ ...... @Override publicCursorquery(Uriuri,String[]projection,Stringselection,String[]selectionArgs,StringsortOrder){ SQLiteDatabasedb=dbHelper.getReadableDatabase(); SQLiteQueryBuildersqlBuilder=newSQLiteQueryBuilder(); Stringlimit=null; switch(uriMatcher.match(uri)){ ...... caseArticles.ITEM_POS:{ Stringpos=uri.getPathSegments().get(1); sqlBuilder.setTables(DB_TABLE); sqlBuilder.setProjectionMap(articleProjectionMap); limit=pos+",1"; break; } ...... } Cursorcursor=sqlBuilder.query(db,projection,selection,selectionArgs,null,null,TextUtils.isEmpty(sortOrder)?Articles.DEFAULT_SORT_ORDER:sortOrder,limit); ...... returncursor; } ...... } 从前面的Step 1中可以看到,传进来的参数uri的值为“content://shy.luo.providers.articles/pos”,通过uriMatcher的match函数来匹配这个uri的时候,得到的匹配码为Articles.ITEM_POS,这个知识点可以参考前面这篇文章 Android应用程序组件Content Provider应用实例 。因为我们的数据是保存在SQLite数据库里面的,因此,必须要构造一个SQL语句来将所请求的数据查询出来。这里是通过SQLiteQueryBuilder类来构造这个SQL查询语句的,构造好了以后,就调用它的query函数来准备一个数据库查询计划。Step 20.SQLiteQueryBuilder.query 这个函数定义在frameworks/base/core/java/android/database/sqlite/SQLiteQueryBuilder.java文件中: publicclassSQLiteQueryBuilder { ...... publicCursorquery(SQLiteDatabasedb,String[]projectionIn, Stringselection,String[]selectionArgs,StringgroupBy, Stringhaving,StringsortOrder,Stringlimit){ ...... Stringsql=buildQuery( projectionIn,selection,groupBy,having, sortOrder,limit); ...... returndb.rawQueryWithFactory( mFactory,sql,selectionArgs, SQLiteDatabase.findEditTable(mTables)); } ...... } 这里首先是调用buildQuery函数来构造一个SQL语句,它无非就是根据从参数传来列名子句、select子句、where子句、group by子句、having子句、order子句以及limit子句来构造一个完整的SQL子句,这些都是SQL语法的基础知识了,这里我们就不关注了。构造好这个SQL查询语句之后,就调用从参数传下来的数据库对象db的rawQueryWithFactory函数来进一步操作了。 Step 21. SQLiteDatabase.rawQueryWithFactory 这个函数定义在frameworks/base/core/java/android/database/sqlite/SQLiteDatabase.java文件中: publicclassSQLiteDatabaseextendsSQLiteClosable{ ...... publicCursorrawQueryWithFactory( CursorFactorycursorFactory,Stringsql,String[]selectionArgs, StringeditTable){ ...... SQLiteCursorDriverdriver=newSQLiteDirectCursorDriver(this,sql,editTable); Cursorcursor=null; try{ cursor=driver.query( cursorFactory!=null?cursorFactory:mFactory, selectionArgs); }finally{ ...... } returncursor; } ...... } 这个函数会在内部创建一个SQLiteCursorDriver对象driver,然后调用它的query函数来创建一个Cursor对象,这个Cursor对象的实际类型是SQLiteCursor,下面我们将会看到,前面我们也已经看到,这个SQLiteCursor的内部就包含了一个数据库查询计划。 本文转自 Luoshengyang 51CTO博客,原文链接:http://blog.51cto.com/shyluo/967007,如需转载请自行联系原作者